Redis事务

  Redis通过MULTIEXECWATCH等命令来实现事务(transaction)功能。事务提供了一种将多个命令请求打包,然后一次性、按顺序地执行多个命令的机制,并且在事务执行期间,服务器不会中断事务而去执行其他客户端命令。

1 事务的实现

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

(1) 事务开始
(2) 命令入队
(3) 事务执行

  1.1 事务开始

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

127.0.0.1:6379> MULTI
OK

  MULTI命令可以将执行该命令的客户端从非事务状态切换至事务状态。

  1.2 命令入队

  当一个客户端处于非事务状态时,这个客户端的命令会立即被服务器执行。与此不同的是,当一个客户端切换到事务状态之后,服务器会根据这个客户端发来的不同的命令执行不同的操作:

(1) 如果客户端发送的命令为EXECDISCARDWATCHMULTI四个命令中的其中一个,那么服务器会立即执行这个命令。
(2) 如果客户端发送的命令是EXECDISCARDWATCHMULTI四个命令以为的其他命令,那么服务器不会立即执行这个命令,而是将这个命令放在一个事务队列中,然后向客户端返回QUEUED回复。

服务器判断命令是该入队还是该执行的过程

  1.3 事务队列

  事务队列是一个以先进先出(FIFO)的方式保存入队的命令,较先入队的命令会被放到数组的前面,而较后入队的命令则会被放到数组的后面。例如:

127.0.0.1:6379>> MULTI
OK

127.0.0.1:6379>> set name Redis;
QUEUED

127.0.0.1:6379>> get name;
QUEUED

127.0.0.1:6379>> set author "Peter Seibei";
QUEUED

127.0.0.1:6379>> get author;
QUEUED

  那么服务器器将会为客户端创建一个事务队列,将上面4条命令入队,最先入队的SET命令放在事务队列的最前面……:

事务队列

  1.4 执行事务

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

127.0.0.1:6379> EXEC
1) OK
2) "Redis"
3) OK
4) "Peter Seibei"

2 WATCH命令的实现

  WATCH命令是一个乐观所(optimistic locking),它可以在EXEC命令执行前,监视任意数量的数据库键,并在EXEC命令执行时,检查监视的键是否至少有一个已经被修改过了,如果修改过了,服务器将拒绝执行事务,并向客户端返回代表事务执行失败的空回复。例如,下面的事务将会执行失败:

127.0.0.1:6379>> WATCH name
OK

127.0.0.1:6379>> MULTI
OK

127.0.0.1:6379>> set "name" "Peter"
QUEUED

127.0.0.1:6379>> EXEC
(nil)
时间 客户端A 客户端B
T1 WATCH "name"
T2 MULTI
T3 SET "name" "Peter"
T4 SET "name" "jack"
T5 EXEC

  在时间T4,客户端B修改了"name"键的值,当客户端A在T5执行EXEC命令时,服务器会发现WATCH监视的键“name”已经被修改,因此服务器拒绝执行客户端A的事务,并向客户端A返回空回复。

  2.1使用WATCH命令监视数据库键

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

一个watched_keys字典

  上图表明:
    (1) 客户端c1和c2正在监视键“name”。
    (2) 客户端c3正在监视键“age”。
    (3) 客户端c2和c4正在监视键“address”。

  2.2 监视机制的触发

  所有对数据库进行修改命令,如SET、LPUSH、SADD、ZREM、DEL等,在执行后都会对watched_keys字典进行检查,查看被修改的数据库键是否是被客户端所监视的键,如果有的话,客户端REDIS_DIRTY_CAS标识将会被打开,表示该客户端的事务安全性已经被破坏。

  2.3 判断事务是否安全

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

(1) 如果客户端的REDIS_DIRTY_ CAS标识已经被打开,那么说明客户端所监视的键当中,至少有一个键已经被修改过了,在这种情况下,客户端提交的事务已经不再安全,所以服务器拒绝执行客户端提交的事务。
(2) 如果客户端的REDIS_DIRTY_CAS标识没有被打开,那么说明客户端监视的所有键都没有被修改过(或者客户端没有监视任何键),事务仍然是安全的,服务器将执行客户端提交的这个事务。

3 事务的ACID性质

  在Redis中,事务总是具有原子性(Atomicity)、一致性(Consistency)和隔离性(Isolation),并且当Redis运行在某种特定的持久化模式下,事务也具有耐久性(Durability)。

  3.1 原子性

  事务具有原子性指的是, 数据库将事务中的多个操作当作一个整体来执行,服务器要么就执行事务中的所有操作, 要么就一个操作也不执行。
  对于Redis的事务功能来说,事务队列中的命令要么就全部都执行,要么就一个都不执行,因此, Redis的事务是具有原子性的。
  下面是一个执行失败的事务,这个事务因为命令入队出错而被服务器拒绝执行:

127.0.0.1:6379> multi
OK

127.0.0.1:6379> set msg hello
QUEUED

127.0.0.1:6379> get
(error) ERR wrong number of arguments for 'get' command

127.0.0.1:6379> get msg
QUEUED

127.0.0.1:6379> exec
(error) EXECABORT Transaction discarded because of previous errors.

  Redis的事务和传统的关系型数据库事务的最大区别在于,Redis不支持事务回滚机制(rollback), 即使事务队列中的某个命令在执行期间出现了错误,整个事务也会继续执行下去,直到将事务队列中的所有命令都执行完毕为止。
  下面展示了即使RPUSH命令在执行期间出现了错误,事务的后续命令也会继续执行下去, 并且之前执行的命令也不会有任何影响:

127.0.0.1:6379> set msg hello
OK

127.0.0.1:6379> multi
OK

127.0.0.1:6379> sadd fruit apple banana cherry
QUEUED

