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

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

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.lryc.cn/news/2396960.html

相关文章:

  • 浅谈JMeter之常见问题Address already in use: connect
  • 【机器学习基础】机器学习入门核心算法:随机森林(Random Forest)
  • 【深度学习】12. VIT与GPT 模型与语言生成:从 GPT-1 到 GPT4
  • 常规算法学习
  • Google 发布的全新导航库:Jetpack Navigation 3
  • Arbitrum Stylus 合约实战 :Rust 实现 ERC20
  • 电脑故障基础知识
  • 12.2Swing中JButton简单分析
  • 内存管理--《Hello C++ Wrold!》(8)--(C/C++)--深入剖析new和delete的使用和底层实现
  • JavaScript性能优化实战指南(详尽分解版)
  • 从 AMQP 到 RabbitMQ:核心组件设计与工作原理(一)
  • Java进阶---JVM
  • 鸿蒙OSUniApp离线优先数据同步实战:打造无缝衔接的鸿蒙应用体验#三方框架 #Uniapp
  • 地震资料裂缝定量识别——学习计划
  • C++ 检查一条线是否与圆接触或相交(Check if a line touches or intersects a circle)
  • 23. Merge k Sorted Lists
  • 每日算法刷题计划Day20 6.2:leetcode二分答案3道题,用时1h20min
  • Spring Security安全实践指南
  • Unity + HybirdCLR热更新 入门篇
  • QuickBASIC QB64 支持 64 位系统和跨平台Linux/MAC OS
  • ElasticSearch迁移至openGauss
  • 【C语言极简自学笔记】项目开发——扫雷游戏
  • Global Security Markets 第5章知识点总结
  • 电子电路:4017计数器工作原理解析
  • Vim 中设置插入模式下输入中文
  • GitHub 趋势日报 (2025年05月31日)
  • Maven概述,搭建,使用
  • 基于大模型的数据库MCP Server设计与实现
  • 【前端】macOS 的 Gatekeeper 安全机制阻止你加载 bcrypt_lib.node 文件 如何解决
  • Unity 环境搭建