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傳送訊息，一個接收者接收訊息，並在控制檯打印出來。如下圖：

傳送端：Send.java 連線到RabbitMQ（此時服務需要啟動），傳送一條資料，然後退出。

1. package com.zhy.rabbit._01;  
2. import com.rabbitmq.client.Channel;  
3. import com.rabbitmq.client.Connection;  
4. import com.rabbitmq.client.ConnectionFactory;  
5. publicclass Send  
6. {  
7.     //佇列名稱
8.     privatefinalstatic String QUEUE_NAME = "hello";  
9.     publicstaticvoid main(String[] argv) throws java.io.IOException  
10.     {  
11.         /** 
12.          * 建立連線連線到MabbitMQ 
13.          */
14.         ConnectionFactory factory = new ConnectionFactory();  
15.         //設定MabbitMQ所在主機ip或者主機名
16.         factory.setHost("localhost");  
17.         //建立一個連線
18.         Connection connection = factory.newConnection();  
19.         //建立一個頻道
20.         Channel channel = connection.createChannel();  
21.         //指定一個佇列
22.         channel.queueDeclare(QUEUE_NAME, false, false, false, null);  
23.         //傳送的訊息
24.         String message = "hello world!";  
25.         //往佇列中發出一條訊息
26.         channel.basicPublish("", QUEUE_NAME, null, message.getBytes());  
27.         System.out.println(" [x] Sent '" + message + "'");  
28.         //關閉頻道和連線
29.         channel.close();  
30.         connection.close();  
31.      }  
32. }  

值得注意的是佇列只會在它不存在的時候建立，多次宣告並不會重複建立。資訊的內容是位元組陣列，也就意味著你可以傳遞任何資料。

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

1. package com.zhy.rabbit._01;  
2. import com.rabbitmq.client.Channel;  
3. import com.rabbitmq.client.Connection;  
4. import com.rabbitmq.client.ConnectionFactory;  
5. import com.rabbitmq.client.QueueingConsumer;  
6. publicclass Recv  
7. {  
8.     //佇列名稱
9.     privatefinalstatic String QUEUE_NAME = "hello";  
10.     publicstaticvoid main(String[] argv) throws java.io.IOException,  
11.             java.lang.InterruptedException  
12.     {  
13.         //開啟連線和建立頻道，與傳送端一樣
14.         ConnectionFactory factory = new ConnectionFactory();  
15.         factory.setHost("localhost");  
16.         Connection connection = factory.newConnection();  
17.         Channel channel = connection.createChannel();  
18.         //宣告佇列，主要為了防止訊息接收者先執行此程式，佇列還不存在時建立佇列。
19.         channel.queueDeclare(QUEUE_NAME, false, false, false, null);  
20.         System.out.println(" [*] Waiting for messages. To exit press CTRL+C");  
21.         //建立佇列消費者
22.         QueueingConsumer consumer = new QueueingConsumer(channel);  
23.         //指定消費佇列
24.         channel.basicConsume(QUEUE_NAME, true, consumer);  
25.         while (true)  
26.         {  
27.             //nextDelivery是一個阻塞方法（內部實現其實是阻塞佇列的take方法）
28.             QueueingConsumer.Delivery delivery = consumer.nextDelivery();  
29.             String message = new String(delivery.getBody());  
30.             System.out.println(" [x] Received '" + message + "'");  
31.         }  
32.     }  
33. }  

分別執行Send.java和Recv.java 順序無所謂。前提RabbitMQ服務開啟。

執行結果：

[x]Sent 'hello world!'

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

[*] Waiting for messages. To exitpress CTRL+C

[x] Received 'hello world!'