您好,欢迎来到二三四教育网。
搜索
您的当前位置:首页RocketMQ重复消息终极解决方案

RocketMQ重复消息终极解决方案

来源:二三四教育网

大神的文章分析了RocketMQ实现顺序消息的原理,由此引出一个新问题:如何解决重复消息问题?

大神给出的回答是:

RocketMQ不保证消息不重复,如果你的业务需要保证严格的不重复消息,需要你自己在业务端去重。

意不意外,惊不惊喜?

赶紧回归正题,业务端如何去重呢?原理很简简单,步骤如下:

1、记录下每个消息的msgID
2、新消息来的时候,查看该消息的msgID是否已记录,是则抛弃,否则消费

那么msgID记录在哪里呢?当然是缓存。所以我在解决这个问题的时候,使用了redis缓存。具体做法如下:

1、消费端接收到消息的时候,调用redis提供的incr方法,以msgID作为key(具有唯一性),value则默认从1开始递增。

2、当incr返回值为1时,设置其失效时间为两分钟以后(每个msgID保留两分钟足矣!),并且该消息需要被消费。

3、当incr返回值大于1时,则忽略该消息。

部分代码如下:

这样就在业务端简单有效地解决了重复消息问题。

Copyright © 2019- how234.cn 版权所有 赣ICP备2023008801号-2

违法及侵权请联系:TEL:199 1889 7713 E-MAIL:2724546146@qq.com

本站由北京市万商天勤律师事务所王兴未律师提供法律服务