深入理解Redis事务、事务异常、乐观锁、管道

Redis事务与MySQL事务

  • 不一样。
  • 原子性：MySQL有Undo Log机制，支持强原子性，和回滚。Redis只能保证事务内指令可以不被干扰的在同一批次执行，且没有机制保证全部成功则提交，部分失败则回滚。
  • 隔离性：MySQL的隔离性指多个事务可以并发执行，MySQL有MVCC机制。而Redis没有，Redis是事务提交前的指令不会被执行，单线程的环境下，也就不存在事务未提交时，事务内外数据不一致的隔离性问题了。
  • 持久性：MySQL事务先写Undo Log，并有Redo Log的两阶段提交机制，可以保证持久性。但是Redis持久化机制只有RDB和AOF持久化策略，若事务成功执行且数据刚好被保存，则可以满足持久性。
  • 一致性：MySQL是指数据库从一个合法（指符合业务预期）状态转换成另一个合法状态，这种只要Redis执行不出错，可以保证。

Redis事务

  • 官方文档：https://redis.io/docs/latest/develop/interact/transactions/
  • 极简概括：将一批要执行的Redis指令，放入Redis的执行队列中，事务执行时（不包含事务未提交时） 使其不被并发过来的任务干扰执行。（无法做到严格意义上的ACID 4特性）。
  • 适用场景：
    • 性能优化：10条命令传输10次执行10次，与1次批量执行10条命令，性能有差异。
    • 乐观锁实现：结合Watch可以实现乐观锁。
  • 优点：如上的应用场景就是优点。
  • 缺点：无法像MySQL那样保证原子性、持久性。
  • 关键字：mutli（开启事务），discard（停止事务）、exec（执行事务）、watch（监视指定key）、unwatch（取消监视所有key）。

事务操作实操

测试multi与exec，常规执行

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set a a
QUEUED
127.0.0.1:6379> set b b
QUEUED
127.0.0.1:6379> exec
1) OK
2) OK

测试discard，事务未提交，强行终止，则修改不会生效

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set a a1
QUEUED
127.0.0.1:6379> set b b1
QUEUED
127.0.0.1:6379> discard
OK
127.0.0.1:6379> get a
"a"
127.0.0.1:6379> get b
"b"

Redis事务异常（语法错误导致整个事务执行失败，非回滚操作）

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set a a2
QUEUED
127.0.0.1:6379> sset b b2
(error) ERR unknown command `sset`, with args beginning with: `b`, `b2`, 
127.0.0.1:6379> exec
(error) EXECABORT Transaction discarded because of previous errors.
127.0.0.1:6379> get a
"a"
127.0.0.1:6379> get b
"b"

Redis事务异常（非语法错误引起的部分失败，无法保证ACID中的A，无回滚机制）

127.0.0.1:6379> multi
OK
127.0.0.1:6379> set a aa
QUEUED
127.0.0.1:6379> incr a
QUEUED
127.0.0.1:6379> set b bb
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 a
"aa"
127.0.0.1:6379> get b
"bb"

有Redis事务，为什么又出来了Lua？

  • Redis事务和Lua机制并不冲突，并且要比Redis事务更加强大。
  • 应对并发安全问题：虽然有了Lua的加持，仍不支持事务回滚或者，强原子性（要么都成功，要么都回滚），但是Lua可以保证当前的操作不被打断（无间隙执行），应对并发（例如超卖）问题，Lua能妥善解决。
  • Redis事务不支持流程控制，只支持函数调用：配合Lua用于实现无间隙执行的复杂逻辑，这样的用法非常多。因为高并发下，若单纯利用编程语言多次调Redis，实现判断或循环逻辑，这中间有间隙，会有并发问题发生。
    Lua是一门高性能脚本语言，Lua由标准C编写而成，几乎在所有操作系统和平台上都可以编译、运行。Lua脚本可以很容易的被C/C++代码调用，也可以反过来调用C/C++的函数，这使得Lua在应用程序中可以被广泛应用。

关于Redis+Lua是否是原子性执行的争议问题

https://redis.io/docs/latest/develop/interact/programmability/eval-intro/
对Redis官网进行搜索，出现了原子性的字眼。
原话是：
Blocking semantics that ensure the script’s atomic execution.
Lua lets you run part of your application logic inside Redis. Such scripts can perform conditional updates across multiple keys, possibly combining several different data types atomically.

