Redis-11使用 watch 命令监控事务

本文涉及的产品
云数据库 Tair(兼容Redis),内存型 2GB
Redis 开源版,标准版 2GB
推荐场景:
搭建游戏排行榜
简介: Redis-11使用 watch 命令监控事务

概述


在 Redis 中使用 watch 命令可以决定事务是执行还是回滚。


一般而言,可以在 multi 命令之前使用 watch 命令监控某些键值对,然后使用 multi 命令开启事务,执行各类对数据结构进行操作的命令,这个时候这些命令就会进入队列。


当 Redis 使用 exec 命令执行事务的时候,它首先会去比对被 watch 命令所监控的键值对,


如果没有发生变化,那么它会执行事务队列中的命令,提交事务;

如果发生变化,那么它不会执行任何事务中的命令,而去事务回滚。


无论事务是否回滚 , Redis 都会去取消执行事务前的 watch 命令


Redis watch流程

流程如下:


20180927151647964.png

Redis 参考了多线程中使用的 CAS (比较与交换, Compare And Swap ) 去执行的。在

数据高并发环境的操作中,我们把这样的一个机制称为乐观锁.


ABA问题


先简要论述其操作的过程:

当一条线程去执行某些业务逻辑,但是这些业务务逻辑操作的数据可能被其他线程共享了,这样会引发多线程中数据不一致的情况。为了克服这个问题,首先,在线程开始时读取这些多线程共享的数据,并将其保存到当前进程的副本中,我们称为旧值( old value), watch 命令就是这样的一个功能 。


然后,开启线程业务逻辑,由 multi 命令提供这一功能。在执行更新前,比较当前线程副本保存的旧值和当前线程共享的值是否一致,如果不一致,那么该数据己经被其他线程操作过,此次更新失败。为了保持一致,线程就不去更新任何值,而将事务回滚:否则就认为它没有被其他线程操作过,执行对应的业务逻辑, exec 命令就是执行“类似”这样的一个功能 。


注意,“类似”这个字眼,因为不完全是,原因是 CAS 原理会产生 ABA 问题。所谓ABA 问题来自于 CAS 原理的一个设计缺陷,它可能引发 ABA 问题


20180927152401333.png


在处理复杂运算的时候,被线程 2 修改的 X 的值有可能导致线程1的运算出错,而最后线程 2 将 X 的值修改为原来的旧值 A,那么到了线程 1运算结束的时间顺序 T6,它将j检测 X 的值是否发生变化,就会拿旧值 A 和 当前的 X 的值 A 比对 , 结果是一致的, 于是提交事务,然后在复杂计算的过程中 X 被线程 2 修改过了,这会导致线程1的运算出错。


在这个过程中,对于线程 2 而言 , X 的值的变化为 A->B->A,所以 CAS 原理的这个设计缺陷被形象地称为“ABA 问题”。


仅仅记录一个旧值去比较是不足够的,还要通过其他方法避免 ABA 问题。常见的方法

如 Hibernate 对缓存的持久对象( PO )加入字段段 version 值,当每次操作一次该 PO,则version=version+ 1 , 这样采用 CAS 原理探测 version 宇段 , 就能在多线程的环境中,排除ABA 问题,从而保证数据的一致性。


Redis 在执行事务的过程中 , 并不会阻塞其他连接的并发,而只是通过 比较 watch 监控的键值对去保证数据的一致性 , 所 以 Redis 多个事务完全可 以在非阻塞的多线程环境中井发执行,而且 Redis 的机制是不会产生 ABA 问题的, 这样就有利于在保证数据一致的基础上 , 提高高并发系统的数据读/写性能。


使用watch成功提交的事务的案例


image.png

127.0.0.1:6379> FLUSHDB
OK
127.0.0.1:6379> SET key1 value1
OK
127.0.0.1:6379> WATCH key1
OK
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> SET key2 value2
QUEUED
127.0.0.1:6379> EXEC
1) OK
127.0.0.1:6379> 

这里我们使用了 watch 命令设置了 一个 key1 的监控 , 然后开启事务设置 key2 , 直至exec 命令去执行事务. 如果在当前会话中修改key1的值,也是可以成功的。


使用watch回滚的事务的案例


