Redis分布式锁奥义

分布式锁

  • 分布式系统进行逻辑处理的时候,经常会遇到并发问题,例如直播场景中,用户需要连麦主播,当多个用户在同一个时刻一起连麦时候,应该保证只有一个用户能连麦成功,我们改怎么保证这种业务场景下保证数据的正确性。
  • 当我们连麦的时候,其实设计到两个步骤操作,首先读取房间座位信息,当发现座位没有被占用,修改作为状态,之后存储。但是这几个步骤并非原子操作,也就是可能存在两个线程同时读取,一起修改,这样肯定会造成数据错乱。怎样来保证读取,修改,存储,这三个步骤的原子操作就是分布式锁需要解决的问题。

分布式锁的奥义

  • 分布式锁本质上实现就是在Redis中占用一个key值,当别的进程也要来占用这个key时候,发现已经存在这个key,就只能放弃,或者等待key消失。我们一般使用setnx(set if not exists) 命令,只允许被一个客户占用,先到先得,在用del删除key,释放key占用给别的线程
  • 存在的问题,比如逻辑执行期间,出现异常,导致del指令无法执行,占用会陷入死锁,永远不能得到释放,这个问题可以通过过期时间解决,我们在设置key时候添加一个过期时间,这样中介出现异常,5s后也会自动释放如下:
新docker-redis:0>setnx lock 3
"1"
新docker-redis:0>expire lock 5
"1"
  • 新的问题, setnx 与expire两个指令并非原子操作,在两个指令执行间隔期间挂机,那么还是会死锁。如果可以一起执行就不会出现这种问题,可能Redis事务来解决问题,但是这种业务场景下不下,因为expire必须在前面setnx成功的前提条件才能够执行,当setnx没有获取锁,expire是不能执行的,此时同一个事务中这两个命令会出现一个成功一个失败,与预期不符合。
  • 为解决此问题,Redis2.8 版本后引入了一个新的指令,是的setnx和expire指令能一起执行,彻底解决分布式锁的问题,从此后,所有第三方锁都可以舍弃了,如下:
新docker-redis:0>set lock true ex 5 nx
"OK"
新docker-redis:0>set lock true ex 5 nx
null
  • 以上指令setnx和expire的组合一起的原子指令,他就是分布式锁解决的奥义。

还有超时问题

  • Redis分布式锁还是解决不了某种超时,比如,我设置5s,但是业务太垃圾了执行了6秒,以至于超过了锁的限制,那么问题出现了。锁以释放,剩余逻辑无法得到保护,第二个线程重新持有锁,然后第一个还没执行完的线程现在执行完了,给你吧key删了,这样是不是很刺激。
  • 为避免这个问题,Redis分布式锁不要用着长时间的任务,如果偶尔出现问题,造成的数据小错误就人肉解决吧。
  • 另外还有一个小的技巧来规避这种删除问题,我们利用value造一个乐观锁,我们在set value的时候设置本轮次逻辑的一个特殊的value值,当我们执行完逻辑后,在删除之前先确认一下value是否本轮次的value,如果不是表示非本轮次,不执行删除,如果是当前value,则删除。
  • 问题又来了,匹配value,删除key,又不是原子操作,Redis也没有类似的delifequals的指令,但是Redis4.0 后提供了lua脚本的支持,因为lua脚本可以保证连续多个指令的原子性执行
  • 这并非完美解决方案,还是有部分逻辑在裸奔,那么我们尽量规避吧,还有就是这么长逻辑,应该想到的是优化。
Redis分布式锁失效情况
  • 在Redis集群中,我们分布式锁是有一定缺陷的,例如在哨兵模式集群中,主节点挂掉,从节点会取而代之,这对客户端是无感知的,比如,客户端A主节点上申请lock,但是这把锁还没同步到Slave节点,主节点挂掉,之后从节点变主节点,B客户端在申请lock,同样成功,这样就存在两把锁,违背了分布式锁的初衷。不安全性由此产生。
    在这里插入图片描述
  • 以上情况在理论上是完全有可能发生的,但是也仅仅只是在主从发生failover的情况下才产生,而且持续时间比较短,业务系统多试情况下是可以容忍的。所以我吗业务中一般会忽略这种极端的情况。
Redlock算法
  • 遇到问题,解决问题,以上出现的极端情况也是有解决方案的,她流产比较复杂,但是有很多开源的libray已经做了良好的封装,用户之间用即可,例如Python中redlock-py
