Redis分布式锁抽丝剥茧

之前码甲哥写了两篇有关线程安全的文章:

·你管这叫线程安全?·.NET八股文:线程同步技术解读

分布式锁是'线程同步'的延续

最近首度应用'分布式锁',现在想想,分布式锁不是孤立的技能点,这其实就是跨主机的线程同步

进程内 跨进程 跨主机
Lock/Monitor、SemaphoreSlim Metux、Semaphore 分布式锁
用户态线程安全 内核态线程安全

单机服务器可以通过共享某堆内存来标记上锁/解锁,线程同步说到底是建立在单机操作系统的用户态/内核态对共享内存的访问控制。

而分布式服务器不是在同一台机器上:跨主机,因此需要将锁标记存储在所有机器进程都能看到的地方。

在开发很多业务场景会使用到锁,例如库存控制,抽奖等。
例如库存只剩1个商品,有三个用户同时打算购买,谁先购买库存立即清零,不能让其他二人也购买成功。

解读分布式锁

我们常说的线程安全、线程同步方案,包括此次的分布式锁都是基于

“多线程/多进程对特定资源同时有更新操作”。

基本考量

1.分布式系统,一个锁在同一时间只能被一个服务器获取 (这是分布式锁的基础)2.具备锁失效机制,防止死锁 (防止某些意外,锁没有得到释放,别人也无法得到锁)

Redis SET resource-name anystring NX EX max-lock-time
是一种最简单的分布式锁实现方案。

SET 命令支持多个参数:

·EX seconds-- 设置过期时间(s)·NX -- 如果key不存在,则设置 ......
因为SET命令参数可以替代SETNX,SETEX,GETSET,这些命令在未来可能被废弃。

上面的命令返回OK(或经过重试),客户端就获取到这个锁;
使用DEL命令解锁;到达超时时间会自动释放锁。

在解锁时,增加一些设计,让系统更加健壮:

3.不要使用固定的String值作为锁标记值,而是使用一个不易被猜中的随机值, 业内称为token4.不使用DEL命令释放锁,而是发送script去移除key

第3、4点是为了解决 :“锁提前过期,客户端A还没有执行完,然后客户端B获取了锁,这时客户端A执行完了,会不会在删锁的时候把B的锁给删掉”            -- 4是3技术上的推荐实现。

脚本如下:

if redis.call('get',KEYS1] ==ARGV[1])then return redis.call('DEL',KEYS[1])else return 0end

下面使用StackExchange.Redis 写了基于以上考量的代码示例:

/// <summary>/// Acquires the lock./// </summary>/// <param name='key'></param>/// <param name='token'>随机值</param>/// <param name='expireSecond'></param> /// <param name='waitLockSeconds'>非阻塞锁</param>static bool Lock(string key, string token,int expireSecond=10, double waitLockSeconds = 0){    var waitIntervalMs = 50;    bool isLock;                DateTime begin = DateTime.Now;    do    {         isLock = Connection.GetDatabase().StringSet(key, token, TimeSpan.FromSeconds(expireSecond), When.NotExists);         if (isLock)             return true;             //不等待锁则返回             if (waitLockSeconds == 0) break;             //超过等待时间,则不再等待             if ((DateTime.Now - begin).TotalSeconds >= waitLockSeconds) break;             Thread.Sleep(waitIntervalMs);     } while (!isLock);     return false; }       /// <summary>  /// Releases the lock.  /// </summary>  /// <returns><c>true</c>, if lock was released, <c>false</c> otherwise.</returns>  /// <param name='key'>Key.</param>  /// <param name='value'>value</param>  static bool UnLock(string key, string value){    string lua_script = @'      if (redis.call('GET', KEYS[1]) == ARGV[1]) then           redis.call('DEL', KEYS[1])            return true            else            return false          end        ';     try     {          var res = Connection.GetDatabase().ScriptEvaluate(lua_script,                                                           new RedisKey[] { key },                                                           new RedisValue[] { value });            return (bool)res;      }     catch (Exception ex)     {          Console.WriteLine($'ReleaseLock lock fail...{ex.Message}');          return false;     }}                private static Lazy<ConnectionMultiplexer> lazyConnection = new Lazy<ConnectionMultiplexer>(() =>        {            ConfigurationOptions configuration = new ConfigurationOptions            {                AbortOnConnectFail = false,                ConnectTimeout = 5000,            };            configuration.EndPoints.Add('10.100.219.9', 6379);            return ConnectionMultiplexer.Connect(configuration.ToString());        });         public static ConnectionMultiplexer Connection => lazyConnection.Value;

以上代码新增了第五点考量:

5. 为避免无限制抢锁,增加了非阻塞锁:轮询_s等待锁,未等到则不再抢锁

使用方式:

下面并行开启三个任务,同时减少库存:

