Redis 事务及其应用

参考：

http://www.runoob.com/redis/redis-transactions.html

https://www.cnblogs.com/qlshine/p/5958504.html

 

Redis 事务能够一次执行多个命令， 而且带有如下两个重要的保证：

• 批量操做在发送 EXEC 命令前被放入队列缓存。
• 收到 EXEC 命令后进入事务执行，事务中任意命令执行失败，其他的命令依然被执行。
• 在事务执行过程，其余客户端提交的命令请求不会插入到事务执行命令序列中。

一个事务从开始到执行会经历如下三个阶段：

• 开始事务。
• 命令入队。
• 执行事务。

---

实例

如下是一个事务的例子， 它先以 MULTI 开始一个事务， 而后将多个命令入队到事务中， 最后由 EXEC 命令触发事务， 一并执行事务中的全部命令：

redis 127.0.0.1:6379> MULTI OK redis 127.0.0.1:6379> SET book-name "Mastering C++ in 21 days" QUEUED redis 127.0.0.1:6379> GET book-name QUEUED redis 127.0.0.1:6379> SADD tag "C++" "Programming" "Mastering Series" QUEUED redis 127.0.0.1:6379> SMEMBERS tag QUEUED redis 127.0.0.1:6379> EXEC 1) OK 2) "Mastering C++ in 21 days" 3) (integer) 3 4) 1) "Mastering Series" 2) "C++" 3) "Programming"

单个 Redis 命令的执行是原子性的，但 Redis 没有在事务上增长任何维持原子性的机制，因此 Redis 事务的执行并非原子性的。

事务能够理解为一个打包的批量执行脚本，但批量指令并不是原子化的操做，中间某条指令的失败不会致使前面已作指令的回滚，也不会形成后续的指令不作。

 

好比：

redis 127.0.0.1:7000> multi OK redis 127.0.0.1:7000> set a aaa QUEUED redis 127.0.0.1:7000> set b bbb QUEUED redis 127.0.0.1:7000> set c ccc QUEUED redis 127.0.0.1:7000> exec 1) OK 2) OK 3) OK

若是在 set b bbb 处失败，set a 已成功不会回滚，set c 还会继续执行。

 

应用

redis 与 mysql 事务的对比:

	mysql	redis
开启	start transaction	multi
语句	普通的sql	普通命令
失败	rollback回滚	discard取消
成功	commit	exec

 

注: rollback 与 discard 的区别
若是已经成功执行了2条语句, 第3条语句出错
rollback后, 前两条语句影响消失
discard只是结束本次事务, 前两条语句形成的影响依然存在
注:
在multi后面的语句中, 语句出错可能有2种状况

1. 语法自己有问题, 这种错误exec时报错, 全部语句得不到执行
2. 语法自己没错误, 但适用对象有问题, 好比zadd操做list对象, exec后会执行正确的语句, 并跳过有不适当的语句

使用redis模拟银行转帐操做:

• 正常状况

  127.0.0.1:6379> set wang 200 #wang有200 OK 127.0.0.1:6379> set zhao 700 #zhao有700 OK 127.0.0.1:6379> 127.0.0.1:6379> multi #开启事务 OK 127.0.0.1:6379> decrby zhao 100 #zhao减100 QUEUED 127.0.0.1:6379> incrby wang 100 #wang加100 QUEUED #以上两个QUEUED表示两条语句被放在队列里面, exec前并无执行 127.0.0.1:6379> exec #执行完毕 1) (integer) 600 2) (integer) 300 127.0.0.1:6379> 

• 意外状况

  127.0.0.1:6379> multi 开启事务 OK 127.0.0.1:6379> 127.0.0.1:6379> decrby zhao 100 #zhao减100 QUEUED 127.0.0.1:6379> das #输入一个错误的命令 (error) ERR unknown command 'das' 127.0.0.1:6379> exec #执行, 提示被忽略 (error) EXECABORT Transaction discarded because of previous errors. 127.0.0.1:6379> 127.0.0.1:6379> mget zhao wang #zhao 和 wang的值不变 1) "600" 2) "300" 127.0.0.1:6379> 

• 另外一种报错状况

  127.0.0.1:6379> multi OK 127.0.0.1:6379> 127.0.0.1:6379> decrby zhao 100 #zhao减100 QUEUED 127.0.0.1:6379> sadd wang pig #故意把wang当作数组加入一个key, 发现并无报错, #由于这条语句被存放在队列里, 并无被执行 QUEUED 127.0.0.1:6379> exec #此时语句才被执行, 因此报错, 可是zhao依然减了100, 说明执行了正确的语句, 跳过了不正取的语句, 影响还在 1) (integer) 500 2) (error) WRONGTYPE Operation against a key holding the wrong kind of value 127.0.0.1:6379> 127.0.0.1:6379> mget zhao wang 1) "500" 2) "300" 127.0.0.1:6379> 

