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

“Hello world” of RabbitMQ

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:

2、Java入門例項 一個producer傳送訊息，一個接收者接收訊息，並在控制檯打印出來。如下圖：

package
 
 com.zhy.rabbit._01;import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;public class Send{ //佇列名稱 private final static String QUEUE_NAME = "hello"; public static void main(String[] argv) throws java.io.IOException {  /**   * 建立連線連線到MabbitMQ   */  ConnectionFactory factory = new ConnectionFactory();  //設定MabbitMQ所在主機ip或者主機名  factory.setHost("localhost");  //建立一個連線  Connection connection = factory.newConnection();  //建立一個頻道  Channel channel = connection.createChannel();  //指定一個佇列  channel.queueDeclare(QUEUE_NAME, false, false, false, null);  //傳送的訊息  String message = "hello world!";  //往佇列中發出一條訊息  channel.basicPublish("", QUEUE_NAME, null, message.getBytes());  System.out.println(" [x] Sent '" + message + "'");  //關閉頻道和連線  channel.close();  connection.close();  }}

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

package com.zhy.rabbit._01;import com.rabbitmq.client.Channel;import com.rabbitmq.client.Connection;import com.rabbitmq.client.ConnectionFactory;import com.rabbitmq.client.QueueingConsumer;public class Recv{ //佇列名稱 private final static String QUEUE_NAME = "hello"; public static void main(String[] argv) throws java.io.IOException,   java.lang.InterruptedException {  //開啟連線和建立頻道，與傳送端一樣  ConnectionFactory factory = new ConnectionFactory();  factory.setHost("localhost");  Connection connection = factory.newConnection();  Channel channel = connection.createChannel();  //宣告佇列，主要為了防止訊息接收者先執行此程式，佇列還不存在時建立佇列。  channel.queueDeclare(QUEUE_NAME, false, false, false, null);  System.out.println(" [*] Waiting for messages. To exit press CTRL+C");    //建立佇列消費者  QueueingConsumer consumer = new QueueingConsumer(channel);  //指定消費佇列  channel.basicConsume(QUEUE_NAME, true, consumer);  while (true)  {   //nextDelivery是一個阻塞方法（內部實現其實是阻塞佇列的take方法）   QueueingConsumer.Delivery delivery = consumer.nextDelivery();   String message = new String(delivery.getBody());   System.out.println(" [x] Received '" + message + "'");  } }}

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

執行結果：

[x]Sent 'hello world!'

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

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

[x] Received 'hello world!'

下一篇將介紹如何通過一個工作佇列（queue）分發耗時任務給不同的工作者(consumers)。