Redis(十三) 事务

在这里插入图片描述

文章目录

  • 前言
  • 事务的特性
  • Redis事务的执行原理
  • Redis中使用事务
    • WATCH UNWATCH实现乐观锁

前言

前面我们学习 MySQL 的时候,肯定也学习了事务。事务是什么?给大家举个例子:假如我给朋友微信转账,我给他转了 100 块钱,当我输入完成密码了之后,我的微信余额减了 100,但是这时我的微信突然没信号了,换句话就是微信服务器突然挂了,当微信服务器重新启动之后,我问我那个朋友 100 块钱收到了没,他说没有,我就去看我的微信余额,发现 100 块钱扣掉了,那么这时候就出现问题了,我的微信余额减少了,但是朋友的微信余额没有增加。遇到这种问题该如何解决呢?那就是使用事务,事务中的语句要么全部执行,要么全部不执行。Redis 中也有事务这个概念,但是和 MySQL 的事务是有区别的。

事务的特性

前面学习的 MySQL 事务有四种特性(ACID):

  1. 原子性(Atomicity):事务中的全部操作在数据库中是不可分割的,要么全部完成,要么均不执行。
  2. 一致性(Consistency):几个并行执行的事务,其执行结果必须与按某一顺序串行执行的结果相一致。
  3. 隔离性(Isolation):事务的执行不受其他事务的干扰,事务执行的中间结果对其他事务必须是透明的。
  4. 持久性(Durability):对于任意已提交事务,系统必须保证该事务对数据库的改变不被丢失,即使数据库出现故障。

上面是 MySQL 事务的特性,Redis 事务对比于 MySQL 事务而言,那真的就是一句话:没有可比性。

原子性是事务中的操作要么全部执行,要么一个都不执行。当事务中的某个操作出现错误的时候,就会将之前的操作进行回滚,回滚到事务开启前的状态,只有操作全部正确执行的时候,才不会发生回滚。但是对于我们的 Redis 来说,如果事务中的操作出现了错误之后,redis 只会报错,然后继续执行事务后面的操作,而不会发生回滚。那么 Redis 的这种操作可以称作是原子性吗?其实也是有的,但是这种性质叫做弱原子性,也可以说 Redis 不具有原子性,大家对于原子性的定义是有歧义的,所以对于 Redis 是否具有原子性也是存在歧义的。

一致性是指在事务开始之前和事务结束以后,数据库的完整性没有被破坏。因为 Redis 的事务不具有回滚的功能,所以也就无法保证事务的一致性,也就是说 Redis 不具有一致性。

持久性是指事务的操作对于数据库的改变是永久的,而由于我们的 Redis 操作数据都是在内存中的,内存中的数据是易失的,不具有持久性,所以 Redis 不具有持久性。

隔离性是指多个事务之间的操作是互不影响的,而我们的 Redis 是单线程模型的服务器程序,所以也就不存在多个事务同时执行的情况,就不存在所谓的隔离性特性。

啊?既然 Redis 的事务 ACID 特性都没有,那么 Redis 的事务是干嘛的啊?其实 Redis 事务的主要功能就是为了“打包”,将一个客户端发送的事务之内的操作放在一起,按照顺序执行,防止被其他客户端发送来的请求命令插队、干扰。

Redis事务的执行原理

Redis 实现事务引入了队列,当客户端开启事务的时候,接下来输入的命令 redis 服务器不会立即执行这些命令,而是会将这些命令放入这个队列中(这个队列是每个客户端都对应的有一个)。只有当遇到执行事务这个命令的时候,队列中的命令才会依次执行,而这个队列中的命令只有全部执行完才会执行其他客户端对应的队列中的命令。

那么为什么 Redis 的事务搞得这么简单,而不是像 MySQL 那样功能齐全呢?MySQL 的事务功能齐全那是需要付出代价的,需要付出更多的空间和时间,而 Redis 又以快著称,因为 redis 操作的对象是内存,内存的价格比硬盘高不少,所以完善 redis 的事务功能就以为需要牺牲速度和空间,那这样还不如直接使用 MySQL。

Redis中使用事务

在 redis 中实现事务需要依赖 MULTIEXECDISCARD命令。

  • MULTI:开启事务
  • EXEC:执行事务
  • DISCARD:丢弃事务

现在一个客户端中开启事务,并且向队列中添加一些命令,但是不执行事务。再开启一个窗口,查看事务中的操作是否执行:

