当前位置：首页 > news >正文

redis分布式锁

news 2026/4/21 13:41:16

文章目录

案例：秒杀
优化一：JVM锁synchronized、ReentrantLock
优化二：分布式锁实现之setnx
优化三：分布式锁实现之redisson
优化四：分布式锁实现之redlock

案例：秒杀

/* * 版本一：单机版模拟商品秒杀 * 问题：单机版没有加锁，高并发导致商品超卖现象 * 解决：加锁呗，jvm级别的锁可以是synchronized、ReentrantLock，加哪一个呢，有什么区别？ * 1. synchronized：锁住整个方法/代码块，不能灵活的释放锁，其他线程等不到锁只能死等 * 2. ReentrantLock：锁住代码块，可以通过tryLock()方法，设置超时时间，超时后灵活自动释放锁 * * 如何选择： * 根据业务需求来选，如果非要抢到锁不可，就使用 synchronized 锁； * 如果可以暂时放弃锁，等会再来强，就使用 ReentrantLock 锁 */@GetMapping("/buyGoods")publicStringbuyGoods(){// 1. 从redis中获取商品的剩余数量Objectresult=redisUtils.get("goods:001");Integernum=Objects.isNull(result)?0:Integer.parseInt(result.toString());// 2. 逻辑处理StringretStr=null;if(num>0){// 商品数量大于零才能出售num=num-1;redisUtils.set("goods:001",num);retStr="你已经成功秒杀商品，此时还剩余："+num+"件"+" 服务器端口: "+serverPort;}else{// 商品售罄retStr="商品已经售罄/活动结束/调用超时，欢迎下次光临"+" 服务器端口: "+serverPort;}System.out.println(retStr);returnretStr;}

优化一：JVM锁synchronized、ReentrantLock

/** * 版本二：通过synchronized、ReentrantLock锁解决单机版商品秒杀问题 * 问题：仅适用于单机环境，在分布式环境中，因为锁的竞争不在同一JVM中，仍然出现超卖现象。所以需要一个让所有线程都能访问的分布式锁来实现，比如redis * 解决方案：redis分布式锁各种实现方案 * * @return */@GetMapping("/buyGoods2")publicStringbuyGoods2(){synchronized(this){Objectresult=redisUtils.get("goods:001");Integernum=Objects.isNull(result)?0:Integer.parseInt(result.toString());StringretStr=null;if(num>0){num=num-1;redisUtils.set("goods:001",num);retStr="你已经成功秒杀商品，此时还剩余："+num+"件"+" 服务器端口: "+serverPort;}else{retStr="商品已经售罄/活动结束/调用超时，欢迎下次光临"+" 服务器端口: "+serverPort;}System.out.println(retStr);returnretStr;}}

优化二：分布式锁实现之setnx

/** * 版本三：分布式锁实现之SETNX * 原理：在多个redis客户端同事通过setnx尝试获取锁，利用redis单线程的特性，可以保证只会有一个客户端成功获取到锁，其他客户端泽失败，并且获取锁成功的客户端，会设置一个过期时间，避免该客户端挂了之后一直持有该锁 * 功能： * 1.获取锁，锁的过期时间设置为10秒，如果获取锁失败，则返回失败，并且保证加锁和设置过期时间为原子操作。 * 存在问题1：加锁如果设置过期时间，可能导致锁误删除，如果不设置过期时间，可能导致死锁 * 存在问题2：不支持可重入，可借助redisson实现可重入锁 * @return */@GetMapping("/buyGoods3")publicStringbuyGoods3(){try{// 1. 获取锁【加锁+设置过期时间原子性，并且不要把加锁和设置过期时间分开写】BooleanlockFlag=redisUtils.setIfAbsent(LOCK_KEY,UUID.randomUUID()+Thread.currentThread().getName(),10L);if(!lockFlag){return"抢锁失败";}// 2. 业务逻辑处理Objectresult=redisUtils.get("goods:001");Integernum=Objects.isNull(result)?0:Integer.parseInt(result.toString());StringretStr=null;if(num>0){num=num-1;redisUtils.set("goods:001",num);retStr="你已经成功秒杀商品，此时还剩余："+num+"件"+" 服务器端口: "+serverPort;}else{retStr="商品已经售罄/活动结束/调用超时，欢迎下次光临"+" 服务器端口: "+serverPort;}System.out.println(retStr);returnretStr;}finally{// 3. 释放锁：判断是否是自己加的锁if(value.equalsIgnoreCase((String)redisUtils.get(LOCK_KEY))){redisUtils.del(LOCK_KEY);// 也可以通过lua脚本实现删除操作原子性}}}

优化三：分布式锁实现之redisson

/** * 版本七：redisson最终版 * 1. 分布式锁的加锁、解锁原子性 * 2. 锁的续期 */@GetMapping("/buyGoods7")publicStringbuyGoods7()throwsException{// 1. 获取可重入的分布式锁【获取到锁的线程可以再次尝试获取锁，并且只能被占用锁的线程解锁】RLockredissonLock=redissonClient.getLock(LOCK_KEY);redissonLock.lock(10,TimeUnit.SECONDS);// 2. 业务逻辑处理try{Objectresult=redisUtils.get("goods:001");Integernum=Objects.isNull(result)?0:Integer.parseInt(result.toString());StringretStr=null;if(num>0){intrealNumber=num-1;redisUtils.set("goods:001",realNumber+"");retStr="你已经成功秒杀商品，此时还剩余："+realNumber+"件"+"\t 服务器端口: "+serverPort;}else{retStr="商品已经售罄/活动结束/调用超时，欢迎下次光临"+"\t 服务器端口: "+serverPort;}System.out.println(retStr);returnretStr;}finally{// 3. 解锁，还在持有锁的状态，并且是当前线程持有的锁再解锁if(redissonLock.isLocked()&&redissonLock.isHeldByCurrentThread()){redissonLock.unlock();}}}