Redis的事务

 redis中的事务定义

事务的基本操作
? 开启事务

multi

设定事务的开启位置，此指令执行后，后续的所有指令均加入到事务中
? 执行事务

exec

设定事务的结束位置，同时执行事务。与multi成对出现，成对使用

 演示2个客户端同时操作一个key,就会发现有问题

127.0.0.1:6379> set name test1
OK
127.0.0.1:6379> get name
"test2"
127.0.0.1:6379>

127.0.0.1:6379> set name test2
OK
127.0.0.1:6379>

 演示开启事务

127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> SET AGE 30
QUEUED
127.0.0.1:6379> get age
QUEUED
127.0.0.1:6379> set age 31
QUEUED
127.0.0.1:6379> get age
QUEUED
127.0.0.1:6379> exec
1) OK
2) (nil)
3) OK
4) "31"

 演示在开启事务的过程中，发现操作事务。

127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set age 32
QUEUED
127.0.0.1:6379> get age
QUEUED
127.0.0.1:6379> set age 33
QUEUED
127.0.0.1:6379> DISCARD
OK
127.0.0.1:6379> get age
"31"
127.0.0.1:6379>

 事务的执行流程

 定义事务的过程中，命令格式输入错误怎么办？
语法错误
指命令书写格式有误

127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set name test
QUEUED
127.0.0.1:6379> get name
QUEUED
127.0.0.1:6379> stde name
(error) ERR unknown command `stde`, with args beginning with: `name`,
127.0.0.1:6379> exec
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379>

处理结果
如果定义的事务中所包含的命令存在语法错误，整体事务中所有命令均不会执行。包括那些语法正确的命令。 

定义事务的过程中，命令执行出现错误怎么办？
运行错误
指命令格式正确，但是无法正确的执行。例如对list进行incr操作

127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set name n1
QUEUED
127.0.0.1:6379> get name
QUEUED
127.0.0.1:6379> set name n2
QUEUED
127.0.0.1:6379> get name
QUEUED
127.0.0.1:6379> LPUSH name a b c
QUEUED
127.0.0.1:6379> get name
QUEUED
127.0.0.1:6379> exec
1) OK
2) "n1"
3) OK
4) "n2"
5) (error) WRONGTYPE Operation against a key holding the wrong kind of value
6) "n2"
127.0.0.1:6379> get name
"n2"
127.0.0.1:6379>

能够正确运行的命令会执行，运行错误的命令不会被执行 ，那就需要自己回滚一些脏数据了。

 注意：已经执行完毕的命令对应的数据不会自动回滚，需要程序员自己在代码中实现回滚。

手动进行事务回滚
? 记录操作过程中被影响的数据之前的状态
? 单数据： string
? 多数据： hash、 list、 set、 zset
? 设置指令恢复所有的被修改的项
? 单数据：直接set（注意周边属性，例如时效）
? 多数据：修改对应值或整体克隆复制

基于特定条件的事务执行——锁

业务场景

天猫双11热卖过程中，对已经售罄的货物追加补货， 4个业务员都有权限进行补货。补货的操作可能是一系列的操作，牵扯到多个连续操作，如何保障不会重复操作？
业务分析
多个客户端有可能同时操作同一组数据，并且该数据一旦被操作修改后，将不适用于继续操作
在操作之前锁定要操作的数据，一旦发生变化，终止当前操作
解决方案
? 对 key 添加监视锁，在执行exec前如果key发生了变化，终止事务执行

watch key1 [key2……] 

取消对所有 key 的监视

unwatch

演示如下，此为第二个客户端，在第一个客户端的开启事务执行

127.0.0.1:6379> set name 123
OK
127.0.0.1:6379>

27.0.0.1:6379> watch name
OK
127.0.0.1:6379> get name
"n2"
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set aa bb
QUEUED
127.0.0.1:6379> get aa
QUEUED
127.0.0.1:6379> exec
1) OK
2) "bb"
127.0.0.1:6379> watch name age
OK
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set aa cc
QUEUED
127.0.0.1:6379> get aa
QUEUED
127.0.0.1:6379> exec
(nil)
127.0.0.1:6379>

 不能在事务中开启watch

127.0.0.1:6379> WATCH name
OK
127.0.0.1:6379> get name
"123"
127.0.0.1:6379> UNWATCH
OK
127.0.0.1:6379>

基于特定条件的事务执行——分布式锁
解决方案
使用 setnx 设置一个公共锁 

127.0.0.1:6379> set num 10
OK
127.0.0.1:6379> SETNX lock 1
(integer) 1
127.0.0.1:6379> INCRBY num -1
(integer) 9
127.0.0.1:6379> del lock
(integer) 1
127.0.0.1:6379> get num
"9"
127.0.0.1:6379>

演示先锁在释放20秒

127.0.0.1:6379> set name 123
OK
127.0.0.1:6379> SETNX lock 1
(integer) 1
127.0.0.1:6379> EXPIRE lock 20
(integer) 1
127.0.0.1:6379> get name
"123"
127.0.0.1:6379> del lock
(integer) 1
127.0.0.1:6379> setnx lock-name 1
(integer) 1
127.0.0.1:6379> EXPIRE lock-name 10
(integer) 1
127.0.0.1:6379>

127.0.0.1:6379> setnx lock-name 1
(integer) 0
127.0.0.1:6379> setnx lock-name 1
(integer) 0
127.0.0.1:6379> setnx lock-name 1
(integer) 0
127.0.0.1:6379> setnx lock-name 1
(integer) 1
127.0.0.1:6379>

利用setnx命令的返回值特征，有值则返回设置失败，无值则返回设置成功
    对于返回设置成功的，拥有控制权，进行下一步的具体业务操作
    对于返回设置失败的，不具有控制权，排队或等待
操作完毕通过del操作释放锁
注意：上述解决方案是一种设计概念，依赖规范保障，具有风险性

使用 expire 为锁key添加时间限定，到时不释放，放弃锁
由于操作通常都是微秒或毫秒级，因此该锁定时间不宜设置过大。具体时间需要业务测试后确认。

expire lock-key second
pexpire lock-key milliseconds

    例如：持有锁的操作最长执行时间127ms，最短执行时间7ms。
    测试百万次最长执行时间对应命令的最大耗时，测试百万次网络延迟平均耗时
    锁时间设定推荐：最大耗时*120%+平均网络延迟*110%
    如果业务最大耗时<<网络平均延迟，通常为2个数量级，取其中单个耗时较长即可

假如在没有执行expire的时候，redis的服务器宕机的话，也会造成死锁，从2.8版本以后，加入了set指令的扩展参数，

setnx和expire指令可以一起执行了，可以解决分布式锁的乱象。

127.0.0.1:6379> set lock:code true ex 5 nx
OK
127.0.0.1:6379> get lock:code
(nil)