但是我想了想有矛盾的地方：
MySQL使用了undo log来保证原子性，要么成功全部执行，要么失败全部回滚。
众所周知，Redis不支持回滚的，那么ACID的A就没办法全部保证，最多是没有执行期间没有间隙，不被其它过来的请求影响，引起并发问题。

然后我又看了看阿里某架构师对此的剖析，跟我设想的一样：
Redis会把Lua脚本当做一个整体去执行，中间不会被其它的命令插入，但是如果执行过程中出现了错误，事务是不会回滚的。
也就意味着执行Lua脚本的过程不可被拆分，不可被中断，但是遇到错误不会回滚。

Redis乐观锁

  • 悲观锁：很悲观，认为数据大概率会有并发一致性问题，首次请求过来时加具有互斥性的锁阻塞其它并发请求，但是Redis是高性能组件，阻塞会带来性能问题，所以不用悲观锁。
  • 乐观锁：乐观，认为数据小概率有并发一致性问题，所以读数据时不上锁，但是写数据时，会判断一下这个数据是否被改动，从而在旧值的基础上做修改，如果数据被改动，则失败掉此次执行。
  • 注意：redis在事务exec或者discard，都会取消对key的watch操作。
  • 解决问题：高并发读多写少场景下Redis数据一致性问题。
  • 演变：

假设用户a账户有100元，此时要添加10元

127.0.0.1:6379> set a_money 100
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incrby a_money 10
QUEUED
127.0.0.1:6379> exec
1) (integer) 110
127.0.0.1:6379> get a_money
"110"

假设用户a账户有110元，此时要添加20元，但是事务未提交期间，已经被其它请求改为了115，然后事务内加了20。
由于是加法，所以值正确，但是事务内的数据一般是不让改的，很多情况下的自增或者自减，是需要以原数据为基础基础为准的（这也是MySQL隔离级别的用意，所以有了当前读和快照读的区分）。

终端1
127.0.0.1:6379> get a_money
"110"
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incrby a_money 20
QUEUED终端2
127.0.0.1:6379> get a_money
"110"
127.0.0.1:6379> incrby a_money 5
(integer) 115终端1
127.0.0.1:6379> get a_money
"110"
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incrby a_money 20
QUEUED
127.0.0.1:6379> exec
1) (integer) 135
127.0.0.1:6379> get a_money
"135"

Redis没有事务的隔离机制怎么办？使用watch加锁。

终端一
127.0.0.1:6379> watch a_money
OK
127.0.0.1:6379> get a_money
"135"
127.0.0.1:6379> multi
OK
127.0.0.1:6379> incrby a_money 20
QUEUED终端二模拟其它并发用户
127.0.0.1:6379> incrby a_money 5
(integer) 140终端1
127.0.0.1:6379> exec
(nil)
127.0.0.1:6379> get a_money
"140"
事务没有成功被执行，因为watch监控了a_money的值，一旦事务执行期间，被事务外的请求锁修改，则失败掉此次事务。
乐观锁，在此处的体现就是，利用watch监控一下事务执行期间，a_money的值是否被改动。

unwatch 使用

终端1
127.0.0.1:6379> set a a
OK
127.0.0.1:6379> watch a
OK
127.0.0.1:6379> unwatch
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set a a1终端2，模拟并发过来的用户请求
127.0.0.1:6379> set a a2
OK终端1，执行unwatch后，取消了对所有key的监控，执行exec时，就不是nil了。
127.0.0.1:6379> exec
1) OK
127.0.0.1:6379> get a
"a1

watch部分key，其余key的反应

终端1
127.0.0.1:6379> set a a
OK
127.0.0.1:6379> set b b
OK
127.0.0.1:6379> watch a
OK
127.0.0.1:6379> multi
OK
127.0.0.1:6379> set a a1
QUEUED
127.0.0.1:6379> set b b1
QUEUED终端2
127.0.0.1:6379> set a a2
OK
127.0.0.1:6379> set b b2
OK终端1，watch a,没有watch b，事务提交时，被watch的key，可以影响没有被watch的key。
127.0.0.1:6379> exec
(nil)
127.0.0.1:6379> get a
"a2"
127.0.0.1:6379> get b
"b2"

