RocketMQ消息幂等去重消费者,支持使用MySQL或者Redis做幂等表,开箱即用
RocketMQDedupListener
通用的RocketMQ消息幂等去重消费者工具类,开箱即用
支持利用Redis或者MySQL做幂等表。支持业务主键去重或消息ID去重(默认)支持消息重复并发控制(重复的消息消费成功/失败前,不会同时消费第二条)接近于EXACTLY-ONCE语义(消息只会且仅会被成功消费一次),极端场景下则为ATLEAST-ONCE语义(消息至少被成功消费一次,不会因为去重的增强而丢失消息)
内置去重原理
见以下流程图
去重实现的来龙去脉
Quick Start
1、继承DedupConcurrentListener类,实现消费回调和去重键的设置回调
public class SampleListener extends DedupConcurrentListener {
public SampleListener(DedupConfig dedupConfi
共有 0 条评论