第十三章 RabbitMQ之消息幂等性
目录
一、引言
幂等是一个数学概念，用函数表达式来描述是这样的：f(x) = f(f(x)) 。在程序开发中，则是指同一个业务，执行一次或多次对业务状态的影响是一致的。有些业务天生就是幂等的，如查询和删除业务执行一次和多次的结果是一样的，而像用户下单、用户退款是非幂等业务。
实际项目开发中，我们在提交表单时，很多时候可能会重复提交表单，这个时候我们通过token令牌等唯一标识来解决，第一次提交页面将缓存中的唯一标识删除，后面再重新提交时缓存中的标识已经被删了因此重复提交失败。
我们在消息消费的过程中也会存在同样的问题，即如何来保障所有业务在接收RabbitMQ消息时保证业务的幂等性，避免消息重复消费呢？
二、消息幂等解决方案
2.1. 方案一
1. 给每个消息都设置/生成一个唯一id，利用id区分是否是重复消息，与消息一起投递给消费者。
2. 消费者接收到消息后处理自己的业务，业务处理成功后将消息ID保存到数据库
3. 如果下次又收到相同消息，去数据库查询判断是否存在，存在则为重复消息放弃处理
核心代码：
我们可以在生产者和消费者两端分别声明消息转换器的Bean，本案例为了方便直接在启动类中声明消息转换器，并配置自动为消息创建id。
package com.example.consumer;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
@SpringBootApplication
public class ConsumerApplication {
public static void main(String[] args) {
SpringApplication.run(ConsumerApplication.class, args);
}
@Bean
public MessageConverter messageConverter(){
// 1.定义消息转换器
Jackson2JsonMessageConverter jjmc = new Jackson2JsonMessageConverter();
// 配置自动创建消息id，用于识别不同消息，也可以在业务中基于ID判断是否是重复消息
jjmc.setCreateMessageIds(true);
return jjmc;
}
}
package com.example.publisher;
import org.springframework.amqp.support.converter.Jackson2JsonMessageConverter;
import org.springframework.amqp.support.converter.MessageConverter;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.Bean;
@SpringBootApplication
public class PublisherApplication {
public static void main(String[] args) {
SpringApplication.run(PublisherApplication.class, args);
}
@Bean
public MessageConverter messageConverter(){
// 1.定义消息转换器
Jackson2JsonMessageConverter jjmc = new Jackson2JsonMessageConverter();
// 配置自动创建消息id，用于识别不同消息，也可以在业务中基于ID判断是否是重复消息
jjmc.setCreateMessageIds(true);
return jjmc;
}
}
通过源码可以看到默认生成的是UUID：
通过RabbitMQ浏览器界面可以看到消息已经生成了一个唯一ID ：
2.2. 方案二
结合业务逻辑，基于业务本身做判断。以余额支付业务为例，我们要在支付后修改订单状态为已支付，应该在修改订单状态前先查询订单状态，判断状态是否是未支付。只有未支付订单才需要修改，其他状态不做处理：
核心代码
上述代码可以通过乐观锁来实现，替换代码如下：
原文地址：https://blog.csdn.net/qushaming/article/details/142864402
免责声明：本站文章内容转载自网络资源，如本站内容侵犯了原著者的合法权益，可联系本站删除。更多内容请关注自学内容网（zxcms.com）！