站长网 资讯 明白微服务下分布式锁的正确姿势

明白微服务下分布式锁的正确姿势

副标题#e# 将key的值设为value ,当且仅当key不存在。若给定的key已经存在,则SETNX不做任何动作。setnx:当key存在,不做任何操作,key不存在,才设置 加锁: SETorderIddriverIdNXPX30000 上面的命令如果执行成功,则客户端成功获取到了锁,接下来就可以

副标题#e#

将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 { 

#p#副标题#e#

      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; 

    } 

#p#副标题#e##p#分页标题#e#

这里可能会有人问,如果我业务的执行时间超过了锁释放的时间,会怎么办呢?我们可以使用守护线程,只要我们当前线程还持有这个锁,到了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了,导致它一直持有这个锁。造成死锁。

本文来自网络,不代表站长网立场,转载请注明出处:https://www.tzzz.com.cn/html/biancheng/zx/2021/0528/7265.html

作者: dawei

【声明】:站长网内容转载自互联网,其相关言论仅代表作者个人观点绝非权威,不代表本站立场。如您发现内容存在版权问题,请提交相关链接至邮箱:bqsm@foxmail.com,我们将及时予以处理。
联系我们

联系我们

0577-28828765

在线咨询: QQ交谈

邮箱: xwei067@foxmail.com

工作时间:周一至周五,9:00-17:30,节假日休息

返回顶部