RabbitMQ消息持久化

桃扇骨 2023-01-07 12:24 125阅读 0赞

# **目录** #

*  一、前言
 *  二、队列持久化
    
     *  　　2.1 查看存在的队列和消息数量
     *  　　2.2 持久化队列
 *  三、消息持久化
 *  四、总结

[回到顶部][Link 1]

**一、前言**

如果我们希望即使在RabbitMQ服务重启的情况下，也不会丢失消息，我们可以将Queue与Message都设置为可持久化的（durable），这样可以保证绝大部分情况下我们的RabbitMQ消息不会丢失。当然还是会有一些小概率事件会导致消息丢失。

[回到顶部][Link 1]

**二、队列持久化**

**　　2.1 查看存在的队列和消息数量**

在windows环境下，在rabbitmq的安装目录/sbin下，通过rabbitmqctl.bat list\_queues查看　![20210117205658424.png][]

这边启动了两个producer,分别生成两个队列hello 和 hello1,并且他们都有一个消息存在

重启rabbitmq，模拟故障

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3c4OTI4MjQxOTY_size_16_color_FFFFFF_t_70][]

可以看到重启后两个队列都消失了

**　　2.2 持久化队列**

我们就hello队列持久化

在声明队列名称时，持久化队列，生产端和消费端都要

<table> 
 <tbody> 
 <tr> 
 <td style="border-color:#C0C0C0;"> 1 </td> 
 <td style="border-color:#C0C0C0;"> channel.queue_declare(queue='hello', durable=True) </td> 
 </tr> 
 </tbody> 
</table>

我们重复上面的操作，但是给hello队列做持久化，而hello1不做，并重启rabbitmq

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3c4OTI4MjQxOTY_size_16_color_FFFFFF_t_70][]

可以看到重启后，hello队列还在，hello1队列消失了，但是原本hello中的一条消息也没有保存下来。所以在这边我们仅仅做到了消息队列的持久化，还没有做消息持久化。

[回到顶部][Link 1]

**三、消息持久化**

我们刚才实现了在rabbitmq崩溃的情况下，就队列本身保存下来，重启后队列还在。接下来我们要将消息也保存下来，即消息的持久化

<table> 
 <tbody> 
 <tr> 
 <td style="border-color:#C0C0C0;"> 1 2 3 4 5 6 7 8 9 </td> 
 <td style="border-color:#C0C0C0;"> channel.basic_publish(exchange='', &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;routing_key='hello', &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;body='hello', &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;properties=pika.BasicProperties( &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;delivery_mode=2,&nbsp;&nbsp;# make message persistent &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;)) &nbsp; # 增加properties，这个properties 就是消费端 callback函数中的properties # delivery_mode = 2&nbsp; 持久化消息 </td> 
 </tr> 
 </tbody> 
</table>

生产端生成一个消息，并重启rabbitmq

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3c4OTI4MjQxOTY_size_16_color_FFFFFF_t_70 1][]

可以看到，经过队列和消息持久化后的hello, 在重启的情况下，队列和消息都存在，没有消失。

消费端再重启后也能正常接收

![20210117205658424.png][]

[回到顶部][Link 1]

**四、总结**

1.  队列持久化需要在声明队列时添加参数 durable=True，这样在rabbitmq崩溃时也能保存队列
2.  仅仅使用durable=True ，只能持久化队列，不能持久化消息
3.  消息持久化需要在消息生成时，添加参数 properties=pika.BasicProperties(delivery\_mode=2)

[Link 1]: https://www.cnblogs.com/bigberg/p/8195622.html#_labelTop
[20210117205658424.png]: /images/20221119/2f301a4c8a3e42498d818585ef93c742.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3c4OTI4MjQxOTY_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20210117205658436.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3c4OTI4MjQxOTY=,size_16,color_FFFFFF,t_70
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3c4OTI4MjQxOTY_size_16_color_FFFFFF_t_70 1]: https://img-blog.csdnimg.cn/20210117205658437.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3c4OTI4MjQxOTY=,size_16,color_FFFFFF,t_70