Redis 事务 总结

news2024/11/28 6:27:59

前言


 相关系列

  • 《Redis & 目录》(持续更新)
  • 《Redis & 事务 & 源码》(学习过程/多有漏误/仅作参考/不再更新)
  • 《Redis & 事务 & 总结》(学习总结/最新最准/持续更新)
  • 《Redis & 事务 & 问题》(学习解答/持续更新)
     

 参考文献

  • 《Redis事务详解》
     
     

概述


    Redis事务并不严格具备ACID属性。在我们对数据库的常规理解中,事务必然会严格遵守原子性/一致性/隔离性/持久性。但由于Redis基于内存设计/实现的原因,其对事务ACID属性的实现并不存在/彻底。因此与其称之为事务,将之称为批处理其实更加贴切…该知识点会在下文讲解ACID时详述。

    Redis事务的意义是为了防止插队。Redis事务中的指令会被打包一次执行,因此可以避免多客户端指令交互执行的情况发生。
 
 

使用


 开启/执行/取消

    事务的开启/执行/取消指令具体如下:

  • MULTI:开启事务;
  • EXEC:执行事务;
// ---- 设置一个键/值为num/1的键值对。
> SET num 1
OK
// ---- 开启事务,并依次递增/递减/递增。每个指令输入后都会返回QUEUED,意味着指令已被成功加入
// 事务队列中,等待最终被执行。
> MULTI
OK
> INCR num
QUEUED
> DECR num
QUEUED
> INCR num
QUEUED
// ---- 执行事务,并返回每条指令的执行结果。
> EXEC
2
1
2
  • DISCARD:在执行前取消事务。
> SET num 1
OK
// ---- 开启事务,并添加递增/递减/递增指令。
> MULTI
OK
> INCR num
QUEUED
> DECR num
QUEUED
> INCR num
QUEUED
// ---- 取消事务。
> DISCARD
OK
// ---- 取消事务后再执行会抛出错误。
> EXEC
(error) ERR EXEC without MULTI

 

 阶段

    Redis事务分为组队/执行两个阶段。组队阶段是Redis事务的第一阶段,由指令“MULTI”在开启事务时同步开启。在组队阶段中Redis会创建相应的事务队列用于顺序接收客户端发送的各项指令,因此事务中的指令其实是多次发送的。而由于Redis不可能在客户端发送全部指令/发送“EXEC”指令/发送“DISCARD”前无限等待,因为整个事务指令发送过程的时长并不可控,因此Redis实际上可以并发接受多个客户端指令。这种并发接收可能是单线程在多客户端之间相互切换实现的,也可能真的有多个线程在各自为政,这具体与Redis的版本有关。随着Redis的不断发展,早期(6.0之前)版本的“单线程实现”描述其实已经不太准确了,就比如现今绝大多数版本的Redis都会启用额外线程来实现数据持久化。但一直以来始终不变的是指令必然只会由唯一的主线程执行,因此在该设计被破坏前,无论Redis如何引入多线程,其都可以被称为单线程实现。

在这里插入图片描述

    Redis事务可能无法进入执行阶段。执行阶段顾名思义,即是将已完成组队的事务指令整体交由主线程依次执行。而由于执行阶段会由“EXEC”负责开启,因此如果客户端事先发送了“DISCARD”指令,那么事务/事务队列就会直接结束/丢弃而无法进入执行阶段。而除此之外如果客户端发送的指令出现语法错误,那事务也会因为原子性而直接结束…该知识点会在下文讲解原子性时详述。
 
 

