SpringCloud电商秒杀微服务Redisson分布式锁方案

一、引言&＃xff1a;

前两篇文章&＃xff0c;介绍了&＃xff1a;

《学会Zookeeper分布式锁--让面试官对你刮目相看》

《SpringBoot电商项目实战-Curator分布式锁实现》

细心的读者可能发现&＃xff0c;号主在分布式锁这条路上“越走越黑”&＃xff0c;已经发表了好几篇相关文章了&＃xff0c;莫慌&＃xff0c;再学完本章&＃xff0c;你就可以在分布式锁场景下拿着倚天剑与屠龙刀叱咤分风云了

因为实际项目可能面临各种业务场景需求&＃xff0c;需要不同的分布式锁方案&＃xff0c;而这些文章并不是类似网上很多的教你ctrl c  &＃43; ctrl &＃43;v&＃xff0c;关键掌握真谛。还不会的建议先去看下第一篇哦&＃xff0c;从实际高并发场景深入浅出&＃xff0c;层层剖析...

1、分布式锁思路分析

锁特点&＃xff1a;

• 排他性&＃xff1a;同一时间&＃xff0c;只有一个线程能获得&＃xff1b;

• 阻塞性&＃xff1a;其它未抢到的线程阻塞等待&＃xff0c;直到锁被释放&＃xff0c;再继续抢&＃xff1b;

• 可重入性&＃xff1a;线程获得锁后&＃xff0c;后续是否可重复获取该锁&＃xff08;避免死锁&＃xff09;。

当然&＃xff0c;还要考虑性能开销等问题。

2、常规的分布式锁解决方案有哪几种&＃xff1a;

• 文件系统&＃xff1a;同一个目录下&＃xff0c;不能存在同名文件

• 数据库锁&＃xff1a;主键 、 唯一约束  、for  update

• 基于Redis的分布式锁&＃xff1a;setnx、set、Redisson

• 基于ZooKeeper的分布式锁&＃xff1a;类似文件系统

直接进入今天正题&＃xff0c;就不多介绍分布式锁的背景、区别之类了&＃xff0c;可以参考前两篇文章哦。

二、redis分布式锁简介

1、基于redis分布式锁

&＃xff08;1&＃xff09;基本锁

• 原理&＃xff1a;利用redis的setnx&＃xff0c;如果不存在某个key则设置值&＃xff0c;设置成功则表示取得锁成功。

• 缺点&＃xff1a;如果获取锁后的进程在没有执行完就挂了&＃xff0c;则锁永远不会释放&＃xff0c;产生死锁。

&＃xff08;2&＃xff09;改进型

• 改进&＃xff1a;在基本锁上setnx后设置expire&＃xff0c;保证超时后也能自动释放锁。

• 缺点&＃xff1a;setnx与expire不是一个原子操作&＃xff0c;可能执行完setnx&＃xff0c;还没来得及执行expire设置过期时间&＃xff0c;该进程就挂了。

&＃xff08;3&＃xff09;增强版

• 改进&＃xff1a;利用Lua脚本&＃xff0c;将setnx与expire变成一个原子操作&＃xff0c;可解决一部分问题。

• 缺点&＃xff1a;还是锁过期问题。

注意&＃xff1a; Redis 从2.6.12版本开始 set 命令支持 NX 、 PX 这些参数来达到 setnx 、 setex 、 psetex 命令的效果。

2、Redisson简介

所以直接使用redis自己实现分布式锁&＃xff0c;相对麻烦&＃xff0c;还存在上面的问题。接下来主要分析Redisson的分布式锁的实现&＃xff0c;一般提及到Redis的分布式锁我们更多的使用的是Redisson的分布式锁&＃xff0c;Redis的官方也是建议我们这样去做的。Redisson点我可以直接跳转到Redisson的官方文档。

注&＃xff1a;redisson 更新注意点

• 2018-02-26更新&＃xff1a;增加tryLock方法&＃xff0c;建议后面去掉DistributedLocker接口和其实现类&＃xff0c;直接在RedissLockUtil中注入RedissonClient实现类&＃xff08;简单但会丢失接口带来的灵活性&＃xff09;。

• 2019-07-11更新&＃xff1a;redisson官方发布了 redisson-spring-boot-starter