• discard取消

  127.0.0.1:6379> mget wang zhao 1) "400" 2) "400" 127.0.0.1:6379> multi OK 127.0.0.1:6379> decrby zhao 100 QUEUED 127.0.0.1:6379> incrby wang 100 QUEUED 127.0.0.1:6379> 127.0.0.1:6379> discard #取消后值没变 OK 127.0.0.1:6379> 127.0.0.1:6379> mget wang zhao 1) "400" 2) "400" 127.0.0.1:6379> exec (error) ERR EXEC without MULTI 127.0.0.1:6379> 

127.0.0.1:6379> mget zhao wang 1) "400" 2) "400" 127.0.0.1:6379> 127.0.0.1:6379> multi OK 127.0.0.1:6379> decrby zhao 100 QUEUED 127.0.0.1:6379> sadd wang pig QUEUED 127.0.0.1:6379> 127.0.0.1:6379> exec 1) (integer) 300 2) (error) WRONGTYPE Operation against a key holding the wrong kind of value 127.0.0.1:6379> 127.0.0.1:6379> discard #不能discard (error) ERR DISCARD without MULTI 127.0.0.1:6379> 127.0.0.1:6379> mget zhao wang 1) "300" 2) "400" 127.0.0.1:6379> 

---

watch key1 key2 ... keyN

做用: 监听 key1 key2 keyN有没有变化, 若是有变化, 则事务取消

unwatch(不加key): 取消全部 watch 监听

场景: 一我的正在买票, ticket-1, money-100, 而票只有一张, 若是在我multi以后, exec以前票被别人买走, 即ticket变为0了, 怎么办?

127.0.0.1:6379> set ticket 1 #加入只有1张票 OK 127.0.0.1:6379> set lisi 300 #lisi有300 OK 127.0.0.1:6379> set wang 300 #wang有300 OK 127.0.0.1:6379> 127.0.0.1:6379> multi #开启事务 OK 127.0.0.1:6379> decr ticket #票数-1 QUEUED 127.0.0.1:6379> decrby lisi 100 #lisi准备买-100 QUEUED 127.0.0.1:6379> #此处尚未exec

假如就在exec前票被别人买走, 打开另外一个终端

127.0.0.1:6379> decr ticket #票-1 (integer) 0 127.0.0.1:6379> get ticket #此时票数为0 "0" 127.0.0.1:6379> 

此时提交lisi

127.0.0.1:6379> exec 1) (integer) -1 #票变为-1 2) (integer) 200 #钱-100 127.0.0.1:6379> 

所以上面的过程不合理

---

要解决上面的状况,要采用监视

127.0.0.1:6379> set ticket 1 #票数为1 OK 127.0.0.1:6379> set lisi 200 #lisi钱是100 OK 127.0.0.1:6379> set wang 300 #wang是300 OK 127.0.0.1:6379> 127.0.0.1:6379> watch ticket #监控ticket有没有变更, 有变更的话则事务取消 OK 127.0.0.1:6379> multi #开启事务 OK 127.0.0.1:6379> decr ticket #ticket-1 QUEUED 127.0.0.1:6379> decrby lisi 100 #钱-100 QUEUED 127.0.0.1:6379>

在exec前票又被另外一我的买走了

127.0.0.1:6379> decr ticket (integer) 0 127.0.0.1:6379> get ticket "0" 127.0.0.1:6379> 

此时票数为0, lisi提交

127.0.0.1:6379> 127.0.0.1:6379> exec #失败 (nil) 127.0.0.1:6379> 127.0.0.1:6379> get lisi #钱并无减小 "200" 127.0.0.1:6379> 

---

Redis 事务命令

下表列出了 redis 事务的相关命令：

 

序号	命令及描述
1	DISCARD  取消事务，放弃执行事务块内的全部命令。
2	EXEC  执行全部事务块内的命令。
3	MULTI  标记一个事务块的开始。
4	UNWATCH  取消 WATCH 命令对全部 key 的监视。
5	WATCH key [key ...] 监视一个(或多个) key ，若是在事务执行以前这个(或这些) key 被其余命令所改动，那么事务将被打断。