• 1
• 6
• 2

晨煦风清/RocketMQDedupListener

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