首先匯入jar包

RabbitMQ示例圖示

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

生產者程式碼如下：

package com.rabbit;

import java.io.IOException;
import java.util.concurrent.TimeoutException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
/**
*
* 類名稱：Test01
* 類描述：傳送訊息
* 建立人：wmh
*
*/
public class Test01 {

public static void main(String[] args) throws IOException, TimeoutException {  

    //建立連結工廠
    ConnectionFactory connFac = new ConnectionFactory() ;  

    //預設連結的主機名,RabbitMQ-Server安裝在本機，所以可以直接用127.0.0.1 
    connFac.setHost("127.0.0.1");  

    //建立連結   
    Connection conn = connFac.newConnection() ;  

    //建立資訊管道  
    Channel channel = conn.createChannel() ;  

    // 建立一個名為queue01的佇列，防止佇列不存在   
    String queueName = "queue01" ;  

    //進行資訊宣告        1.佇列名2.是否持久化，3是否侷限與連結，4不再使用是否刪除，5其他的屬性
    channel.queueDeclare(queueName, false, false, false, null) ; 
    String msg = "Hello World!";  

    //傳送訊息  
    // 在RabbitMQ中，訊息是不能直接傳送到佇列，它需要傳送到交換器（exchange）中。
    // 第一引數空表示使用預設exchange，第二引數表示傳送到的queue，第三引數是傳送的訊息是（位元組陣列）
    channel.basicPublish("", queueName , null , msg.getBytes());  

    System.out.println("傳送  message[" + msg + "] to "+ queueName +" success!");  

    //關閉管道
    channel.close();  
    //關閉連線
    conn.close();   
}  
 

}

傳送訊息完成，效果如下：

控制檯中顯示：

佇列中顯示：

消費者程式碼如下：

package com.rabbit;
import java.io.IOException;
import java.util.concurrent.TimeoutException;

import com.rabbitmq.client.Channel;
import com.rabbitmq.client.Connection;
import com.rabbitmq.client.ConnectionFactory;
import com.rabbitmq.client.ConsumerCancelledException;
import com.rabbitmq.client.QueueingConsumer;
import com.rabbitmq.client.QueueingConsumer.Delivery;
import com.rabbitmq.client.ShutdownSignalException;

/**
*
* 類名稱：Test02
* 類描述：接受訊息
* 建立人：wmh
*
*/

public class Test02 {

public static void main(String[] args) throws IOException, ShutdownSignalException,
ConsumerCancelledException, InterruptedException, TimeoutException {  

    // 建立連結工廠
    ConnectionFactory connFac = new ConnectionFactory() ;  

    //預設連結的主機名,RabbitMQ-Server安裝在本機，所以可以直接用127.0.0.1 
    connFac.setHost("127.0.0.1");  

    //建立連結    
    Connection conn = connFac.newConnection() ;  

    //建立資訊管道  
    Channel channel = conn.createChannel() ;  

    //定義Queue名稱  
    String queueName = "queue01";  
    //1.佇列名2.是否持久化，3是否侷限與連結，4不再使用是否刪除，5其他的屬性
    channel.queueDeclare(queueName, false, false, false, null) ;  

    //上面的部分，與Test01是一樣的  

    //宣告一個消費者,配置好獲取訊息的方式  
    QueueingConsumer consumer = new QueueingConsumer(channel) ;  
    channel.basicConsume(queueName, true, consumer) ;  

    //迴圈獲取訊息  
    while(true){  

        //迴圈獲取資訊  
        //指向下一個訊息，如果沒有會一直阻塞
        Delivery delivery = consumer.nextDelivery() ;  

        String msg = new String(delivery.getBody()) ;    

        System.out.println("接收 message[" + msg + "] from " + queueName);  
    }  
}

}

接受訊息完成，效果如下：

控制檯中顯示：

佇列中顯示：