RabbitMQ 入門 Helloworld

轉載請標明出處：http://blog.csdn.net/lmj623565791/article/details/37607165

本系列教程主要來自於官網入門教程的翻譯，而後本身進行了部分的修改與實驗，內容僅供參考。

「Hello world」 of RabbitMQ

一、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

二、介紹

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

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

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

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

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

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

注：須要在官網下載rabbitmq-java-client-bin-*.zip將jar放入項目的classpath.

發送端： Send.java 鏈接到RabbitMQ（此時服務須要啓動），發送一條數據，而後退出。

[java]  view plain  copy

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 不斷等待服務器推送消息，而後在控制檯輸出。

[java]  view plain  copy

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. }  

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

運行結果：

[x]Sent 'hello world!'

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

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

[x] Received 'hello world!'

下一篇將介紹如何經過一個工做隊列（queue）分發耗時任務給不一樣的工做者(consumers)。