SpringBoot+Redisson自定義注解一次解決重復(fù)提交問題

更新時(shí)間：2024年03月03日 10:32:29 作者：程序員濟(jì)癲

項(xiàng)目中經(jīng)常會(huì)出現(xiàn)重復(fù)提交的問題，本文主要介紹了SpringBoot+Redisson自定義注解一次解決重復(fù)提交問題，具有一定的參考價(jià)值，感興趣的可以了解一下

前言

項(xiàng)目中經(jīng)常會(huì)出現(xiàn)重復(fù)提交的問題，而接口冪等性也一直以來是做任何項(xiàng)目都要關(guān)注的疑難點(diǎn)，網(wǎng)上可以查到非常多的方案，我歸納了幾點(diǎn)如下：

1）、數(shù)據(jù)庫層面，對責(zé)任字段設(shè)置唯一索引，這是最直接有效的方式，不好的地方就是一旦觸發(fā)就會(huì)在服務(wù)端拋數(shù)據(jù)庫相關(guān)異常；

2）、代碼層面，增加業(yè)務(wù)邏輯判斷，先查詢一遍若沒有才插入，這也是最容易想到的方式，反正寫上就對了，不好的地方就是分布式場景下依然避免不了問題；

3）、前端層面，對于觸發(fā)事件的操作比如按鈕等，最好點(diǎn)擊過后都設(shè)置幾秒的置灰時(shí)間，能很大程度上解決惡意提交的問題。

以上幾點(diǎn)經(jīng)常在項(xiàng)目中結(jié)合使用，不過有一種更通用的方案，就是自定義注解，寫一個(gè)專門處理這類問題的注解，之后在有需要用到的接口上直接加上這個(gè)注解即可，十分方便。

實(shí)現(xiàn)步驟

1、引入依賴

完整依賴如下：

使用的SpringBoot版本3.0之前最新的發(fā)布版本2.6.3，3.0版本要求JDK17，所以短時(shí)間內(nèi)不會(huì)在行業(yè)中普遍的，企業(yè)中成熟的版本依然是2.x。

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <parent>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-parent</artifactId>
      <version>2.6.3</version>
      <relativePath/> <!-- lookup parent from repository -->
   </parent>
   <groupId>com.example</groupId>
   <artifactId>resubmit</artifactId>
   <version>0.0.1-SNAPSHOT</version>
   <name>resubmit</name>
   <description>Demo project for Spring Boot</description>
   <properties>
      <java.version>1.8</java.version>
   </properties>
   <dependencies>
        <!-- spring web -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <!-- spring aop 實(shí)現(xiàn)自定義注解用到 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-aop</artifactId>
        </dependency>
        <!-- spring processor 加載項(xiàng)目配置使用，也可以不用，但I(xiàn)DEA配置類頂端會(huì)有警告 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-configuration-processor</artifactId>
            <optional>true</optional>
        </dependency>
        <!-- spring jdbc -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-jdbc</artifactId>
        </dependency>
        <!-- mysql 不填寫版本號(hào)默認(rèn)是8.0以上 -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <scope>runtime</scope>
        </dependency>
        <!-- springData redis 不填寫版本號(hào)默認(rèn)和springboot版本一致 -->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>
        <!-- redission 注意版本號(hào)和springData-redis要對應(yīng) 這里26對應(yīng)springData-redis的2.6版本 -->
        <dependency>
            <groupId>org.redisson</groupId>
            <artifactId>redisson-spring-data-26</artifactId>
            <version>3.16.8</version>
        </dependency>
        <!-- fastjson 解析json用到，也可以換成自己喜歡用的 -->
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>1.2.79</version>
        </dependency>
        <!-- mybatis-plus 參考官網(wǎng)，目前是最新版 -->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-boot-starter</artifactId>
            <version>3.5.1</version>
        </dependency>
        <!-- 代碼生成器 mybatisPlus自帶的生成器 -->
        <dependency>
            <groupId>com.baomidou</groupId>
            <artifactId>mybatis-plus-generator</artifactId>
            <version>3.5.1</version>
        </dependency>
        <!-- freemarker模板生成器 引入代碼生成器需要 -->
        <dependency>
            <groupId>org.freemarker</groupId>
            <artifactId>freemarker</artifactId>
            <version>2.3.31</version>
        </dependency>
        <!-- swagger 因?yàn)閙ybatisPlus代碼生成器會(huì)自帶swagger的注解 -->
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-swagger2</artifactId>
            <version>2.7.0</version>
        </dependency>
        <dependency>
            <groupId>io.springfox</groupId>
            <artifactId>springfox-swagger-ui</artifactId>
            <version>2.7.0</version>
        </dependency>
        <!-- lombok 因?yàn)閙ybatisPlus代碼生成器會(huì)自帶lombok的注解 -->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <optional>true</optional>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
            <scope>test</scope>
        </dependency>
    </dependencies>

   <build>
      <plugins>
         <plugin>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-maven-plugin</artifactId>
            <configuration>
               <excludes>
                  <exclude>
                     <groupId>org.projectlombok</groupId>
                     <artifactId>lombok</artifactId>
                  </exclude>
               </excludes>
            </configuration>
         </plugin>
      </plugins>
   </build>

