Skip to content

Latest commit

 

History

History
 
 

springboot-mq-idempotent-consume

Folders and files

NameName
Last commit message
Last commit date

parent directory

..
 
 
 
 
 
 

本例主要演示springboot和kafka集成,实现消费端幂等消费

实现原理如下:

  • 1、生产者发送消息时,携带一个全局唯一的id
  • 2、消费端消费时,先根据这个全局唯一的id去redis查询一下
  • 3、如果该ID已经被消费过,则不进行处理
  • 4、如果该ID没被消费过,则进行处理,处理结束后,把该ID存入redis,且value设置为已消费

注:消费端必须开启手动确认,不能是自动确认