(三)库存超卖案例实战——使用redis分布式锁解决“超卖”问题

前言

在上一节内容中我们介绍了如何使用mysql数据库的传统锁（行锁、乐观锁、悲观锁）来解决并发访问导致的“超卖问题”。虽然mysql的传统锁能够很好的解决并发访问的问题，但是从性能上来讲，mysql的表现似乎并不那么优秀，而且会受制于单点故障。本节内容我们介绍一种性能更加优良的解决方案，使用内存数据库redis实现分布式锁从而控制并发访问导致的“超卖”问题。关于redis环境的搭建这里不做介绍，可查看作者往期博客内容。

正文

  • 在项目中添加redis的依赖和配置信息

- pom依赖配置

<!--        数据库连接池工具包-->
<dependency><groupId>org.apache.commons</groupId><artifactId>commons-pool2</artifactId>
</dependency><!--redis启动器-->
<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-data-redis</artifactId>
</dependency>

- application.yml配置

spring:application:name: ht-atp-platdatasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://192.168.110.88:3306/ht-atp?characterEncoding=utf-8&serverTimezone=GMT%2B8&useAffectedRows=true&nullCatalogMeansCurrent=trueusername: rootpassword: rootprofiles:active: dev# redis配置redis:host: 192.168.110.88lettuce:pool:# 连接池最大连接数(使用负值表示没有限制) 默认为8max-active: 8# 连接池中的最小空闲连接 默认为 0min-idle: 1# 连接池最大阻塞等待时间(使用负值表示没有限制) 默认为-1max-wait: 1000# 连接池中的最大空闲连接 默认为8max-idle: 8

- redis序列化配置

package com.ht.atp.plat.config;import com.fasterxml.jackson.annotation.JsonAutoDetect;
import com.fasterxml.jackson.annotation.JsonTypeInfo;
import com.fasterxml.jackson.annotation.PropertyAccessor;
import com.fasterxml.jackson.databind.ObjectMapper;
import com.fasterxml.jackson.databind.jsontype.impl.LaissezFaireSubTypeValidator;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.redis.connection.RedisConnectionFactory;
import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.data.redis.serializer.Jackson2JsonRedisSerializer;
import org.springframework.data.redis.serializer.StringRedisSerializer;@Configuration
public class RedisConfig {/*** @param factory* @return*/@Beanpublic RedisTemplate<String, Object> redisTemplate(RedisConnectionFactory factory) {// 缓存序列化配置，避免存储乱码RedisTemplate<String, Object> template = new RedisTemplate<>();template.setConnectionFactory(factory);Jackson2JsonRedisSerializer jackson2JsonRedisSerializer = new Jackson2JsonRedisSerializer(Object.class);ObjectMapper objectMapper = new ObjectMapper();objectMapper.setVisibility(PropertyAccessor.ALL, JsonAutoDetect.Visibility.ANY);objectMapper.activateDefaultTyping(LaissezFaireSubTypeValidator.instance,ObjectMapper.DefaultTyping.NON_FINAL, JsonTypeInfo.As.PROPERTY);jackson2JsonRedisSerializer.setObjectMapper(objectMapper);StringRedisSerializer stringRedisSerializer = new StringRedisSerializer();// key采用String的序列化方式template.setKeySerializer(stringRedisSerializer);// hash的key也采用String的序列化方式template.setHashKeySerializer(stringRedisSerializer);// value序列化方式采用jacksontemplate.setValueSerializer(jackson2JsonRedisSerializer);// hash的value序列化方式采用jacksontemplate.setHashValueSerializer(jackson2JsonRedisSerializer);template.afterPropertiesSet();return template;}
}

  •  在redis中增加商品P0001的库存数量为10000

  • 使用redis不加锁的业务测试

- 业务测试代码