实现


 原子性

    Redis事务具备“伪”原子性。原子性通俗的说法就是“要么一起成功,要么一起失败”,关于Redis事务的原子性一直是相当具有争议的点,原因就是其未曾“完全”遵循原子性的定义,即其允许在某些情况下部分成功。因此Redis具备原子性虽然属于官方说法,但仍有部分开发者坚持认为其并不具备原子性。而对于作者本人而言我认为Redis是具有原子性的,只是基于其功能定位而难以/无法实现的足够彻底而已,因此我将这种原子性称为“伪”原子性。

    Redis事务在组队阶段具备“真”原子性。对于在组队阶段的事务而言,如果客户端输入的指令在语法上存在错误,那么其整个事务/事务队列都会直接结束/丢弃。该行为符合原子性的标准定义,因此Redis事务在组队阶段具备“真”原子性…具体图示/案例如下:

在这里插入图片描述

> SET num 1
OK
> MULTI
OK
> INCR num
QUEUED
// ---- 错误指令,不同版本的Redis/图形客户端在此会有不同的表现,我这里显示排队成功,但有些版本会直接报错。
> INCR1 num
QUEUED
> INCR num
QUEUED
// ---- 执行时由于存在错误指令会抛出异常,整体不执行。
> EXEC
ReplyError: EXECABORT Transaction discarded because of previous errors.

    Redis事务在执行阶段具备“伪”原子性。对于在执行阶段的事务而言,即使其在过程中出现某指令执行异常的情况,Redis也只会记录该异常并继续执行后续指令,因此Redis事务并不具备数据回滚能力。该行为明显违背了原子性的标准定义,因此Redis事务在执行阶段只具备“伪”原子性…具体图示/案例如下:

在这里插入图片描述

> SET name aaa
OK
> MULTI
OK
> SET name bbb
QUEUED
// ---- 该指令没有语法错误,但字符串类型是无法递增的。
> INCR name
QUEUED
> SET name ccc
QUEUED
// ---- 执行后只有两个结果,因为第二条指令会执行失败。可能是因为Redis版本/图形客户端
// 的原因,我这里没有抛出异常。
> EXEC
OK
OK

 

 一致性/持久性

    Redis事务具备结构一致性,但不具备内容一致性。Redis并不像Mysql一样对数据存在为空/大小/长度/范围/唯一/外键等结构性约束,故而事务数据只要计算成功其结构就必然合理,因此Redis事务具备结构一致性。但与此同时Redis事务却不具备内容一致性,因为其“伪”原子性无法保证所有指令全都执行成功。例如Redis事务就无法保证账号A/B在收/支上的一致性,因为两者的指令都存在失败可能,而任意一方的失败都将导致收支上的不平衡,因为Redis事务不具备内容一致性。

    Redis事务不(直接)具备持久性。所谓持久性是指数据被永久保存的特性,Redis存在RDB/AOF两种持久化机制,在两者被打开至少一个的情况下,Redis可以将内存中的数据持久化至磁盘中永久保存,从而“尽可能”避免在宕机/关机/重启/断电时丢失数据。该知识点会在Redis持久化的专项文章中详述,此处我们只需知道的是:虽然Redis具备全局性的数据持久化能力,但遗憾的是该机制的运行与事务是完全独立的,即事务的执行并不会强制触发该机制以实现对事务数据的持久化。因此Redis事务是不具备持久性的,虽然全局性的持久化机制可以在一定程度上间接达成这个效果。
 

 隔离性/WATCH

    Redis事务具备“读已递交”级别的隔离性。所谓隔离性是指事务并发期间的相互影响程度,这种相互影响在数据库的标准定义中被从低到高的被分为四个级别,其具体名称/问题/效果如下所示。而Redis没有设计任何专项机制去提升事务的隔离性,因此Redis事务仅天然具有“读已递交”级别的隔离性。为什么不是“读未递交”级别的隔离性呢?这是因为Redis事务压根没有统一递交的说法…其指令的每次执行都可以直接视作数据的一次递交。

