Redis事务

2018-05-06  本文已影响0人  涵仔睡觉

Redis事务通过MULTI、EXEC、WATCH等命令来实现。事务提供一种将多个命令请求打包，然后一次性、按顺序地执行多个命令的机制，并且在事务执行期间，服务器不会执行其他客户端的命令请求。

事务的实现

事务的三个阶段：

  1. 事务开始
    MULTI命令会将客户端的flags属性打开REDIS_MULTI标识，意味着事务开始。

  2. 命令入队
    当客户端处于事务状态时，服务器根据不同的命令会有不同的表现：

每个Redis客户端都有自己的事务状态，保存在mstate属性中，mstate中包含一个事务队列，事务队列是一个multiCmd数组，数组中每个元素保存了一个已入队命令的相关信息：

typedef struct redisClient {
... ...
multiState mstate;    // 事务状态
... ...
} redisClient;

typedef struct multiState {
multiCmd *commands;  // 事务队列，FIFO顺序
int count;                         // 已入队命令计数
} multiState;

typedef struct multiCmd {
robj **argv;                             // 参数
int argc;                                   // 参数数量
struct redisCommand *cmd; // 命令指针
} multiCmd;
image
  1. 事务执行
    当一个处于事务状态的客户端向服务器发送EXEC命令时，服务器会遍历这个客户端的事务队列，执行队列中保存的所有命令，最后将执行命令所得到的结果全部返回给客户端。

WATCH命令的实现

WATCH命令是一个乐观锁，在EXEC命令执行之前监视任意数量的数据库键，并在EXEC执行时，检查被监视的键是否有被修改过了（被另一个客户端修改了），如果是的话服务器将拒绝执行事务，并向客户端返回表示事务执行失败的空回复。

每个Redis数据库都保存着一个watch_keys字典，键是被WATCH命令监视的数据键，值是一个链表，链表记录了所有监视对应键的客户端：

typedef struct redisDb {
... ...
dict *watch_keys;   // 正被WATCH监视的键
... ...
} redisDb;
image

所有对数据库进行修改的命令，包括SET、LPUSH、SADD、ZREM、DEL、FLUSHDB等，在执行之后都会对watch_keys进行检查，查看是否有客户端正在监视刚刚被修改的数据库键，若有则将被修改键的客户端的REDIS_DIRTY_CAS标识打开，表示盖客户端的事务安全性已经被破坏。

当服务器接收到客户端发来的EXEC命令，服务器根据这个客户端是否打开了REDIS_DIRTY_CAS标识来决定是否执行事务：


image

事务的ACID性质

事务的ACID性质：原子性（Atomicity）、一致性（Consistency）、隔离性（Isolation）和耐久性（Durability）。

上一篇 下一篇

猜你喜欢

热点阅读