RabbitMQ—持久化

RabbitMQ—持久化

引言

• 如何保障当 RabbitMQ 服务停掉以后消息生产者发送过来的消息不丢失？
• 默认情况下 RabbitMQ 退出或由于某种原因崩溃时，它丢失队列和消息，除非告知它不要这样做。
• 确保消息不会丢失需要做两件事：我们需要将队列和消息都标记为持久化。

队列持久化

如何实现队列持久化？
在声明队列的时候把 durable 参数设置为true即可持久化

注意点：有相同名字的队列未持久化，需要将该相同名字的队列删除才能持久化

持久化之后，rabbitmq服务器重启，该队列依旧会存在

消息持久化

如何实现：在生产者发送消息的代码修改属性，将props参数设置为MessageProperties.PERSISTENT_TEXT_PLAIN，即可开启消息持久化

注意点：

• 队列持久化必须开启，否则不会生效
• 消息标记为持久化并不能完全保证不会丢失消息

消息的不公平分发

即能者多劳，假如有两个消费者，一个处理的快，一个处理的慢，那么采用轮询的话，处理的快的消费者就会去等待处理的慢的消费者，这个属于公平分发。而不公平分发，处理的快的不会去等待，而是继续处理下一个消息。

如何开启：在生产者中设置如下参数

意思就是如果这个消息我还没有处理完或者我还没有应答你，你先别分配给我，我目前只能处理一个任务，然后 rabbitmq 就会把该任务分配给没有那么忙的那个空闲消费者。
优点：提高工作线程的利用率
缺点：如果所有的消费者都没有完成手上任务，队列还在不停的添加新任务，队列有可能就会遇到队列被撑满的情况，这个时候就只能添加新的 worker 或者改变其他存储任务的策略。