doc : 【幂等】： 防重token令牌方案实现

- 使用默认内存token存储【后续实现redis】
- 使用请求依赖Const.REQUEST_TOKEN_VALUE_HOLDER 二维数组模拟请求参数传参数。【后续需要在web环境中，获取 请求Header中的token和服务中UserId】

pom.xml

@@ -49,6 +49,11 @@
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-aop</artifactId>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.data</groupId>
+            <artifactId>spring-data-redis</artifactId>
+            <scope>provided</scope>
+        </dependency>
     </dependencies>
 
 

src/main/java/com/kx/config/RedisAutoConfiguration.java

+package com.kx.config;
+
+import org.springframework.boot.autoconfigure.condition.ConditionalOnClass;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.redis.core.RedisOperations;
+
+/**
+ * redis引入，工具类使用redis相关的配置
+ *
+ * @author kongxiang
+ */
+@Configuration(proxyBeanMethods = false)
+@ConditionalOnClass(RedisOperations.class)
+public class RedisAutoConfiguration {
+}

src/main/java/com/kx/utils/id/IdAlgorithmRegister.java

@@ -54,9 +54,11 @@ public class IdAlgorithmRegister {
                 }else {
                     Integer[] arr = nameOrderMap.get(algorithm);
                     if (arr[0] < orderValue){
-                        arr[0] = orderValue;// 取较大的order
-                        arr[1] = i; // 更新下表
-                       // nameOrderMap.put(algorithm,arr) ;
+                        // 取较大的order
+                        arr[0] = orderValue;
+                        // 更新下表
+                        arr[1] = i;
+                        // nameOrderMap.put(algorithm,arr) ;
                     }else if (arr[0 ] == orderValue){
                         // 如果order一致，比较类名的字符串字典大小，取大值
                         String up = idGeneratorList.get(arr[0]).getClass().getSimpleName();

src/main/java/com/kx/utils/idempotent/aop/IdempotentAnnotationAspect.java

@@ -5,7 +5,6 @@ import com.kx.utils.idempotent.annotation.Idempotent;
 import com.kx.utils.idempotent.bean.IdempotentProperties;
 import com.kx.utils.idempotent.impl.AntiDuplicateTokenHandler;
 import lombok.extern.slf4j.Slf4j;
-import org.aspectj.lang.JoinPoint;
 import org.aspectj.lang.ProceedingJoinPoint;
 import org.aspectj.lang.annotation.Around;
 import org.aspectj.lang.annotation.Aspect;
@@ -17,8 +16,12 @@ import org.springframework.stereotype.Component;
 import org.springframework.util.StringUtils;
 
 import java.lang.reflect.Method;
-import java.util.function.DoubleToIntFunction;
 
+/**
+ * 幂等注解切面
+ *
+ * @author kongxiang
+ */
 @Component
 @Aspect
 @Slf4j
@@ -29,6 +32,7 @@ public class IdempotentAnnotationAspect {
 
     @Autowired
     private TokenValueRequestHolder tokenValueRequestHolder;
+
     /**
      * aop 切面
      * \@annotation 所有注解的方法
@@ -40,7 +44,7 @@ public class IdempotentAnnotationAspect {
 
 
     @Around(value = "condition()")
-    public Object round(ProceedingJoinPoint joinPoint ) throws Throwable {
+    public Object round(ProceedingJoinPoint joinPoint) throws Throwable {
         // 获取执行的方法
         MethodSignature methodSignature = (MethodSignature) joinPoint.getSignature();
         Method method = methodSignature.getMethod();
@@ -59,16 +63,16 @@ public class IdempotentAnnotationAspect {
         log.debug("方法上注解存在  : " + (methodAnnotation != null));
         log.debug("类上注解存在  : " + (classAnnotation != null));
 
-        IdempotentProperties idempotentProperties = getIdempotentPropertiesFromAnnotation(classAnnotation,methodAnnotation);
+        IdempotentProperties idempotentProperties = getIdempotentPropertiesFromAnnotation(classAnnotation, methodAnnotation);
         log.info("幂等配置: cacheKey : {}", idempotentProperties.getCacheKey());
 
-        String token  = tokenValueRequestHolder.getToken();
+        String token = tokenValueRequestHolder.getToken();
         String value = tokenValueRequestHolder.getValidValue();
-        boolean validStatus = antiDuplicateTokenHandler.validToken(idempotentProperties,token, value);
-        if (validStatus){
+        boolean validStatus = antiDuplicateTokenHandler.validToken(idempotentProperties, token, value);
+        if (validStatus) {
             Object object = joinPoint.proceed();
             return object;
-        }else {
+        } else {
             throw new RuntimeException("操作已经处理，请稍后再试");
         }
     }
@@ -77,37 +81,37 @@ public class IdempotentAnnotationAspect {
      * 从 {@link Idempotent} 注解中获取 幂等配置
      * 优先级： 方法上的优先级高于类上的优先级，方法上配置的properties覆盖类上的。同属性覆盖而非 method 替换 class 所有的。
      *
-     * @param classAnnotation 类上的Idempotent注解
+     * @param classAnnotation  类上的Idempotent注解
      * @param methodAnnotation 方法 上的Idempotent注解
      * @return 获取的幂等配置对象
-     *
      */
     private IdempotentProperties getIdempotentPropertiesFromAnnotation(Idempotent classAnnotation, Idempotent methodAnnotation) {
         IdempotentProperties idempotentProperties = new IdempotentProperties();
         // 先加载类注解信息
-        if (classAnnotation != null ){
-            idempotentProperties = getIdempotentPropertiesFromAnnotation(idempotentProperties,classAnnotation);
+        if (classAnnotation != null) {
+            idempotentProperties = getIdempotentPropertiesFromAnnotation(idempotentProperties, classAnnotation);
         }
         // 后加载方法上注解信息，如果有存在的配置，替换类上的
-        if (methodAnnotation != null){
-            idempotentProperties = getIdempotentPropertiesFromAnnotation(idempotentProperties,methodAnnotation);
+        if (methodAnnotation != null) {
+            idempotentProperties = getIdempotentPropertiesFromAnnotation(idempotentProperties, methodAnnotation);
         }
         return idempotentProperties;
     }
 
     /**
      * 获取配置
+     *
      * @param annotation 注解
      * @return 配置
      */
-    private IdempotentProperties getIdempotentPropertiesFromAnnotation(IdempotentProperties idempotentProperties,Idempotent annotation ) {
-        if (annotation == null){
+    private IdempotentProperties getIdempotentPropertiesFromAnnotation(IdempotentProperties idempotentProperties, Idempotent annotation) {
+        if (annotation == null) {
             return new IdempotentProperties();
         }
-        if (idempotentProperties == null){
+        if (idempotentProperties == null) {
             idempotentProperties = new IdempotentProperties();
         }
-        if (!StringUtils.isEmpty(annotation.value())){
+        if (!StringUtils.isEmpty(annotation.value())) {
             idempotentProperties.setCacheKey(annotation.value());
         }
         return idempotentProperties;

src/main/resources/META-INF/spring.factories

@@ -3,4 +3,5 @@
 org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
   com.kx.config.ConfigPropertiesAutoConfiguration,\
   com.kx.config.IdAutoConfiguration,\
-  com.kx.config.IdempotentAutoConfiguration
\ No newline at end of file
+  com.kx.config.IdempotentAutoConfiguration,\
+  com.kx.config.RedisAutoConfiguration
\ No newline at end of file