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

如何解决RabbitMQ消息的重复消费问题

什么情况下会导致消息的重复消费——在消费者还没成功发送自动确认机制时发生:

  • 网络抖动
  • 消费者挂了

解决方案

  • 每条消息设置一个唯一的标识id
  • 幂等方案:【Redis分布式锁、数据库锁(悲观锁、乐观锁)】

 面试官:如何解决MQ消息重复消费的问题

候选人:我们当时是设置了自动确认机制,当服务还没来得及给MQ确认的时候,服务宕机了,导致服务重启之后,又消费了一次消息。这样就重复消费了。

因为我们当时有一个业务的唯一标识,我们再处理消息时,先到数据库查询一下,这个数据是否存在,如果不存在,说明没有处理过,这个时候就可以正常处理这个消息了。如果已经存在这个数据了,就说明消息重复消费了,我们就不需要再消费了。

第二种就是典型的幂等性问题,比如,Redis分布式锁、数据库的锁都是可以的。

http://www.lryc.cn/news/473074.html

相关文章:

  • Java调用chatgpt
  • 将你的 Kibana Dev Console 请求导出到 Python 和 JavaScript 代码
  • 成都世运会志愿者招募报名流程及证件照制作方法
  • 大数据技术的前景如何?
  • LLM | 论文精读 | 基于大型语言模型的自主代理综述
  • 详解Redis相关缓存问题
  • ubuntu 24 (wayland)如何实现无显示器远程桌面
  • 《模拟电子技术基础》第六版PDF课后题答案详解
  • python知识收集
  • 传奇996_3——使用补丁添加怪物
  • 「Mac畅玩鸿蒙与硬件13」鸿蒙UI组件篇3 - TextInput 组件获取用户输入
  • MCU裸机任务调度架构
  • 【Web前端】JavaScript 对象原型与继承机制
  • 【华为HCIP实战课程二十六】中间到中间系统协议IS-IS配置默认路由及IS-IS数据库,网络工程师
  • mysql上课总结(2)(DCL的所有操作总结、命令行快速启动/关闭mysql服务)
  • 法律智能助手:开源NLP系统助力法律文件高效审查与检索
  • 如何使用AdsPower指纹浏览器克服爬虫技术限制,安全高效进行爬虫!
  • 四、虚拟化配置寄存器(HCR_EL2)
  • 我要成为算法高手-滑动窗口篇
  • jenkins搭建及流水线配置
  • Vue v-on
  • 快速生成高质量提示词,Image to Prompt 更高效
  • SELS-SSL/TLS
  • 算法:排序
  • MyBatis-Plus 更新对象时如何将字段值更新为 null
  • Unreal5从入门到精通之如何在VR中使用3DUI
  • ViSual studio如何安装 并使用GeographicLib
  • Java程序设计:spring boot(11)——分布式缓存 Ehcache 整合
  • 豆包,攻克数字是个什么工具?《GKData-挖掘数据的无限可能》(数据爬虫采集工具)
  • 说一说QWidget