本系列教程主要來自于官網入門教程的翻譯，然後自己進行了部分的修改與實驗，内容僅供參考。
“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:
注意：producer（生産者）,consumer（消費者）,broker（RabbitMQ服務）并不需要部署在同一台機器上，實際上在大多數實際的應用中，也不會部署在同一台機器上。
2、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. new ConnectionFactory();
18. //設定MabbitMQ所在主機ip或者主機名
19. "localhost");
20. //建立一個連接配接
21. Connection connection = factory.newConnection();
22. //建立一個頻道
23. Channel channel = connection.createChannel();
24. //指定一個隊列
25. false, false, false, null);
26. //發送的消息
27. "hello world!";
28. //往隊列中發出一條消息
29. "", QUEUE_NAME, null, message.getBytes());
30. " [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. new ConnectionFactory();
18. "localhost");
19. Connection connection = factory.newConnection();
20. Channel channel = connection.createChannel();
21. //聲明隊列，主要為了防止消息接收者先運作此程式，隊列還不存在時建立隊列。
22. false, false, false, null);
23. " [*] Waiting for messages. To exit press CTRL+C");
24.
25. //建立隊列消費者
26. new QueueingConsumer(channel);
27. //指定消費隊列
28. true, consumer);
29. while (true)
30. {
31. //nextDelivery是一個阻塞方法（内部實作其實是阻塞隊列的take方法）
32. QueueingConsumer.Delivery delivery = consumer.nextDelivery();
33. new String(delivery.getBody());
34. " [x] Received '" + message + "'");
35. }
36.
37. }
38. } 分别運作Send.java和Recv.java 順序無所謂。前提RabbitMQ服務開啟。
運作結果：
[x]Sent 'hello world!'
----------------------------------------
[*] Waiting for messages. To exitpress CTRL+C