掌握Redis分布式锁的正确姿势 (2)

目录结构:

在这里插入图片描述

方式一:基于 SETNX 实现分布式锁

将key的值设为value ,当且仅当key不存在。
若给定的key已经存在,则SETNX不做任何动作。
setnx:当key存在,不做任何操作,key不存在,才设置

加锁:

SET orderId driverId NX PX 30000
上面的命令如果执行成功,则客户端成功获取到了锁,接下来就可以访问共享资源了;而如果上面的命令执行失败,则说明获取锁失败。

释放锁:
关键,判断是不是自己加的锁。

GrabService :

public interface GrabService { /** * 商品抢单 * @param orderId * @param driverId * @return */ public ResponseResult grabOrder(int orderId, int driverId); }

GrabRedisLockServiceImpl :

@Service("grabRedisLockService") public class GrabRedisLockServiceImpl implements GrabService { @Autowired StringRedisTemplate stringRedisTemplate; @Autowired OrderService orderService; @Override public ResponseResult grabOrder(int orderId , int driverId){ //生成key String lock = "order_"+(orderId+""); /* * 情况一,如果锁没执行到释放,比如业务逻辑执行一半,运维重启服务,或 服务器挂了,没走 finally,怎么办? * 加超时时间 */ // boolean lockStatus = stringRedisTemplate.opsForValue().setIfAbsent(lock.intern(), driverId+""); // if(!lockStatus) { // return null; // } /* * 情况二:加超时时间,会有加不上的情况,运维重启 */ // boolean lockStatus = stringRedisTemplate.opsForValue().setIfAbsent(lock.intern(), driverId+""); // stringRedisTemplate.expire(lock.intern(), 30L, TimeUnit.SECONDS); // if(!lockStatus) { // return null; // } /* * 情况三:超时时间应该一次加,不应该分2行代码, * */ boolean lockStatus = stringRedisTemplate.opsForValue().setIfAbsent(lock.intern(), driverId+"", 30L, TimeUnit.SECONDS); if(!lockStatus) { return null; } try { System.out.println("用户:"+driverId+" 执行抢单逻辑"); boolean b = orderService.grab(orderId, driverId); if(b) { System.out.println("用户:"+driverId+" 抢单成功"); }else { System.out.println("用户:"+driverId+" 抢单失败"); } } finally { /** * 这种释放锁有,可能释放了别人的锁。 */ // stringRedisTemplate.delete(lock.intern()); /** * 下面代码避免释放别人的锁 */ if((driverId+"").equals(stringRedisTemplate.opsForValue().get(lock.intern()))) { stringRedisTemplate.delete(lock.intern()); } } return null; } }

这里可能会有人问,如果我业务的执行时间超过了锁释放的时间,会怎么办呢?我们可以使用守护线程,只要我们当前线程还持有这个锁,到了10S的时候,守护线程会自动对该线程进行加时操作,会续上30S的过期时间,直到把锁释放,就不会在进行续约了,开启一个子线程,原来时间是N,每隔N/3,在去续上N

关注点:

key,是我们的要锁的目标,比如订单ID。

driverId 是由我们的商品ID,它要保证在足够长的一段时间内在所有客户端的所有获取锁的请求中都是唯一的。即一个订单被一个用户抢。

NX表示只有当orderId不存在的时候才能SET成功。这保证了只有第一个请求的客户端才能获得锁,而其它客户端在锁被释放之前都无法获得锁。

PX 30000表示这个锁有一个30秒的自动过期时间。当然,这里30秒只是一个例子,客户端可以选择合适的过期时间。

这个锁必须要设置一个过期时间。 否则的话,当一个客户端获取锁成功之后,假如它崩溃了,或者由于发生了网络分区,导致它再也无法和Redis节点通信了,那么它就会一直持有这个锁,而其它客户端永远无法获得锁了。antirez在后面的分析中也特别强调了这一点,而且把这个过期时间称为锁的有效时间(lock validity time)。获得锁的客户端必须在这个时间之内完成对共享资源的访问。

此操作不能分割。

SETNX orderId driverId
EXPIRE orderId 30
虽然这两个命令和前面算法描述中的一个SET命令执行效果相同,但却不是原子的。如果客户端在执行完SETNX后崩溃了,那么就没有机会执行EXPIRE了,导致它一直持有这个锁。造成死锁。

方式二:基于redisson实现分布式锁

流程图:

在这里插入图片描述


代码实现:

@Service("grabRedisRedissonService") public class GrabRedisRedissonServiceImpl implements GrabService { @Autowired RedissonClient redissonClient; @Autowired OrderService orderService; @Override public ResponseResult grabOrder(int orderId , int driverId){ //生成key String lock = "order_"+(orderId+""); RLock rlock = redissonClient.getLock(lock.intern()); try { // 此代码默认 设置key 超时时间30秒,过10秒,再延时 rlock.lock(); System.out.println("用户:"+driverId+" 执行抢单逻辑"); boolean b = orderService.grab(orderId, driverId); if(b) { System.out.println("用户:"+driverId+" 抢单成功"); }else { System.out.println("用户:"+driverId+" 抢单失败"); } } finally { rlock.unlock(); } return null; } }

关注点:

内容版权声明:除非注明,否则皆为本站原创文章。

转载注明出处:https://www.heiqu.com/wpspdz.html