• .NET结合Redis实现分布式锁
  • 发布于 2个月前
  • 154 热度
    0 评论
使用场景

在做Web项目的时候,有很多特殊的场景要使用到锁

比如说抢红包,资源分配,订单支付等场景

就拿抢红包来说,如果一个红包有5份,同时100个人抢如果没有用到锁的话

100个人同时并发都抢成功,那就出大事了

怎么实现锁
class Test  
{  
    //定义一个私有成员变量,用于Lock  
    private static object lockobj = new object();  
    void DoSomething()  
    {  
        lock (lockobj)  
        {  
            //需要锁定的代码块  
        }  
    }  
} 

这样我们就可以很好的控制并发的情况,从而不出现问题

但是在项目还小的时候,可能只运行在一台服务器,一个进程的情况下

这种代码不会出现问题

但是在部署在多台服务器,每个服务器开多个进程的情况下

.net自带的lock锁只能保证同一个进程在并发情况在不出现问题

而多服务器,多进程情况下。lock锁就不能满足我们的要求了

怎么实现分布式锁

实现思路为
当我们在执行代码前,先去设置一个分布式锁
其实就是给Redis设置一个Key,但是要这个Key不存再的情况下才可以设置成功
如果设置成功,表示当前进程拿到锁,可以执行后续代码 
如果设置失败,表示其它进程已经锁定,那么我们就要让当前进程休眠一下,然后再去重试设置锁
直到设置锁成功,才表示当前进程锁定,才可以执行自定义代码
在执行自宝义代码后,释放锁,这样其它进程就可以拿到锁了
我们在设置锁的时候,为了防此自定义代码报错,而出现死锁的情况
所以我们在设置锁的时候可以设置锁的一个过期时间,这样就算自定义代码出错,没有释放锁的情况下
其它进程也可以在一定时间内拿到锁,当然可以try,catch把自定义代码包起来
代码实现
      //TODO:拿锁
        //定义一个锁的Key
        var lockKey = CacheKeyFormat.AssignLockKeyFormat;
        var isLocked = false;//是否已经锁定,默认否
        do
        {
            //使用do-while先去给Redis的lockKey随便设置一个值
            //但是设置的条件是,如果当前lockKey存再(表示其它进程已经锁定了)就返回false
            //如果lockKey不存再(表示当前没有其它进程锁定),就反回true,并且设置过期时间为600毫秒(如果进行没有释放,报错死锁的情况)
            isLocked = redisDb.StringSet(lockKey, id, TimeSpan.FromMilliseconds(600), StackExchange.Redis.When.NotExists);

            //如果isLocked反回false表示被其它进程锁定,那么当前进程休眠200毫秒后,再去设置锁
            //重复此动作直到当前进程拿到锁为止
            if (!isLocked)
          system.Threading.Thread.leep(200);
        } while (!isLocked);

        //TODO:执行其它动作,to do something

        //在执行完自定义代码后,释放锁
        redisDb.KeyDelete(CacheKeyFormat.AssignLockKeyFormat);

这样的话,不管项目部署多少服务器,开多少个进程
我们都能保证在这个情况下,这个执行动作是一个一个执行,不会存再并发不可控的情况
用户评论