文件名称：RocketMQDedupListener:RocketMQ消息幂等去重消费者，支持使用MySQL或者Redis做幂等表，开箱即用
文件大小：55KB
文件格式：ZIP
更新时间：2024-06-19 04:12:52
deduplication rocketmq rocketmq-client Java
RocketMQDedupListener 通用的RocketMQ消息幂等去重消费者工具类，开箱即用 支持利用Redis或者MySQL做幂等表。 支持业务主键去重或消息ID去重（默认） 支持消息重复并发控制（重复的消息消费成功/失败前，不会同时消费第二条） 接近于EXACTLY-ONCE语义（消息只会且仅会被成功消费一次），极端场景下则为ATLEAST-ONCE语义（消息至少被成功消费一次，不会因为去重的增强而丢失消息） 内置去重原理 见以下流程图 去重实现的来龙去脉 可以参考本人在官方微信发表的博文： Quick Start 1、继承DedupConcurrentListener类，实现消费回调和去重键的设置回调 public class SampleListener extends DedupConcurrentListener { public SampleListener(
【文件预览】：
RocketMQDedupListener-master
----src()
--------main()
----dedup-flow.png(40KB)
----README.md(9KB)
----pom.xml(2KB)
----.gitignore(240B)