上代码
/**接口幂等性设计*/
@RestController
public class IdempotentController {
@Autowired
private RedisTemplate<String, String> redisTemplate;
/**
* 提交接口,需要携带有效的token参数
*/
@PostMapping("/submit")
public String submit(@RequestParam("token") String token) {
// 检查Token是否有效
if (!isValidToken(token)) {
return "Invalid token";
}
// 具体的接口处理逻辑,在这里实现你的业务逻辑
// 使用完毕后删除Token
deleteToken(token);
return "Success";
}
@PostMapping("/submit2")
public String submit2(@RequestParam("token") String token) {
// 使用SETNX命令尝试将Token保存到Redis中,如果返回1表示设置成功,说明是第一次提交;否则返回0,表示重复提交
Boolean success = redisTemplate.opsForValue().setIfAbsent(token, "true", Duration.ofMinutes(10));
if (success == null || !success) {
return "Duplicate submission";
}
try {
// 具体的接口处理逻辑,在这里实现你的业务逻辑
return "Success";
} finally {
// 使用DEL命令删除Token
redisTemplate.delete(token);
}
}
/**
* 检查Token是否有效
*/
private boolean isValidToken(String token) {
// 检查Token是否存在于Redis中
return redisTemplate.hasKey(token);
}
/**
* 删除Token
*/
private void deleteToken(String token) {
// 从Redis中删除Token
redisTemplate.delete(token);
}
/**
* 生成Token接口,用于获取一个唯一的Token
*/
@GetMapping("/generateToken")
public String generateToken() {
// 生成唯一的Token
String token = UUID.randomUUID().toString();
// 将Token保存到Redis中,并设置过期时间(例如10分钟)
redisTemplate.opsForValue().set(token, "true", Duration.ofMinutes(10));
return token;
}
}
标签:return,String,redis,Token,接口,token,设计,redisTemplate
From: https://www.cnblogs.com/pushbug/p/18363316