名称问题效果
读未递交脏读/不可重复度/幻读会读取到其它事务未递交的数据,并且即无法保证数据的内容不变化,也无法保证数据的数量不变化
读已递交不可重复度/幻读不会读取到其它事务未递交的数据,但即无法保证数据的内容不变化,也无法保证数据的数量不变化
可重复读幻读不会读取到其它事务未递交的数据,并且可以保证数据的内容不变化,但无法保证数据的数量不变化
序列化/事务串行执行,相互之间完全不影响

    Redis事务在执行阶段具备“序列化”等级的隔离级别。由于单线程实现的原因,Redis事务在执行阶段其实具备“序列化”等级的隔离级别。因为在此期间其它事务最多只能处于组队阶段而无法处于执行阶段,甚至在早期版本中都可能不存在其它事务,因此对于当前正在执行的事务来说是绝对不可能出现目标数据被并发修改的情况的。那为什么说Redis事务只具备“读已递交”级别的隔离性呢?这是因为如果反过来看正处于组队阶段的当前事务,那么其目标数据就完全可能被处于执行阶段的其它事务所并发修改,从而导致出现执行前提被破坏的“竞态条件”情况…具体示例时间表如下:

时间事务1事务2
T1商品总量为5000,开启事务商品总量为5000,开启事务
T2组队指令 – 设置商品总量为4000(-1000)组队指令 – 设置商品总量为3000(-2000)
T3单线程执行指令 – 商品总量被设置为3000T4单线程执行指令 – 商品总量被设置为4000但正确总量应该为2000

    Redis提供了乐观锁机制的{WTACH}指令用于监控事务的目标数据。上述问题的本质还是线程安全问题,其核心在于指令的执行依据被并发修改,因此只要能够控制这一点就能为事务的正确执行提供基础可能。对此Redis基于乐观锁机制提供了{WTACH}指令用于监控目标数据,其本质是记录目标数据的快照。而当事务进入执行阶段时其会将最新的目标数据与快照进行对比,并在发现目标数据已变化的情况下拒绝执行事务并返回null…具体示例如下:

  • WATCH key [key …]:监控目标数据集,并在目标数据发生变化时拒绝执行事务。
        ------------------------- 入参 -------------------------
        key [key …] @ 键集:需监控目标数据集的键集,多个键之间使用" "分割。
// ---- 设置/监控目标数据,并开启事务。
> SET goal aaaa
OK
> WATCH goal
OK
> MULTI
OK
// ---- 更新目标数据。
> SET goal bbbb
QUEUED
// ---- 如果目标数据在事务组队期间被其它线程/事务修改,当前事务将不会执行并返回null。
> EXEC
null

 
 

管道


    管道可大幅提升多指令的执行效率。管道相当于将事务的组队阶段从服务端转移到了客户端执行,因此其不会像事务一样多次发送指令,而是会直接将已完成打包/组队的命令集一次性发送至服务端执行。而又因为Redis执行的高效性会使得指令/数据的RRT @ Round Trip Time @ 往返时间/网络传输时间远远多于指令的执行时间,因此多指令/数据的一次性发送/返回能够有效提升批量操作的执行效率,也因此管道被广泛用于数据大批量导入/导出的场景中。

在这里插入图片描述

    Redis管道无法通过原生指令开启…下文展示的是通过Jedis使用管道的模板:

public static void testPipeLineAndNormal(Jedis jedis) throws InterruptedException {
    // ---- 开启管道。
    Pipeline pipeline = jedis.pipelined();
    // ---- 在管道中添加多个SET指令。
    for (int i = 0; i < 10000; i++) {
        pipe.set(String.valueOf(i), String.valueOf(i));
    }
    // ---- 一次性发送/执行管道指令。
    pipe.sync();
}

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

正点原子阿尔法ARM开发板-IMX6ULL(十一)——IIC协议和SPI协议--AP3216C环境光传感器和ICM20608六轴传感器

文章目录 一、前言二、 IIC协议2.1 协议解读2.1.1 起始位、停止位、数据传输2.1.2 写时序2.1.3 读时序 2.2 代码分析2.3 AP3216C环境光传感器的代码分析 三、SPI协议3.1 协议解读3.2 代码分析3.3 ICM-20608六轴传感器代码分析 一、前言 看了IIC&#xff0c;我之前毕设用过这个…

