Redis 事务

Redis 事务

Redis 事务：一次执行多个命令

Redis事务工作特点：

• 批量操作放入队列缓存。（执行有顺序）
• 事务中任意命令执行失败，其余的命令依然被执行。（不保证原子性）
• 在事务执行过程，其他命令请求不会插入到事务执行命令序列中。（排他性）

三个阶段：

• 开始事务。（multi）
• 命令入队。
• 执行事务。(exec)

实例

127.0.0.1:6379> multi #开启事务
OK

########## 命令入队 开始##################
127.0.0.1:6379(TX)> set k1 v1
QUEUED
127.0.0.1:6379(TX)> set k2 v2
QUEUED
127.0.0.1:6379(TX)> get k1
QUEUED
127.0.0.1:6379(TX)> set k3 v3
QUEUED
########### 命令入队 结束 #################

127.0.0.1:6379(TX)> exec # 执行事务
1) OK
2) OK
3) "v1"
4) OK

放弃事务

127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> set k4 v4
QUEUED
127.0.0.1:6379(TX)> set k5 v5
QUEUED
127.0.0.1:6379(TX)> discard #取消事务
OK
127.0.0.1:6379> get k4 ####取消执行事务中所有命令，k4就会没值
(nil)

命令有误，事务中所有命令都不执行

127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> set k1 v1
QUEUED
127.0.0.1:6379(TX)> getset k2 #命令错误
(error) ERR wrong number of arguments for 'getset' command
127.0.0.1:6379(TX)> set k3 v3
QUEUED
127.0.0.1:6379(TX)> exec
(error) EXECABORT Transaction discarded because of previous errors.

运行时异常

127.0.0.1:6379> set k1 v1 
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> INCR k1 #k1自加一，必须时数值,有错误，不影响其他命令执行
QUEUED
127.0.0.1:6379(TX)> set k2 v2 
QUEUED
127.0.0.1:6379(TX)> exec
1) (error) ERR value is not an integer or out of range
2) OK
127.0.0.1:6379> get k2
"v2"

Redis 事务--锁

Watch：相当于乐观锁

通过监视key的值是否改变来决定事务能否正常提交

实例

正常执行

127.0.0.1:6379> set money 100
OK
127.0.0.1:6379> set out 0
OK
127.0.0.1:6379> watch money #监视money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> decrby money 20
QUEUED
127.0.0.1:6379(TX)> incrby out 20
QUEUED
127.0.0.1:6379(TX)> exec #正常执行
1) (integer) 80
2) (integer) 20

事务正常执行完成后，watch监视结束

多线程操作

127.0.0.1:6379> watch money
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> DECRBY money 50
QUEUED
127.0.0.1:6379(TX)> INCRBY out 50
QUEUED
127.0.0.1:6379(TX)> 

事务没有执行，另一个线程修改了监视的key

执行事务

127.0.0.1:6379(TX)> exec #执行失败
(nil)

重新执行事务，使用UNWATCH命令（用于取消 WATCH 命令对所有 key 的监视）来保证下一个事务的执行不会受到影响

127.0.0.1:6379> watch money #开启监视
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> DECRBY money 50
QUEUED
127.0.0.1:6379(TX)> INCRBY out 50
QUEUED
127.0.0.1:6379(TX)> exec # 执行之前，另一个线程执行了 set money 200
(nil)
127.0.0.1:6379> UNWATCH  #取消 WATCH 命令对所有 key 的监视
OK
127.0.0.1:6379> WATCH money #开启监视
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379(TX)> DECRBY money 50
QUEUED
127.0.0.1:6379(TX)> INCRBY out 50
QUEUED
127.0.0.1:6379(TX)> exec
1) (integer) 150
2) (integer) 50

分布式锁(setnx)

利用setnx命令的特征（存在Key则返回设置失败，不存在Key则返回设置成功），并通过del命令释放锁。

127.0.0.1:6379> set num 10
OK
127.0.0.1:6379> setnx lock-num 2 #设置key
(integer) 1
127.0.0.1:6379> incrby num -1
(integer) 9
127.0.0.1:6379> del lock-num #释放，如果不释放的话，就无法再次通过setnx设置key
(integer) 1
127.0.0.1:6379> setnx lock-num 1 
(integer) 1
127.0.0.1:6379> setnx lock-num 1
(integer) 0

使用setnx可能会出现忘记释放的情况，需要针对key设置有效时间

• expire lock-key second
• pexpire lock-key milliseconds

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

 由于操作通常都是微秒或毫秒级，因此该锁定时间不宜设置过大。具体时间需要业务测试后确认。

 例如：持有锁的操作最长执行时间127ms，最短执行时间7ms。

 测试百万次最长执行时间对应命令的最大耗时，测试百万次网络延迟平均耗时

 锁时间设定推荐：最大耗时*120%+平均网络延迟*110%

 如果业务最大耗时<<网络平均延迟，通常为2个数量级，取其中单个耗时较长即可