一前言

本篇內容的內容是實作介面等冪次校驗，

二實作方案

主流的實作方案如下

2.1 唯一索引

給表加唯一索引，次方法最簡單，當資料重復插入時，直接報SQL例外，對應用影響不大；

alter table 表名 add unique(欄位)

示例，兩個欄位為唯一索引，如果出現完全一樣的 order_name， create_time 就直接重復報例外；

alter table `order`  add unique(order_name,create_time)

2.2 鎖

分布式鎖也可以實作介面等冪次校驗，知識追尋者有寫過一篇使用redis實作分布式鎖思路的一篇檔案，小伙伴們可以參考下《為什么你不會redis分布式鎖？因為你沒看到這篇文章》

使用樂觀鎖（基于版本號實作），或者悲觀鎖（表鎖或者行鎖）實作；

2.3 先查詢后判斷

入庫時先查詢是否有該資料，無插入，否則不插入；

2.4 token 機制

token 機制也就是本篇文章的重點；大致實作思路就是發起請求的時候先去 redis 獲取 token ，將獲取的token 放入請求的hearder ，當請求到達服務端的時候攔截請求，對請求的 hearder 中的token，進行校驗，如果校驗通過則放開攔截，洗掉token，否則使用自定義例外回傳錯誤資訊；

三使用redis 實作介面等冪性校驗

3.1 redis 工具類

關于 RedisTemplate 的配置可以參考知識追尋者發布的文章《springboot集成redis(基礎篇)》

/**
 * @Author lsc
 * <p> </p>
 */

@Component
public class RedisUtils {

    @Autowired
    private RedisTemplate<String, Object> redisTemplate;

    /**
     * 判斷key是否存在
     * @param key 鍵
     * @return boolean
     */
    public boolean hasKey(String key) {
        try {
            return redisTemplate.hasKey(key);
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }


      /**
     * 洗掉key
     * @param key 鍵
     */
    public Boolean del(String key) {
        if (key != null && key.length() > 0) {
            return redisTemplate.delete(key);
        }else  {
            return false;
        }
    }


    /**
     * 普通快取獲取
     * @param key 鍵
     * @return 值
     */

    public Object get(String key) {

        return key == null ? null : redisTemplate.opsForValue().get(key);
    }


    /**
     * 普通快取放入并設定時間
     * @param key 鍵
     * @param value 值
     * @param time 時間(秒) time要大于0 如果time小于等于0 將設定無限期
     * @return true成功 false 失敗
     */

    public boolean set(String key, Object value, long time) {
        try {
            if (time > 0) {
                redisTemplate.opsForValue().set(key, value, time, TimeUnit.SECONDS);
            }
            return true;
        } catch (Exception e) {
            e.printStackTrace();
            return false;
        }
    }

}

3.2 token 工具類

使用 uuid 生成隨機字串，通過md5加密防止token被解密，保證token的唯一性與安全性；，設定過期時間為 30 秒，即在30秒內只能提交成功一次請求，根據不同的業務需求，讀者們自行處理；

/**
 * @Author lsc
 * <p> </p>
 */
@Component
public class TokenUtis {

    @Autowired
    RedisUtils redisUtils;

    // token 過期時間為30秒
    private final static Long TOKEN_EXPIRE = 30L;

    private final static String TOKEN_NAME = "token";
    /* *
     * @Author lsc
     * <p> 生成token 放入快取</p>
     * @Param []
     */
    public String generateToken() {
        String uuid = UUID.randomUUID().toString();
        String token = DigestUtils.md5DigestAsHex(uuid.getBytes());
        redisUtils.set(TOKEN_NAME,token,TOKEN_EXPIRE);
        return token;
    }
    /* *
     * @Author lsc
     * <p> token 校驗 </p>
     * @Param [request]
     */
    public boolean verifyToken(HttpServletRequest request) {
        String token = request.getHeader(TOKEN_NAME);
        // header中不存在token
        if(StringUtils.isEmpty(token)) {
           // 拋出自定義例外
            System.out.println("token不存在");
            throw new GlobleException(CodeMsg.BAD_REQUEST);
        }
        // 快取中不出在 
        if(!redisUtils.hasKey(TOKEN_NAME)) {
            // 拋出自定義例外
            System.out.println("token已經過期");
            throw new GlobleException(CodeMsg.BAD_REQUEST);
        }
        String cachToekn = (String)redisUtils.get(TOKEN_NAME);
        if (!token.equals(cachToekn)){
            // 拋出自定義例外
            System.out.println("token校驗失敗");
            throw new GlobleException(CodeMsg.BAD_REQUEST);
        }
        // 移除token
        Boolean del = redisUtils.del(TOKEN_NAME);
        if (!del){
            // 拋出自定義例外
            System.out.println("token洗掉失敗");
            throw new GlobleException(CodeMsg.BAD_REQUEST);
        }
        return true;
    }
}

3.3 注解

定義注解，使用在方法上，當控制層的方法上被注釋時，表示該請求為等冪性請求；

/**
 * @Author lsc
 * <p> </p>
 */
@Target({ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
public @interface Idempotent {

}

3.4 攔截器配置

選擇前置攔截器，每次請求都校驗到達的方法上是否有等冪性注解，如果有則進行token 校驗；

/**
 * @Author lsc
 * <p> </p>
 */
@Component
public class IdempotentInterceptor implements HandlerInterceptor {

    @Autowired
    private TokenUtis tokenUtis;

    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
        if (!(handler instanceof HandlerMethod)) {
            return true;
        }
        // 對有Idempotent注解的方法進行攔截校驗
        HandlerMethod handlerMethod = (HandlerMethod) handler;
        Method method = handlerMethod.getMethod();
        Idempotent methodAnnotation = method.getAnnotation(Idempotent.class);
        if (methodAnnotation != null) {
            // token 校驗
            tokenUtis.verifyToken(request);
        }
        return true;
    }


    @Override
    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {

    }

    @Override
    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {

    }
}

對攔截器進行url模式匹配，并注入spring容器

/**
 * @Author lsc
 * <p> </p>
 */
@Configuration
public class WebConfiguration implements WebMvcConfigurer {

    @Autowired
    IdempotentInterceptor idempotentInterceptor;

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        // 攔截所有請求
        registry.addInterceptor(idempotentInterceptor).addPathPatterns("/**");
    }

3.5 控制層

對控制層進行撰寫如下，發起請求時通過 getToken 方法獲取token,將獲取的token 放入 hearder 后再請求 testIdempotent 方法

/**
 * @Author lsc
 * <p> </p>
 */
@RestController
public class ZszxzController {

    @Autowired
    TokenUtis tokenUtis;

    @GetMapping("zszxz/token")
    public ResultPage getToken(){
        String token = tokenUtis.generateToken();
        JSONObject jsonObject = new JSONObject();
        jsonObject.put("token",token);
        return ResultPage.sucess(CodeMsg.SUCESS,jsonObject);
    }

    @Idempotent
    @GetMapping("zszxz/test")
    public ResultPage testIdempotent(){
        return ResultPage.sucess(CodeMsg.SUCESS,"校驗成功");
    }
}