</project>

2、配置application.yml

這里注意，生產(chǎn)環(huán)境項(xiàng)目是要區(qū)分application.yml、application-dev.yml、application-test.yml、application-prod.yml的，這里只是實(shí)現(xiàn)功能的小案例，就只寫了這一個(gè)。

# 端口，改成自己的。
server:
  port: 8888

# 數(shù)據(jù)源，使用hikari，現(xiàn)在一般項(xiàng)目都是默認(rèn)的這個(gè)數(shù)據(jù)源了，更詳細(xì)的配置可以百度。
spring:
  datasource:
    type: com.zaxxer.hikari.HikariDataSource
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/resubmit_demo?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf8&useSSL=false
    username: root # 換成自己數(shù)據(jù)庫的賬號(hào)
    password: 123456 # 換成自己數(shù)據(jù)庫的密碼
  # redis配置，換成自己的。
  redis:
    database: 11
    host: 192.168.1.197
    port: 6379
    password: 123456
    jedis:
      pool:
        max-active: 1000
        max-wait: -1ms
        max-idle: 50
        min-idle: 1

# redission配置，這里直接讀取的redis變量.
redisson:
  singleserverconfig:
    address: "redis://${spring.redis.host}:${spring.redis.port}"
    password: ${spring.redis.password}
    database: ${spring.redis.database}

3、編寫配置類

1）、redis配置類

package com.example.resubmit.config;

import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.*;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;

/**
 * <p>
 *  redis配置類
 * </p>
 *
 * @author 福隆苑居士，公眾號(hào)：【Java分享客棧】
 * @since 2022-02-08
 */
@Configuration
public class RedisConfig {

   @Bean
   public StringRedisTemplate stringRedisTemplate(RedisConnectionFactory redisConnectionFactory) {
      StringRedisTemplate redisTemplate = new StringRedisTemplate();
      redisTemplate.setConnectionFactory(redisConnectionFactory);
      return redisTemplate;
   }

   @Bean
   public RedisTemplate redisTemplate(RedisConnectionFactory factory) {
      RedisTemplate<String, Object> template = new RedisTemplate<>();
      template.setConnectionFactory(factory);

      Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);
      ObjectMapper objectMapper = new ObjectMapper();
      objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);
      objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance, ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);
      jackson2JsonRedisSerializer.setObjectMapper(objectMapper);

      StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();
      // key采用String的序列化方式
      template.setKeySerializer(stringRedisSerializer);
      // hash的key也采用String的序列化方式
      template.setHashKeySerializer(stringRedisSerializer);
      // value序列化方式采用jackson
      template.setValueSerializer(jackson2JsonRedisSerializer);
      // hash的value序列化方式采用jackson
      template.setHashValueSerializer(jackson2JsonRedisSerializer);
      template.afterPropertiesSet();
      return template;
   }
}

2）、Redisson配置類

package com.example.resubmit.config;

import com.fasterxml.jackson.core.JsonProcessingException;
import org.redisson.Redisson;
import org.redisson.api.RedissonClient;
import org.redisson.config.Config;
import org.redisson.config.SingleServerConfig;
import org.redisson.spring.data.connection.RedissonConnectionFactory;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.context.properties.ConfigurationProperties;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.util.StringUtils;

/**
 * <p>
 *  redission配置類
 * </p>
 *
 * @author 福隆苑居士，公眾號(hào)：【Java分享客?！?
 * @since 2022-02-08
 */
