接口幂等性设计_insert操作幂等性实现_下-【官方】百战程序员_IT在线教育培训机构


xxxxxxxxxx
<dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-redis</artifactId>
        </dependency>

添加Redis相关配置


xxxxxxxxxx
spring.redis.host=localhost
spring.redis.port=6379

自定义注解

即添加了该注解的接口要实现幂等性验证。


xxxxxxxxxx
@Target({ElementType.TYPE, ElementType.METHOD})
@Retention(RetentionPolicy.RUNTIME)
@Documented
public @interface ApiIdempotentAnn {
  boolean value() default true;
}

生成Token


xxxxxxxxxx
 /**
     * 跳转注册页面
     * @return
     */
    @GetMapping("/toAddUser")
    public ModelAndView  adduser(){
        ModelAndView modelAndView = new ModelAndView();
        // 生成Token
        String s = UUID.randomUUID().toString();
        // 保存redis
        stringRedisTemplate.opsForValue().set(s,Thread.currentThread().getId()+"");
        modelAndView.setViewName("addUser");
        modelAndView.addObject("token",s);

        return modelAndView;
    }

幂等性拦截器


xxxxxxxxxx
package com.itbaizhan.idempotentdemo.config;

import com.itbaizhan.idempotentdemo.ApiIdempotentAnn;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.stereotype.Component;
import org.springframework.web.method.HandlerMethod;
import org.springframework.web.servlet.HandlerInterceptor;

import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.PrintWriter;
import java.lang.reflect.Method;

@Component
public class ApiIdempotentInceptor implements HandlerInterceptor {

    @Autowired
    private StringRedisTemplate stringRedisTemplate;

    /**
     *表示在所有请求之前完成的拦截，一般使用居多
     * @param request
     * @param response
     * @param handler
     * @return
     * @throws Exception
     */
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {
        if (!(handler instanceof HandlerMethod)) {
            return true;
        }
        final HandlerMethod handlerMethod = (HandlerMethod) handler;
        // 获取方法
        final Method method = handlerMethod.getMethod();
        // 判断有没有添加需要幂等性注解
        boolean methodAnn = method.isAnnotationPresent(ApiIdempotentAnn.class);
        // 判断是否开启幂等性严重
        if (methodAnn && method.getAnnotation(ApiIdempotentAnn.class).value()) {
            // 需要实现接口幂等性
            boolean result = checkToken(request);
            if (result) {
                return true;
            } else {
                response.setContentType("application/json; charset=utf-8");
                PrintWriter writer = response.getWriter();
                writer.print("重复调用");
                writer.close();
                response.flushBuffer();
                return false;
            }
        }
        return false;
    }

    private boolean checkToken(HttpServletRequest request) {
        String token = request.getParameter("token");
        if (null == token || "".equals(token)) {
            // 没有token，说明重复调用或者
            return false;
        }
        // 返回是否删除成功
        return stringRedisTemplate.delete(token);
    }
}

配置拦截器

WebMvcConfigurer配置类其实是Spring内部的一种配置方式，可以自定义一些Handler，Interceptor，ViewResolver，MessageConverter等等的东西对springmvc框架进行配置。


xxxxxxxxxx
package com.itbaizhan.idempotentdemo.config;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.servlet.config.annotation.InterceptorRegistry;
import org.springframework.web.servlet.config.annotation.WebMvcConfigurer;

import java.util.ArrayList;
import java.util.List;

@Configuration
public class WebConfig implements WebMvcConfigurer {

    @Autowired
    private ApiIdempotentInceptor apiIdempotentInceptor;

    @Override
    public void addInterceptors(InterceptorRegistry registry) {
        List<String> list=new ArrayList<String>();
        list.add("/user/toAddUser");
        list.add("/user/index");
registry.addInterceptor(apiIdempotentInceptor).excludePathPatterns(list);

    }
}

接口幂等性设计_insert操作幂等性实现_下

接口幂等性设计_insert操作幂等性实现_上接口幂等性设计_Update操作幂等性原理

北京市昌平区回龙观镇南店村综合商业楼2楼226室