一个事务从开始到结束通常会经历以下三个阶段
1. 事务开始
2. 命令入队
3. 事务执行
每个redis客户端都有自己的事务状态,这个是无状态保存在客户端状态的mstate属性里面
点击(此处)折叠或打开
-
typedef struct redisClient{
-
//...
-
multiState mstate; /*multi/exec state*/
-
//...
-
} redisClient;
-
typedef struct multiState{
-
// 事务队列,fifo
-
multiCmd *commands;
-
int count;
-
}multiState;
-
-
typedef struct multiCmd{
-
robj **argv;
-
int argc;
-
struct redisCommand *cmd;
- }multiCmd;
每一个redis数据库都保存着一个watched_keys字典,这个字典的键是某个被WATCH命令监视的数据库键,而字典的值则是一个链表,链表中记录了所有监视相应数据库键的客户端
点击(此处)折叠或打开
-
typedef struct redisDb{
-
// ...
-
dict *watched_keys;
-
// ...
- }redisDb;
通过这个字典,服务器可以清楚的知道哪些数据键正在被监视,以及哪些客户端正在监视这些数据库键。
所有对数据库进行修改的命令,比如SET, LPUSH, SADD, ZREM, DEL, FLUSHDB等等,在执行之后都会调用touchWatchKey函数对watched_keys字典进行检查,查看是否有客户端正在监听刚刚被命令修改过得数据库键,如果有,这个函数会将客户端的REDIS_DIRTY_CAS标识打开,标识该客户端的事务安全性已经被破坏。