3万字聊聊什么是Redis(七)

本文涉及的产品
云数据库 Redis 版,社区版 2GB
推荐场景:
搭建游戏排行榜
简介: 继上篇Redis技术总结六,我们继续聊聊Redis的相关技术!

Redis如何应对并发


我们使用Redis时,一定会遇到并发访问问题,比如我最近一直常遇到的电商项目。在进行修改库存时,控制不好就会出现库存不正确的情况。

为了保证数据的正确性,Redis提供了两种方法

  • 加锁
  • 原子操作

加锁

加锁是我们在解决并发访问时,最先接触,也是最简单的一种操作,客户端需要先获得锁,否则就无法进行操作,当一个客户端获得该锁后,其他客户端就无法进行更新数据操作。只有客户端释放锁后,另一个客户端才能拿到这把锁更新操作。

上述方案主要有两个问题:

  1. 每次操作只允许一个用户也就是只允许一个客户端进行操作。极大的降低了性能的并发访问性能。
  2. Redis锁必须用分布式锁。而分布式锁实现复杂,需要用额外的存储系统来提供加解锁操作

原子操作

原子操作是另一种提供并发访问控制的方法。原子操作是指执行过程保持原子性的操作,而且原子操作执行时并不需要再加锁,实现了无锁操作。这样一来,既能保证并发控制,还能减少对系统并发性能的影响。

原子操作主要分两种

  • Redis单命令操作,可以说是原子操作
  • 多个命令写入Lua脚本,比原子性的方式执行单个Lua脚本

Redis单命令操作,我们可以理解成电商项目的修改库存,从读取到修改到写入。一气呵成!采用一个命令实现,我们可以使用 INCR/DECR 命令。

Redis的Lua脚本,是在我们无法使用单命令实现需求时,同时也要保证并发控制时的一种方案。比如使用的判断一些的写法就必须采用Lua脚本实现。


Redis的分布式锁

聊到分布式锁的实现,我们可以先来看看单机锁吧。

对于在单机上运行的多线程程序来说,锁本身可以用一个变量表示。

  • 变量值为 0 时,表示没有线程获取锁;
  • 变量值为 1 时,表示已经有线程获取到锁了。

我们保证数据不被其他访问修改时,底层的实现就是判断访问时拿到的这个变量与修改时的变量是否是一致的。如果是一致的就说明数据可以修改,如果不是一致的说明有线程先行一步把这个值改动了。那如果再动的话数据肯定就错了。

科普一下MySQL,MySQL里利用的是每条数据的版本号来判断的。

分布式锁也是同样的原理实现的。加锁和释放锁的逻辑和单机锁是一样的。加锁时同样需要判断锁变量的值,根据锁变量值来判断能否加锁成功;释放锁时需要把锁变量值设置为 0,表明客户端不再持有锁。

和单机锁不同的事,分布式的锁必须由一个共享的存储系统来维护。只有这样,多个客户端才可以通过访问共享存储系统来访问锁变量。相应的,加锁和释放锁的操作就变成了读取、判断和设置共享存储系统中的锁变量值。

实现分布式锁需要注意哪些要求

  1. 加锁与释放锁的过程涉及多个操作,一定要保证原子性
  2. 利用共享存储系统保存锁变量时,如果共享存储系统发生宕机如何处理?我们需要保证共享存储系统的可靠性。

单个节点

Redis可以采用键值对保存锁变量,再接收和处理不同客户端发送的加锁和释放锁的操作请求。

我们一点一点分析一下,键值对又是如何处理的呢?

我们要赋予锁变量一个变量名,把这个变量名作为键值对的键,而锁变量的值,则是键值对的值,这样一来,Redis 就能保存锁变量了,客户端也就可以通过 Redis 的命令操作来实现锁操作。为了便于理解,如下图所示(引用蒋德均老师)

image.png

加锁之后如果要释放锁的话,就是把变量的value值变成0。

看似没有问题,其实还是有问题的。问题就出在 读取锁变量如何保证原子性?

我们之前聊过一个是单命令执行,另一种是Lua脚本执行。这个场景我们依然可以这样处理

  1. 通过使用Redis提供的SETNX 命令(这个命令在执行时会判断键值对是否存在,如果不存在,就设置键值对的值,如果存在,就不做任何设置)
  2. 通过Lua脚本判断处理