@Configuration
@ConfigurationProperties(prefix = "redisson.singleserverconfig")
public class RedissonSpringDataConfig {

   private static final Logger log = LoggerFactory.getLogger(RedissonSpringDataConfig.class);

    private String address;
    private int database;
    private String password;

    @Bean
    public RedissonConnectionFactory redissonConnectionFactory(RedissonClient redisson) {
        return new RedissonConnectionFactory(redisson);
    }

    @Bean(destroyMethod = "shutdown")
    public RedissonClient redisson() throws JsonProcessingException {
      log.debug("[RedissonSpringDataConfig][redisson]>>>> address: {}, database: {}, password: {}", address, database, password);
        Config config = new Config();
        SingleServerConfig sconfig= config.useSingleServer()
            .setAddress(address)
         .setDatabase(database);
        // 如果redis設(shè)置了密碼，這里不設(shè)置密碼就會(huì)報(bào)“org.redisson.client.RedisAuthRequiredException: NOAUTH Authentication required”錯(cuò)誤。
        if(StringUtils.hasText(password)){
            sconfig.setPassword(password);
        }
        return Redisson.create(config);
    }

    public String getAddress() {
        return address;
    }

    public void setAddress(String address) {
        this.address = address;
    }

    public int getDatabase() {
        return database;
    }

    public void setDatabase(int database) {
        this.database = database;
    }

    public String getPassword() {
        return password;
    }

    public void setPassword(String password) {
        this.password = password;
    }
}

4、MybatisPlus代碼生成器

這個(gè)生成器我參考官網(wǎng)的做了優(yōu)化和注釋，一看就能明白。

package com.example.resubmit.generator;

import com.baomidou.mybatisplus.generator.FastAutoGenerator;
import com.baomidou.mybatisplus.generator.config.OutputFile;
import com.baomidou.mybatisplus.generator.engine.FreemarkerTemplateEngine;

import java.util.Collections;

/**
 * @作者: 福隆苑居士，公眾號(hào)：【Java分享客?！?
 * @日期: 2022/2/8 20:51
 * @描述: mybatis-plus代碼生成器
 */
public class CodeGenerator {

   private static final String url = "jdbc:mysql://localhost:3306/resubmit_demo?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=utf8&useSSL=false";
   private static final String username = "root";
   private static final String password = "123456";
   private static final String outputDir = "D:\workspace\workspace_java\resubmit\src\main\java"; // entity、mapper、service、controller生成的目錄地址，換成自己項(xiàng)目的。
   private static final String xmlOutputDir = "D:\workspace\workspace_java\resubmit\src\main\resources\mapper"; // xxMapper.xml生成的目錄地址，換成自己項(xiàng)目的。

   public static void main(String[] args) {
      FastAutoGenerator.create(url, username, password)
            .globalConfig(builder -> {
               builder.author("福隆苑居士，公眾號(hào)：【9i分享客?！?) // 設(shè)置作者
                     .enableSwagger() // 開啟 swagger 模式
                     .fileOverride() // 覆蓋已生成文件
                     .outputDir(outputDir); // 指定輸出目錄
            })
            .packageConfig(builder -> {
               builder.parent("com.example.resubmit") // 設(shè)置父包名，和自己項(xiàng)目的父包名一致即可。
                     .moduleName("") // 設(shè)置父包模塊名，為空就會(huì)直接生成在父包名目錄下。
                     .pathInfo(Collections.singletonMap(OutputFile.mapperXml, xmlOutputDir)); // 設(shè)置mapperXml生成路徑
            })
            .strategyConfig(builder -> {
               builder.addInclude("tb_user") // 設(shè)置需要生成的表名，多個(gè)用逗號(hào)隔開。
                     .addTablePrefix("t_", "tb_", "c_"); // 設(shè)置過濾表前綴，多個(gè)用逗號(hào)隔開。
            })
            .templateEngine(new FreemarkerTemplateEngine()) // 使用Freemarker引擎模板，默認(rèn)的是Velocity引擎模板
            .execute();
   }

}

5、定義響應(yīng)實(shí)體

這個(gè)因人而定，可以自己定義，也可以直接用我的。

package com.example.resubmit.util;

import com.example.resubmit.enums.ResponseCodeEnum;
import com.fasterxml.jackson.annotation.JsonIgnore;

/**
 * <p>
 *  自定義響應(yīng)結(jié)果
 * </p>
 *
 * @author 福隆苑居士，公眾號(hào)：【Java分享客?！?
 * @since 2022-02-08
 */
public class ResultEntity<T> {

