第十三章 RabbitMQ之消息幂等性

news2024/11/28 16:26:42

一、引言

二、消息幂等解决方案

2.1. 方案一

2.2. 方案二

一、引言

幂等是一个数学概念，用函数表达式来描述是这样的：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：