没有合适的资源?快使用搜索试试~ 我知道了~
资源推荐
资源详情
资源评论
Spring Boot + Redis + 注解 + 拦截器来实现接口幂等性校验
一、概念
幂等性, 通俗的说就是一个接口, 多次发起同一个请求, 必须保证操作只能执行一次
比如:
订单接口, 不能多次创建订单
支付接口, 重复支付同一笔订单只能扣一次钱
支付宝回调接口, 可能会多次回调, 必须处理重复回调
普通表单提交接口, 因为网络超时等原因多次点击提交, 只能成功一次
等等
二、常见解决方案
唯一索引 -- 防止新增脏数据
token机制 -- 防止⻚面重复提交
悲观锁 -- 获取数据的时候加锁(锁表或锁行)
乐观锁 -- 基于版本号version实现, 在更新数据那一刻校验数据
分布式锁 -- redis(jedis、redisson)或zookeeper实现
状态机 -- 状态变更, 更新数据时判断状态
三、本文实现
本文采用第2种方式实现, 即通过redis + token机制实现接口幂等性校验
四、实现思路
为需要保证幂等性的每一次请求创建一个唯一标识token, 先获取token, 并将此token存入redis, 请求接口时, 将此token放到
header或者作为请求参数请求接口, 后端接口判断redis中是否存在此token:
如果存在, 正常处理业务逻辑, 并从redis中删除此token, 那么, 如果是重复请求, 由于token已被删除, 则不能通过校验, 返
回请勿重复操作提�
如果不存在, 说明参数不合法或者是重复请求, 返回提�即可
五、项目简介
springboot
redis
https://github.com/wangzaiplus/springboot/tree/wxw
<!-- Redis-Jedis -->
<dependency>
<groupId>redis.clients</groupId>
<artifactId>jedis</artifactId>
<version>2.9.0</version>
</dependency>
<!--lombok 本��到@Slf4j注解, 也可不引�, �定义log即可-->
<dependency>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.16.10</version>
</dependency>
@ApiIdempotent注解 + 拦截器对请求进行拦截
@ControllerAdvice全局异常处理
压测工具: jmeter
说明:
本文重点介绍幂等性核心实现
,
关于
s
p
r
i
n
g
b
oo
t
如何集成
r
e
d
i
s
、
S
e
r
v
e
r
R
e
s
p
o
n
s
e
、
R
e
s
p
o
n
s
e
C
o
d
e
等细枝末节不在本文讨论范
围之内
,
有兴趣的小伙伴可以查看我的
G
i
t
hu
b
项目
:
六、代码实现
pom
JedisUtil
@Component
@Slf4j
public class JedisUtil {
@Autowired
private JedisPool jedisPool;
private Jedis getJedis() {
return
jedisPool.getResource();
}
/**
*
设值
*
*
@param key
*
@param value
*
@return
*/
public String set(String key, String value) {
Jedis jedis = null;
try
{
jedis = getJedis();
return jedis.set(key, value);
}
catch (Exception e) {
log.error("set key:{} value:{} error", key, value, e);
return null;
} finally {
close(jedis);
}
}
/**
*
设值
*
*
@param key
*
@param value
*
@param expireTime 过期时间, 单位: s
*
@return
*/
public String set(String key, String value, int expireTime) {
Jedis jedis = null;
try
{
jedis = getJedis();
return jedis.setex(key, expireTime, value);
}
catch (Exception
e)
{ log.error("set key:{} value:{} expireTime:{} error",
key, value, expireTime, e); return null;
} finally {
close(jedis);
}
}
/**
*
取值
*
*
@param key
*
@return
*/
public String get(String key) {
Jedis jedis = null;
try
{
jedis = getJedis();
return jedis.get(key);
} catch (Exception e) {
log.error("get key:{} error", key, e);
return null;
} finally {
close(jedis);
}
}
/**
*
删除key
*
*
@param key
*
@return
*/
public Long del(String key) {
Jedis jedis = null;
try
{
jedis = getJedis();
return
jedis.del(key.getBytes());
} catch (Exception e) {
log.error("del key:{} error", key, e);
return null;
} finally {
close(jedis);
}
}
/**
*
判断key是否存在
剩余10页未读,继续阅读
资源评论
小小哭包
- 粉丝: 1902
- 资源: 3908
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功