static void Main(string[] args){ // 尝试并行执行3个任务 Parallel.For(0, 3, x => { string token = $'loki:{x}'; bool isLocked = Lock('loki', token, 5, 10); if (isLocked) { Console.WriteLine($'{token} begin reduce stocks (with lock) at {DateTime.Now}.'); Thread.Sleep(1000); Console.WriteLine($'{token} release lock {UnLock('loki', token)} at {DateTime.Now}. '); } else { Console.WriteLine($'{token} begin reduce stocks at {DateTime.Now}.'); } });}

可以看到三个并行任务依次获取/释放锁

输出总结

本文从基础的线程安全、线程同步,认识到分布式锁是跨主机的资源线程/进程同步方案, 以步步为营的风格 演示了RedisSET命令做分布式锁的设计考量,好记性不如烂笔头。

(0)

相关推荐

  • Redis实现分布式文件夹锁

    缘起 最近做一个项目,类似某度云盘,另外附加定制功能,本人负责云盘相关功能实现,这个项目跟云盘不同的是,以项目为分配权限的单位,同一个项目及子目录所有有权限的用户可以同时操作所有文件,这样就很容易出现 ...

  • SpringBoot整合Redis正确的实现分布式锁的示例代码

    前言 最近在做分块上传的业务,使用到了Redis来维护上传过程中的分块编号. 每上传完成一个分块就获取一下文件的分块集合,加入新上传的编号,手动接口测试下是没有问题的,前端通过并发上传调用就出现问题了 ...

  • 基于Redis实现分布式锁

    我们知道分布式锁的特性是排他.避免死锁.高可用.分布式锁的实现可以通过数据库的乐观锁(通过版本号)或者悲观锁(通过for update).Redis的setnx()命令.Zookeeper(在某个持久 ...

  • Redis分布式锁升级版RedLock及SpringBoot实现

    分布式锁概览 在多线程的环境下,为了保证一个代码块在同一时间只能由一个线程访问,Java中我们一般可以使用synchronized语法和ReetrantLock去保证,这实际上是本地锁的方式.但是现在 ...

  • Redis分布式锁的正确实现方式

    前言 分布式锁一般有三种实现方式:1. 数据库乐观锁:2. 基于Redis的分布式锁:3. 基于ZooKeeper的分布式锁.本篇博客将介绍第二种方式,基于Redis实现分布式锁.虽然网上已经有各种介 ...

  • 应该没人比我更细了吧:带你深入剖析Redis分布式锁!

    什么是分布式锁 说到Redis,我们第一想到的功能就是可以缓存数据,除此之外,Redis因为单进程.性能高的特点,它还经常被用于做分布式锁. 锁我们都知道,在程序中的作用就是同步工具,保证共享资源在同 ...

  • 继续项目实战,集成Redis分布式锁(大神勿进)

    本文是我们小项目的第三篇文了,本次我们来把分布式锁应用到我们的项目中,使用Redis实现的分布式锁功能,这一切都是为我们往后的工作做铺垫,希望大家能get到分布式锁这项新技能. 第一篇:Spring ...

  • 七种方案!探讨Redis分布式锁的正确使用姿势

    前言 日常开发中,秒杀下单.抢红包等等业务场景,都需要用到分布式锁.而Redis非常适合作为分布式锁使用.本文将分七个方案展开,跟大家探讨Redis分布式锁的正确使用方式.如果有不正确的地方,欢迎大家 ...

  • Redis 分布式锁使用不当,酿成一个重大事故,超卖了100瓶飞天茅台!!!

    回复"Java"获取面试宝典 基于Redis使用分布式锁在当今已经不是什么新鲜事了. 本篇文章主要是基于我们实际项目中因为redis分布式锁造成的事故分析及解决方案.我们项目中的抢 ...

  • 细说Redis分布式锁

    谈起Redis锁,下面三个,算是出现最多的高频词汇: Setnx Redlock Redisson Setnx 其实目前通常所说的Setnx命令,并非单指Redis的setnx key value这条 ...

  • Redis实现分布式锁

    一.redis分布式锁的简易实现 用redis实现分布式锁是一个老生常谈的问题了.因为redis单条命令执行的原子性和高性能,当多个客户端执行setnx(相同key)时,最多只有一个获得成功.因此在对 ...

  • 从入门到精通-Redis,图文并茂、分布式锁、主从复制、哨兵机制、Cluster集群、缓存击穿、缓存雪崩、持久化方案、缓存淘汰策略 附案例源码

    导读 篇幅较长,干货十足,阅读需要花点时间,全部手打出来的字,难免出现错别字,敬请谅解.珍惜原创,转载请注明出处,谢谢~! 学习之前,先附上一张知识脑图,百度上找哒~~~ NoSql介绍与Redis介 ...