<dependency>
		    <groupId>com.rabbitmq</groupId>
		    <artifactId>amqp-client</artifactId>
		    <version>3.3.4</version>
		</dependency>

package RABBIT_MQ;
import com.rabbitmq.client.*;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
public class RabbitMQSender {
    //交換機(jī)
    private final static String exchange_name = "x.mySys.test";
    //路由鍵
    private final static String route_key = "topmess";
    public static void main(String[] args) throws IOException, TimeoutException {
        //定義一個(gè)鏈接工廠
        ConnectionFactory connectionFactory = new ConnectionFactory();
        //設(shè)置服務(wù)地址
        connectionFactory .setHost("10.123.123.123");
        //設(shè)定端口
        connectionFactory .setPort(5673);
        //設(shè)定用戶(hù)名
        connectionFactory .setUsername("myuser");
        //設(shè)定密碼
        connectionFactory .setPassword("mypass");
        //設(shè)定虛擬機(jī)
        connectionFactory .setVirtualHost("my_host");
        //從mq工具類(lèi)獲取連接信息
        Connection connection = connectionFactory.newConnection();
        //獲取一個(gè)通道
        Channel channel = connection.createChannel();
        String message = "Hello World!";
        channel.basicPublish(exchange_name, route_key, null, message.getBytes());
        System.out.println("運(yùn)行完畢，已發(fā)送消息【" + message + "】");
        channel.close();
        connection.close();
    }
}

package RABBIT_MQ;
import java.io.IOException;
import java.util.concurrent.TimeoutException;
import com.rabbitmq.client.AMQP;
import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.DefaultConsumer;
import com.rabbitmq.client.Envelope;
public class RabbitMQReceiver {
    private static String queue_name="q.mySys.test";
    public static void main(String[] args) throws IOException, TimeoutException {
        //定義一個(gè)鏈接工廠
        ConnectionFactory connectionFactory = new ConnectionFactory();
        //設(shè)置服務(wù)地址
        connectionFactory .setHost("10.123.123.123");
        //設(shè)定端口
        connectionFactory .setPort(5673);
        //設(shè)定用戶(hù)名
        connectionFactory .setUsername("myuser");
        //設(shè)定密碼
        connectionFactory .setPassword("mypass");
        //設(shè)定虛擬機(jī)
        connectionFactory .setVirtualHost("my_host");
        //從mq工具類(lèi)獲取連接信息
        Connection connection = connectionFactory.newConnection();
        //獲取一個(gè)通道
        Channel channel = connection.createChannel();
        //監(jiān)聽(tīng)該隊(duì)列，false代表手動(dòng)確認(rèn)
        channel.basicConsume(queue_name,false,new DefaultConsumer(channel){
            public void handleDelivery(String consumerTag, Envelope envelope, AMQP.BasicProperties basicProperties, byte[] body) throws IOException{
                System.out.println("接收到的消息："+ new String(body,"UTF-8"));
            }
        });
        System.out.println("運(yùn)行完畢，等待mq接收消息");
    }
}