当前位置：网站首页>Redis消息队列重复消费问题

Redis消息队列重复消费问题

2022-06-12 12:50:00 【Li_XiaoJin】

最近遇到的一个问题，记录一下。

事情原委

我们目前项目中短信模块就是采用的 Redis 来作消息队列，起因是最近有应用反映下发短信时，偶尔会有发送两次的情况。

经过排查，确实是会存在，这个是我们研发之前的处理是发送短信后就会删除锁，这样如果出现网络波动的情况，就会出现发送两次的情况。

具体情况是这样，我们有两个实例，每个实例都订阅了topic，发送时会通知每个消费者，每个实例去获取锁，然后发送短信；当时的情况是这样，生产者发送后，消费者开始消费第一个实例消费的时间是 18:10:024，然后进行业务处理，发送短信完成时间是 18:10:056（通过日志查看到时间），处理得很快，几十毫秒就处理完了，然后把锁删除。第二个实例消费的时间是 18:10:244，这时第一个实例已经处理完成，并且把锁删除掉，所以这时第二个实例尝试获取锁时会直接成功，接着进行业务处理，重新发送第二条短信完成时间是 18:10:268。所以就造成偶尔会出现发送两次的情况。

找到问题所在就开始修复了，主要解决思路是让第二次获取锁失败就行了。

这里我们修改为获取锁进行业务处理完成之后，不直接删除锁，而是让它过一段时间失效，这样别的实例再此期间再获取锁时就不会成功了，即使第一次处理得很快，也不会被两次消费处理。

这里我们设置失效时间是 1分钟，后期可以根据业务情况进行调整。