1. <output id="hzk7v"><pre id="hzk7v"><address id="hzk7v"></address></pre></output>
      <output id="hzk7v"></output>
    2. <nav id="hzk7v"><i id="hzk7v"><em id="hzk7v"></em></i></nav>
    3. <listing id="hzk7v"><delect id="hzk7v"><em id="hzk7v"></em></delect></listing>

      详解ASP.Net Core 中如何借助CSRedis实现一个安全高效的分布式锁

       更新时间£º2019年04月09日 15:29:27   作者£º菠萝吹雪¡ªCode   我要评论

      这篇文章主要介绍了ASP.Net Core 中如何借助CSRedis实现一个安全高效的分布式锁£¬文中通过示例代码介绍的非常详细£¬对大家的学习或者工作具有一定的参考学习价值£¬需要的朋友们下面随着小编来一起学习学习吧

      引言£º最近回头看了看开发的.Net Core 2.1项目的复盘总结£¬其中在多处用到Redis实现的分布式锁£¬虽然在OnResultExecuting方法中做了防止死锁的处理£¬但在某些场景下还是会发生死锁的问题£¬下面我只展示部分代码£º

      问题£º

      £¨1£©这里setnx设置的值¡°1?#20445;?#25105;想问£¬你最后del的这个值一定是你自己创建的吗£¿

      £¨2£©图中标注的步骤1和步骤2不是原子操作£¬会有死锁的概率吗£¿

      大家可?#36816;?#32771;一下先£¬下面让我们带着这两个问题往下看£¬下面介绍一下使用Redis实现分布式锁常用的几个命令¡£

      一¡¢使用Redis实现分布式锁常见的几个命令

      Setnx

      命令£ºSETNX key value
      说明?#33322;?key 的值设为 value £¬当且仅当 key 不存在¡£若给定的 key 已经存在£¬则 SETNX 不做任何动作¡£SETNX 是¡ºSET if Not eXists¡»(如果不存在£¬则 SET)的简?#30784;?br /> 时间复杂度£ºO(1)
      返回值£º设置成功£¬返回1 £» 设置失败£¬返回 0

      Getset

      命令£ºGETSET key value
      说明?#33322;?#32473;定 key 的值设为 value £¬并返回 key 的旧值(old value)¡£当 key 存在但不是字符串类型时£¬返回一个错误¡£
      时间复杂度£ºO(1)
      返回值£º返回给定 key 的旧值; 当 key 没有旧值时£¬?#24067;词 ¿?key 不存在时£¬返回 nil ¡£

      Expire

      命令£ºEXPIRE key seconds
      说明?#20309;?#32473;定 key 设置生存时间£¬当 key 过期时(生存时间为 0 )£¬它会被自动删除¡£
      时间复杂度£ºO(1)
      返回值£º设置成功返回 1 £»当 key 不存在或者不能为 key 设置生存时间时(比如在低于 2.1.3 版本的 Redis 中你尝试更新 key 的生存时间)£¬返回 0 ¡£

      Del

      命令£ºDEL key [key ...]
      说明£º删除给定的一个或多个 key ¡£不存在的 key 会被忽略¡£
      时间复杂度£ºO(N); N 为被删除的 key 的数量¡£
      删除单个字符串类型的 key £¬时间复杂度为O(1)¡£
      删除单个列表¡¢集合¡¢有序集合或哈希表类型的 key £¬时间复杂度为O(M)£¬ M 为以上数据结构内的元素数量¡£
      返回值£º被删除 key 的数量¡£

      好了£¬命令熟悉之后£¬下面我们就开始一步一步实现分布式锁¡£

      二¡¢使用Redis实现分布式锁版本一£º与时间戳的结合

      对于上面的setnx设置的默?#29616;?£¬我们采用时间戳来防止问题一£¬下面先让我们来看下想当然写法流程图¡£

      流程图£º

      C#代码实现£º

      static void Main(string[] args)
          {
            var lockTimeout = 5000;//单位是毫秒
            var currentTime = DateTime.Now.ToUnixTime(true);
            if (SetNx("lockkey", currentTime+ lockTimeout,lockTimeout))
            {
              //TODO:一些业务逻辑代码
              //.....
              //.....
              //最后?#22836;?#38145;
              Remove("lockkey");
            }
            else
            {
              Console.WriteLine("没有获得分布式锁");
            }
            Console.ReadKey();
          }
      
          public static bool SetNx(string key,long time ,double expireMS)
          {
            if (redisClient.SetNx(key, time))
            {
              if (expireMS > 0)
                redisClient.Expire(key, TimeSpan.FromMilliseconds(expireMS));
              return true;
            }
            return false;
          }
      
          public static bool Remove(string key)
          {
            return redisClient.Del(key) > 0;
          }

      上面的代码中value的值我们使用时间戳£¬不是一个固定的值了£¬至少能保证你删除的key确实是你自己的£¬所以£¬建议大家在设value的值时£¬不要设置一个固定的值£¬最好是随机的¡£但是这样写虽然解决了问题一£¬但是这?#20013;?#27861;还是存在一定的风险£¬虽然Redis是单线程的并且setnx¡¢expire是原子操作£¬但是先setnx再expire就不是原子操作了£¡£¡£¡我们要考虑多线程环境和容器部署时多实例环境等等£¬那这样的写法就会出现问题¡£

      比如£º现在有A¡¢B?#25945;?#26381;务器在跑这个应用£¬当A台应用跑到£ºsetnx成功但是还没有设置过期时间的时候£¬突然重启服务£¬这个时候在分布式环境中就会发生死锁的问题£¬因为你没有设置过期时间¡£

      下面我们通过调试来展示死锁的场景£º

      A应用£º在执行到setnx成功但是在执行expire之前宕机了£¬此时的Redis已经有数据了£¬但是没有过期时间

      B应用£º运行正常

      但是B应用就会一?#34987;?#21462;不到锁£¬导致死锁¡£

      所以上面在获取锁的逻辑还是有问题的£¬为了解决这个问题£¬我们采用下面的方式来处理¡£

      三¡¢使用Redis实现分布式锁版本二£º双重防死锁

      流程图£º

      C#代码实现£º

      public static void RedisLockV2()
          {
            var lockTimeout = 5000;//单位是毫秒
            var currentTime = DateTime.Now.ToUnixTime(true);
      
            if (SetNxV2("lockkey",DateTime.Now.ToUnixTime(true)+lockTimeout))
            {
              //设置过期时间
              redisClient.Expire("lockkey", TimeSpan.FromMilliseconds(5000));
              //TODO:一些业务逻辑代码
              
              Console.WriteLine("处理业务ing");
              Thread.Sleep(100000);
      
              Console.WriteLine("处理业务ed");
              //最后?#22836;?#38145;
              Remove("lockkey");
            }
            else
            {
              //未获取到锁£¬继续判?#24076;?#21028;断时间戳看?#35789;?#21542;可以重置并获取锁
              var lockValue = redisClient.Get("lockkey");
              var time = DateTime.Now.ToUnixTime(true);
      
              if (!string.IsNullOrEmpty(lockValue) && time> lockValue.ToInt64())
              {
                //再次用当前时间戳getset
                //返回固定key的旧值£¬旧值判断是否可以获取锁
                var getsetResult = redisClient.GetSet("lockkey", time);
                if (getsetResult == null || (getsetResult != null && getsetResult == lockValue))
                {
                  Console.WriteLine("获取到Redis锁了");
                  //真正获取到锁
                  redisClient.Expire("lockkey", TimeSpan.FromMilliseconds(5000));
                  //TODO:一些业务逻辑代码
                  //.....
                  //.....
                  Console.WriteLine("处理业务");
                  //最后?#22836;?#38145;
                  Remove("lockkey");
                }
                else
                {
                  Console.WriteLine("没有获取到锁");
                }
      
              }
              else
              {
                Console.WriteLine("没有获取到锁");
              }
            }
            
          }

      现在£¬Redis中的情况如下£º

      我们运行上面的代码£¬结果如下£º

      副本.exe中添加一行代码¡£来模拟这种场景£º有A¡¢B?#25945;?#26381;务器在跑这个应用£¬当A台应用跑到£ºsetnx成功但是还没有设置过期时间的时候£¬突然重启服务£¬这个时候在分布式环境中就会发生死锁的问题£¬因为你没有设置过期时间

      我们先执行Lottery.ThriftRpc - 副本.exe£¬等Redis里面有值了£¬并且这个key是没有过期时间£¬再关闭掉该程序£º

      然后£¬再执行Lottery.ThriftRpc.exe

      看£¬我们是不是解决了该问题£¬至于过期时间设置为多少要结合你的具体业务处理时间来计算出一个合理的值£¬好了£¬聊到这里关于Redis的分布式锁就讲完了£¬希望对你有帮助£¬谢谢¡£

      四¡¢总结£º

      上面的示例中Redis的组件用的是CSRedisCore£¬这里只是自己的一点体会£¬如果你有更好的办法£¬可以在评论区讨论£¬关于Redis的理论讲解有太多的文章了£¬大家可以参考£¬关于Redis的文章我只总结工作中遇到的一些问题£¬关于文章中的源码£¬我就不提供了£¬太简单了¡£后面?#19968;?#19981;定期分享一些Redis的问题£¬希望大家多多支持¡£

      以上所述是小编给大家介绍的ASP.Net Core 中如何借助CSRedis实现一个安全高效的分布式锁详解整合£¬希望对大家有所帮助£¬如果大家有任何疑问请给我留言£¬小编会及时回复大家的¡£在此也非常?#34892;?#22823;家对脚本之家网站的支持£¡

      相关文章

      最新评论

      3dÊÔ»úºÅÖвÊÍø

        1. <output id="hzk7v"><pre id="hzk7v"><address id="hzk7v"></address></pre></output>
          <output id="hzk7v"></output>
        2. <nav id="hzk7v"><i id="hzk7v"><em id="hzk7v"></em></i></nav>
        3. <listing id="hzk7v"><delect id="hzk7v"><em id="hzk7v"></em></delect></listing>

            1. <output id="hzk7v"><pre id="hzk7v"><address id="hzk7v"></address></pre></output>
              <output id="hzk7v"></output>
            2. <nav id="hzk7v"><i id="hzk7v"><em id="hzk7v"></em></i></nav>
            3. <listing id="hzk7v"><delect id="hzk7v"><em id="hzk7v"></em></delect></listing>