消息中间件 - RabbitMQ消息持久化

男娘i 2022-09-08 00:20 276阅读 0赞

手动ACK应答可以处理任务不丢失的情况，但是如何保障当 RabbitMQ 服务停掉以后消息生产者发送过来的消息不丢失？

默认情况下 RabbitMQ 退出或由于某种原因崩溃时，它忽视队列和消息，除非告知它不要这样做。确保消息不会丢失需要做两件事：**需要将队列和消息都标记为持久化**。

本章节实现简单的队列和消息的持久化功能，更加强有力的持久化策略，在后面发布确认章节再详述。

## 队列持久化 ##

生产者和消费者的信道都需要将下面的 queueDeclare() 方法的 durable 属性设置值为 true。

在com.rabbitmq.client.Channel类中，有以下方法：

/** * Declare a queue * @param queue the name of the queue * @param durable 是否持久化到磁盘 true if we are declaring a durable queue (the queue will survive a server restart) * @param exclusive true if we are declaring an exclusive queue (restricted to this connection) * @param autoDelete true if we are declaring an autodelete queue (server will delete it when no longer in use) * @param arguments other properties (construction arguments) for the queue * @return a declaration-confirm method to indicate the queue was successfully declared */
    Queue.DeclareOk queueDeclare(String queue, boolean durable, boolean exclusive, boolean autoDelete,
                                 Map<String, Object> arguments) throws IOException;

## 消息持久化 ##

生产者发送消息的信道设置上参数 MessageProperties.PERSISTENT\_TEXT\_PLAIN，表示消息持久化到磁盘上。

channel.basicPublish("", QUEUE_NAME, MessageProperties.PERSISTENT_TEXT_PLAIN, (msg).getBytes(StandardCharsets.UTF_8));

发表评论取消回复

表情：

评论列表（有 0 条评论，276人围观）

还没有评论，来说两句吧...

相关阅读

相关 RabbitMQ消息中间件

课程简介课程导读：RabbitMQ中间件本课程带你轻松入门，深度掌握RabbitMQ。 RabbitMQ是实现了高级消息队列协议（AMQP）的开源消息代理软件（亦称面

ゞ浴缸里的玫瑰/ 2023年09月27日 14:45/ 0 赞/ 145 阅读

相关消息中间件RabbitMQ

目录一、前言 1、为什么要使用MQ 1.1、削峰 1.2、解耦 1.3、异步 2、MQ分类 3、MQ选择 3.1、Kafka 3.2、RocketMQ

╰+攻爆jí腚メ/ 2023年09月23日 13:26/ 0 赞/ 131 阅读

相关 RabbitMQ消息持久化

目录一、前言二、队列持久化　　2.1 查看存在的队列和消息数量　　2.2 持久化队列三、消息持久化

桃扇骨/ 2023年01月07日 12:24/ 0 赞/ 178 阅读

相关 RabbitMQ 消息中间件

1、消息中间件 1、简介消息中间件也可以称消息队列，基于数据通信来进行分布式系统的集成。当下主流的消息中间件有RabbitMQ、Kafka、ActiveMQ、

た入场券/ 2022年12月15日 11:20/ 0 赞/ 187 阅读

相关消息中间件 - RabbitMQ消息持久化

手动ACK应答可以处理任务不丢失的情况，但是如何保障当 RabbitMQ 服务停掉以后消息生产者发送过来的消息不丢失？默认情况下 RabbitMQ 退出或由于某种原因崩溃时

男娘i/ 2022年09月08日 00:20/ 0 赞/ 277 阅读

相关消息中间件 - RabbitMQ 消息应答

一、场景消费者完成一个任务可能需要一段时间，如果其中一个消费者处理一个长的任务并仅只完成了部分突然它挂掉了，会发生什么情况？RabbitMQ 一旦向消费者传递了一条

傷城~/ 2022年09月08日 00:20/ 0 赞/ 287 阅读

相关 RabbitMQ消息的持久化

RabbitMQ消息持久化需要将消息和队列都持久化队列持久化 //为Channel定义queue的属性，queueName为queue名称第二个参数持久化标志

客官°小女子只卖身不卖艺/ 2022年08月20日 09:21/ 0 赞/ 257 阅读

相关 RabbitMQ-消息应答和消息持久化

文章目录 RabbitMQ-消息应答和消息持久化 1.消息应答 RabbitMQ-消息应答和消息持久化 1.消息应答 > A

本是古典何须时尚/ 2022年05月30日 08:55/ 0 赞/ 294 阅读

相关消息中间件-RabbitMQ

消息中间件 1.采用异步处理模式消息发送者可以发送一个消息而且不用等待相应。消息接收者订阅或监听该通道。一条消息最终可以转发给一个或多个消息接收者。 2.应用按

男娘i/ 2021年09月29日 23:20/ 0 赞/ 533 阅读

相关消息中间件-RabbitMQ

【更多资讯及资料获取，关注微信公众号号：浅醉JAVA】消息中间件-RabbitMQ 一 RabbitMQ简介 MQ全程为Message Queue，消息队列（M

川长思鸟来/ 2021年09月22日 16:26/ 0 赞/ 516 阅读