背景

为什么会出现这种问题呢？还得从rmq的消息投递和消费说起，下面给出一个例子

image

1：生成者投递消息到broker

2：broker接受到消息并ack

3：消费者从broker中push/pull消息

4：3步骤完事后回复broker ——》 ACK

对于上述的完成流程，只要破坏其中的ack流程就会导致消息重复发送或重新消费，以下列出部分

破坏条件	影响	案例
破坏broker给生产者的ack	生产者可能会重复发送	broker负载高，延迟大，突然不在线等
破坏消费者给broker的ack	消费者可能会重复消费	在ack回复的时候，broker觉得自己ack超时了等原因
...........	...........	...........

分析

我们只要控制好每条消息只是消费一次就ok了，那么消息的幂等处理就来了，根据消费者部署拓扑分如下几种情况

部署拓扑	解决办法	备注
单点	可以使用 synchronized + 业务check
集群	考虑使用高性能的分布式锁 + 业务check

流程如下

image

消息进到消费者中，肯定是顺序进入的，只要保证这个处理消息的方法处理业务逻辑是顺序的，主要还是在于数据的处理问题，需要在厨业具体业务逻辑的时候，判断这条消息是否消费过，如果没有消费过，直接消费就好，如果消费了，直接丢弃，回复一个OK

流程如下

image-20220217202311965

消息分别进入到消费者1和消费者2中，不巧的是，这时候两个jvm都会去查数据库之类的check状态，发现都是合法，就会继续下面的操作，导致消息多次消费。而是有了下面的流程

改进流程

image-20220218183531419

分布式锁：目前市面上有几种常见的分布式解决方案

参考

分布式锁常见解决方案

1、本篇从引入为什么会有消息重复消费，原因，以及基本的杜绝原理

2、扩展了分布式锁常见的几种解决方案