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

RocketMQ消息幂等去重消费者,支持使用MySQL或者Redis做幂等表,开箱即用最先出现在Python成神之路

版权声明:
作者:Zad
链接:https://www.techfm.club/p/24561.html
来源:TechFM
文章版权归作者所有,未经允许请勿转载。

THE END
分享
二维码
< <上一篇
下一篇>>