为什么要用分布式锁?
先上一张截图,这是在浏览别人的博客时看到的.
在了解为什么要用分布式锁之前,我们应该知道到底什么是分布式锁.
锁按照不同的维度,有多种分类.比如
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); }); }