127.0.0.1:6379> rpush msg bye redis
QUEUED

127.0.0.1:6379> sadd alphabet a b c
QUEUED

127.0.0.1:6379> exec
1) (integer) 3
2) (error) WRONGTYPE Operation against a key holding the wrong kind of value
3) (integer) 3

  Redis为什么不支持回滚:不支持事务回滚是因为这种复杂的功能和Redis追求简单高效的设计主旨不相符,并且Redis事务的执行时错误通常都是编程错误产生的, 这种错误通常只会出现在开发环境中, 而很少会在实际的生产环境中出现。

  3.2 一致性

  事务的一致性是指,如果数据库执行前是一致的,那么在事务执行后,无论事务是否执行成功,数据库也应该是一致的。

  3.2.1入队错误

  如果一个事务在入队命令的过程中,出现了命令不存在,或者命令的格式不正确等情况, 那么Redis将拒绝执行这个事务。因为服务器会拒绝执行人队过程中出现错误的事务, 所以Redis事务的一致性不会被带有入队错误的事务影响。

127.0.0.1:6379> multi
OK

127.0.0.1:6379> set msg hello
QUEUED

127.0.0.1:6379> YAHOOO
(error) ERR unknown command 'YAHOOO'

127.0.0.1:6379> get msg
QUEUED

127.0.0.1:6379> exec
(error) EXECABORT Transaction discarded because of previous errors.

  Redis 2.6.5以前的入队错误处理:Redis会忽略错误的命令,而正确的命令如上面的SETGET仍然会被执行。

  3.2.2 执行错误

  执行错误通常都是一些不能在入队时被服务器发现的错误, 这些错误只会在命令实际执行时被触发。即使在事务的执行过程中发生了错误, 服务器也不会中断事务的执行, 它会继续执行事务中余下的其他命令, 并且已执行的命令(包括执行命令所产生的结果)不会被出错的命令影响。
  因为在事务执行的过程中, 出错的命令会被服务器识别出来, 并进行相应的错误处理, 所以这些出错命令不会对数据库做任何修改, 也不会对事务的一致性产生任何影响。

127.0.0.1:6379> set msg hello
OK

127.0.0.1:6379> multi
OK

127.0.0.1:6379> sadd fruit apple banana cherry
QUEUED

127.0.0.1:6379> rpush msg bye redis
QUEUED

127.0.0.1:6379> sadd alphabet a b c
QUEUED

127.0.0.1:6379> exec
1) (integer) 3
2) (error) WRONGTYPE Operation against a key holding the wrong kind of value
3) (integer) 3

  3.2.3 服务器停机

(1) 如果服务器运行在无持久化的内存模式下,那么重启之后的数据库将是空白的, 因此数据总是一致的。
(2) 如果服务器运行在RDB模式或AOF模式下, 那么在事务中途停机不会导致不一致,因为服务器可以根据RDB文件或AOF文件来回复数据,从而将数据库还原到一个一致的状态。

  3.3 隔离性

  事务的隔离性指的是,即使数据库中有多个事务并发地执行,各个事务之间也不会互相 影响,并且在并发状态下执行的事务和串行执行的事务产生的结果完全相同。
  因为Redis使用单线程的方式来执行事务(以及事务队列中的命令),并且服务器保证, 在执行事务期间不会对事务进行中断,因此,Redis的事务总是以串行的方式运行的,并且 事务也总是具有隔离性的。

  3.4 耐久性

事务的耐久性指的是,当一个事务执行完毕时,执行这个事务所得的结果巳经被保存到 永久性存储介质(比如硬盘)里面了, 即使服务器在事务执行完毕 之后停机, 执行事务所得的结果也不会丢失。Redis事务的耐久性由服务器所使用持久化模式决定的:

(1) 当服务器在无持久化的内存模式下运作时,事务不具有耐久性。因为一旦服务器停机,
服务器所有的数据都将丢失。
(2) 当服务器在ROB持久化模式下运作时,事务同样不具有耐久性。因为服务器只会在特定的保存条件下才会执行BGSAVE命令,并且异步执行的BGSAVE命令不能保证事务的数据第一时间被保存到硬盘上。
(3) 当服务器运行在AOF持久化模式下,并且appendfsync选项的值为always时,程序总会在执行命令之后调用同步(sync)函数,将命令数据真正地保存到硬盘里。

4 小结

(1) 事务提供了一种将多个命令打包,然后一次性、有序地执行的机制。
(2) 多个命令会被人队到事务队列中, 然后按先进先出(FIFO)的顺序执行。
(3) 事务在执行过程中不会被中断,当事务队列中的所有命令都被执行完毕之后,事务
才会结束。
(4) 带有WATCH命令的事务会将客户端和被监视的键在数据库的watched_keys字典关联,当键被修改时,程序会将所有监视被修改键的客户端的REDIS_DIRTY_CAS标识打开,服务只有在REDIS_DIRTY_CAS标识没有打开时,才会执行客户端提交的事务,否则服务器拒绝执行事务。
(5) Redis事务不支持回滚机制。
(6) Redis的事务总是具有ACID中的原子性、一致性和隔离性,当服务器运行在AOF持久化模式下,并且appendfsync选项的值为always时,事务也具有耐久性。
  本文完


  注:本文参考《Redis设计与实现》,如发现错误,请指正!

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 211,743评论 6 492
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 90,296评论 3 385
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 157,285评论 0 348
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 56,485评论 1 283
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 65,581评论 6 386
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,821评论 1 290
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,960评论 3 408
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,719评论 0 266
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,186评论 1 303
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,516评论 2 327
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,650评论 1 340
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 34,329评论 4 330
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,936评论 3 313
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,757评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,991评论 1 266
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 46,370评论 2 360
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 43,527评论 2 349

推荐阅读更多精彩内容