当前位置: 首页 > java >正文

分布式锁和数据库锁完成接口幂等性

1、分布式锁

唯一主键与乐观锁的本质是使用了数据库的锁,但由于数据库锁的性能不太好,所以我们可使用Redis、Zookeeper等中间件来实现分布式锁的功能,以Redis为例实现幂等:当用户通过浏览器发起请求,服务端接收到请求后,使用唯一标识(如订单号)作为Redis的key。然后使用Redis的set命令,将该唯一标识存储到Redis中并设置超时时间,业务根据Redis返回的结果做不同的处理:
(1)如果保存Redis成功,那么允许当前的线程执行业务操作。
(2)若保存Redis失败,说明是重复请求,则直接响应客户端,请求处理成功。
在分布式锁中要设置一个合理的过期时间,如果设置过短,无法有效的防止重复请求;如果设置过长,占用了Redis的存储空间,在请求非常多的情况下会给Redis造成压力。
在这里插入图片描述

2、状态机机制

在业务表中有状态的时候,如订单表中的订单状态(待提交、待支付、待发货、待收货等等)这些状态的值是有规律的,按照业务节点一级级的流转,那么我们就能利用这个特性实现接口的幂等,假如订单id为order_abc12356的订单当前状态是待支付,当用户支付后,订单的状态要变成待发货,更新的语句如下:

update order set status = 2 where order_id =order_abc12356 and status = 1 

线程T1请求时,该订单的状态是待支付(status = 1),所以该update语句可以正常更新数据,sql执行结果的影响行数是1,订单状态变成了2。线程T2相同的请求过来,再执行相同的sql时,由于订单状态变成了2,再用status=1作为条件,无法查询出需要更新的数据,所以最终sql执行结果的影响行数是0,即不会真正的更新数据。数据表记录中的状态来作为条件做更新其实跟乐观锁使用版本号类似。
在这里插入图片描述

3、数据库悲观锁

假设我们查询到某个订单A后,然后更新订单的状态,此时就可以使用数据库的悲观锁实现。使用悲观锁可以添加for update关键字,即对这行记录上锁,上行锁还是表锁取决于where后面的查询字段索引的类型,假设订单的id是唯一主键,那么就是行锁,可以使用sql查询

select * from order where order_id = 具体id  for update

若是线程T1执行了select … for update,此时就会对这行记录上锁了,那么直到整个线程T1提交事务之前,T2线程来查询相同的订单id数据会进入到阻塞状态。当T1完成业务处理之后释放锁,其他的线程才可以继续操作这条数据。悲观锁在同一事务操作过程中锁住了一行数据,别的请求过来只能等待,如果当前事务耗时比较长,就很影响接口性能。对于Mysql数据库,要求存储引擎必须用innodb,因为innodb才支持事务,另外orderId字段一定要是主键或者唯一索引,不然会锁整张表。:
在这里插入图片描述

4、数据库乐观锁

数据库乐观锁方案一般适用于执行"更新操作"的过程,我们可以提前在对应的数据表中额外添加一个字段来充当数据的版本标识。这样每次对该数据表的这条数据执行更新时,都会将该版本标识作为一个条件,值为上次待更新数据中的版本标识的值,每次更新的时候,我们使用版本号来进行字段校验以及进行update更新

UPDATE order SET status=1,version=version+1 WHERE id=id值 AND version=0;

在WHERE后面的条件id=id值AND version=0 被执行后,id=id值 的 version被更新为1,所以如果重复执行该条sql语句将不生效,因为id=id值 AND version=0的数据已经不存在,通过这样方式就能保住更新的幂等,多次更新对结果不会产生影响
在这里插入图片描述

5、数据库唯一主键

数据库唯一主键的实现原理是使用数据库中主键唯一约束的特性,一般来说唯一主键比较适用于添加数据时的幂等性场景,唯一主键能保证一张表中只能存在一条该唯一主键记录,使用数据库唯一主键实现接口幂等性时需要注意的是,为了保证在分布式环境下ID的全局唯一性,这里的主键一般使用分布式ID充当主键:在这里插入图片描述

http://www.xdnf.cn/news/10083.html

相关文章:

  • 深度学习初探:当机器开始思考(superior哥AI系列第1期)
  • 线程池的详细知识(含有工厂模式)
  • STM32通过rt_hw_hard_fault_exception中的LR寄存器追溯程序问题​
  • 深圳南山沙河社区联合心美行动举办“青少年天赋提升”助青春成长
  • 用于工业设备的高精度仪表放大器“NL9620”开始上市~日本首家!高EMC性能的仪表放大器
  • 使用matlab读取txt文件中的2进制数据
  • 文字转图片的字符画生成工具
  • JavaScript 计算两个日期之间天数的全面指南
  • [网页五子棋][对战模块]前后端交互接口(建立连接、连接响应、落子请求/响应),客户端开发(实现棋盘/棋子绘制)
  • 将Kotti从Pyramid1.0升级到2.0 (失败的记录)
  • CATIA高效工作指南——测量分析篇(一)
  • C++ TCP程序增加TLS加密认证
  • Java本地缓存实现方案全解析:原理、优缺点与应用场景
  • C/C++ 面试复习笔记(2)
  • 漫画Android:事件分发的过程是怎样的?
  • JS数组 concat() 与扩展运算符的深度解析与最佳实践
  • MySQL + CloudCanal + Iceberg + StarRocks 构建全栈数据服务
  • 单元测试报错
  • 由反汇编代码确定结构体的完整声明
  • 调试技巧总结
  • SAP 生产订单收货数量超额报错问题研究
  • 《java创世手记》---java基础篇(上)
  • 【Linux基础知识系列】第五篇-软件包管理
  • Ubuntu本地文件上传github(版本控制)
  • 常见压缩算法性能和压缩率对比 LZ4 LZO ZSTD SNAPPY
  • Haproxy搭建web群集
  • WWW22-可解释推荐|用于推荐的神经符号描述性规则学习
  • 【免费的高清录屏软件】OBS Studio
  • 架构加速-深度学习教程
  • A类地址中最小网络号(0.x.x.x) 默认路由 / 无效/未指定地址