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 时听到较多的一个词语&…

LBS解决方案

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

长沙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…

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

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

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

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

互联网10年,激战如梦

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

网络编程-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;微软已战略转…

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

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

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

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

想基于K8s按需扩展应用程序,可从这几方面入手

马修赫瑟&#xff08;Matthew Heusser&#xff09;在花费了十年时间进行编程&#xff0c;测试和项目管理之后&#xff0c;Matt Heusser于2011年创立了自己的公司Excelon Development。该协会前董事会成员Matt还是软件测试人员&#xff0c;是德国波茨坦最具影响力的敏捷测试专业…

windows环境下ELK平台搭建

背景 日志系统主要包括系统日志&#xff0c;应用程序日志和安全日志。系统运维和开发人员可以通过日志了解服务器的软件&#xff0c;硬件信息&#xff0c;检查配置过程中的错误以及错误发生的原因。通常分析日志可以了解服务器的负荷&#xff0c;性能安全性&#xff0c;从而及时…

EntityFramework Core 3.x上下文构造函数可以注入实例呢?

今天讨论的话题来自一位微信好友遇到问题后请求我的帮助&#xff0c;当然他的意图并不是本文标题&#xff0c;只是我将其根本原因进行了一个概括&#xff0c;接下来我们一起来探索标题的问号最终的答案是怎样的呢&#xff1f;老规矩&#xff0c;首先我们定义如下上下文public c…

SpringCloud常见问题总结(一)

Eureka常见问题 Eureka注册服务慢 默认情况&#xff0c;服务注册到Eureka Server 的过程比较慢。在开发或者测试时候&#xff0c;如果能够加速注册的过程&#xff0c;从而提升工作效率。Spring Cloud官方文档详细描述了该问题的原因并提供了解决方案&#xff1a; //原文 Why…

[剑指offer]面试题21:包含min函数的栈

面试题21&#xff1a;包含min函数的栈 题目&#xff1a;定义栈的数据结构&#xff0c;请在该类型中实现一个能够得到栈的最小元素的min函数。在该栈中&#xff0c;调用min、push及pop的时间复杂度都是O&#xff08;1&#xff09;。 栈内压入3、4、2、1之后接连两次弹出栈顶数字…

IO 模型知多少

1. 引言同步异步I/O&#xff0c;阻塞非阻塞I/O是程序员老生常谈的话题了&#xff0c;也是自己一直以来懵懵懂懂的一个话题。比如&#xff1a;何为同步异步&#xff1f;何为阻塞与非阻塞&#xff1f;二者的区别在哪里&#xff1f;阻塞在何处&#xff1f;为什么会有多种IO模型&am…

[剑指offer]面试题22:栈的压入、弹出序列

面试题22&#xff1a;栈的压入、弹出序列 题目&#xff1a;输入两个整数序列&#xff0c;第一个序列表示栈的压入顺序&#xff0c;请判断第二个序列是否为该栈的弹出顺序。假设压入栈的所有数字均不相等。例如序列1、2、3、4、5 是某栈的压栈序列&#xff0c;序列4、5、3、2、1…