• 1
• 6
• 2

晨煦风清/RocketMQDedupListener

通用的RocketMQ消息幂等去重消费者工具类,开箱即用 支持利用Redis或者MySQL做幂等表。 支持业务主键去重或消息ID去重(默认) 支持消息重复并发控制(重复的消息消费成功/失败前,不会同时消费第二条) 接近于EXACTLY-ONCE语义(消息只会且仅会被成功消费一次),极端场景下则为ATLEAST-ONCE语义(消息至少被成功消费一次,不会因为去重的增强而丢失消息)