image.png


客户端一

127.0.0.1:6379> FLUSHDB
OK
127.0.0.1:6379> 
127.0.0.1:6379> SET key1 value1
OK
127.0.0.1:6379> WATCH key1
OK
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set key2 value2
QUEUED
# 在这一步暂停下,打开第二个客户端去修改key1的值,然后再exec
127.0.0.1:6379> exec
(nil)
127.0.0.1:6379> 



客户端二:

然后回到客户端1 执行exec

注意 T2 和 T6 时刻命令的说明,数据已经被回滚了,并没有执行事务。


相关实践学习
基于Redis实现在线游戏积分排行榜
本场景将介绍如何基于Redis数据库实现在线游戏中的游戏玩家积分排行榜功能。
云数据库 Redis 版使用教程
云数据库Redis版是兼容Redis协议标准的、提供持久化的内存数据库服务,基于高可靠双机热备架构及可无缝扩展的集群架构,满足高读写性能场景及容量需弹性变配的业务需求。 产品详情:https://www.aliyun.com/product/kvstore     ------------------------------------------------------------------------- 阿里云数据库体验:数据库上云实战 开发者云会免费提供一台带自建MySQL的源数据库 ECS 实例和一台目标数据库 RDS实例。跟着指引,您可以一步步实现将ECS自建数据库迁移到目标数据库RDS。 点击下方链接,领取免费ECS&RDS资源,30分钟完成数据库上云实战!https://developer.aliyun.com/adc/scenario/51eefbd1894e42f6bb9acacadd3f9121?spm=a2c6h.13788135.J_3257954370.9.4ba85f24utseFl
相关文章
|
2月前
|
缓存 NoSQL Redis
Redis 事务
10月更文挑战第18天
27 1
|
2月前
|
缓存 NoSQL Java
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
64 3
大数据-50 Redis 分布式锁 乐观锁 Watch SETNX Lua Redisson分布式锁 Java实现分布式锁
|
2月前
|
NoSQL Java Redis
redis的基本命令,并用netty操作redis(不使用springboot或者spring框架)就单纯的用netty搞。
这篇文章介绍了Redis的基本命令,并展示了如何使用Netty框架直接与Redis服务器进行通信,包括设置Netty客户端、编写处理程序以及初始化Channel的完整示例代码。
58 1
redis的基本命令,并用netty操作redis(不使用springboot或者spring框架)就单纯的用netty搞。
|
26天前
|
存储 NoSQL Java
Redis命令:列表模糊删除详解
通过本文的介绍,我们详细探讨了如何在Redis中实现列表的模糊删除。虽然Redis没有直接提供模糊删除命令,但可以通过组合使用 `LRANGE`和 `LREM`命令,并在客户端代码中进行模糊匹配,来实现这一功能。希望本文能帮助你在实际应用中更有效地操作Redis列表。
36 0
|
2月前
|
缓存 NoSQL 测试技术
Redis如何解决频繁的命令往返造成的性能瓶颈!
Redis如何解决频繁的命令往返造成的性能瓶颈!
|
2月前
|
SQL 分布式计算 NoSQL
大数据-42 Redis 功能扩展 发布/订阅模式 事务相关的内容 Redis弱事务
大数据-42 Redis 功能扩展 发布/订阅模式 事务相关的内容 Redis弱事务
25 2
|
2月前
|
缓存 NoSQL Redis
Redis命令:列表模糊删除详解
Redis命令:列表模糊删除详解
69 3
|
2月前
|
NoSQL 关系型数据库 MySQL
Redis 事务特性、原理、具体命令操作全方位诠释 —— 零基础可学习
本文全面阐述了Redis事务的特性、原理、具体命令操作,指出Redis事务具有原子性但不保证一致性、持久性和隔离性,并解释了Redis事务的适用场景和WATCH命令的乐观锁机制。
297 0
Redis 事务特性、原理、具体命令操作全方位诠释 —— 零基础可学习
|
2月前
|
NoSQL Redis 数据安全/隐私保护
Redis 命令
10月更文挑战第15天
29 0
|
3月前
|
监控 NoSQL 关系型数据库
9)Redis 居然也有事务
9)Redis 居然也有事务
34 0