zoukankan      html  css  js  c++  java
  • MVC使用Redis实现分布式锁

    使用场景

    在做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.Sleep(200);
            } while (!isLocked);
    
            //TODO:执行其它动作,to do something
    
            //在执行完自定义代码后,释放锁
            redisDb.KeyDelete(CacheKeyFormat.AssignLockKeyFormat);
    这样的话,不管项目部署多少服务器,开多少个进程

    我们都能保证在这个情况下,这个执行动作是一个一个执行,不会存再并发不可控的情况

  • 相关阅读:
    hdu 5036 概率+bitset
    hdu 5037 周期优化
    hdu 5038 求出现次数最多的grade
    hdu 5040 bfs
    hdu 5045 N个人做M道题的正确率
    hdu 5046 二分+DLX模板
    hdu 5047 大数找规律
    c:set注意事项
    It is indirectly referenced from required .class files(导入项目报错原因与解决方法)
    oracle-01722,函数subtr,instr
  • 原文地址:https://www.cnblogs.com/liuju150/p/ASPNET_MVC_Redis_Lock.html
Copyright © 2011-2022 走看看