RabbitMQ队列可靠性保证

痛定思痛。 2023-02-27 05:49 11阅读 0赞

###    **问题1、** ###

Producer在把Message发送Broker的过程中，因为网络问题等发生丢失，或者Message到了Broker，Consumer还没来得及消费，Broker挂掉了。

**解决方法：**  
一般都是使用confirm机制以及持久化方式解决，  
1)创建Queue的时候设置持久化，保证Broker持久化Queue的元数据，但是不会持久化Queue里面的消息，  
2)这样只有Message支持化到磁盘之后才会发送confirm通知Producer ack进行确认。

这两步过后，即使Broker挂了，Producer肯定收不到ack的，就可以进行重发。

### 问题2、 ###

Consumer有消费到Message，但是内部出现问题，Message还没处理，Broker以为Consumer处理完了，将Message标记为处理成功了。

**解决方法：**  
就要关闭Consumer的autoack，消息处理完成后，进行手动ack。

### 问题3、 ###

Consumer有消费到Message，但是由于各种原因，收到了多条重复的Message。

**解决方法：**  
首先也是需要Consumber关闭autoack，消息处理完成后，进行手动ack。  
同时在Consumer端记录已经处理过的Message编号，可以是消息ID之类的，下次再接收到相同消息ID的时候自动抛弃。并ack回复处理成功。

**Producer端整体流程：**

*1、生产端发送message给Broker，持久化message,*

*2、Broker给Confirm响应返回生产端,*

*3、生产端接收到confirm，对message状态更改,*

*5、分布式定时任务获取message的状态,*

*6、如果消息不能成功投递，重新进行发送，记录重发次数,*

*7、当重发3次之后，将状态修改，只能人工进行干预。*

**Consumer端整体流程：**

*1、消费端监听到message，检查是否已处理过，确保不会重复处理过该消息，*

*2、对message进行各种业务或者入库处理,*

*3、业务处理完成之后，ack回复Queue,*

*4、如果处理失败或者长时间没有ack，那么Broker会从新推送message过来。*

发表评论取消回复

表情：

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

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

相关阅读

相关如何保证 RabbitMQ 的消息可靠性

前言项目开发中经常会使用消息队列来完成异步处理、应用解耦、流量控制等功能。虽然消息队列的出现解决了一些场景下的问题，但是同时也引出了一些问题，其中使用消息队列时如何保证

ゞ浴缸里的玫瑰/ 2023年10月09日 21:21/ 0 赞/ 29 阅读

相关如何保证 RabbitMQ 的消息可靠性

前言项目开发中经常会使用消息队列来完成异步处理、应用解耦、流量控制等功能。虽然消息队列的出现解决了一些场景下的问题，但是同时也引出了一些问题，其中使用消息队列时如何保证

不念不忘少年蓝@/ 2023年09月27日 18:29/ 0 赞/ 12 阅读

相关如何保证 RabbitMQ 的消息可靠性

前言项目开发中经常会使用消息队列来完成异步处理、应用解耦、流量控制等功能。虽然消息队列的出现解决了一些场景下的问题，但是同时也引出了一些问题，其中使用消息队列时如何保证

不念不忘少年蓝@/ 2023年09月27日 18:27/ 0 赞/ 107 阅读

相关【RabbitMQ】图解RabbitMQ是如何保证消息可靠性的

目录一、概述 1、消息可靠性 2、SpringBoot整合RabbitMQ配置文件二、生产者---RabbitMQ服务器如何保证信息不丢失 1、confirm确认

超、凢脫俗/ 2023年09月27日 17:29/ 0 赞/ 153 阅读

相关 RabbitMQ队列可靠性保证

问题1、 Producer在把Message发送Broker的过程中，因为网络问题等发生丢失，或者Message到了Broker，Consumer还没来得及消费，B

痛定思痛。/ 2023年02月27日 05:49/ 0 赞/ 12 阅读

相关 RabbitMQ如何保证消息的可靠性

[RabbitMQ如何保证消息的可靠性][RabbitMQ] 1、保证消息不丢失(三步) 1.1、开启事务(不推荐) 1.2、开启confirm(推荐) 1.

今天药忘吃喽~/ 2023年01月22日 15:49/ 0 赞/ 7 阅读

相关 rabbitMQ消息的可靠性投递分析和保证方案

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ub

ゞ浴缸里的玫瑰/ 2023年01月14日 14:56/ 0 赞/ 132 阅读

相关【RabbitMQ】如何保证消息可靠性投递？

RabbitMQ的可靠性投递，也就是在使用RabbitMQ实现异步通信的时候，消息丢了怎么办，消息重复消费怎么办？在RabbitMQ里面提供了很多保证消息可靠投递的机制，这个也

野性酷女/ 2022年12月22日 02:27/ 0 赞/ 161 阅读

相关 RabbitMq保证消息可靠性

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM5

缺乏、安全感/ 2022年12月09日 01:58/ 0 赞/ 513 阅读

相关《RabbitMQ》如何保证消息的可靠性

一条消费成功被消费经历了生产者->MQ->消费者，因此在这三个步骤中都有可能造成消息丢失。一消息生产者没有把消息成功发送到MQ 1.1 事务机制 `AMQP`

短命女/ 2021年09月18日 05:40/ 0 赞/ 427 阅读