    private String code;

    private String msg;

    private T data;

    public ResultEntity(){}

    public ResultEntity(String code, String msg){
        this.code = code;
        this.msg = msg;
    }

    public ResultEntity(String code, String msg, T data){
        this.code = code;
        this.msg = msg;
        this.data = data;
    }

    @JsonIgnore
    public boolean isSuccess() {
        return ResponseCodeEnum.SUCCESS.getCode().equals(this.getCode());
    }

    public String getCode() {
        return code;
    }

    public void setCode(String code) {
        this.code = code;
    }

    public String getMsg() {
        return msg;
    }

    public void setMsg(String msg) {
        this.msg = msg;
    }

    public T getData() {
        return data;
    }

    public void setData(T data) {
        this.data = data;
    }

    public static ResultEntity fail(String code, String msg) {
        return new ResultEntity(code, msg);
    }

    public static <T> ResultEntity fail(String code, String msg, T data) {
        return new ResultEntity(code, msg, data);
    }

    public static ResultEntity ok(String code, String msg) {
        return new ResultEntity(code, msg);
    }

    public static <T> ResultEntity ok(String code, String msg, T data) {
        return new ResultEntity(code, msg, data);
    }

    public static ResultEntity ok(String msg) {
        return new ResultEntity(ResponseCodeEnum.SUCCESS.getCode(), msg);
    }

    public static <T> ResultEntity ok(String msg, T data) {
        return new ResultEntity(ResponseCodeEnum.SUCCESS.getCode(), msg, data);
    }

    public static ResultEntity fail(String msg) {
        return new ResultEntity(ResponseCodeEnum.FAIL.getCode(), msg);
    }
}

6、Redisson工具類

package com.example.resubmit.redission;

import org.redisson.Redisson;
import org.redisson.api.RLock;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.stereotype.Component;
import org.springframework.util.StringUtils;

import javax.annotation.Resource;
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;

/**
 * <p>
 * 加鎖解鎖工具類
 * </p>
 *
 * @author 福隆苑居士，公眾號(hào)：【Java分享客?！?
 * @since 2022-02-08
 */
@Component
public class RedisLock {
   private static final Logger log = LoggerFactory.getLogger(RedisLock.class);

   // todo  待優(yōu)化，最好使用自定義的線程池，自定義工作隊(duì)列和最大線程數(shù)。
   private static final ScheduledExecutorService EXECUTOR_SERVICE = Executors.newScheduledThreadPool(4);
   @Resource
   private Redisson redisson;

   /**
    * Redission獲取鎖
    *
    * @param lockKey      鎖名
    * @param uuid         唯一標(biāo)識(shí)
    * @param delaySeconds 過期時(shí)間
    * @param unit         單位
    * @return 是否獲取成功
    */
   public boolean Rlock(String lockKey, final String uuid, long delaySeconds, final TimeUnit unit) {
      RLock rLock = redisson.getLock(lockKey);
      boolean success = false;
      try {
         // log.debug("===lock thread id is :{}", Thread.currentThread().getId());
         success = rLock.tryLock(0, delaySeconds, unit);
      } catch (InterruptedException e) {
         log.error("[RedisLock][Rlock]>>>> 加鎖異常: ", e);
      }
      return success;
   }

   /**
    * Redission釋放鎖
    *
    * @param lockKey 鎖名
    */
   public void Runlock(String lockKey) {
      RLock rLock = redisson.getLock(lockKey);
      log.debug("[RedisLock][Rlock]>>>> {}, status: {} === unlock thread id is: {}", rLock.isHeldByCurrentThread(), rLock.isLocked(),
            Thread.currentThread().getId());
      rLock.unlock();
   }

