当前位置: 首页 > article >正文

RabbitMQ如何保证消息不丢失(面试版)

下图是RabbitMQ消息的发送过程,在任何环节消息都有可能丢失:

 生产者确认机制

开启生产者确认机制,确保生产者的消息能到达队列

RabbitMQ提供了publisher confirm 机制来避免消息发送到MQ过程中丢失 。 消息发送到MQ后 , 会返回一个结果给发送者,表示消息是否处理成功。

  • 当消息发送到队列后,会返回一个publish-comfirm ack,告诉生产者已经收到消息;
    • 导致消息丢失的原因一:在此过程中失败的场景有两个:消息发送到交换机会失败,交换机路由消息到队列失败。
      • 消息发送到交换机会失败:返回一个publish-confirm的nack
      • 交换机路由消息到队列失败:返回一个publish-return的ack
      • 消息发送失败之后如何处理?
        • 通过回调方法即时重发
        • 记录日志
        • 保证到数据库然后定时重发,成功发送后即刻删除表中的数据
  • 导致消息丢失的原因二:当消息发送到队列中,但MQ宕机了,如何解决:
    • 开启持久化功能,确保消息未消费前在队列中不会丢失
      •  
  • 导致消息丢失的原因三: 消费者导致消息丢失,如何解决(两种解决方案):
    • 开启消费者确认机制为auto,由spring确认消息处理成功后完成ack
    • 开启消费者失败重试机制,多次重试失败后将消息投递到异常交换机,交由人工处理


http://www.kler.cn/a/281336.html

相关文章:

  • Oracle(86)什么是索引重建(Index Rebuild)?
  • 【商城源码需要不断升级哪些方面】
  • 游戏引擎详解——图片
  • 快速排序——算法世界的速度传奇
  • 解决 `java.sql.SQLException` 的正确方法
  • 【动态规划】子数组系列一(数组中连续的一段)
  • Spring Boot(八十七):集成opencc4j实现中文简繁转换
  • 进程间的同步与互斥
  • 根据子网前缀的长度计算ip范围
  • Python知识点:如何使用MongoDB与PyMongo进行NoSQL数据库操作
  • 零基础5分钟上手亚马逊云科技-基础设施即代码开发
  • 深入理解Java代理模式:从静态到动态的实现与应用
  • [000-01-011].第2节:持久层方案的对比
  • 更新RK3588开发板的rknn_server和librknnrt.so【这篇文章是RKNPU2从入门到实践 --- 【5】的配套文章】
  • 服务器在插入一个新的磁盘后需要做的操作(仅限新盘)
  • 揭秘无线领夹麦克风五大行业隐秘:音质失真、隐私泄露需警惕!
  • 搜维尔科技:使用MANUS VR手套控制特斯拉机器人叠衣服操作
  • 同模块下的ability之间的跳转
  • HTML5 浏览器支持
  • android gradle特别慢