rabbitMQ是一個在AMQP基礎上完整的，可服用的企業訊息系統。他遵循Mozilla Public License 開源協議。

 rabbitmq是一個消費的代理；通過生產者客戶端生產一個資訊，轉送給消費者客戶端;在這個傳輸過程中，根據你的需要可以經過路由、緩衝、持久化來得到這個訊息。

  先通過一個例子開始：通過rabbitmq輸出"Hello World!"

其中P代表生產者、C表示消費者、中間紅色部分代表訊息佇列

生產者客戶端的傳送訊息程式如下：

1. package com.abin.test;  
2. import java.io.IOException;  
3. import com.rabbitmq.client.Channel;  
4. import com.rabbitmq.client.Connection;  
5. import com.rabbitmq.client.ConnectionFactory;  
6. public class Send {  
7.     private final static String QUEUE_NAME = "hello";  
8.     public static void main(String[] args) throws IOException {  
9.         ConnectionFactory factory = new
    ConnectionFactory();  
10.         factory.setHost("localhost");  
11.         Connection connection = factory.newConnection();  
12.         Channel channel = connection.createChannel();  
13.         channel.queueDeclare(QUEUE_NAME, false, false, false, null);  
14.         String message = "Hello World!";  
15.         channel.basicPublish(""
    , QUEUE_NAME, null, message.getBytes());  
16.         System.out.println(" [x] Sent '" + message + "'");  
17.         channel.close();  
18.         connection.close();  
19.     }  
20. }  

執行結果如下：

1. [x] Sent 'Hello World!'  

消費者客戶端接收訊息程式如下：

1. package com.abin.test;  
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. public class Reqv {  
7.     private final static String QUEUE_NAME = "hello";  
8.     public static void main(String[] argv) throws Exception {  
9.         ConnectionFactory factory = new ConnectionFactory();  
10.         factory.setHost("localhost");  
11.         Connection connection = factory.newConnection();  
12.         Channel channel = connection.createChannel();  
13.         channel.queueDeclare(QUEUE_NAME, false, false, false, null);  
14.         System.out.println(" [*] Waiting for messages. To exit press CTRL+C");  
15.         QueueingConsumer consumer = new QueueingConsumer(channel);  
16.         channel.basicConsume(QUEUE_NAME, true, consumer);  
17.         while (true) {  
18.             QueueingConsumer.Delivery delivery = consumer.nextDelivery();  
19.             String message = new String(delivery.getBody());  
20.             System.out.println(" [x] Received '" + message + "'");  
21.         }  
22.     }  
23. }  

 執行程式得到的結果如下：

1. [*] Waiting for messages. To exit press CTRL+C  
2. [x] Received 'Hello World!'  

 如果消費者出現“[x] Received 'Hello World!'”說明已接收到此訊息資訊。