管道

  • 官方文档：https://redis.io/docs/latest/develop/use/pipelining/
  • 极简概括：将多个指令的操作，一次性发送给Redis，进行批量处理。
  • 解决问题：减少网络开销，减少频繁接收命令的开销（10轮request->exec->response，精简为1次request->10次exec->1次response），避免多条Redis指令通信往返时间。避免Redis服务器频繁的从用户态到内核态的调用，减少上下文通信时间。
  • 与事务对比：批量处理指令的行为，类似事务。
  • 注意：redis-cli会话内部并未提供管道命令，（但是使用Linux Shell端支持STDIN标准输入到redis-cli实现管道，例如echo -e "set a aa \n set b bb" | redis-cli --pipe），但redis-server提供了这个机制，管道机制最好用编程语言的客户端演示。
若在redis-cli会话内部实现管道，会有如下提示：
127.0.0.1:6379> pipe
(error) ERR unknown command `pipe`, with args beginning with: 
127.0.0.1:6379> pipeline
(error) ERR unknown command `pipeline`, with args beginning with:
  • PHP实现：
<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);$pipe = $redis->pipeline();$pipe->set('key1', 'value1');
$pipe->set('key2', 'value2');
$pipe->get('key1');
$pipe->get('key2');$responses = $pipe->exec();var_dump($responses);$redis->close();返回执行的结果
array(4) {[0]=>bool(true)[1]=>bool(true)[2]=>string(6) "value1"[3]=>string(6) "value2"
}

管道异常情况（Redis语法错误）

以PHP为例，经实际测试（set函数缺少参数2），Redis调用语法错误（非PHP语法错误），会升级为PHP出现致命错误，管道流程走不下去。

Fatal error: Uncaught ArgumentCountError: Redis::set() expects at least 2 arguments, 1 given in E:\Host\test\t1.php:7
Stack trace:
#0 E:\Host\test\t1.php(7): Redis->set('a')
#1 {main}thrown in E:\Host\test\t1.php on line 7

管道异常情况（Redis执行异常）

经过实测，对字符串进行递增操作，除了incr返回false外，其余上下文代码执行不受影响。

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);$pipe = $redis->pipeline();$pipe->set('a', 'a');
$pipe->incr('a');
$pipe->set('b', 'b');
$pipe->get('a');
$pipe->get('b');$responses = $pipe->exec();var_dump($responses);$redis->close();array(5) {     [0]=>        bool(true)[1]=>bool(false)[2]=>bool(true)[3]=>string(1) "a"[4]=>string(1) "b"
}

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【YOLOv5/v7改进系列】引入ODConv——即插即用的卷积块

【YOLOv5/v7改进系列】引入ODConv——即插即用的卷积块

一、导言 提出了一种称为全维度动态卷积(ODConv)的新颖设计&#xff0c;旨在克服当前动态卷积方法的局限性并提升卷积神经网络(CNN)的性能。以下是该论文提出的全维度动态卷积设计的优点和存在的缺点分析&#xff1a; 优点&#xff1a; 增强特征学习能力&#xff1a; ODConv通…
阅读更多...
【UML用户指南】-04-从代码到UML的关键抽象

【UML用户指南】-04-从代码到UML的关键抽象

1、关键抽象 声明了一个名为paint的操作&#xff0c;它的实现调用名为drawString的另一个操作&#xff0c;drawString操作负责在指定的位置上打印“Hello,World!”。在通常的面向对象的方式下&#xff0c;drawString是一个名称为g的参数上的一个操作&#xff0c;g的类型是类Gr…
阅读更多...
VMWare下安装Linux虚拟机（图文）

VMWare下安装Linux虚拟机（图文）

大家好&#xff0c;在当今科技发展迅速的时代&#xff0c;虚拟化技术在企业和个人用户中变得越来越普遍。VMware作为一款领先的虚拟化软件&#xff0c;为用户提供了在单一物理计算机上运行多个操作系统的能力&#xff0c;为开发、测试和运维等任务提供了便利。在这篇文章中&…
阅读更多...
打开C语言常用的内存函数大门(三) —— memset()函数（内含讲解用法和模拟实现）