import redlock
addres=[{"host":"localhost","port":6789,"db":0
},{"host":"localhost","port":6789,"db":0
},{"host":"localhost","port":6789,"db":0
}]
dlm = redlock.Redlock(addrs)
success = dlm.lock("lock-liaojiamin", 5000)
if success:print 'lock success'dlm.unlock('lock-liaojiamin')
else:print 'ock failed'
  • 为了使用Redlock,需要提供多个Redis实例,这些实例之间相互独立,没有主从关系。通很多分布式算法一样,Redlock用大多数机制。
    • 加锁时候向过半节点发送set(key, value, nx=True, ex=xxx)指令,只要过半节点set成功,就认为加锁成功
    • 释放锁需要想所有节点发送del指令
    • Redlock需要想多个节点进行读写,意味着相比单实例Redis的性能会下降。
Redlock使用场景
  • 业务室对高可用性有苛刻的要求,希望一台Redis挂了也完全不受影响,就应该考虑用Redlock
  • 代价是需要更多的Redis实例,性能也下降,代码删还需引入额外的library,运维上也需要特殊对待,这些都是成本。

上一篇:Redis流量控制策略
下一篇:LBS解决方案

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/news/310577.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

.NET Core + Kubernetes:Pod

在 .NET Core Kubernetes:快速体验 文章中,已经实现将一个 .NET Core API 服务部署在 Kubernetes 集群中,接下来将逐步了解 Kubernetes 中各核心模块。首先当然是 Pod,我相信 Pod 是在接触 Kubernetes 时听到较多的一个词语&…

[剑指offer]面试题10:二进制中1的个数

面试题10:二进制中1的个数 题目:请实现一个函数,输入一个整数,输出该数二进制表示中 1 的个数。例如把9表示成二进制是1001,有2位是1。因此如果输入9,该函数输出2。 ❖ 可能引起死循环的解法 代码如下: …

LBS解决方案

LBS解决方案 LBS(基于地理位置的服务)服务是现在移动互联网中比较常用的功能,例如外卖中我附近的店铺,通常是以客户位置坐标为中心,查询一定范围内的店铺信息,按照距离由近及原进行倒叙排序 方案一&#…

[剑指offer]面试题13:在O(1)时间删除链表结点

