RabbitMQ持久化机制(消息持久化、队列持久化)
目录
1、概述
如何保障当 RabbitMQ 服务停掉以后消息生产者发送过来的消息不丢失,默认情况下 RabbitMQ 退出或由于某种原因崩溃时,它忽视队列和消息,除非告知它不要这样做。确保消息不会丢失需要做两件事:我们需要将队列和消息都标记为持久化。
2、队列持久化
好处: 当队列开启持久化时,重启MQ后队列依然存在;
注意: 如果队列已经存在,再开启持久化时会报错,需要先删除原有队列,再开启持久化
代码实现:
在生产者中,在声明队列时,开启持久化
public static void main(String[] args) throws Exception { // 获取Channel Channel channel = RabbitMqUtils.getChannel();// 第二个参数设置为true表示开启持久化channel.queueDeclare(QUEUE_NAME, true, false, false, null); String message = "hello world"; channel.basicPublish("", QUEUE_NAME, null, message.getBytes()); System.out.println("消息发送完毕"); }
通过RabbitMq的Web管理页面,可以看到Features
属性显示为D
则表示持久化成功;
3、消息持久化
好处: 当消息开启持久化时,重启MQ后消息依然存在;
注意: 将消息标记为持久化并不能完全保证不会丢失消息。因为当消息刚准备存储在磁盘的时候,但是还没有存储完,消息还在缓存的一个间隔点,此时宕机会导致消息丢失;但是对于我们的简单任务队列而言,这已经绰绰有余了。
// 在生产者中,将推送消息时的参数设置为MessageProperties.PERSISTENT_TEXT_PLAIN,就表示消息持久化channel.basicPublish("", QUEUE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes());
代码实现:
public static void main(String[] args) throws Exception { // 获取Channel Channel channel = RabbitMqUtils.getChannel();// 第二个参数设置为true表示开启持久化channel.queueDeclare(QUEUE_NAME, true, false, false, null); String message = "hello world"; // MessageProperties.PERSISTENT_TEXT_PLAIN设置为消息持久化 channel.basicPublish("", QUEUE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN, message.getBytes()); System.out.println("消息发送完毕"); }