   /**
    * Redission延遲釋放鎖
    *
    * @param lockKey 鎖名
    * @param delayTime 延遲時(shí)間
    * @param unit 單位
    */
   public void delayUnlock(final String lockKey, long delayTime, TimeUnit unit) {
      if (!StringUtils.hasText(lockKey)) {
         return;
      }
      if (delayTime <= 0) {
         Runlock(lockKey);
      } else {
         EXECUTOR_SERVICE.schedule(() -> Runlock(lockKey), delayTime, unit);
      }
   }

}

7、自定義注解

這里增加了延遲時(shí)間的屬性，默認(rèn)8秒。

package com.example.resubmit.redission;

import java.lang.annotation.*;

/**
 * <p>
 * 防重復(fù)提交注解
 * </p>
 *
 * @author 福隆苑居士，公眾號(hào)：【Java分享客棧】
 * @since 2022-02-08
 */
@Target(ElementType.METHOD)
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface NotResubmit {

    /**
     * 延時(shí)時(shí)間 在延時(shí)多久后可以再次提交,默認(rèn)8秒
     * @return 秒
     */
    int delaySeconds() default 8;
}

8、防重注解的實(shí)現(xiàn)

這里是實(shí)現(xiàn)防重注解的核心代碼，這里append實(shí)體屬性時(shí)用到了toString()方法，所以要求我們生成的實(shí)體對象一定要有toString()方法。

package com.example.resubmit.redission;

import com.example.resubmit.enums.ResponseCodeEnum;
import com.example.resubmit.util.ResultEntity;
import org.aspectj.lang.ProceedingJoinPoint;
import org.aspectj.lang.Signature;
import org.aspectj.lang.annotation.Around;
import org.aspectj.lang.annotation.Aspect;
import org.aspectj.lang.reflect.MethodSignature;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.http.ResponseEntity;
import org.springframework.stereotype.Component;
import org.springframework.util.DigestUtils;

import javax.annotation.Resource;
import java.lang.reflect.Method;
import java.nio.charset.Charset;
import java.util.concurrent.TimeUnit;

/**
 * <p>
 * 防重復(fù)提交注解的實(shí)現(xiàn)，使用AOP。
 * </p>
 *
 * @author 福隆苑居士，公眾號(hào)：【Java分享客?！?
 * @since 2022-02-08
 */
@Aspect
@Component
public class LockMethodAOP {
   private static final Logger log = LoggerFactory.getLogger(LockMethodAOP.class);

   @Resource
   private RedisLock redisLock;

   /**
    * 這里注意，我的注解寫在同一個(gè)包下所以沒有包名，如果換自己的目錄，要改為@annotation(com.xxx.NotResubmit)加上完整包名.
    */
   @Around("execution(public * *(..)) && @annotation(NotResubmit)")
   public Object interceptor(ProceedingJoinPoint pjp) throws Throwable {
      // 獲取到這個(gè)注解
      MethodSignature signature = (MethodSignature) pjp.getSignature();
      Method method = signature.getMethod();
      NotResubmit lock = method.getAnnotation(NotResubmit.class);

      final String lockKey = generateKey(pjp);

      // 上鎖
      final boolean success = redisLock.Rlock(lockKey, null, lock.delaySeconds(), TimeUnit.SECONDS);
      if (!success) {
         // 這里也可以改為自己項(xiàng)目自定義的異常拋出
         return ResponseEntity.badRequest().body(ResultEntity.fail(ResponseCodeEnum.FAIL.getCode(), "操作太頻繁"));
      }
      return pjp.proceed();
   }

   private String generateKey(ProceedingJoinPoint pjp) {
      StringBuilder sb = new StringBuilder();
      Signature signature = pjp.getSignature();
      MethodSignature methodSignature = (MethodSignature) signature;
      Method method = methodSignature.getMethod();
      sb.append(pjp.getTarget().getClass().getName())//類名
            .append(method.getName());//方法名
      for (Object o : pjp.getArgs()) {
         sb.append(o.toString());
      }
      return DigestUtils.md5DigestAsHex(sb.toString().getBytes(Charset.defaultCharset()));
   }

}

9、編寫控制器

這里在插入方法上加了@NotResubmit(delaySeconds = 10)注解，表示這個(gè)插入方法執(zhí)行時(shí)，10秒內(nèi)不允許重復(fù)提交，10秒后才可以插入成功，這個(gè)時(shí)間可以根據(jù)需要在不同的接口上自行修改。

package com.example.resubmit.controller;

import com.example.resubmit.entity.User;
import com.example.resubmit.redission.NotResubmit;
import com.example.resubmit.service.IUserService;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PostMapping;
import org.springframework.web.bind.annotation.RequestBody;
import org.springframework.web.bind.annotation.RequestMapping;

import org.springframework.stereotype.Controller;

import java.time.LocalDateTime;
import java.util.List;

/**
 * <p>
 *  控制器
 * </p>
 *
 * @author 福隆苑居士，公眾號(hào)：【Java分享客?！?
 * @since 2022-02-08
 */
@Controller
@RequestMapping("/api/user")
public class UserController {