面试题13:在O(1)时间删除链表结点 题目:给定单向链表的头指针和一个结点指针,定义一个函数在 O(1)时间删除该结点。链表结点与函数的定义如下: struct ListNode {int value;ListNod…

长沙IT技术圈百万年薪大佬?是否存在?

作者:邹溪源,长沙资深互联网从业者,架构师社区特邀嘉宾!01引子不知不觉,IT技术圈开始流传起“百万年薪”的故事,有人问我,长沙有百万大佬么?其实我也不知道。02背景长沙自古以来就是…

网络编程-网络分层的意义

网络 我们生活在一个网络无处不在的一个虚拟世界中,网络中的每一个设备都是一个节点。大多是我们的计算机,但是他还可以连接其他设备,例如打印机,路由器,网关,你的手机,智能家居等。我们可以使…

网络编程-TCP/IP协议栈-IP协议

协议 协议就是约定的一种规则&#xff0c;例如扑克游戏中约定好的各种规则&#xff0c;2<3<4<5<…等&#xff0c;以此作为游戏规则。当所有人都遵循这个规则&#xff0c;那么久可以不需要任何多余的交流就可以进行游戏&#xff0c;这个方式形成的约定就是一种协议…

.NET项目升级手记:可为空引用

c# 8引入了新特性&#xff1a;“可为空引用”&#xff08;详情&#xff09;&#xff0c;这个功能个人觉得挺好的&#xff0c;能够非常明确的表现程序设计者的意图&#xff0c;编译器能够进行检查&#xff0c;尽最大可能减小NullReferenceException错误。如果是新项目&#xff0…

[剑指offer]面试题15:链表中倒数第k个结点

面试题15&#xff1a;链表中倒数第k个结点 题目&#xff1a;输入一个链表&#xff0c;输出该链表中倒数第 k 个结点。为了符合大多数人的习惯&#xff0c;本题从1 开始计数&#xff0c;即链表的尾结点是倒数第1 个结点。例如一个链表有6个结点&#xff0c;从头结点开始它们的值…

.NET与鲲鹏共展翅,昇腾九万里(一)

2019年1月7日&#xff0c;华为推出鲲鹏920处理器&#xff0c;便宣告了构建鲲鹏生态系统的开始。据官方介绍&#xff0c;鲲鹏是一个包含了鲲鹏计算单元、AI处理单元、智能管理、智能网卡的片上系统SoC&#xff0c;在此之上加上服务器操作系统&#xff0c;从而形成一个生态的闭环…

#define与const的区别

一:区别 &#xff08;1&#xff09;就起作用的阶段而言&#xff1a; #define是在编译的预处理阶段起作用&#xff0c;而const是在 编译、运行的时候起作用。 &#xff08;2&#xff09;就起作用的方式而言&#xff1a; #define只是简单的字符串替换&#xff0c;没有类型检查。…

网络编程-TCP/IP协议栈-TCP协议

TCP协议 TCP协议作用 TCP协议位于协议栈的传输层。当应用层向TCP层发送用于网间传输的&#xff0c;用8字节表示的数据流&#xff0c;TCP则吧数据流分割成适当长度的报文段&#xff0c;最大传输段大小&#xff08;MSS&#xff09;通常受到改计算机连接的网络数据链路层的最大传…

互联网10年,激战如梦

— 1 —1969年&#xff0c;美国国防部研究计划署第一次将互联网应用于军事连接。随后美国西南部四所名校的四台计算机通过这项技术连接起来。谁也没想到&#xff0c;这项计划会对人类的命运产生如此重大影响。1993年&#xff0c;互联网真正诞生。美国白宫宣布开始提供「在线服务…

[剑指offer]面试题16:反转链表

面试题16&#xff1a;反转链表 题目&#xff1a;定义一个函数&#xff0c;输入一个链表的头结点&#xff0c;反转该链表并输出反转后链表的头结点。链表结点定义如下&#xff1a; struct ListNode {int value;ListNode *next; };代码如下: ListNode *ReverseList(ListNode *p…

网络编程-TCP/IP协议栈-UDP/HTTP协议

UDP协议 UDP协议全称是用户数据报协议&#xff0c;在网络中她与TCP协议一样用于处理数据包&#xff0c;两个协议同处于协议栈的传输层&#xff0c;和TCP不同的是&#xff0c;UDP是一种无连接的协议栈。 因为UDP是无连接的&#xff0c;所以相对来说&#xff0c;UDP的报头比TCP要…

十问十答 Ms-PL 许可证

Microsoft 公共许可证&#xff08;The Microsoft Public License&#xff09;是微软为释出开源项目而编写和发布的自由开源软件许可证。如果你用 .NET 开发&#xff0c;你会经常碰见 Ms-PL。在微软的自由开源项目托管地 Codeplex&#xff08;已寿终正寝&#xff0c;微软已战略转…

[剑指offer]面试题17:合并两个排序的链表

面试题17&#xff1a;合并两个排序的链表 题目&#xff1a;输入两个递增排序的链表&#xff0c;合并这两个链表并使新链表中的结点仍然是按照递增排序的。例如输入图3.7中的链表1和链表2&#xff0c;则合并之后的升序链表如链表3所示。链表结点定义如下&#xff1a; struct Li…

网络编程-HTTPS协议的实现原理

HTTP传输协议缺点 之前几篇文章中详细讲解了TCP/IP协议栈中的几个协议&#xff0c;其中个就有对HTTP做了一个比较详细的讲解。HTTP是基于TCP进行传输的&#xff0c;其中传输的内容都是明文报文数据&#xff0c;如果我是一个黑客&#xff0c;我会想办法获取这个HTTP消息体&…

从案例角度解析建模平台动态规则引擎

源宝导读&#xff1a;明源云ERP建模平台提供了强大的页面联动规则引擎&#xff0c;原来需要编写代码完成的联动控制逻辑&#xff0c;现在只需要点点鼠标&#xff0c;通过配置完成。本文从实际案例的角度出发&#xff0c;介绍原始的代码逻辑如何转化为引擎规则的过程。一、背景明…

[剑指offer]面试题18:树的子结构

面试题18&#xff1a;树的子结构 题目&#xff1a;输入两棵二叉树A和B&#xff0c;判断B是不是A的子结构。二叉树结点的定义如下&#xff1a; struct BinaryTreeNode {int value;BinaryTreeNode *lchild;BinaryTreeNode *rchild; };代码如下: bool HasSubtree(BinaryTreeNode…