CS-Notes 学习笔记
Java 后端 · 分布式与消息队列

怎样避免重复消费?

先自己想一想,再看参考要点

参考要点

  • 处理完才确认,崩溃后会重复投递,所以消费逻辑要幂等:用业务唯一标识(订单号加事件类型,不用消息 ID)作去重键,在同一个本地事务中先写去重表再执行业务,主键冲突就直接确认
  • 有状态的业务用条件更新(WHERE status = 'UNPAID')
  • Kafka 的恰好一次不能代替业务幂等
在学习站中自测这道题看这道题所在的一天

学习站:先用面试题自评定级,按水平和面试日期排出每天的计划,自评过的题按间隔复习。免费、无需注册,记录只保存在自己的浏览器中。