事务的命令包括 MULTI 、 DISCARD 、 EXEC 和 WATCH
MULTI
SET key001 1
GET key001
EXEC
事务队列是一个数组,每个数组项是都包含三个属性:
WATCH 命令用于在事务开始之前监视任意数量的键:当调用 EXEC 命令执行事务时,如果任意一个被监视的键已经被其他客户端修改了,那么整个事务不再执行,直接返回失败.
客户端 1:
## 执行失败的命令
redis> WATCH name
OK
redis> MULTI
OK
redis> SET name peter
QUEUED
redis> EXEC
(nil)
客户端 2:
## 执行失败的命令
redis> WATCH name
OK
redis> MULTI
OK
redis> SET name peter
QUEUED
redis> EXEC
(nil)
时间 | 客户端A | 客户端B |
---|---|---|
T1 | WATCH name | |
T2 | MULTI | |
T3 | SET name peter | |
T4 | SET name john | |
T5 | EXEC |
监控 Key 的实现:
REDIS_DIRTY_CAS
选项 在上图中,如果某个客户端对 key1 进行了修改(比如执行 DEL key1 ),那么所有监视 key1 的客户端,包
括 client2 、 client5 和 client1 的 REDIS_DIRTY_CAS
选项都会被打开,当客户端 client2
、 client5 和 client1 执行 EXEC 的时候,它们的事务都会以失败告终。
A 原子性 C 一致性 I 隔离性 D 持久性
原子性
单个 Redis 的习性是原子性的,Redis 没有对事务做任何维持原子性的操作。如果 Redis 事务在执行过程中, Redis 被停止,Redis不会对重试和回滚。
一致性
一致性的问题可以分为三个步骤考虑:入队错误、执行错误、 Redis 进程被终结。
入队列错误
在命令入队的过程中,如果客户端向服务器发送了错误的命令,比如命令的参数数量不对,等等,那么服务器将向客户端返回一个出错信息,并且将客户端的事务状态设为REDIS_DIRTY_EXEC 。当客户端执行 EXEC 命令时, Redis 会拒绝执行状态为 REDIS_DIRTY_EXEC 的事务,并返回失败信息。
执行错误
如果命令在事务执行的过程中发生错误,比如说,对一个不同类型的 key 执行了错误的操作,那么 Redis 只会将错误包含在事务的结果中,这不会引起事务中断或整个失败,不会影响已执行事务命令的结果,也不会影响后面要执行的事务命令,所以它对事务的一致性也没有影响。
Redis 进程被终结
隔离性
Redis 的一个实例是单进程的程序,并且它保证在执行事务是,不会对事务中断,所以 Redis 的事务总是带有隔离性的。
持久性
因为事务不过是用队列包裹起了一组 Redis 命令,并没有提供任何额外的持久性功能,所以事务的持久性由 Redis 所使用的持久化模式决定
订阅的模型:
频道支持模糊的匹配:
当有信息发送到 tweet.shop.kindle 频道时,信息除了发送给 clientX 和 clientY 之外,还会发送给订阅 tweet.shop.* 模式的 client123 和 client256
struct redisServer {
// ...
list *pubsub_patterns;
// ...
};
typedef struct pubsubPattern {
redisClient *client;
robj *pattern;
} pubsubPattern;
client 属性保存着订阅模式的客户端,而 pattern 属性则保存着被订阅的模式。每当调用 PSUBSCRIBE 命令订阅一个模式时,程序就创建一个包含客户端信息和被订阅模式的 pubsubPattern 结构,并将该结构添加到 redisServer.pubsub_patterns 链表中
typedef struct slowlogEntry {
// 命令参数
robj **argv;
// 命令参数数量
int argc;
// 唯一标识符
long long id; /* Unique entry identifier. */
// 执行命令消耗的时间,以纳秒(1 / 1,000,000,000 秒)为单位
long long duration; /* Time spent by the query, in nanoseconds. */
// 命令执行时的时间
time_t time; /* Unix time at which the query was executed. */
} slowlogEntry;
// 记录服务器状态的 redis.h/redisServer 结构里保存了几个和慢查询有关的属性:
struct redisServer {
// ... other fields
// 保存慢查询日志的链表
list *slowlog; /* SLOWLOG list of commands */
// 慢查询日志的当前 id 值
long long slowlog_entry_id; /* SLOWLOG current entry ID */
// 慢查询时间限制
long long slowlog_log_slower_than; /* SLOWLOG time limit (to get logged) */
// 慢查询日志的最大条目数量
unsigned long slowlog_max_len; /* SLOWLOG max number of items logged */
// ... other fields
};