Vmware虚拟机解决摄像头无效,相机失效

问题&#xff1a; 使用vmware虚拟机&#xff0c;打开windows的虚拟机&#xff0c;发现找不到摄像头&#xff0c;打开自带的相机软件报错&#xff1a; 解决方法如下&#xff0c;依次点击vmware状态栏的 虚拟机-可移动设备-chicony integrated camera-连接&#xff08;断开与主…

MySQL用户权限管理属于SQL语句中的DCL语句

1.用户授权 语法&#xff1a;grant 权限&#xff0c;权限&#xff0c;on 库名&#xff0c;表名 to 用户名 [identified by 密码] MySQL5的版本&#xff0c;如果这个用户事先不存在&#xff0c;这个grant命令去给用户授权的时候&#xff0c;会将用户一起创建出来&#xff0…

已解决 django.db.utils.OperationalError: (1051, “Unknown table

报错信息&#xff1a; django.db.utils.OperationalError: (1051, "Unknown table bjybolg.tool_submission")python manage.py migrate --fake 命令用于告诉 Django 假装已经应用某个迁移&#xff0c;而不实际执行该迁移的操作。这通常在以下情况下非常有用&#x…

Linux shell编程学习笔记87:blkid命令——获取块设备信息

0 引言 在进行系统安全检测时&#xff0c;我们需要收集块设备的信息&#xff0c;这些可以通过blkid命令来获取。 1 blkid命令的安装 blkid命令是基于libblkid库的命令行工具&#xff0c;可以在大多数Linux发行版中使用。 如果你的Linux系统中没有安装blkid命令&#xff0c;…

堆的应用——堆排序和TOP-K问题

1.堆排序 想法⼀&#xff1a; 基于已有数组建堆、取堆顶元素完成排序。也就是利用写好的堆数据结构&#xff08;之前的文章有讲解&#xff09;&#xff0c;去实现排序。 void HeapSort(int* a, int n){HP hp;for(int i 0; i < n; i){HPPush(&hp,a[i]);}int i 0;whi…

HexForge:一款用于扩展安全汇编和十六进制视图的IDA插件

关于HexForge HexForge是一款用于扩展安全汇编和十六进制视图的IDA插件&#xff0c;在该工具的帮助下&#xff0c;广大研究人员可以方便地直接从 IDA Pro 界面数据解码、解密或执行安全数据审计任务。 功能介绍 1、从 IDA 的反汇编或十六进制视图复制原始十六进制&#xff1b;…

00 DSA-- 入门、实现动态数组、实现链表、栈和队列、环形数组、哈希表

两种代码模式 核心代码模式 核心代码模式&#xff1a;就是给你一个函数框架&#xff0c;你需要实现函数逻辑&#xff0c;这种模式一般称之为。 目前大部分刷题平台和技术面试/笔试场景都是核心代码模式。 比如力扣第一题两数之和&#xff0c;就是给出 twoSum 函数的框架如下…

Jmeter压力测试简单教程(包括服务器状态监控)

前段时间公司需要对服务器进行压力测试&#xff0c;包括登录前的页面和登录后的页面&#xff0c;主要目的是测试负载均衡的实现效果。不知道是不是因为Jmeter不如loadRunner火爆还是什么&#xff0c;网上关于Jmeter的资料有很多但是大多千篇一律&#xff0c;要么简单弄个页面测…

Android 开发 调节声音 SeekBar自定义样式

效果图 xml布局 mipmap/seekbar图片随意一张图都可以&#xff0c;这里我的图就不贴出来了 <SeekBarandroid:id"id/seekBar"android:layout_marginLeft"8dp"android:layout_width"377dp"android:layout_height"8dp"android:layou…

循序渐进丨openGauss / MogDB 数据库内存占用相关SQL

一、内存总体分布 数据库总体内存使用分布 select * from gs_total_memory_detail; 当dynamic_used_memory大于max_dynamic_memory就会报内存不足&#xff1b;如果此时dynamic_used_memory小于max_dynamic_memory&#xff0c;而dynamic_peak_memory大于max_dynamic_memory表…

基于vite和vue3、 eslint、prettier、stylelint、husky规范

前言 在现代的前端开发中&#xff0c;代码规范非常重要。它可以提高团队的协作效率&#xff0c;减少代码错误&#xff0c;使代码更易于维护。为了实现代码规范化&#xff0c;我们可以使用一些工具来辅助我们的开发流程&#xff0c;包括eslint、prettier、stylelint、husky&am…

MYSQL-SQL-03-DQL(Data Query Language,数据查询语言)(单表查询)

DQL&#xff08;数据查询语言&#xff09; DQL英文全称是Data Query Language(数据查询语言)&#xff0c;数据查询语言&#xff0c;用来查询数据库中表的记录。 查询关键字: SELECT 在一个正常的业务系统中&#xff0c;查询操作的频次是要远高于增删改的&#xff0c;当我们去访…

宇音天下最新力作 | VTX356语音识别合成芯片问世

北京宇音天下科技有限公司&#xff0c;依托在语音技术领域的丰富经验和技术积累&#xff0c;成功推出了一款具有里程碑意义的语音识别合成芯片——VTX356。这款芯片的问世&#xff0c;不仅彰显了公司在智能语音处理领域的专业实力&#xff0c;也预示着智能家居、车载电子、智能…

开始菜单增强工具 StartAllBack v3.7.10.4910 直装激活版

StartAllBack中文版(StartIsBack)是一款Win11开始菜单增强工具&#xff0c;可以为Windows11恢复经典样式的Windows7主题风格开始菜单和任务栏&#xff0c;功能包括了&#xff1a;自定义开始菜单样式和操作&#xff0c;个性化任务栏及资源管理器等。 详细功能 √ 全面更新中文语…

java中Scanner的nextLine和next方法

思考&#xff0c;输入1 2 3 4 5加上enter&#xff0c;输出什么 import java.util.Scanner;public class Main {public static void main(String[] args) {Scanner sc new Scanner(System.in);int[][] m new int[2][2];for (int i 0; i < 2; i) {for (int j 0; j < 2;…

DataX数据同步

背景&#xff1a; 业务需求中&#xff0c;经常会有同步各种系统或者数仓的数据到自己的库进行使用。比如从oracle同步到自己的mysql&#xff0c;自己写代码如果数据量大需要考虑多线程并发等。最近使用了阿里的Datax项目&#xff0c;操作简单并高效。 Datax Datax概述&支…

如何使用的是github提供的Azure OpenAI服务

使用的是github提供的Azure OpenAI的服务gpt-4o 说明&#xff1a;使用的是github提供的Azure OpenAI的服务&#xff0c;可以无限薅羊毛。开源地址 进入&#xff1a; 地址 进入后点击 右上角“Get API key”按钮 点击“Get developer key” 选择Beta版本“Generate new to…

高可用HA软件

高可用HA&#xff08;High Availability&#xff09;软件在分布式系统架构设计中至关重要&#xff0c;它们能够减少系统停机时间&#xff0c;确保应用程序持久、不间断地提供服务。以下是四款常用的高可用HA软件介绍&#xff1a; Keepalived Keepalived起初是为LVS&#xff08;…

Python小白学习教程从入门到入坑------第十八课 异常模块与包【上】(语法基础)

一、异常 在Python中&#xff0c;异常&#xff08;Exception&#xff09;是一种用于处理在程序运行时可能发生的错误情况的机制 异常允许程序在检测到错误时不是简单地崩溃&#xff0c;而是能够优雅地处理这些错误&#xff0c;可能包括记录错误信息、清理资源、或者向用户提…