在消息队列RabbitMQ入门介绍里,描述了RabbitMQ的持久性设置。在设置持久化后,消息保存在磁盘上,即使RabbitMQ重启或服务器重启,消息都不会丢失。
RabbitMQ支持消息的持久化,也就是数据写在磁盘上,为了数据安全考虑,我想大多数用户都会选择持久化。消息队列持久化包括3个部分:
(1)exchange持久化,在声明时指定durable => 1
(2)queue持久化,在声明时指定durable => 1
(3)消息持久化,在投递时指定delivery_mode => 2(1是非持久化)如果exchange和queue都是持久化的,那么它们之间的binding也是持久化的。如果exchange和queue两者之间有一个持久化,一个非持久化,就不允许建立绑定。
但是,即使设置了持久化,也不能百分百保证消息不会丢失。有很小的概率在RabbitMQ接受到消息后,还没来得及写到磁盘,就发生重启了。另外,RabbitMQ也不会对每一个消息执行fsync(2),消息可能仅仅写入到缓存,还没来得及flush到硬件存储。因此RabbitMQ的持久性设置并非足够安全,对于普通的工作队列也许够用了。如果需要加强的安全保证,可以把发布消息的代码封装在事务里。