C# Redis分布式锁 - 单节点

为什么要用分布式锁?
先上一张截图,这是在浏览别人的博客时看到的.
文章插图
在了解为什么要用分布式锁之前,我们应该知道到底什么是分布式锁.
锁按照不同的维度,有多种分类.比如
1.悲观锁,乐观锁;
2.公平锁,非公平锁;
3.独享锁,共享锁;
4.线程锁,进程锁;
等等.
我们平时用的锁,比如 lock,它是线程锁,主要用来给方法,代码块加锁.由于进程的内存单元是被其所有线程共享的,所以线程锁控制的实际是多个线程对同一块内存区域的访问.
有线程锁,就必然有进程锁.顾名思义,进程锁的目的是控制多个进程对共享资源的访问.因为进程之间彼此独立,各个进程是无法控制其他进程对资源的访问,所以只能通过操作系统来控制.比如 Mutex.
但是进程锁有一个前提,那就是需要多个进程在同一个系统中,如果多个进程不在同一个系统,那就只能使用分布式锁来控制了.
分布式锁是控制分布式系统中不同系统之间访问共享资源的一种锁实现.它和线程锁,进程锁的作用都是一样,只是范围不一样.
所以要实现分布式锁,就必须依靠第三方存储介质来存储锁的信息.因为各个进程之间彼此谁都不服谁,只能找一个带头大哥咯;
以下示例需引用NUGET: CSRedisCore
示例一
文章插图
CSRedisClient redisClient = new CSRedis.CSRedisClient("127.0.0.1:6379,defaultDatabase=0");var lockKey = "lockKey";var stock = 5;//商品库存var taskCount = 10;//线程数量redisClient.Del(lockKey);//测试前,先把锁删了.for (int i = 0; i < taskCount; i++){Task.Run(() =>{//获取锁do{//setnx : key不存在才会成功,存在则失败.var success = redisClient.SetNx(lockKey, 1);if (success == true){break;}Thread.Sleep(TimeSpan.FromSeconds(1));//休息1秒再尝试获取锁} while (true);Console.WriteLine($"线程:{Task.CurrentId} 拿到了锁,开始消费");if (stock <= 0){Console.WriteLine($"库存不足,线程:{Task.CurrentId} 抢购失败!");redisClient.Del(lockKey);return;}stock--;//模拟处理业务Thread.Sleep(TimeSpan.FromSeconds(new Random().Next(1, 3)));Console.WriteLine($"线程:{Task.CurrentId} 消费完毕!剩余 {stock} 个");//业务处理完后,释放锁.redisClient.Del(lockKey);});}
文章插图
运行结果:
文章插图
看起来貌似没毛病,实际上上述代码有个致命的问题:
当某个线程拿到锁之后,如果系统崩溃了,那么锁永远都不会被释放.因此,我们应该给锁加一个过期时间,当时间到了,还没有被主动释放,我们就让redis释放掉它,以保证其他消费者可以拿到锁,进行消费.
这里给锁加过期时间也有讲究,不能拿到锁后再加,比如:
文章插图
......//setnx : key不存在才会成功,存在则失败.var success = redisClient.SetNx(lockKey, 1);if (success == true){redisClient.Set(lockKey, 1, expireSeconds: 5);break;}
文章插图
这样操作的话,获取锁和设置锁的过期时间就不是原子操作,同样会出现上面提到的问题.Redis 提供了一个合而为一的操作可以解决这个问题.