1 package com.zhy.rabbit._01;
 2
 3 import com.rabbitmq.client.Channel;
 4 import com.rabbitmq.client.Connection;
 5 import com.rabbitmq.client.ConnectionFactory;
 6
 7 public class Send
 8 {
 9     //队列名称
10     private final static String QUEUE_NAME = "hello";
11
12     public static void main(String[] argv) throws java.io.IOException
13     {
14         /**
15          * 创建连接连接到MabbitMQ
16          */
17         ConnectionFactory factory = new ConnectionFactory();
18         //设置MabbitMQ所在主机ip或者主机名
19         factory.setHost("localhost");
20         //创建一个连接
21         Connection connection = factory.newConnection();
22         //创建一个频道
23         Channel channel = connection.createChannel();
24         //指定一个队列
25         channel.queueDeclare(QUEUE_NAME, false, false, false, null);
26         //发送的消息
27         String message = "hello world!";
28         //往队列中发出一条消息
29         channel.basicPublish("", QUEUE_NAME, null, message.getBytes());
30         System.out.println(" [x] Sent '" + message + "'");
31         //关闭频道和连接
32         channel.close();
33         connection.close();
34      }
35 }

 1 package com.zhy.rabbit._01;
 2
 3 import com.rabbitmq.client.Channel;
 4 import com.rabbitmq.client.Connection;
 5 import com.rabbitmq.client.ConnectionFactory;
 6 import com.rabbitmq.client.QueueingConsumer;
 7
 8 public class Recv
 9 {
10     //队列名称
11     private final static String QUEUE_NAME = "hello";
12
13     public static void main(String[] argv) throws java.io.IOException,
14             java.lang.InterruptedException
15     {
16         //打开连接和创建频道，与发送端一样
17         ConnectionFactory factory = new ConnectionFactory();
18         factory.setHost("localhost");
19         Connection connection = factory.newConnection();
20         Channel channel = connection.createChannel();
21         //声明队列，主要为了防止消息接收者先运行此程序，队列还不存在时创建队列。
22         channel.queueDeclare(QUEUE_NAME, false, false, false, null);
23         System.out.println(" [*] Waiting for messages. To exit press CTRL+C");
24
25         //创建队列消费者
26         QueueingConsumer consumer = new QueueingConsumer(channel);
27         //指定消费队列
28         channel.basicConsume(QUEUE_NAME, true, consumer);
29         while (true)
30         {
31             //nextDelivery是一个阻塞方法（内部实现其实是阻塞队列的take方法）
32             QueueingConsumer.Delivery delivery = consumer.nextDelivery();
33             String message = new String(delivery.getBody());
34             System.out.println(" [x] Received '" + message + "'");
35         }
36
37     }
38 }

　　[x]Sent 'hello world!'

　　----------------------------------------