在使用RabbitMQ之前，需要了解RabbitMQ的工作原理。

RabbitMQ的工作原理

RabbitMQ是訊息代理。從本質上說，它接受來自生產者的資訊，並將它們傳遞給消費者。在兩者之間，它可以根據你給它的路由，緩衝規則進行傳遞訊息。

示例圖

RabbitMQ的術語解釋

生產者：生產訊息，傳送訊息。類似工廠。
消費者：接受訊息，使用訊息。類似顧客。
佇列：儲存訊息。類似倉庫、中轉站。佇列可以儲存很多的訊息，因為它基本上是一個無限制的緩衝區，前提是你的機器有足夠的儲存空間。多個生產者可以將訊息傳送到同一個佇列中，多個消費者也可以只從同一個佇列接收資料。這就是佇列的特性。

RabbitMQ 訊息生產者的程式碼實現

import java.util.HashMap;
import java.util.Map;
import com.alibaba.fastjson.JSON;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.Channel;
public class RabbitProducer {
    private final static String QUEUE_NAME = "RabbitMQ_Hello"
 
; //訊息佇列名

      public static void main(String[] argv) throws Exception {
         //建立連線連線到RabbitMQ 
        ConnectionFactory factory = new ConnectionFactory();
        // 設定ip
        factory.setHost("127.0.0.1");
        /*   //設定埠
        factory.setPort(15672);
        //設定使用者名稱
        factory.setUsername("guest");
        //設定密碼
        factory.setPassword("guest");
       //設定url(包括ip、埠、使用者名稱、密碼)
        factory.setUri("amqp://guest:
 
[email protected]:15672");
      */    
        // 建立一個連線  
        Connection connection = factory.newConnection();
        // 建立一個頻道 
        Channel channel = connection.createChannel();
        // 指定一個佇列  
        channel.queueDeclare(QUEUE_NAME, false, false, false, null);
        Map<String,Object> map=new HashMap<String,Object>();  
          map.put("java", "hello");
          map.put("RabbitMQ", "Hello");
        //傳送的訊息
        String message = JSON.toJSONString(map); 
        // 往佇列中發出一條訊息 
        channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); 
        System.out.println(" [x] Sent '" + message + "'");
        // 關閉頻道和連線  
        channel.close();
        connection.close();   
      }
}

RabbitMQ訊息消費者的程式碼實現

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.QueueingConsumer;

//消費者 
public class RabbitConsumer {

  private final static String QUEUE_NAME = "RabbitMQ_Hello"; //訊息佇列名

  public static void main(String[] argv) throws Exception {

        ConnectionFactory factory = new ConnectionFactory();
        factory.setHost("127.0.0.1");
       // 開啟連線和建立頻道，與傳送端一樣  
        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) {  //消費者程式執行開著 如果生產者新增了資料會自動獲取
          Thread.sleep(500);
             // nextDelivery是一個阻塞方法（內部實現其實是阻塞佇列的take方法）  
          QueueingConsumer.Delivery delivery = consumer.nextDelivery();
          String message = new String(delivery.getBody());
          System.out.println("'[x] Received '" + message );
  }   
  }
}

開啟本地的RabbitMQ，之後執行生產者程式碼，會將訊息儲存到RabbitMQ中，可以通過RabbitMQ web介面看到訊息。

執行消費者程式碼，會將該訊息消費掉，可以在RabbitMQ web介面可以發現上面儲存的訊息已經沒有了。

通過這個demo，可以對訊息佇列有了一個的基本的瞭解了。