127.0.0.1:6379> keys *
(empty array)
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set key1 111
QUEUED
127.0.0.1:6379> set key2 222
QUEUED
127.0.0.1:6379> set key3 333
QUEUED
127.0.0.1:6379>
127.0.0.1:6379> get key1
(nil)
127.0.0.1:6379> get key2
(nil)
127.0.0.1:6379> get key3
(nil)

然后执行事务,再看是否执行操作:

127.0.0.1:6379> EXEC
1) OK
2) OK
3) OK

使用 EXEC 执行事务之后,返回的是事务中的每个操作的返回值

127.0.0.1:6379> get key1
"111"
127.0.0.1:6379> get key2
"222"
127.0.0.1:6379> get key3
"333"

上面就是一个完整的事务,那么如果事务中的操作出现了错误,会发生什么:

127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set key4 444
QUEUED
127.0.0.1:6379> setget key5 555
(error) ERR unknown command `setget`, with args beginning with: `key5`, `555`, 
127.0.0.1:6379> set key5 555
QUEUED
127.0.0.1:6379> EXEC
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379> get key4
(nil)
127.0.0.1:6379> get key5
(nil)
127.0.

前面不是说了 redis 事务中的操作出现了问题不是不会发生回滚吗?这里为什么事务中的操作都没有执行呢?其实对于 redis 事务是否回滚取决于错误发生的类型,如果发生错误的类型是编译时异常,也就是命令错误时,就会发生回滚,运行时异常则不会发生回滚:

127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set key4 nihao
QUEUED
127.0.0.1:6379> INCR key4
QUEUED
127.0.0.1:6379> set key5 555
QUEUED
127.0.0.1:6379> EXEC
1) OK
2) (error) ERR value is not an integer or out of range
3) OK
127.0.0.1:6379> get key4
"nihao"
127.0.0.1:6379> get key5
"555"

这里 key4 不是 intstr 类型,所以执行 INCR 自增的时候就会发生错误,但是由于这里的错误类型是运行时异常,所以事务就不会发生回滚。

然后看看丢失当前事务的操作:

127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set key6 666
QUEUED
127.0.0.1:6379> set key7 777
QUEUED
127.0.0.1:6379> DISCARD
OK
127.0.0.1:6379> get key6
(nil)
127.0.0.1:6379> get key7
(nil)

这是 DISCARD 丢失事务的实现。如果在开启了事务,并且向服务器发送了若干命令之后,服务器突然重启了。服务器重启也就意味了内存中的数据都丢失了,那么事务对应的队列中的数据也就丢失了,这时候该怎么办呢?其实这时就相当于执行了 DISCARD 丢弃事务的操作。

WATCH UNWATCH实现乐观锁

假设在事务开始的过程,执行之前,其他客户端对数据进行了修改,而当前客户端事务中也会对这个数据进行修改,但是对于这个数据修改多次是不允许的,那么在开启事务之后,执行事务之前,如何判断在这个事务中要使用到的数据已经被修改了呢?

这就需要使用到 WATCH 命令和 UNWATCH 命令了。通过使用 WATCH key 就可以监视这个 key,当监视了这个 key 之后,如果在事务中需要修改这个 key 之前,这个 key 已经被修改了,那么事务就会相当于执行 DISCARD 命令,丢弃当前事务。

先开启事务,并向 redis 服务器发送几个命令,但是不执行,然后再开启一个窗口修改 watch 监视的key:

127.0.0.1:6379> keys *
(empty array)
127.0.0.1:6379> set key1 111
OK
127.0.0.1:6379> WATCH key1
OK
127.0.0.1:6379> MULTI
OK
127.0.0.1:6379> set key1 333
QUEUED
127.0.0.1:6379> set key1 222
OK

执行事务:

127.0.0.1:6379> EXEC
(nil)
127.0.0.1:6379> get key1
"222"

可以看到 key1 最终的结果是另一个窗口修改的 key1 的值,另一个窗口修改的操作是早于当前窗口事务的修改的操作的,按理来说,key1 的值应该是事务中修改的 key1 的值,结果却相反,说明当前窗口的事务中的操作没有执行,事务被丢弃了。

使用 UNWATCH 可以接触 WATCH 对于 key 的监视。

这个 WATCH 命令就相当于我们前面学习多线程中的加乐观锁的操作,乐观锁假设在大多数情况下,多个线程或事务之间不会发生冲突,因此在读取数据时不会上锁。相反,乐观锁会在更新数据时判断在此期间数据是否被其他线程或事务修改过。