    /*** 使用redis不加锁*/@Overridepublic void checkAndReduceStock() {// 1. 查询库存数量String stockQuantity = redisTemplate.opsForValue().get("P0001").toString();// 2. 判断库存是否充足if (stockQuantity != null && stockQuantity.length() != 0) {Integer quantity = Integer.valueOf(stockQuantity);if (quantity > 0) {// 3.扣减库存redisTemplate.opsForValue().set("P0001", String.valueOf(--quantity));}}}

- 使用jmeter压测，查看测试结果：库存并没有减少为0，说明存在“超卖”问题

  • 使用redis的setnx指令加锁，开启三个相同服务，使用jmeter压测

- redis加锁测试代码

/*** 使用redis加锁* */@Overridepublic void checkAndReduceStock() {// 1.使用setnx加锁Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock-stock", "0000");// 2.重试：递归调用,如果获取不到锁if (!lock) {try {//暂停50msThread.sleep(50);this.checkAndReduceStock();} catch (InterruptedException e) {e.printStackTrace();}} else {try {// 3. 查询库存数量String stockQuantity = (String) redisTemplate.opsForValue().get("P0001");// 4. 判断库存是否充足if (stockQuantity != null && stockQuantity.length() != 0) {Integer quantity = Integer.valueOf(stockQuantity);if (quantity > 0) {// 5.扣减库存redisTemplate.opsForValue().set("P0001", String.valueOf(--quantity));}} else {System.out.println("该库存不存在！");}} finally {// 5.解锁redisTemplate.delete("lock-stock");}}}

- 开启服务7000、7001、7002

 - jmeter压测结果：平均访问时间364ms，接口吞吐量为每秒249

- redis数据库库存结果为：0，并发“超卖”问题解决

  • 以上普通加锁方式存在死锁问题及死锁问题的解决方案

- 死锁产生的原因：在上述redis加锁的正常情况下，是可以解决并发访问的问题，但是也存在死锁的问题，例如7000的服务获取到锁之后，由于服务异常导致锁没有释放，那么7001和7002服务将永远不可能获取到锁。

- 解决方案：给锁设置过期时间，自动释放锁

①使用expire设置过期时间（缺乏原子性：如果在setnx和expire之间出现异常，锁也无法释放）

②使用setex指令设置过期时间：set key value ex 3 nx（保证原子性操作既达到setnx的效果，又设置了过期时间）

- 代码实现

public void checkAndReduceStock() {// 1.使用setex加锁,保证加锁的原子性，以及锁可以自动释放Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock-stock", "0000",3, TimeUnit.SECONDS);// 2.重试：递归调用,如果获取不到锁if (!lock) {try {//暂停50msThread.sleep(50);this.checkAndReduceStock();} catch (InterruptedException e) {e.printStackTrace();}} else {try {// 3. 查询库存数量String stockQuantity = (String) redisTemplate.opsForValue().get("P0001");// 4. 判断库存是否充足if (stockQuantity != null && stockQuantity.length() != 0) {Integer quantity = Integer.valueOf(stockQuantity);if (quantity > 0) {// 5.扣减库存redisTemplate.opsForValue().set("P0001", String.valueOf(--quantity));}} else {System.out.println("该库存不存在！");}} finally {// 5.解锁redisTemplate.delete("lock-stock");}}}

- 测试结果：库存扣减为0，锁也释放

  •  防止误删，在以上普通加锁的方式下，存在锁被误删除的情况

- 锁误删除的原因：在上面的加锁场景中，会出现以下的情况，A请求方法获取到锁之后，在业务还没有执行完成，锁就被自动释放，这个时候B请求方法也会获取到锁，在B业务还未执行完成之前，A执行完成并执行手动删除锁操作，这个时候会把B业务的锁释放掉，导致B刚刚获取到锁就被释放，从而产生后续的并发访问问题。

- 模拟锁误删除产生的并发问题

- 库存扣减结果：没有扣减为0，产生并发问题

- 解决方案，每个请求使用全局唯一UUID为value值，删除锁之前，先判断value值是否相同，相同再删除锁

public void checkAndReduceStock() {// 1.使用setex加锁,保证加锁的原子性，以及锁可以自动释放String uuid = UUID.randomUUID().toString();Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock-stock", uuid, 1, TimeUnit.SECONDS);// 2.重试：递归调用,如果获取不到锁if (!lock) {try {//暂停50msThread.sleep(10);this.checkAndReduceStock();} catch (InterruptedException e) {e.printStackTrace();}} else {try {// 3. 查询库存数量String stockQuantity = (String) redisTemplate.opsForValue().get("P0001");// 4. 判断库存是否充足if (stockQuantity != null && stockQuantity.length() != 0) {Integer quantity = Integer.valueOf(stockQuantity);if (quantity > 0) {// 5.扣减库存redisTemplate.opsForValue().set("P0001", String.valueOf(--quantity));}} else {System.out.println("该库存不存在！");}} finally {// 5.先判断是否是自己的锁，然后再解锁String redisUuid = (String) redisTemplate.opsForValue().get("lock-stock");if (StringUtils.equals(uuid, redisUuid)) {redisTemplate.delete("lock-stock");}}}}

- 存在的问题：由于判断锁和解锁的操作不具有原子性，仍然会存在误删除的操作，如A请求在完成判断之后准备删除锁的时候，此时A的锁自动释放，B请求获取到锁，这个时候A请求会手动将B请求的锁删除掉，依然存在并发访问的问题。该概率很小。

  •  使用lua脚本解决锁手动释放删除的操作是原子性操作

- lua代码解决误删操作

public void checkAndReduceStock() {// 1.使用setex加锁,保证加锁的原子性，以及锁可以自动释放String uuid = UUID.randomUUID().toString();Boolean lock = redisTemplate.opsForValue().setIfAbsent("lock-stock", uuid, 1, TimeUnit.SECONDS);// 2.重试：递归调用,如果获取不到锁if (!lock) {try {//暂停50msThread.sleep(10);this.checkAndReduceStock();} catch (InterruptedException e) {e.printStackTrace();}} else {try {// 3. 查询库存数量String stockQuantity = (String) redisTemplate.opsForValue().get("P0001");// 4. 判断库存是否充足if (stockQuantity != null && stockQuantity.length() != 0) {Integer quantity = Integer.valueOf(stockQuantity);if (quantity > 0) {// 5.扣减库存redisTemplate.opsForValue().set("P0001", String.valueOf(--quantity));}} else {System.out.println("该库存不存在！");}} finally {// 5.先判断是否是自己的锁，然后再解锁String script = "if redis.call('get', KEYS[1]) == ARGV[1] " +"then " +"   return redis.call('del', KEYS[1]) " +"else " +"   return 0 " +"end";redisTemplate.execute(new DefaultRedisScript<>(script, Boolean.class), Arrays.asList("lock-stock"), uuid);}}}

结语

关于使用redis分布式锁解决“超卖”问题的内容到这里就结束了，我们下期见。。。。。。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/123984.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

vue3后台管理系统之跨域代理

vue3后台管理系统之跨域代理

vite.config.js中 server: {port: 5002,host: true, //0.0.0.0open: false,strictPort: true,proxy: {// 请求前缀/api&#xff0c;只有加了/api前缀的请求才会走代理(前端自定义)/api: {target: http://127.0.0.1:8000,// 获取服务器地址的设置changeOrigin: true,// 路径重写…
阅读更多...
判断时间是否连续

判断时间是否连续

判断多个时间是否排序 思路当多参的时间传过来,先排序,然后遍历集合对比是否连续的只要一处不是连续的就直接返回false //判断时间是否连续的public static Boolean verificationDate(Date... dates) throws ParseException {boolean flag true;SortedSet<Date> setDat…
阅读更多...
AMD HIP并行编程语言及其矢量相加实例——一文带你快速入门

AMD HIP并行编程语言及其矢量相加实例——一文带你快速入门

✍️写在前面&#xff1a;随着计算的应用场景变得日益复杂多样&#xff0c;为了跟上人工智能算法对算力的需求&#xff0c;GPU硬件架构快速走向多样化&#xff0c;GPU生产厂家众多&#xff0c;且在商业和市场等因素的影响下&#xff0c;GPU通用计算编程模型也日益多元化。因此&…
阅读更多...
Gateway一个诡异问题处理过程

Gateway一个诡异问题处理过程

一、前言 我们搭好了网关和一个基础微服务&#xff08;含用户体系、门店服务、商品服务、客户服务&#xff09;&#xff0c;然后用APIfox测试过程中发现通过网关入口请求某些接口&#xff0c;一段时间后返回错误&#xff0c;查看系统日志发现除了报There is no session with i…
阅读更多...
（Java）泛型总结

（Java）泛型总结

泛型类 public class Student<E> {private E a;public Student(E a){this.aa;}public void show(){System.out.println(a);} } 泛型方法 public <E> void show(E a){System.out.println(a);} 泛型接口 public interface Inter <T>{void show(T a); } 类…
阅读更多...
流程封装与基于加密接口的测试用例设计

流程封装与基于加密接口的测试用例设计

接口测试仅仅掌握 Requests 或者其他一些功能强大的库的用法&#xff0c;是远远不够的&#xff0c;还需要具备能根据公司的业务流程以及需求去定制化一个接口自动化测试框架的能力。所以&#xff0c;接下来&#xff0c;我们主要介绍下接口测试用例分析以及通用的流程封装是如何…
阅读更多...
USACO12OPEN Balanced Cow Subsets G（meet in the middle）

USACO12OPEN Balanced Cow Subsets G（meet in the middle）

洛谷P3067 [USACO12OPEN] Balanced Cow Subsets G 题目大意 我们定义一个奶牛集合 S S S是平衡的&#xff0c;当且仅当满足以下两个条件&#xff1a; S S S非空 S S S可以被划分为两个集合 A , B A,B A,B&#xff0c;满足 A A A里的奶牛产量之和等于 B B B里的牛奶产量之和 …
阅读更多...
并发编程 -常用并发设计模式

并发编程 -常用并发设计模式

1. 优雅终止线程的设计模式 思考&#xff1a;在一个线程 T1 中如何优雅的终止线程 T2&#xff1f; 错误思路1&#xff1a;使用线程对象的 stop() 方法停止线程 stop 方法会真正杀死线程&#xff0c;如果这时线程锁住了共享资源&#xff0c;那么当它被杀死后就再也没有机会释 …
阅读更多...
记一些oracle的踩坑记录

记一些oracle的踩坑记录

这里写自定义目录标题 concat只能拼接2个参数批量插入时&#xff0c; ORA-00926: 缺失 VALUES 关键字 concat只能拼接2个参数 公司脚手架拉下来的有拼接三个参数的&#xff0c;如concat("%", #{keyowrd}, "%)执行到相关语句会报错。需要写成concat(concat(&quo…
阅读更多...
Python selenium元素的定位

Python selenium元素的定位

视频版教程&#xff1a;一天掌握python爬虫【基础篇】 涵盖 requests、beautifulsoup、selenium 对象的定位应该是自动化测试的核心&#xff0c;要想操作一个对象&#xff0c;首先应该识别这个对象。一个对象就是一个人一样&#xff0c;他 会有各种的特征&#xff08;属性&…
阅读更多...
go语言写的在线oj系统

go语言写的在线oj系统

1、持续更新。。。。大家等我写完
阅读更多...
postgresql的windows

postgresql的windows

1. 资源下载&#xff1a; https://www.postgresql.org/download/windows/ 2. 安装 双击&#xff0c;指定D盘目录&#xff0c;接下来默认安装&#xff0c;一直到出现下面的最后一步。一定要去除勾选复选框。 在最后&#xff0c;点击FINISH。 3. 初始化 4. 检查和修改配置 1&am…
阅读更多...
ADC芯片的分辨率一定等于测量精度吗？

ADC芯片的分辨率一定等于测量精度吗？

开发充气泵方案或者电子秤方案ADC芯片都是我们必不可少的&#xff0c;其功能中的分辨率是芯片的重要一个功能&#xff0c;所谓分辨率就是最小能够分辨的模拟电压值。但常常会困扰到工程师的是&#xff0c;分辨率一定等于测量精度吗&#xff1f;市面上12位分辨率的数据采集卡的精…
阅读更多...
数据结构：优先级队列（堆）

数据结构：优先级队列（堆）

概念 优先级队列是啥&#xff1f; 队列是一种先进先出 (FIFO) 的数据结构 &#xff0c;但有些情况下&#xff0c; 操作的数据可能带有优先级&#xff0c;一般出队 列时&#xff0c;可能需要优先级高的元素先出队列。 在这种情况下&#xff0c; 数据结构应该提供两个最基本的…
阅读更多...
converted from warning

converted from warning

converted from warning 关注微信&#xff1a;生信小博士 本地或者其它服务器跑同样的代码是正常的&#xff0c;只是有警告&#xff0c;但是在西柚云服务器上面运行会报错&#xff1f; 这是由于您两个环境使用的包版本不一样导致的&#xff0c;有如下解决方法 或者之前只是告警…
阅读更多...
Jetpack Compose | State状态管理及界面刷新

Jetpack Compose | State状态管理及界面刷新

我们知道Jetpack Compose&#xff08;以下简称Compose&#xff09;中的 UI 可组合项是通过Composable 声明的函数来描述的&#xff0c;如&#xff1a; Composable fun Greeting() {Text(text "init",color Color.Red,modifier Modifier.fillMaxWidth()) }上面的代…
阅读更多...
MySQL实战1

MySQL实战1

文章目录 主要内容一.墨西哥和美国第三高峰1.准备工作代码如下&#xff08;示例&#xff09;: 2.目标3.实现代码如下&#xff08;示例&#xff09;: 4.相似例子代码如下&#xff08;示例&#xff09;: 二.用latest_event查找当前打开的页数1.准备工作代码如下&#xff08;示例&…
阅读更多...
Windows 操作系统提供的函数SetEvent以及ResetEvent，用于操作事件对象。它们属于同步原语函数，用于实现线程同步和互斥

Windows 操作系统提供的函数SetEvent以及ResetEvent，用于操作事件对象。它们属于同步原语函数，用于实现线程同步和互斥

文章目录 前言1、ResetEvent2、SetEvent3、WaitForSingleObject4、WaitForMultipleObjects 前言 SetEvent 和 ResetEvent 是 Windows 操作系统提供的函数&#xff0c;用于操作事件对象。它们属于同步原语函数&#xff0c;用于实现线程同步和互斥。这些函数的类型如下&#xff1…
阅读更多...
C++设计模式_20_Composite 组合模式

C++设计模式_20_Composite 组合模式

Composite 组合模式和后面谈到的Iterator&#xff0c;Chain of Resposibility都属于“数据结构”模式。Composite 组合模式核心是通过多态的递归调用解耦内部和外部的依赖关系。 文章目录 1. “数据结构”模式1.1 典型模式 2. 动机( Motivation )3. 模式定义4. Composite 组合模…
阅读更多...
科普|电源自动测试系统测试的项目都有哪些？

科普|电源自动测试系统测试的项目都有哪些？

电源自动测试系统是一种用于电源性能自动测试的集成系统&#xff0c;它可以自动检测电源模块或开关电源的输入、输出、保护等各个方面。该系统通常由数据软件和各类硬件测试仪器共同组成&#xff0c;利用通讯总线、测试夹具以及其它线缆等将仪器进行连接组成整体的系统结构&…
阅读更多...
最新文章

Copyright @ 2022~2023