用户在执行完加锁操作后,需要释放锁,释放锁就是把value标志为0。可以采用SETNXDEL 命令组合来实现加锁和释放锁操作。下面贴一下伪代码方便大家理解下。

// 加锁
SETNX huanshao_lock_key 1
// 业务处理(库存,用户积分,订单号等)
DO THINGS
// 释放锁
DEL huanshao_lock_key

有何风险?

  1. 假如某个客户端在执行了 SETNX 命令、加锁之后,紧接着却在操作共享数据时发生了异常,结果一直没有执行最后的 DEL 命令释放锁。因此,锁就一直被这个客户端持有,其它客户端无法拿到锁,也无法访问共享数据和执行后续操作,这会给业务应用带来影响。
  2. 如果客户端 A 执行了 SETNX 命令加锁后,假设客户端 B 执行了 DEL 命令释放锁,此时,客户端 A 的锁就被误释放了。如果客户端 C 正好也在申请加锁,就可以成功获得锁,进而开始操作共享数据。这样一来,客户端 A 和 C 同时在对共享数据进行操作,数据就会被修改错误,这也是业务层不能接受的

如何解决?

  1. 可以通过给锁设置过期时间,就算是共享存储系统崩溃了,或者异常了这个锁再一段时间后就会自动释放了。
  2. 我们需要能区分来自不同客户端的锁操作,我们可以给不同客户端设置一个唯一值,在释放锁操作时,客户端需要判断,当前锁变量的值是否和自己的唯一标识相等,只有在相等的情况下,才能释放锁。这样一来,就不会出现误释放锁的问题了

可以通过如下指令进行设置

// 加锁, unique_value作为客户端唯一性的标识  
// [EX seconds 分钟 | PX milliseconds 秒钟 ]
SET huanshao_lock_key unique_value NX PX 10000

我们刚刚在说 SETNX 命令的时候提到,对于不存在的键值对,它会先创建再设置值(也就是“不存在即设置”),为了能达到和 SETNX 命令一样的效果,Redis 给 SET 命令提供了类似的选项 NX,用来实现“不存在即设置”。如果使用了 NX 选项,SET 命令只有在键值对不存在时,才会进行设置,否则不做赋值操作。此外,SET 命令在执行时还可以带上 EX 或 PX 选项,用来设置键值对的过期时间。

释放锁时,不能再像之前那样简简单单的DEL就删了,需要判断当前是否是自己的锁,伪代码如下

//释放锁 比较unique_value是否相等,避免误释放
//KEYS[1]表示 huanshao_lock_key,ARGV[1]是当前客户端的唯一标识
//这两个也是调用Lua脚本时,必传的两个参数
if redis.call("get",KEYS[1]) == ARGV[1] then
    return redis.call("del",KEYS[1])
else
    return 0
end

如果采用这种方式的话,为了保证原子性肯定要上Lua脚本了。


多个节点

多节点的话和单节点差不多,但是有个很大的区别就是不能依赖单个命令操作了。我们需要按照一定的步骤和规则进行加解锁操作,否则,就可能会出现锁无法工作的情况。 分布式锁的算法

Redis采用的分布式锁算法是 Redlock。基本实现思路是让客户端和多个独立的 Redis 实例依次请求加锁,如果客户端能够和半数以上的实例成功地完成加锁操作,那么我们就认为,客户端成功地获得分布式锁了,否则加锁失败。这样一来,即使有单个 Redis 实例发生故障,因为锁变量在其它实例上也有保存,所以,客户端仍然可以正常地进行锁操作,锁变量并不会丢失

我们来具体看下 Redlock 算法的执行步骤。Redlock 算法的实现需要有 N 个独立的 Redis 实例。接下来,我们可以分成 3 步来完成加锁操作。

  1. 客户端获取当前时间。
  2. 客户端按顺序依次向 N 个 Redis 实例执行加锁操作。
  3. 一旦客户端完成了和所有 Redis 实例的加锁操作,客户端就要计算整个加锁过程的总耗时。

第二步 加锁操作和在单实例上执行的加锁操作一样,使用 SET 命令,带上 NX,EX/PX 选项,以及带上客户端的唯一标识。当然,如果某个 Redis 实例发生故障了,为了保证在这种情况下,Redlock 算法能够继续运行,我们需要给加锁操作设置一个超时时间。

