0


RabbitMQ重复消费

1、重复消费的原因

1)多个消费者,其中一个消费信息后没有通知队列(没有给mq发ack,或者给mq发ack的过程中挂了、失败了),队列又把消息发给了其他消费者就会重复消费。

2)对于非幂等性操作,要防止重复消费;
对于幂等性操作一般不用防止重复消费。
多次操作,得到的结果相同,就是幂等性操作;比如,查询属于幂等性操作,新增、更新属于非幂等性操作。

2、解决方法

用redis。
在消费者收到消息时,先执行setnx,setnx是redis命令,是’SET if Not eXists’(如果不存在,则 SET)的简写,RedisTemplate中也有对应的方法。setnx执行后,如果返回true说明key不存在、设置成功,如果返回false说明key已存在、设置失败。

eg:我们约定
id=0,表示正在执行
id=1,表示执行成功

消费者收到消息,在执行业务前,先用setnx方法试着将id放入redis中,

Boolen result = redisTemplate.opsForValue().setIfAbsent(orderId+"_reineforce", "0");

1)如果key不存在,即setnx返回true,消费者就正常消费;
2)如果key存在,即setnx返回false,那么就要取出key的值作判断,
为0就不消费;
为1就说明该消息其他消费者已经消费过了,只是发ack没成功,这里直接ack就行。

极端情况
第一个消费者正在执行业务时,挂了、出现死锁,这种怎么办?
在setnx的基础上,再给key设置一个生存时间,防止出现死锁。


本文转载自: https://blog.csdn.net/Derek7117/article/details/128627106
版权归原作者 梅西库里RNG 所有, 如有侵权,请联系我们删除。

“RabbitMQ重复消费”的评论:

还没有评论