项目代码:https://github.com/DaZuiZui/Interface-idempotency
1.什么是幂等性 首先我们思考一下什么是幂等性,一个接口多次调用没有副作用就是幂等性,如果一个接口多次被调用产生的副作用就不是幂等性了,就出现了幂等性的问题
2.解决方案 2.1 分布式锁+token 我们保证幂等性是利用redis+token实现的,首先我们我们通过从服务器获取token,然后请求的时候携带token进行请求,如果token在redis中存在就把token删除,如果不存在就不进行 *** 作。
3.code 3.1 分布式锁+tokenpom.xml
<dependencies>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-webartifactId>
dependency>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-data-redisartifactId>
dependency>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-aopartifactId>
dependency>
<dependency>
<groupId>org.springframework.bootgroupId>
<artifactId>spring-boot-starter-testartifactId>
<scope>testscope>
dependency>
dependencies>
Controller层
@RestController
public class TestController {
@Autowired
private RedisTemplate redisTemplate;
@GetMapping("/getToken")
public String getToken(){
String token = UUID.randomUUID().toString().substring(0,8);
redisTemplate.opsForValue().set(token,"1",60*10, TimeUnit.SECONDS);
return token;
}
@GetMapping("/sub")
public void sub(String token) throws InterruptedException {
//todo 业务 *** 作
}
}
Aop层
@Aspect
@Component
public class TestAop {
@Autowired
private RedisTemplate redisTemplate;
@Before("execution(* com.dazuizui.idempotentinterface.controller.TestController.sub(..))")
public void befor(JoinPoint proceedingJoinPoint) throws Exception {
Object[] args = proceedingJoinPoint.getArgs();
boolean b = redisTemplate.delete(args[0]);
System.out.println(b);
if (!b){
//todo 日志 *** 作
throw new Exception("幂等性 *** 作");
}
}
}
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)