什么是接口的幂等性，如何实现接口幂等性？
幂等性原本是数学上的概念，用在接口上就可以理解为：同一个接口，多次发出同一个请求，必须保证操作只执行一次。 调用接口发生异常并且重复尝试时，总是会造成系统所无法承受的损失，所以必须阻止这种现象的发生。 比如下面这些情况，如果没有实现接口幂等性会有很严重的后果： 支付接口，重复支付会导致多次扣钱 订单接口，同一个订单可能会多次创建。
唯一索引 使用唯一索引可以避免脏数据的添加，当插入重复数据时数据库会抛异常，保证了数据的唯一性。
乐观锁 这里的乐观锁指的是用乐观锁的原理去实现，为数据字段增加一个version字段，当数据需要更新时，先去数据库里获取此时的version版本号
select version from tablename where xxx更新数据时首先和版本号作对比，如果不相等说明已经有其他的请求去更新数据了，提示更新失败。
update tablename set count=count+1,version=version+1 where version=#{version}悲观锁 乐观锁可以实现的往往用悲观锁也能实现，在获取数据时进行加锁，当同时有多个重复请求时其他请求都无法进行操作
分布式锁 幂等的本质是分布式锁的问题，分布式锁正常可以通过redis或zookeeper实现；在分布式环境下，锁定全局唯一资源，使请求串行化，实际表现为互斥锁，防止重复，解决幂等。
token机制 token机制的核心思想是为每一次操作生成一个唯一性的凭证，也就是token。一个token在操作的每一个阶段只有一次执行权，一旦执行成功则保存执行结果。对重复的请求，返回同一个结果。token机制的应用十分广泛。
这里展示通过token机制实现接口幂等性的案例：github文末自取 首先引入需要的依赖：
<dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-redis</artifactId></dependency><dependency> <groupId>org.apache.commons</groupId> <artifactId>commons-lang3</artifactId> <version>3.4</version></dependency><dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId></dependency>首先配置一下通用的请求返回体
public class Response { private int status; private String msg; private Object data; //省略get、set、toString、无参有参构造方法}以及返回code
public enum ResponseCode { // 通用模块 1xxxx ILLEGAL_ARGUMENT(10000, '参数不合法'), REPETITIVE_OPERATION(10001, '请勿重复操作'), ; ResponseCode(Integer code, String msg) { this.code = code; this.msg = msg; } private Integer code; private String msg; public Integer getCode() { return code; } public void setCode(Integer code) { this.code = code; } public String getMsg() { return msg; } public void setMsg(String msg) { this.msg = msg; }}public class ServiceException extends RuntimeException{ private String code; private String msg; //省略get、set、toString以及构造方法}配置全局异常捕获器
@ControllerAdvicepublic class MyControllerAdvice { @ResponseBody @ExceptionHandler(ServiceException.class) public Response serviceExceptionHandler(ServiceException exception){ Response response=new Response(Integer.valueOf(exception.getCode()),exception.getMsg(),null); return response; }}@Servicepublic interface TokenService { public Response createToken(); public Response checkToken(HttpServletRequest request);}具体实现类，核心的业务逻辑都写在注释中了
@Servicepublic class TokenServiceImpl implements TokenService { @Autowired private RedisTemplate redisTemplate; @Override public Response createToken() { //生成uuid当作token String token = UUID.randomUUID().toString().replaceAll('-',''); //将生成的token存入redis中 redisTemplate.opsForValue().set(token,token); //返回正确的结果信息 Response response=new Response(0,token.toString(),null); return response; } @Override public Response checkToken(HttpServletRequest request) { //从请求头中获取token String token=request.getHeader('token'); if (StringUtils.isBlank(token)){ //如果请求头token为空就从参数中获取 token=request.getParameter('token'); //如果都为空抛出参数异常的错误 if (StringUtils.isBlank(token)){ throw new ServiceException(ResponseCode.ILLEGAL_ARGUMENT.getCode().toString(),ResponseCode.ILLEGAL_ARGUMENT.getMsg()); } } //如果redis中不包含该token，说明token已经被删除了，抛出请求重复异常 if (!redisTemplate.hasKey(token)){ throw new ServiceException(ResponseCode.REPETITIVE_OPERATION.getCode().toString(),ResponseCode.REPETITIVE_OPERATION.getMsg()); } //删除token Boolean del=redisTemplate.delete(token); //如果删除不成功（已经被其他请求删除），抛出请求重复异常 if (!del){ throw new ServiceException(ResponseCode.REPETITIVE_OPERATION.getCode().toString(),ResponseCode.REPETITIVE_OPERATION.getMsg()); } return new Response(0,'校验成功',null); }}这是比较重要的一步，通过自定义注解在需要实现接口幂等性的方法上添加此注解，实现token验证
@Target({ElementType.METHOD})@Retention(RetentionPolicy.RUNTIME)public @interface ApiIdempotent {}接口拦截器
public class ApiIdempotentInterceptor implements HandlerInterceptor { @Autowired private TokenService tokenService; @Override public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception { if (!(handler instanceof HandlerMethod)) { return true; } HandlerMethod handlerMethod= (HandlerMethod) handler; Method method=handlerMethod.getMethod(); ApiIdempotent methodAnnotation=method.getAnnotation(ApiIdempotent.class); if (methodAnnotation != null){ // 校验通过放行，校验不通过全局异常捕获后输出返回结果 tokenService.checkToken(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 { }}配置webConfig，添加拦截器
@Configurationpublic class WebConfig implements WebMvcConfigurer { @Override public void addInterceptors(InterceptorRegistry registry) { registry.addInterceptor(apiIdempotentInterceptor()); } @Bean public ApiIdempotentInterceptor apiIdempotentInterceptor() { return new ApiIdempotentInterceptor(); }}配置redis，使得中文可以正常传输
@Configurationpublic class RedisConfig { //自定义的redistemplate @Bean(name = 'redisTemplate') public RedisTemplate<String,Object> redisTemplate(RedisConnectionFactory factory){ //创建一个RedisTemplate对象，为了方便返回key为string，value为Object RedisTemplate<String,Object> template = new RedisTemplate<>(); template.setConnectionFactory(factory); //设置json序列化配置 Jackson2JsonRedisSerializer jackson2JsonRedisSerializer=new Jackson2JsonRedisSerializer(Object.class); ObjectMapper objectMapper=new ObjectMapper(); objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY); objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance); //string的序列化 StringRedisSerializer stringRedisSerializer=new StringRedisSerializer(); //key采用string的序列化方式 template.setKeySerializer(stringRedisSerializer); //value采用jackson的序列化方式 template.setValueSerializer(jackson2JsonRedisSerializer); //hashkey采用string的序列化方式 template.setHashKeySerializer(stringRedisSerializer); //hashvalue采用jackson的序列化方式 template.setHashValueSerializer(jackson2JsonRedisSerializer); template.afterPropertiesSet(); return template; }}最后是controller
@RestController@RequestMapping('/token')public class TokenController { @Autowired private TokenService tokenService; @GetMapping public Response token(){ return tokenService.createToken(); } @PostMapping('checktoken') public Response checktoken(HttpServletRequest request){ return tokenService.checkToken(request); }}首先通过token接口创建一个token出来，此时redis中也存在了该token
在jmeter中同时运行50个请求，我们可以观察到，只有第一个请求校验成功，后续的请求均提示请勿重复操作。
联系客服
