参考文档:事务(transactions)
注意:
Redis 事务没有隔离级别的概念!
Redis 单条命令是保证原子性的,但是事务不保证原子性!
Redis事务的本质:一组命令的集合,一个事务的所有命令都会被序列化,在事务执行的过程中,会按顺序执行。
一次性、顺序性、排他性!
- 开启事务(multi)
- 命令入队
- 执行事务(exec)
用法:
MULTI 命令用于开启一个事务,它总是返回OK
。 MULTI 执行之后, 客户端可以继续向服务器发送任意多条命令, 这些命令不会立即被执行, 而是被放到一个队列中, 当 EXEC命令被调用时, 所有队列中的命令才会被执行。
另一方面, 通过调用 DISCARD , 客户端可以清空事务队列, 并放弃执行事务。
正常执行事务:
127.0.0.1:6379> MULTI #开启事务
OK
127.0.0.1:6379> set key1 1 #入队
QUEUED
127.0.0.1:6379> set key2 2 #入队
QUEUED
127.0.0.1:6379> get key2 #入队
QUEUED
127.0.0.1:6379> set key3 3 #入队
QUEUED
127.0.0.1:6379> EXEC #执行事务
1) OK
2) OK
3) "2"
4) OK
放弃事务:
127.0.0.1:6379> MULTI #开启事务
OK
127.0.0.1:6379> set k1 1
QUEUED
127.0.0.1:6379> set k2 2
QUEUED
127.0.0.1:6379> DISCARD #取消事务
OK
127.0.0.1:6379> get k2 #事务队列的中的命令都不会被执行!
(nil)
编译型异常(代码有问题!命令错误),事务中的所有命令都不会被执行!
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set k1 1
QUEUED
127.0.0.1:6379> setget k2 2 #错误的命令
(error) ERR unknown command `setget`, with args beginning with: `k2`, `2`,
127.0.0.1:6379> set k3 3
QUEUED
127.0.0.1:6379> EXEC #执行事务报错!
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379> get k1 #所有的命令都没有执行
(nil)
运行时异常(比如:1/0),如果事务队列中存在语法性错误的时候,那么其他命令可以正常执行。
127.0.0.1:6379> set k1 "v1"
OK
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> INCR k1 #语法出错,执行失败。但是不影响事务的执行
QUEUED
127.0.0.1:6379> set k2 2
QUEUED
127.0.0.1:6379> get k2
QUEUED
127.0.0.1:6379> EXEC
1) (error) ERR value is not an integer or out of range
2) OK
3) "2"
127.0.0.1:6379> get k2
"2"
监控! Watch
悲观锁:(性能极低,一般不用)
- 很悲观,认为什么时候都会出现问题,无论做什么都会加锁!
乐观锁:
- 很乐观,认为什么时候都不会出问题,所以不会上锁!更新数据的时候去判断一下,在此期间是否有人修改过这个数据。
- 获取version
- 更新时比较version
Redis监视测试Watch
1、正常执行成功:
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> DECRBY money 20
QUEUED
127.0.0.1:6379> INCRBY out 20
QUEUED
127.0.0.1:6379> EXEC
1) (integer) 80
2) (integer) 20
注意:事务正常执行成功后watch锁失效
2、测试多线程修改值,使用watch可以当作redis的乐观锁操作!
########################################################
线程1
########################################################
127.0.0.1:6379> WATCH money #监视money
OK
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> DECRBY money 10
QUEUED
127.0.0.1:6379> INCRBY out 10
QUEUED
127.0.0.1:6379> EXEC #执行之前,线程2修改了我们的值,这个时候就会导致线程执行失败
(nil)
########################################################
#线程2
########################################################
127.0.0.1:6379> get money
"80"
127.0.0.1:6379> set money 1000
OK
127.0.0.1:6379> get money
"1000"
3、如果修改失败,将监控的值重新获取就可以了。
127.0.0.1:6379> UNWATCH # 1、如果发现事务执行失败,就先解锁
OK
127.0.0.1:6379> WATCH money # 2、 获取最新的值,再次监视
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> DECRBY money 100
QUEUED
127.0.0.1:6379> INCRBY out 100
QUEUED
127.0.0.1:6379> EXEC # 3、比对监视的值是否再次发生变化,如果没有变化,那么可以执行成功,如果变化了就会再次执行失败!
1) (integer) 900
2) (integer) 120