与乐观锁相对应的就是悲观锁,悲观锁总是假设最坏的情况,即认为数据在处理过程中总是会被其他线程或事务修改,因此在数据处理开始之前就先对数据进行锁定。

乐观锁相对于悲观锁更轻量。WATCH 的执行流程大概就是,在事务中,要修改监视的值时,先判断当前key的值是否和使用 WATCH key 监视key的时候的值相同,如果相同就允许修改,不同则 DISCARD。这样虽然可以,但是又会发生 ABA 问题,就是这个值被修改过了,只不过在我判断之前这个值又被改了回来,当出现这种情况的时候也是会出现问题的,所以 redis 的 WATCH 乐观锁的实现就是根据版本号来判断的,当使用 WATCH key 监视 key 的时候就会为这个 key 定义一个版本号,当对这个 key 进行修改的时候,版本号就会加上或者减去一个值(要加每次修改,版本号都是加,减,版本号则是减,不会出现这次修改,版本号变大,下次修改版本号变小的情况),所以通过版本号的操作就很好的解决了 ABA 问题。

WATCH 命令只针对于事务来说

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:/a/642594.html

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

5.18 TCP机械臂模拟

#include <netinet/tcp.h>//包含TCP选项的头文件 #include <arpa/inet.h> #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <linux/input.h>//读取输入事件 #include <sys/types.h> #include <sys/stat.h&…

C++vector的简单模拟实现

文章目录 目录 文章目录 前言 一、vector使用时的注意事项 1.typedef的类型 2.vector不是string 3.vector 4.算法sort 二、vector的实现 1.通过源码进行猜测vector的结构 2.初步vector的构建 2.1 成员变量 2.2成员函数 2.2.1尾插和扩容 2.2.2operator[] 2.2.3 迭代器 2…

Linux基础(五):常用基本命令

从本节开始&#xff0c;我们正式进入Linux的学习&#xff0c;通过前面的了解&#xff0c;我们知道我们要以命令的形式使用操作系统&#xff08;使用操作系统提供的各类命令&#xff0c;以获得字符反馈的形式去使用操作系统。&#xff09;&#xff0c;因此&#xff0c;我们是很有…

纯代码如何实现WordPress搜索包含评论内容?

WordPress自带的搜索默认情况下是不包含评论内容的&#xff0c;不过有些WordPress网站评论内容比较多&#xff0c;而且也比较有用&#xff0c;所以想要让用户在搜索时也能够同时搜索到评论内容&#xff0c;那么应该怎么做呢&#xff1f; 网络上很多教程都是推荐安装SearchWP插…

shelll 正则表达式

sort sort命令对行内容进行排序 sort语法&#xff1a; 1.sort &#xff08;选项&#xff09; 参数 2.cat file | sort 选项 选项&#xff1a; -n 按照数字进行排序 -r 反向排序 -k 指定排序 -f 忽略大小写 会将小写字母转化成大写字母来比较 -b 忽略每行前面的空格 .........…

CentOS上升级glibc2.17至glibc2.31

glibc是Linux系统中的重要组件之一。在CentOS中&#xff0c;glibc通常是作为系统的默认C标准库使用的&#xff0c;因为它是许多软件的基础库。在CentOS中&#xff0c;glibc的版本通常与CentOS版本一起发布。因为CentOS通常会优先选择稳定性而不是最新性&#xff0c;所以CentOS使…

【linux】docker下nextcloud安装人脸识别插件

一、插件源码地址&#xff1a; GitCode - 开发者的代码家园 二、插件官网地址&#xff1a; Releases - Face Recognition - Apps - App Store - Nextcloud 三、插件安装教程&#xff1a; 1、查看本地nextcloud版本号 http://ipAddress:8080/settings/admin/overview 2、找…

基于51单片机的火灾检测设计(仿真+程序+原理图+论文报告+讲解视频)

基于51单片机的火灾检测设计 基于51单片机的火灾检测设计&#xff08;仿真程序原理图论文报告&#xff09;功能要求仿真图&#xff1a;原理图&#xff1a;源程序&#xff1a;论文/报告&#xff1a;资料清单&#xff1a; 基于51单片机的火灾检测设计&#xff08;仿真程序原理图论…

论文阅读--CLIPasso

让计算机把真实图片抽象成简笔画&#xff0c;这个任务很有挑战性&#xff0c;需要模型捕获最本质的特征 以往的工作是找了素描的数据集&#xff0c;而且抽象程度不够高&#xff0c;笔画是固定好的&#xff0c;素描对象的种类不多&#xff0c;使得最后模型的效果十分受限 之所以…

