yangl的博客

积少成多

0%

redis事务

发表于 更新于 分类于 Valine：
本文字数： 3.2k 阅读时长 ≈ 3 分钟

Redis事务概念

  • Redis 的单条命令是保证原子性的，但是redis事务不能保证原子性

Redis 事务本质：一组命令的集合。

—————– 队列 set set set 执行 ——————-

事务中每条命令都会被序列化，执行过程中按照顺序执行，不允许其他命令进行干扰。

  • 一次性
  • 循序性
  • 排他性
  1. Redis 事务没有隔离级别的概念
  2. Redis 单条命令是保证原子性的，但是事务不保证原子性

Redis 事务操作过程

  • 开启事务（multi）
  • 命令入队
  • 执行事务（exec）

执行事务

所有事务中的命令在加入时没有被执行，直到提交时才会开始执行（Exec）一次性完成。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
127.0.0.1:6379> multi				# 开启事务
OK
127.0.0.1:6379> set name1 yangl1	# 命令进入队列
QUEUED
127.0.0.1:6379> set name2 yangl2	# 命令进入队列
QUEUED
127.0.0.1:6379> get name1			# 命令进入队列
QUEUED
127.0.0.1:6379> set name3 yangl3	# 命令进入队列
QUEUED
127.0.0.1:6379> keys *				# 命令进入队列
QUEUED
127.0.0.1:6379> exec				# 执行事务
1) OK
2) OK
3) "yangl1"
4) OK
5) 1) "name2"
   2) "name1"
   3) "name3"
127.0.0.1:6379>

取消事务(discurd)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
127.0.0.1:6379> multi				# 开启事务
OK
127.0.0.1:6379> set name1 yangl1	# 命令进入队列
QUEUED
127.0.0.1:6379> set name2 yangl2	# 命令进入队列
QUEUED
127.0.0.1:6379> DISCARD				# 放弃事务
OK
127.0.0.1:6379> EXEC				# 执行事务
(error) ERR EXEC without MULTI
127.0.0.1:6379> 
127.0.0.1:6379> get name1			# 被放弃事务中命令并未执行
(nil)
127.0.0.1:6379>

事务错误

代码语法错误

（编译时异常）所有的命令都不执行

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
127.0.0.1:6379> MULTI				# 开始事务
OK
127.0.0.1:6379> set name1 yangl		# 命令进入队列
QUEUED
127.0.0.1:6379> set name2 yangl2	# 命令进入队列
QUEUED
127.0.0.1:6379> get name1 name2		# 错误命令
(error) ERR wrong number of arguments for 'get' command	# 会报错但是不影响后续命令入队
127.0.0.1:6379> 
127.0.0.1:6379> set name3 yangl3	# 命令进入队列
QUEUED
127.0.0.1:6379> get name3			# 命令进入队列
QUEUED
127.0.0.1:6379> EXEC				# 执行事务
(error) EXECABORT Transaction discarded because of previous errors.	# 执行报错
127.0.0.1:6379> get name1			
(nil)	# 其他命令并没有被执行
127.0.0.1:6379>

代码逻辑错误

（运行时异常） 其他命令能正常执行 ——> 所以不保证事务的原子性

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
127.0.0.1:6379> MULTI				# 开启事务
OK
127.0.0.1:6379> set name1 yangl1	# 命令进入队列
QUEUED
127.0.0.1:6379> set name2 yangl2	# 命令进入队列
QUEUED
127.0.0.1:6379> INCR name1			# 命令进入队列（运行时会报错，对字符串进行增量）
QUEUED
127.0.0.1:6379> get name2			# 命令进入队列
QUEUED
127.0.0.1:6379> EXEC				# 执行事务
1) OK
2) OK
3) (error) ERR value is not an integer or out of range
4) "yangl2"
127.0.0.1:6379>

小结

  1. 虽然中间有一条命令报错了，但是后面的指令依旧正常执行成功了。
  2. 所以说Redis单条指令保证原子性，但是Redis事务不能保证原子性。

监控

悲观锁

  • 很悲观，认为什么时候都会出现问题，无论做什么都会加锁

乐观锁

  • 很乐观，认为什么时候都不会出问题，所以不会上锁！更新数据的时候去判断一下，在此期间是否有人修改过这个数据
  • 获取version
  • 更新的时候比较version

正常执行

使用 watch key 监控指定数据，相当于乐观锁加锁。

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
127.0.0.1:6379> set user1 100		# 设置用户1 余额:100
OK
127.0.0.1:6379> set suer2 0			# 设置用户2 余额:0
OK
127.0.0.1:6379> WATCH money			# 监视money (上锁)
OK
127.0.0.1:6379> MULTI 				# 开启事务
OK
127.0.0.1:6379> DECRBY user1 30		# 用户1 余额减少：30
QUEUED
127.0.0.1:6379> INCRBY user2 30		# 用户2 余额增加：30
QUEUED
127.0.0.1:6379> EXEC				# 执行事务，监视值没有被中途修改，事务正常执行
1) (integer) 70
2) (integer) 30
127.0.0.1:6379>

多线程操作

测试多线程修改值，使用 watch 可以当做 redis 的乐观锁操作（相当于 get version）

线程1：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
127.0.0.1:6379> set user1 100		# 设置用户1 余额:100
OK
127.0.0.1:6379> set user2 0			# 设置用户2 余额:0
OK
127.0.0.1:6379> WATCH user1			# 监视money (上锁)
OK
127.0.0.1:6379> MULTI				# 开启事务
OK
127.0.0.1:6379> DECRBY user1 30		# 用户1 余额减少：30
QUEUED
127.0.0.1:6379> INCRBY user2 30		# 用户2 余额增加：30
QUEUED
127.0.0.1:6379> 					# 此时事务并没有执行

线程2：

1
2
3
127.0.0.1:6379> INCRBY user1 100	# 修改了 线程1 中监视的 user1
(integer) 200
127.0.0.1:6379>

线程1

1
2
3
4
5
6
127.0.0.1:6379> EXEC		# 执行之前，另一个线程修改了我们的值，这个时候就会导致事务执行失败
(nil) 	# 没有结果，说明事务执行失败
127.0.0.1:6379> get user1	# 线程2 修改生效
"200"
127.0.0.1:6379> get user2	# 线程1事务执行失败，数值没有被修改
"0"

解锁获取最新值，然后再加锁进行事务。

unwatch 进行解锁。

注意：每次提交执行 exec 后都会自动释放锁，不管是否成功


----------- 本文结束啦感谢您阅读 -----------