打开C语言常用的内存函数大门(三) —— memset()函数（内含讲解用法和模拟实现）

文章目录 1. 前言2. memset函数2.1 memset函数原型2.2 memset函数参数的介绍2.3 memset函数的使用演示 3. memset函数的模拟实现4. 总结 1. 前言 哈喽&#xff0c;我们又见面了。通过前面两个内存函数(memcpy、memmove函数)讲解的锤炼后&#xff0c;对如何解析一个自己从来没有…
阅读更多...
【TB作品】msp430f5529单片机墨水屏，口袋板，tmp421温度，温控风扇

【TB作品】msp430f5529单片机墨水屏，口袋板，tmp421温度，温控风扇

文章目录 一、扬声器模块介绍二、驱动介绍三、程序介绍四、全部代码下载 msp430f5529d单片机墨水屏&#xff0c;口袋板&#xff0c;tmp421温度&#xff0c;温控风扇 基本要求&#xff1a;高于20度开转&#xff0c;温度越高转速越快&#xff0c;高于40度风扇停转&#xff0c;温…
阅读更多...
PHPstudy情况下上传图片马需要的.htaccess文件

PHPstudy情况下上传图片马需要的.htaccess文件

网上的方法是无效的&#xff1a; <FilesMatch "test.jpg">SetHandler application/x-httpd-php</FilesMatch>原因是新版本的phpstudy使用了cgi模式,而网上的方法只适用于linux模式。 <FilesMatch "tpm.png"> AddHandler fcgid-script …
阅读更多...
知识计算概述

知识计算概述

文章目录 知识计算研究现状技术发展趋势 知识计算 随着知识图谱技术及应用的不断发展&#xff0c;图谱质量和知识完备性成为影响知识图谱应用的两大重要难题&#xff0c;以图谱质量提升、潜在关系挖掘与补全、知识统计与知识推理作为主要研究内容的知识计算成为知识图谱应用的重…
阅读更多...
C语言 | Leetcode C语言题解之第119题杨辉三角II

C语言 | Leetcode C语言题解之第119题杨辉三角II

题目&#xff1a; 题解&#xff1a; int* getRow(int rowIndex, int* returnSize) {*returnSize rowIndex 1;int* row malloc(sizeof(int) * (*returnSize));row[0] 1;for (int i 1; i < rowIndex; i) {row[i] 1LL * row[i - 1] * (rowIndex - i 1) / i;}return row…
阅读更多...
Qt第三方库QicsTable简单实例（1）

Qt第三方库QicsTable简单实例（1）

闲来无事&#xff0c;无意间看到一个Qics表格操作第三方库&#xff0c;自己写了一个特别简单的实例&#xff0c;效果如图所示&#xff1a; 操作界面的数据还是特别快的&#xff0c;因为使用了模型
阅读更多...
【Spring Cloud】分布式配置动态刷新

【Spring Cloud】分布式配置动态刷新

目录 问题解决方案1.使用Spring Boot Actuator监控接口【不推荐】流程图使用Spring Boot Actuator的步骤 2.Spring Cloud Bus第一种方案问题Spring Cloud Bus流程图Spring Cloud Bus实现客户端刷新的步骤开发准备实现1. 在config-server中添加依赖2.在config-server中添加配置a…
阅读更多...
你喜欢什么样的狗？喜欢内狗还是外狗？论看门狗的重要性：极低功耗微处理器复位电路CN803/CN809/CN810

你喜欢什么样的狗？喜欢内狗还是外狗？论看门狗的重要性：极低功耗微处理器复位电路CN803/CN809/CN810

看门狗&#xff1a;缩写WTD,英文WATCH DOG. 你的程序会死机吗&#xff1f; 陷入死循环或程序指针不知跑哪里去了&#xff0c;看门狗的作用是把程序拉回来&#xff0c;重新开始跑。 有了看门狗&#xff0c;程序就不会死机&#xff0c;所以很重要。 比如一个温度控制器&#xf…
阅读更多...
OBproxy基础运维

OBproxy基础运维

