RabbitMQ — 数据持久化实现MQ可靠性

上篇我们实现：publisher发送到MQ的可靠性实现，那么接下来MQ本身对于消息的处理该如何保证可靠呢？

数据持久化

消息到达MQ以后，如果MQ不能及时保存，也会导致消息丢失，所以MQ的可靠性也非常重要。

为了提升性能，默认情况下MQ的数据都是在内存存储的临时数据，重启后就会消失。为了保证数据的可靠性，必须配置数据持久化。

由图像可知实现在MQ中数据持久化：

交换机（Exchange）持久化

队列（Queue）持久化

消息（Message）持久化

事实上，我们在编写代码时默认是实现持久化了。

默认实现过程：在默认情况下，RabbitMQ会将接收到的信息保存在内存中以降低消息收发的延迟。出现消息堆积问题，RabbitMQ的内存占用就会越来越高，直到触发内存预警上限。此时RabbitMQ会将内存消息刷到磁盘上。

简单描述：导致消息积压——>触发内存预警上限——>RabbitMQ会将内存消息储存磁盘

这是默认的处理机制，一般情况下是没有问题的。

在一些情况下：

1.消费者宕机或出现网络故障

2.消息发送量激增，超过了消费者处理速度

3.消费者处理业务发生阻塞

问题：RabbitMQ会将内存消息储存磁盘需要耗时较久——>阻塞队列进程——>生产者的所有请求都会被阻塞。

解决方案：3.12版本之后，LazyQueue已经成为所有队列的默认格式。因此官方推荐升级MQ为3.12版本或者所有队列都设置为LazyQueue模式。

当然，如果你的MQ为3.12版本之下的，解决方法如下：

（添加x-queue-mod=lazy参数可设置队列为Lazy模式）

1.如果你是基于@Bean方式声明队列：

@Bean
public Queue lazyQueue(){
    return QueueBuilder
            .durable("lazy.queue")
            .lazy() // 开启Lazy模式
            .build();
}

2.如果你是基于注解来声明队列:

@RabbitListener(queuesToDeclare = @Queue(
        name = "lazy.queue",
        durable = "true",
        arguments = @Argument(name = "x-queue-mode", value = "lazy")
))
public void listenLazyQueue(String msg){
    log.info("接收到 lazy.queue的消息：{}", msg);
}

对于已经存在的队列，也可以配置为lazy模式:(通过命令行)

rabbitmqctl set_policy Lazy "^lazy-queue$" '{"queue-mode":"lazy"}' --apply-to queues