Transaction in Redis

冰岩作坊 March 2, 2022

Abstract

为啥要取abstract,可能是因为最近看论文有点PTSD了

Redis通过MULTI、EXEC、WATCH等命令来实现事务功能。事务提供了一种将多个命令请求打包,然后一次性、按顺序地执行多个命令的机制,并且在事务执行期间,服务器不会中断事务而改去执行其他客户端的命令请求,它会将事务中的所有命令都执行完毕,然后才去处理其他客户端的命令请求

事务的实现

一个事务从开始到结束通常会经历以下三个阶段:

事务开始

MULTI命令的执行标志着事务的开始

将执行该命令的客户端从非事务状态切换至事务状态,这一切换是通过在客户端状态的flags属性中打开REDIS_MULTI标识来完成的

这里的客户端指的是在Redis服务器中存着客户端状态的数据结构

命令入队

当一个客户端处于非事务状态时,这个客户端发送的命令会立即被服务器执行

但是,当一个客户端切换到事务状态之后,服务器会根据这个客户端发来的不同命令执行不同的操作

事务队列

每个Redis客户端都有自己的事务状态,这个事务状态保存在客户端状态的mstate属性里面

事务状态包含一个FIFO的事务队列,以及一个已入队命令的计数器,也就是事务队列的长度

事务队列是一个multiCmd类型的数组,数组中的每个multiCmd结构都保存了一个已入队命令的相关信息,包括指向命令实现函数的指针、命令的参数,以及参数的数量

1
typedef struct redisClient  redisClient;typedef struct multiState  multiState;typedef struct multiCmd  multiCmd;

执行事务

当一个处于事务状态的客户端向服务器发送EXEC命令时,这个EXEC命令将立即被服务器执行。服务器会遍历这个客户端的事务队列,执行队列中保存的所有命令,最后将执行命令所得的结果全部返回给客户端

WATCH命令的实现

WATCH命令是一个乐观锁,他可以在EXEC命令执行之前,监视任意数量的数据库键,并在EXEC命令执行时,检查被监视的键是否至少有一个已经被修改过了,如果是的话,服务器将拒绝执行事务,并向客户端返回代表事务执行失败的空回复

接下来介绍下WATCH命令的实现原理,以及事务系统如何监视某个键,并在键被修改的情况下,确保事务的安全性

使用WATCH命令监视数据库键

每个Redis数据库都保存着一个watched_keys字典,这个字典的键是某个被WATCH命令监视的数据库键,字典的值则是一个链表,链表中记录了所有监视相应数据库键的客户端

通过这个字典,服务器可以清楚的知道哪些数据库键正在被监视,以及哪些客户端正在监视这些数据库键

监视机制的触发

所有对数据库进行修改的命令,在执行后都会调用相应的函数对watched_keys字典进行检查,查看是否有客户端正在监视刚刚被命令修改过的数据库键,如果有的话,那么这个函数就会将监视被修改键的客户端的REDIS_DIRTY_CAS标识打开,表示该客户端的事务安全性已经被破坏

判断事务是否安全

当服务器接收到一个客户端发来的EXEC命令时,服务器会根据这个客户端是否打开了REDIS_DIRTY_CAS标识来决定是否执行事务。如果这个标识没有被打开,就执行客户端提交的这个事务

事务的ACID性质

传统的关系数据库中,常常用ACID性质来校验事务功能的可靠性和安全性

在Redis中,事务总是具有原子性、一致性和隔离性,在Redis运行在某种特定的持久化模式中,事务也具有耐久性

原子性

对于Redis的事务功能来说,事务队列中的命令要么就全部都执行,要么就一个都不执行,因此,Redis的事务是具有原子性的

但是,Redis的事务和传统的关系型数据库事务的最大区别在于,Redis不支持事务回滚机制rollback,即使事务队列中的某个命令在执行期间出现了错误,整个事务也会继续执行下去,直到将事务队列中的所有命令都执行完毕为止

这是因为Redis的作者认为这种复杂的功能和Redis追求简单高效的设计主旨不相符,并且认为事务的执行时遇到错误通常都是编程错误产生的,这种错误通常只会出现在开发环境,没有必要开发事务回滚功能

一致性

一致性指数据符合数据库本身的定义和要求,没有包含非法或者无效的错误数据

Redis通过谨慎的错误检测和简单的设计来保证事务的一致性

隔离性

Redis在实际执行事务时是单线程的,并且,服务器保证在执行事务时不会对事务进行中断。Redis的事务总是以串行的方式运行的,总是具有隔离性的

持久性

Redis事务的持久性由Redis使用的持久化模式决定

但是,在一个事务的最后加上SAVE命令总可以保证事务的耐久性

不过这种做法效率较低,不具有实用性