x

StackExchange.Redis

private readonly IDatabase _db;

string key = string.Concat("{自己命名的Redis前缀}", task.TaskDetailsId);
//获取本机服务器IP地址
string valIp = GetLocalIP();
//Redis缓存中的IP地址,
var valIpRedis = _db.StringGet(redisKey);

            /*
             * 方案1.每次都获取锁(redis.LockTake),而不去判断缓存中的值(valIpRedis)
             * 方案2.每次先判断缓存中的值(valIpRedis),没有缓存再去获取锁.
             * 目前采用的是方案2.
             *
             *      如果以后执行周期和缓存过期时间发生改变可能存在的风险:
             *      1.方案1风险:如果设置的过期时间比执行周期长,服务器都获取不到锁了,任务这次就不会执行,只能等到缓存清除之后才可以获取到锁.(例如:过期时间24H,执行周期1H,那么24H内,只会执行1次)
             *      2.方案2风险:服务器A刚获取完缓存的IP地址,就过期了,而服务器B此时也刚好获取到了锁.就会执行两次.(例如:过期时间1H,执行周期1H,那么1H内,可能会执行2次)
             */
            if (valIpRedis != null && valIpRedis == valIp)
            {
                isCanRun = true;
            }
            //如果Redis中没有缓存,去获取锁,获取成功,即可执行...
            else if (redis.LockTake(key, valIp, TimeSpan.FromMilliseconds(taskExpiry)))
            {
                isCanRun = true;
            }
            if (isCanRun)
       {

                    //记录日志{XX任务开始执行,服务器IP地址为xx.xx.xx.xx}
                    //开始执行各个定时任务{Quartz}
                    ((ITask)Activator.CreateInstance(Type.GetType("Your Class Type"))).Execute(task);

       }

传送门

C#通过Redis实现分布式锁

x

原文地址：https://www.cnblogs.com/love-zf/p/11260492.html