简介 obproxy 属于OceanBase的代理&#xff0c;生产环境中 OceanBase 数据库的数据 会以 多副本的形式 存放在各个 OBServer 节点上&#xff0c;obproxy 接收用户发出的 SQL 请求&#xff0c;并将 SQL 请求转发至最佳目标 OBServer 节点&#xff0c;最后将执行结果返回给用户&…
阅读更多...
算法题解记录27+++随机链表的复制（百日筑基）

算法题解记录27+++随机链表的复制（百日筑基）

一、题目描述&#xff1a; 题目难度&#xff1a;中等 给你一个长度为 n 的链表&#xff0c;每个节点包含一个额外增加的随机指针 random &#xff0c;该指针可以指向链表中的任何节点或空节点。 构造这个链表的 深拷贝。 深拷贝应该正好由 n 个 全新 节点组成&#xff0c;其中每…
阅读更多...
Flutter开发指南

Flutter开发指南

Flutter开发指南&#xff08;Android 开发角度&#xff09; 与Android 的对比 1.Android 的View 与Flutter 的对应关系&#xff1a; a.在android 中&#xff0c;view 是屏幕显示的基础&#xff0c;比如 button&#xff0c;文本&#xff0c;列表&#xff0c;输入框都是 view。…
阅读更多...
小柴带你学AutoSar系列一、基础知识篇（4）编译

小柴带你学AutoSar系列一、基础知识篇（4）编译

小柴带你学AutoSar总目录https://blog.csdn.net/qianshang52013/article/details/138140235?spm1001.2014.3001.5501 Flechazohttps://www.zhihu.com/people/jiu_sheng 编译真的很重要&#xff01;了解一下机器是如何工作的吧。当然啦&#xff01;通过学习这篇文章还可以学习…
阅读更多...
unityBIM

unityBIM

Revit模型到Unity勉强能用 1、Revit直接导出FBX&#xff0c;然后拖到unity里面 2、通过Navisworks导出FBX&#xff0c;拖到unity里面。 我什么都还没做&#xff0c;只建立了一个空的URP效果&#xff0c;把FBX拖进去&#xff0c;挂了一个相机控制器&#xff0c;效果勉强看得过…
阅读更多...
中医的悠久历史文化

中医的悠久历史文化

中医&#xff0c;作为中华民族的传统医学&#xff0c;拥有着悠久的历史和深厚的文化底蕴。自古以来&#xff0c;中医便以其独特的理论体系和治疗方法&#xff0c;为中华民族的繁衍昌盛做出了巨大贡献。如今&#xff0c;随着现代医学的不断发展&#xff0c;中医依然以其独特的魅…
阅读更多...
APP上架 篇三：ICP备案

APP上架 篇三：ICP备案

文章目录 系列文章ICP备案简介非经营性备案与经营性备案ICP备案官网ICP备案流程ICP备案实例（阿里云服务器+新网域名）ICP备案费用ICP许可证的流程和费用系列文章 APP上架 篇一：上架资质要求 APP上架 篇二：注册域名 APP上架 篇三：ICP备案 系列计划预告： APP上架 篇二：计…
阅读更多...
奇安信_NAC终端安全准入系统（相关问题整理）

奇安信_NAC终端安全准入系统（相关问题整理）

奇安信终端安全准入系统 ,下称NAC 一、入网控制方式 1.IP流量控制 2.802.1X 准入 需要NAC、交换机、终端 以802.1X 3.DHCP 准入 将NAC作为DHCP服务器&#xff0c;为客户端分配地址&#xff0c;并对分配地址的客户端进行入网管控。 &#xff08;*&#xff09;可选 强制入网…
阅读更多...
【计算机毕设】SpringBoot海滨体育馆管理系统设计与实现 - 源码免费（私信领取）

【计算机毕设】SpringBoot海滨体育馆管理系统设计与实现 - 源码免费（私信领取）

免费领取源码 &#xff5c; 项目完整可运行 &#xff5c; v&#xff1a;chengn7890 诚招源码校园代理&#xff01; 1. 引言 体育馆作为重要的体育场馆&#xff0c;承担着举办体育赛事、健身活动和文化演出等多种功能。为了提高体育馆的管理效率和服务质量&#xff0c;本项目旨在…
阅读更多...
最新文章

Copyright @ 2022~2023