在ubuntu中关于驱动得问题:如何将nouveau驱动程序加入黑名单和安装NVIDIA显卡驱动

提示&#xff1a;文章写完后&#xff0c;目录可以自动生成&#xff0c;如何生成可参考右边的帮助文档 文章目录 一、nouveau驱动程序加入黑名单二、安装NVIDIA显卡驱动 一、nouveau驱动程序加入黑名单 (1) 打开黑名单列表文件 终端输入&#xff1a; sudo gedit /etc/modprobe…

共享单车(八):数据库

实现后台数据库访问模块的框架&#xff0c;能够实现验证请求并响应&#xff08;支持数据库操作&#xff09;。 数据库设计 class SqlTabel //负责数据库表的创建 { public:SqlTabel(std::shared_ptr<MysqlConnection> sqlconn) :sqlconn_(sqlconn) {}bool CreateUserI…

Mysql之基本架构

1.Mysql简介 mysql是一种关系型数据库&#xff0c;由表结构来存储数据与数据之间的关系&#xff0c;同时为sql(结构化查询语句)来进行数据操作。 sql语句进行操作又分为几个重要的操作类型 DQL: Data Query Language 数据查询语句 DML: Data Manipulation Language 添加、删…

Windows下安装部署rocketmq

1.1.下载安装rocketmq 下载 | RocketMQ 下载完后解压到自定义目录&#xff0c;MQ解压路径\rocketmq-all-4.6.0-bin-release&#xff1b;&#xff08;Windows10系统解压路径不要出现空格&#xff09; 1.2.配置环境变量 配置环境变量&#xff0c;变量名&#xff1a;ROCKETM…

Git 仓库中 -- 代码冲突产生、定位、解决的流程

目录 前置知识1 工具环境2 冲突的产生2.1 仓库中的源代码2.2 人员 A 首先更改代码2.3 人员 B 更改代码&#xff0c;产生冲突2.3.1 第一次错误提示&#xff1a;2.3.2 第二次错误提示&#xff1a; 3 查看冲突4 手动解决冲突4.1 方式一4.2 方式二&#xff08;tortoisegit&#xff…

mysql设置密码,修改密码,破解密码

目录 mysql官方文档 1. mysql中文文档地址&#xff1a; 2. mysql英文文档地址&#xff1a; 一、数据库设置密码&#xff1a; 1.命令行模式&#xff1a; 2.进入数据库设置密码&#xff1a; 二、数据库修改密码&#xff08;需要知道旧密码&#xff09;&#xff1a; 1.命令…

vue 展示svg矢量图可缩放拖动

使用插件&#xff1a;svg-pan-zoom <template> <!-- svg图--><div id"svgContainer"></div> </template><script> import svgPanZoom from svg-pan-zoom import svgFile from ../datav/img/220kVscb.svg // 路径根据实际情况调…

同旺科技 FLUKE ADPT 隔离版发布 ---- 说明书

所需设备&#xff1a; 1、FLUKE ADPT 隔离版 内附链接&#xff1b; 应用于&#xff1a;福禄克Fluke 12E / 15BMax / 17B Max / 101 / 106 / 107 应用于&#xff1a;福禄克Fluke 15B / 17B / 18B

Spring 事件监听

参考&#xff1a;Spring事件监听流程分析【源码浅析】_private void processbean(final string beanname, fi-CSDN博客 一、简介 Spring早期通过实现ApplicationListener接口定义监听事件&#xff0c;Spring 4.2开始通过EventListener注解实现监听事件 FunctionalInterface p…

栈和队列的经典例题,LeetCode 括号匹配问题;栈实现队列;队列实现栈;队列带环问题

1.前序 又有很久没有更新文章了&#xff0c;这次带你们手撕几道基础题&#xff1b;真的就和康纳吃饭一样简单&#xff01;&#xff01;&#xff01; 如果还不会队列和栈的可以去看看之前写的博客&#xff1b; 栈的实现 队列概念以及实现 <- 快速传送 目录 1.前序 …

HTTP响应的基本概念

目录 HTTP响应中的一些信息 HTTPS HTTP响应中的一些信息 状态码&#xff1a;描述了这次HTTP请求是否成功&#xff0c;以及失败的原因。 1&#xff09;200 ---OK 表示这次访问成功了。 2&#xff09;404 ---Not Found 表示客户端请求的资源在服务器这边不存在。 3&a…