   private final IUserService userService;

   public UserController(IUserService userService) {
      this.userService = userService;
   }

   /**
    * 查詢列表
    * @return 結(jié)果
    */
   @GetMapping("/list")
   public ResponseEntity<List<User>> list() {
      return ResponseEntity.ok().body(userService.list());
   }

   /**
    * 插入記錄
    * @return 結(jié)果
    */
   @NotResubmit(delaySeconds = 10)
   @PostMapping("/insert")
   public ResponseEntity<List<User>> insert(@RequestBody User user) {
      // 插入
      user.setCreatedAt(LocalDateTime.now());
      user.setCreatedBy("冰敦敦");
      user.setUpdatedAt(LocalDateTime.now());
      user.setUpdatedBy("冰敦敦");
      userService.save(user);
      // 返回列表
      return ResponseEntity.ok().body(userService.list());
   }
}

10、效果

1）、執(zhí)行接口插入一條記錄

2）、連續(xù)點(diǎn)擊看注解是否生效

可以發(fā)現(xiàn)，會(huì)返回操作太頻繁的提示，并沒有插入數(shù)據(jù)庫。

3）、等待10秒過后再執(zhí)行

發(fā)現(xiàn)又可以插入進(jìn)去了

總結(jié)

通過最終效果可以發(fā)現(xiàn)，自定義的防重注解實(shí)現(xiàn)起來并沒有那么難，核心思想如下：

把實(shí)體類的屬性append并進(jìn)行簽名，作為redisson加鎖的key，在aop攔截到使用這個(gè)注解的接口方法時(shí)，就會(huì)根據(jù)傳入的對象和上一次提交時(shí)傳入的對象進(jìn)行屬性簽名的匹配，只要完全一致，代表是重復(fù)提交，只有在超過延遲時(shí)間后才能成功通過攔截，最終執(zhí)行業(yè)務(wù)。

這也是選取整合mybatisPlus的原因，因?yàn)樗拇a生成器會(huì)自動(dòng)生成帶有toString()方法的代碼，如果不想使用，直接用lombok注解也可以。

最后，你其實(shí)可以發(fā)現(xiàn)，掌握了方法后，這個(gè)注解不僅可以拿來做防重，進(jìn)行優(yōu)化改造后還可以用來做接口限流，是不是很有意思呢。

到此這篇關(guān)于SpringBoot+Redisson自定義注解一次解決重復(fù)提交問題的文章就介紹到這了,更多相關(guān)SpringBoot Redisson重復(fù)提交內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

SpringBoot+Redisson自定義注解一次解決重復(fù)提交問題

目錄

前言

實(shí)現(xiàn)步驟

1、引入依賴

2、配置application.yml

3、編寫配置類

4、MybatisPlus代碼生成器

5、定義響應(yīng)實(shí)體

6、Redisson工具類

7、自定義注解

8、防重注解的實(shí)現(xiàn)

9、編寫控制器

10、效果

總結(jié)

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线 免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

SpringBoot+Redisson自定義注解一次解決重復(fù)提交問題

目錄

前言

實(shí)現(xiàn)步驟

1、引入依賴

2、配置application.yml

3、編寫配置類

4、MybatisPlus代碼生成器

5、定義響應(yīng)實(shí)體

6、Redisson工具類

7、自定義注解

8、防重注解的實(shí)現(xiàn)

9、編寫控制器

10、效果

總結(jié)

相關(guān)文章

最新評論

大家感興趣的內(nèi)容

最近更新的內(nèi)容

常用在線小工具

国产无遮挡裸体免费直播视频,久久精品国产蜜臀av,动漫在线视频一区二区,欧亚日韩一区二区三区,久艹在线免费视频,国产精品美女网站免费,正在播放 97超级视频在线观看,斗破苍穹年番在线观看免费,51最新乱码中文字幕

1、引入依賴

3、編寫配置類

4、MybatisPlus代碼生成器

5、定義響應(yīng)實(shí)體

6、Redisson工具類

9、編寫控制器

10、效果