Redis 事务
1.Redis 事务可以一次执行多个命令, 并且带有以下三个重要的保证:
- 批量操作在发送 EXEC 命令前被放入队列缓存。
- 收到 EXEC 命令后进入事务执行,事务中任意命令执行失败,其余的命令依然被执行。
- 在事务执行过程,其他客户端提交的命令请求不会插入到事务执行命令序列中。
一个事务从开始到执行会经历以下三个阶段:
- 开始事务。
- 命令入队。
- 执行事务。
2.正常执行事务!
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 k2
QUEUED #进入队列
127.0.0.1:6379(TX)> exec #执行事务
1) OK
2) OK
3) "v2"
3.取消事务
127.0.0.1:6379> multi #开启事务
OK
127.0.0.1:6379(TX)> set k1 v1
QUEUED #进入队列
127.0.0.1:6379(TX)> discard #取消事务
OK
127.0.0.1:6379> get k1
(nil)
4.Redis编译时异常 不会被执行
127.0.0.1:6379> multi #开启事务
OK
127.0.0.1:6379(TX)> set k1 v1
QUEUED #进入队列
127.0.0.1:6379(TX)> get k2 v2 #执行事务时报错
(error) ERR wrong number of arguments for 'get' command
127.0.0.1:6379(TX)> set k2 v2
QUEUED
127.0.0.1:6379(TX)> exec #执行事务
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379> get k1 #所有的命令都不会生效
(nil)
5.Redis运行时异常 正常的命令任然会被执行
Redis单条命令式保证原子性,但是事务不保证原子性!
127.0.0.1:6379> multi #开启事务
OK
127.0.0.1:6379(TX)> set k1 "v1"
QUEUED #进入队列
127.0.0.1:6379(TX)> incr k1 #字符串自增会报错 但是其他命令任然会执行
QUEUED
127.0.0.1:6379(TX)> set k2 v2
QUEUED
127.0.0.1:6379(TX)> exec
1) OK
2) (error) ERR value is not an integer or out of range
3) OK
127.0.0.1:6379> get k2
"v2"
Redis实现锁
1.悲观锁:
-
每次去拿数据的时候都认为别人会修改,所以每次在拿数据的时候都会上锁,这样别人想拿这个数据就会阻塞直到它拿到锁
2.乐观锁 :
-
每次去拿数据的时候都认为别人不会修改,所以不会上锁,但是在更新的时候会判断一下在此期间别人有没有去更新这个数据,可以使用版本号机制和CAS算法实现。
-
实现: 获取version,更新的时候比较version
3.Redis正常转账
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
4.多线程转账失败(实现回滚)
线程1正常转账
线程2 在线程1提交之前修改了money
#线程2
127.0.0.1:6379> get money
"100"
127.0.0.1:6379> incrby money 100
(integer) 200
127.0.0.1:6379> get money
"200"
#线程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(TX)> decrby money 10
QUEUED
127.0.0.1:6379(TX)> incrby out 10
QUEUED
127.0.0.1:6379(TX)> exec #事务失败
(nil)
127.0.0.1:6379> get money
"200"
##########################################################################
#在事务提交失败的时候需要先解除监视,然后再次监视
127.0.0.1:6379> unwatch
OK
127.0.0.1:6379> watch
(error) ERR wrong number of arguments for 'watch' command
127.0.0.1:6379> watch money
OK