如果客户端在和一个 Redis 实例请求加锁时,一直到超时都没有成功,那么此时,客户端会和下一个 Redis 实例继续请求加锁。加锁操作的超时时间需要远远地小于锁的有效时间,一般也就是设置为几十毫秒。

第三步 客户端只有在满足下面的这两个条件时,才能认为是加锁成功。

  1. 客户端从超过半数(大于等于 N/2+1)的 Redis 实例上成功获取到了锁
  2. 客户端获取锁的总耗时没有超过锁的有效时间。

在满足了这两个条件后,我们需要重新计算这把锁的有效时间,计算的结果是锁的最初有效时间减去客户端为获取锁的总耗时。如果锁的有效时间已经来不及完成共享数据的操作了,我们可以释放锁,以免出现还没完成数据操作,锁就过期了的情况。

当然,如果客户端在和所有实例执行完加锁操作后,没能同时满足这两个条件,那么,客户端向所有 Redis 节点发起释放锁的操作。

在 Redlock 算法中,释放锁的操作和在单实例上释放锁的操作一样,只要执行释放锁的 Lua 脚本就可以了。这样一来,只要 N 个 Redis 实例中的半数以上实例能正常工作,就能保证分布式锁的正常工作了。

所以,在实际的业务应用中,如果你想要提升分布式锁的可靠性,就可以通过 Redlock 算法来实现。


结尾


大概总结了Redis在处理并发访问时,如果不采取措施在进行读写,修改,写会时会有数据错误。我们要保证临界区(执行的代码)代码的互斥性。

根据暴露的问题提供了两种方案。加锁和原子操作。根据原子操作慢慢了转向了Lua脚本的必要性。

接下来又介绍了Redis分布式锁的实现。从单节点,多节点分别进行的介绍。

单节点中,通过把变量保存在键值对上,并且加上过期时间,防止共享存储系统发生宕机影响整个业务系统。

使用完后进行释放时,涉及到了DEL命令以及多个命令执行时,介绍了Lua脚本。

还有一点就是多个客户端释放锁时,有可能并发导致释放的不是自己的锁导致数据错误,采用了客户端唯一标识进行判断释放。(Lua脚本内操作的)

多节点中,通过借助共享存储系统进行锁的分配管理。基于单个 Redis 实例实现分布式锁时,会面临实例异常或崩溃的情况,这会导致实例无法提供锁操作于是展开介绍了Redlock算法。


相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
存储 消息中间件 NoSQL
redis入门到精通系列(一):入门redis看这一篇就够了
如果你是计算机专业学生 ,那么一定使用过关系型数据库mysql。在请求量小的情况下,使用mysql不会有任何问题,但是一旦同时有成千上万个请求同时来访问系统时,就会出现卡顿甚至系统崩溃的情况。最典型的例子就是早期的12306购票网站,一旦到了购票高峰期,12306肯定崩溃。造成这个原因的罪魁祸首就是关系型数据库。
1509 0
redis入门到精通系列(一):入门redis看这一篇就够了
|
3月前
|
存储 NoSQL Redis
redis入门学习
redis入门学习
26 0
|
3月前
|
NoSQL 网络安全 Redis
Redis进阶-Redis使用建议一二事
Redis进阶-Redis使用建议一二事
18 0
|
4月前
|
存储 NoSQL Linux
【Redis入门】 —— 关于Redis的一点儿知识
【Redis入门】 —— 关于Redis的一点儿知识
|
9月前
|
存储 XML NoSQL
Redis从入门到实战(一、Redis简介)
Redis从入门到实战(一、Redis简介)
110 0
|
11月前
|
SQL 缓存 NoSQL
Redis学习记录
Redis学习记录
70 0
|
存储 SQL NoSQL
Redis学习笔记( 入门篇)
Redis学习笔记( 入门篇)
170 0
Redis学习笔记( 入门篇)
|
存储 NoSQL 算法
万字详解Redis技术
Redis(Remote Dictionary Server)是一个开源的使用 ANSI C 标准(c语言)编写、支持网络、可基于内存亦可持久化、Key-Value 类型的非关系型数据库,并提供多种语言的 API. 本文干活满满~~~
万字详解Redis技术
|
NoSQL MongoDB Redis
redis学习记录
学习redis的记录
|
缓存 监控 NoSQL
3万字聊聊什么是Redis(二)
继上篇Redis技术总结一,我们继续聊聊Redis的相关技术!
3万字聊聊什么是Redis(二)