佇列持久化

在之前的例子中，我們所用的佇列都是臨時佇列，當服務重啟後之前建立的佇列就都沒有了。

佇列的持久化是在定義佇列時的第二個引數決定的(false為佇列不用持久化)

1. channel.queueDeclare(queueName, false, false,false,null);  

訊息持久化

1. channel.basicPublish("", queueName, MessageProperties.PERSISTENT_TEXT_PLAIN, msg.getBytes());  

示例程式碼

1. import java.io.IOException;  
2. import com.rabbitmq.client.Channel;  
3. import com.rabbitmq.client.Connection;  
4. import com.rabbitmq.client.ConnectionFactory;  
5. import com.rabbitmq.client.MessageProperties;  
6. /** 
7.  * 訊息持久化 
8.  * @author menghh 
9.  * 
10.  */
11. publicclass Send04 {  
12.     publicstaticvoid main(String[] args) throws IOException {  
13.         ConnectionFactory factory = new ConnectionFactory();  
14.         //RabbitMQ-Server安裝在本機，所以直接用127.0.0.1
15.         factory.setHost("127.0.0.1"
    );  
16.         //建立一個連線
17.         Connection conn = factory.newConnection();  
18.         //建立一個通訊通道
19.         Channel channel = conn.createChannel();  
20.         //定義Queue名稱
21.         String queueName = "queue01";  
22.         //為Channel定義queue的屬性，queueName為queue名稱
23.         channel.queueDeclare(queueName, true, false,false,null);  
24.         String msg = "Hello World!";  
25.         //傳送訊息
26.         /** 
27.          * 測試條件：1、在訊息佇列持久化的前提下2、接收訊息方設定接收方式為手動接收，並不對接收訊息進行確認 
28.          * 不採用訊息持久化，重啟RabbitMQ服務後，訊息佇列存在，訊息接收不到 
29.          * 採用訊息持久化，重啟RabbitMQ服務後，訊息佇列存在，訊息依然可以接收到訊息，說明訊息被持久化 
30.          */
31.         channel.basicPublish("", queueName, MessageProperties.PERSISTENT_TEXT_PLAIN, msg.getBytes());  
32. //      channel.basicPublish("", queueName, null, msg.getBytes());
33.         System.out.println("send message["+msg+"] to "+queueName+"success!");  
34.         //關閉通道
35.         channel.close();  
36.         //關閉連線
37.         conn.close();  
38.     }  
39. }  

1. import com.rabbitmq.client.Channel;  
2. import com.rabbitmq.client.Connection;  
3. import com.rabbitmq.client.ConnectionFactory;  
4. import com.rabbitmq.client.QueueingConsumer;  
5. import com.rabbitmq.client.QueueingConsumer.Delivery;  
6. /** 
7.  * 訊息持久化 
8.  * @author menghh 
9.  * 
10.  */
11. publicclass Recv04 {  
12.     publicstaticvoid main(String[] args) throws Exception{  
13.         ConnectionFactory factory = new ConnectionFactory();   
14.         factory.setHost("127.0.0.1");  
15.         Connection conn = factory.newConnection();  
16.         Channel channel = conn.createChannel();  
17.         String queueName = "queue01";  
18.         channel.queueDeclare(queueName, true, false, false, null);  
19.         //以上部分和sender一樣
20.         //配置好獲取訊息得方式
21.         QueueingConsumer consumer =  new QueueingConsumer(channel);  
22.         channel.basicConsume(queueName, false,consumer);  
23.         //迴圈獲取訊息
24.         while(true){  
25.             //獲取訊息，如果沒有訊息，這一步將會一直阻塞
26.             Delivery delivery = consumer.nextDelivery();  
27.             String msg = new String(delivery.getBody());  
28.             //確認訊息，已經收到  
29.             channel.basicAck(delivery.getEnvelope().getDeliveryTag(),false);    
30.             System.out.println("received message["+msg+"] from "+queueName);  
31.         }  
32.     }  
33. }  

測試結果：