本文将引入最新的redisson和springboot的集成包&＃xff1a;redisson-spring-boot-starter&＃xff0c;网上的很多教程可能还是使用redisson老版本&＃xff0c;互相copy。redisson介绍可参考官网&＃xff0c;有中英文wiki 。

参考官网&＃xff1a;

https://github.com/redisson/redisson/tree/master/redisson-spring-boot-starter#spring-boot-starter

注&＃xff1a;本示例为方便演示&＃xff0c;仅提供如何实现redisson分布式锁方案&＃xff0c;库存直接读取数据库&＃xff0c;自己可以改造放到redis等缓存中&＃xff0c;这个不会的自己去脑补。

三、项目实战

1、添加依赖&＃xff1a;

org.redisson redisson-spring-boot-starter 3.11.2

2、application.yml配置

3、redissson.yml 配置

4、新建一个redisson配置&＃xff0c;读取配置文件redisson.yml&＃xff0c;并将RedissonClient注册到spring ioc容器

&＃64;Configurationpublic class RedissonConfig { &＃64;Bean(destroyMethod &＃61; "shutdown") public RedissonClient redisson() throws IOException { // 1. 创建Config对象&＃xff0c;读取配置属性 // 2. 创建Redisson对象,传入Config对象 RedissonClient redisson &＃61; Redisson.create(Config.fromYAML( new ClassPathResource("redisson.yml").getInputStream())); return redisson; }}

5、新建一个商品服务实现类

&＃64;Servicepublic class ProductServiceImpl implements IProductService { &＃64;Autowired    private ProductDao productDao; &＃64;Autowired    private RedissonClient redissonClient; /** * 秒杀商品 * &＃64;param productId 商品ID * &＃64;param number 数量 * &＃64;return */ &＃64;Override public Boolean seckillProduct(Long productId, Integer number) { String key &＃61; "seckill_stock_lock_" &＃43; productId; RLock lock &＃61; redissonClient.getLock(key); try { //获取分布式锁 lock.lock(); Product product &＃61; productDao.selectById(productId); if ( product!&＃61;null && product.getStocks() &＃61;&＃61; 0) { return false; } Integer stocks &＃61; product.getStocks() - 1; productDao.updateStocksById(productId,stocks); } catch (Exception e) { e.printStackTrace(); } finally { lock.unlock(); } return true; }}

6、新建一个controller&＃xff0c;并提供一个http接口&＃xff1a;秒杀商品

&＃64;RestController&＃64;RequestMapping("/product")public class ProductController { &＃64;Autowired private IProductService productService; /** * 秒杀商品测试 * &＃64;return */ &＃64;GetMapping("seckillTest") public String seckillProductTest() { Boolean flag &＃61; productService.seckillProduct(1L, 1); if(flag &＃61;&＃61;true){ return "创建订单成功"; } else{ return "库存不足"; } }}

7、数据库product商品表数据如下&＃xff0c;id&＃61;1的库存为30个&＃xff0c;如下&＃xff1a;

8、使用并发测试工具类&＃xff0c;如jmeter ,新建一个测试任务&＃xff0c;并发线程设为50或其他&＃xff0c;模拟多人同时并发秒杀某个商品&＃xff0c;启动项目&＃xff0c;然后测试&＃xff1a;

9、全部执行成功后&＃xff0c;查看数据库中数据&＃xff0c;库存已经为0&＃xff0c;没有出现负数&＃xff0c;超卖的情况。

完结&＃xff0c;分布式锁专题终于告一段落&＃xff0c;你学会了吗

注&＃xff1a;本示例为方便演示&＃xff0c;仅提供如何实现redisson分布式锁方案&＃xff0c;库存直接读取数据库&＃xff0c;自己可以改造放到redis等缓存中&＃xff0c;这个不会的自己去脑补。

●SpringBoot电商项目实战-Curator分布式锁实现

●学会Zookeeper分布式锁&＃xff0c;让面试官对你刮目相看

●SpringBoot&＃43;Token实现接口幂等性|防止表单重复提交

一只 有深度 有灵魂 的公众号0.0  "阿甘正专"

来都来了&＃xff0c;点个在看再走吧~~~