RabbitMQ持久化机制(消息持久化、队列持久化)

RabbitMQ持久化机制(消息持久化、队列持久化)

目录

1、概述2、队列持久化3、消息持久化

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("消息发送完毕");
    }