RabbitMQ 入門 Helloworld，rabbitmqhelloworld

RabbitMQ 入門 Helloworld，rabbitmqhelloworld

1、Windows下RabbitMQ的安裝

　　下載Erlang，地址：http://www.erlang.org/download/otp_win32_R15B.exe ，雙擊安裝即可（首先裝）

　　下載RabbitMQ，地址：http://www.rabbitmq.com/releases/rabbitmq-server/v3.3.4/rabbitmq-server-3.3.4.exe ，雙擊安裝即可

　　下載rabbit-client.jar ，Java代碼時需要導入。地址：http://www.rabbitmq.com/releases/rabbitmq-java-client/v3.3.4/rabbitmq-java-client-bin-3.3.4.zip

　　安裝完成後，在RabbitMQ的安裝目錄的sbin先會有：rabbitmq-server.bat。在cmd下：進入sbin目錄，運行rabbitmq-server start。

2、介紹

　　RabbitMQ 是信息傳輸的中間者。本質上，他從生產者（producers）接收消息，轉發這些消息給消費者（consumers）.換句話說，他能夠按根據你指定的規則進行消息轉發、緩沖、和持久化。

　　RabbitMQ 的一些常見的術語：
　　Producing意味著無非是發送。一個發送消息的程序是一個producer(生產者)。一般用下圖表示Producer：

　　Queue（隊列）類似郵箱。依存於RabbitMQ內部。雖然消息通過RabbitMQ在你的應用中傳遞，但是它們只能存儲在queue中。隊列不受任何限制，可以存儲任何數量的消息—本質上是一個無限制的緩存。很多producers可以通過同一個隊列發送消息，相同的很多consumers可以從同一個隊列上接收消息。一般用下圖表示隊列：

　　Consuming（消費）類似於接收。consumer是基本屬於等待接收消息的程序。一般使用下圖表示Consumer:

　　注意：producer（生產者）,consumer（消費者）,broker（RabbitMQ服務）並不需要部署在同一台機器上，實際上在大多數實際的應用中，也不會部署在同一台機器上。

2、Java入門實例
　　 一個producer發送消息，一個接收者接收消息，並在控制台打印出來。如下圖：

 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 }

　　值得注意的是隊列只會在它不存在的時候創建，多次聲明並不會重復創建。信息的內容是字節數組，也就意味著你可以傳遞任何數據。

　　接收端：Recv.java 不斷等待服務器推送消息，然後在控制台輸出。

 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 }