详解mysql事务,事务并发安全问题的复现以及大事务的优化

好文推荐:
2.5万字详解23种设计模式
springboot 实现延时队列(超级实用)
2.5万字讲解DDD领域驱动设计

文章目录

  • 1. 事务定义
  • 2. 事务特性(ACID)
  • 3. 事务并发问题
  • 4. 事务隔离级别
  • 5. 基础命令
  • 6. 脏读复现
  • 7. 不可重复读复现
  • 8. 幻读复现
    • 8.1 幻读疑问
    • 8.2 MVCC
    • 8.3 快照读
    • 8.4 当前读
    • 8.5 幻读再次复现
  • 9. 大事务问题
  • 总结

在这里插入图片描述

1. 事务定义

MySQL事务是指一系列数据库操作(例如INSERT、UPDATE、DELETE等)被作为一个单独的执行单元来执行的过程。事务可以确保数据库在并发环境下的数据一致性和完整性,并支持原子性、一致性、隔离性和持久性的特性(也称为ACID特性)。

2. 事务特性(ACID)

  1. 原子性(Atomicity):事务是一个原子操作单元,要么全部执行成功,要么全部失败回滚。如果事务中的任何一个操作失败,则整个事务将被回滚到初始状态。

  2. 一致性(Consistency):事务在执行之前和执行之后,数据库的状态必须保持一致。这意味着事务将从一个一致的状态转换到另一个一致的状态,确保数据的完整性。

  3. 隔离性(Isolation):每个事务的执行都应该与其他事务相互隔离,使它们彼此独立。事务的隔离性确保并发执行的事务不会相互干扰,从而防止数据损坏或不一致。

  4. 持久性(Durability):一旦事务提交成功,其所做的更改将永久保存在数据库中,即使在系统故障或重启后也能够恢复。持久性确保事务的结果能够长期存储,以便供后续读取和使用。

3. 事务并发问题

两个事务都是读操作不会有并发问题,只有在读写或者写写场景下,就有并发问题了,后面会通过实战复现一下四种问题。

  1. 脏读:在读读场景下,一个事务读取了另一个未提交(或已回滚)事务的数据。如果读取到的数据最终不会被提交,那么本次读取就是脏读。

  2. 不可重复读:在读写(update)场景下,同一个事务内,多次读取同一行数据时,得到了不同的结果。这是由于其他事务在读取期间修改了数据造成的。

  3. 幻读:在读写(insert)场景下,一个事务读到另一个事务已提交的新插入的数据。其实这样的说法并不准确,严谨来说是在repeatable read隔离级别下,只有在当前读的情况下,才会有幻读问题,在快照读的情况下,是没有幻读问题的。什么是当前读,什么是快照读,下文会结合实例一一讲解。

  4. 更新丢失:在写写(update)场景下,两个事务同时读取同一行数据,并且同时进行修改。由于事务隔离级别的不同或执行顺序的不同,其中一个事务的修改可能会覆盖另一个事务的修改,导致更新丢失。

4. 事务隔离级别

事务隔离级别是数据库管理系统(DBMS)提供的一种机制,用于控制并发事务之间的可见性和相互影响程度。MySQL 支持四种事务隔离级别:

  1. read uncommitted:未提交读
    ①最低的隔离级别。
    ②事务可以读取其他未提交事务的未提交数据。
    ③会导致脏读、不可重复读和幻读。
  2. read committed:已提交读
    ①事务只能读取已提交事务的数据,不能读取未提交事务的数据。
    ②解决了脏读问题,但导致不可重复读和幻读。
  3. repeatable read:可重复读,MySQL默认的隔离级别。
    ①事务在开始时读取一个快照,然后在事务结束之前都使用该快照。
    ②其他事务的插入和更新会在事务结束前被阻塞。
    ③解决了脏读和不可重复读的问题,但仍存在幻读现象,幻读这里画重点,后面会讲到。
  4. serializable:序列化
    ①最高的隔离级别。
    ②所有事务按顺序执行,不允许并发,所以不建议使用,否则MySQL没有一点并发能力了
    ③提供了最强的隔离保证,完全防止脏读、不可重复读和幻读,但可能会导致性能下降,因为并发性受到限制。
事务隔离级别   		  脏读     不可重复读    幻读
read uncommitted:     否         否         否
read committed :      是         否         否
repeatable read:      是         是         否
serializable:        是         是         是

5. 基础命令

  1. 查看当前会话的事务隔离级别
SELECT @@tx_isolation;
  1. 设置当前会话的隔离级别
set session transaction isolation level read uncommitted;
set session transaction isolation level read committed;
set session transaction isolation level repeatable read;
set session transaction isolation level serializable;
  1. 开启一个事务
BEGIN;
  1. 提交一个事务
COMMIT;
  1. 回滚一个事务
ROLLBACK;

6. 脏读复现

将事务隔离级别设置为:read uncommitted

  1. 事务A:查询数据
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level read uncommitted;
-- 开启事务
begin;  
select * from student;

查询结果:在这里插入图片描述

  1. 事务B:修改id=1的age为19,但不提交事务
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level read uncommitted;
-- 开启事务
begin;  
update student set age = 28 where id = 1;
  1. 事务A:再次查询数据,id=1的数据age改为了19,发生了脏读
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level read uncommitted;
-- 开启事务
begin;  
select * from student;

查询结果:在这里插入图片描述

  1. 解决方案:提升隔离级别为:read committed

7. 不可重复读复现

将事务隔离级别设置为:read committed,虽然解决了脏读,但是存在不可重复读

  1. 事务A:先查询数据
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level read uncommitted;
-- 开启事务
begin;  
select * from student;

查询结果:在这里插入图片描述

  1. 事务B:修改id=1的age为19,并且提交事务
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level read committed; 
-- 开启事务
begin;
update student set age = 19 where id = 1;
commit;
  1. 事务A:再次查询数据,发生了不可重复读
select @@tx_isolation; #查看当前会话的事务隔离级别
set session transaction isolation level read committed; #设置当前会话的隔离级别
begin; #开启事务
select * from student #查询数据

查询结果:在这里插入图片描述

  1. 解决方案:提升事务隔离级别:repeatable read

8. 幻读复现

将事务隔离级别设置为:repeatable read,可以解决脏读和重复读

8.1 幻读疑问

  1. 事务A:先查询数据
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level repeatable read;
-- 开启事务
begin;  
select * from student;

查询结果:在这里插入图片描述2. 事务B:插入一条数据,并提交事务

-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level repeatable read; 
-- 开启事务
begin;
INSERT INTO student (id, name, age) VALUES(3, '刘备', 38);
commit;
  1. 事务A:再次查询数据,大家可能会疑问,并没有出现事务B插入的数据,没有发生预想的幻读现象,这是为什么呢?这里就涉及到几个概念
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level repeatable read;
-- 开启事务
begin;  
select * from student;

在这里插入图片描述

8.2 MVCC

  1. MVCC(Multi-Version Concurrency Control):多版本并发控制,是一种用于处理并发事务的数据库管理系统技术。
  2. MVCC通过在数据库中维护多个版本的数据来实现事务隔离,从而允许多个事务并发执行而不会发生冲突。
  3. 用来解决数据库的并发读写的应用场景问题(一个事务在读,一个事务在写,保证数据一致性),采用无锁的方式来解决,这个是最牛逼的。
  4. MVCC主要用于支持可重复读(Repeatable Read)隔离级别,并在许多现代数据库系统中得到广泛应用,包括MySQL和PostgreSQL。

8.3 快照读

快照读是MVCC的核心特性之一。

  1. 当事务启动时,它创建一个事务快照,以捕获数据库中的当前状态。
  2. 在整个事务期间,事务只能看到在其启动时存在的数据版本。
  3. 快照读适用于可重复读(Repeatable Read)隔离级别,它确保在整个事务期间数据保持一致性。
  4. 读取一致性:事务在其整个生命周期内都会看到一个一致的数据快照,无论其他事务是否在同时进行。
  5. 无锁读取,MVCC通常不需要使用显式锁来实现事务隔离,因为每个事务都有自己的数据快照,不需要锁定其他事务正在读取的数据。
  6. 所有的select查询语句在可重复读、读已提交的隔离级别下都是快照读。

8.4 当前读

  1. 当前读是一种更加实时的读取方式。
  2. 与快照读不同,当前读不使用已存在的快照,而是始终访问数据库的最新版本。
  3. 当前读适用于读取最新数据的需求,通常用于读取而不是写入操作。
  4. 但需要注意,当前读可能会与其他事务的写操作发生冲突,因此需要格外小心以避免并发问题。
  5. 除了select操作都会触发(update,delete,insert,select…lock in share mode,select…for update)都是当前读。lock in share mode是共享锁,for update是排他锁,相关mysql各种锁的问题,关注小编后续发布文章!

8.5 幻读再次复现

  1. 事务A:当前读查询数据
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level repeatable read;
-- 开启事务
begin;  
select * from student for update;
  1. 事务B:插入一条数据
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level repeatable read; 
-- 开启事务
begin;
INSERT INTO student (id, name, age) VALUES(3, '刘备', 38);
commit;
  1. 事务A:再次查询,来了来了它来了,幻读问题出现了!!!
-- 查看当前会话的事务隔离级别
select @@tx_isolation; 
-- 设置当前会话的隔离级别
set session transaction isolation level repeatable read;
-- 开启事务
begin;  
select * from student for update;

结果如下:在这里插入图片描述

9. 大事务问题

大事务问题通常涉及对数据库中大量数据进行处理的事务,这些事务可能导致性能下降、锁冲突或事务执行时间过长。

  1. 假设有一个下单的应用场景,每当用户提交订单时,系统会执行以下操作:
    ①创建一个新订单记录
    ②从用户购物车中删除已购买的商品
    ③更新商品库存。
    现在,假设有一天,你的网站举办了一个促销活动,吸引了大量用户同时下订单。这导致了大量的 “订单处理” 事务同时运行,每个事务都要对订单和库存进行操作。

  2. 大量订单处理事务同时运行可能会导致以下问题:
    ①锁冲突:多个事务同时尝试修改相同的订单或商品库存,导致锁定和等待。
    ②性能下降:大量的数据库操作可能导致数据库性能急剧下降。
    ③事务超时:事务执行时间过长,导致超时问题。
    解决目标就是,缩短事务执行时间,提高性能

  3. 解决方法:
    ①事务拆分:
    将大事务拆分成多个小事务,每个小事务只处理一个订单或一组相关订单。
    这可以减小每个事务的范围,减少锁冲突和提高并发性。
    ②使用乐观锁:
    使用乐观锁机制来处理商品库存更新。每个事务在更新库存之前检查库存是否足够,如果不够就回滚事务。
    这可以避免大规模的锁冲突。
    ③使用消息队列:
    将订单处理任务放入消息队列,然后由后台任务异步处理。
    这将减轻数据库的压力,并允许系统在非高峰时段处理订单。
    ⑤性能优化:
    优化数据库表结构和索引以提高查询性能。
    使用数据库缓存来减少重复查询。
    ⑥定期清理历史数据:
    定期清理订单和日志数据,以减少数据库负担。

总结

  1. 我们在实际项目中,一般都会使用mysql默认的隔离级别, repeatable read可重复读
  2. 可重复读解决了事务并发安全问题的脏读,不可重复读
  3. 当前读的幻读问题MySQL是怎么解决呢,其实MySQL是通过next-key lock 临键锁来避免幻读问题的,相关mysql各种锁的问题,关注小编后续发布文章!

如果看到这里,说明你喜欢这篇文章,请关注和点赞小编。关注【微信公众号微信】搜索【老板再来一杯时光】回复【进群】即可进入无广告交流群!回复【java】即可获取【java基础经典面试】一份!

好文推荐:
2.5万字详解23种设计模式
springboot 实现延时队列(超级实用)
2.5万字讲解DDD领域驱动设计

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

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

相关文章

网络服务第二次作业

[rootlocalhost ~]# vim /etc/httpd/conf.d/vhosts.conf <Virtualhost 192.168.101.200:80> #虚拟主机IP及端口 DocumentRoot /www/openlab #网页文件存放目录 ServerName www.openlab.com #服务器域名 </VirtualHost> …

【力扣每日一题】2023.9.2 最多可以摧毁的敌人城堡数量

目录 题目&#xff1a; 示例&#xff1a; 分析&#xff1a; 代码&#xff1a; 题目&#xff1a; 示例&#xff1a; 分析&#xff1a; 这道题难在阅读理解&#xff0c;题目看得我匪夷所思&#xff0c;错了好多个测试用例才明白题目说的是什么。 我简单翻译一下就是寻找1和…

枚举的简单介绍

目录 概念&#xff1a; 枚举的声明&#xff1a; 枚举的使用&#xff1a; 枚举的取值&#xff1a; 枚举的优点&#xff1a; #define的功能&#xff1a; 而与#define对比&#xff0c;枚举的优点有&#xff1a; 概念&#xff1a; 枚举顾名思义就是⼀⼀列举。 把可能的取值…

8.react18并发模式与startTransition(搜索高亮思路)

React 18 之前,渲染是一个单一的,不间断的,同步的事务,一旦渲染开始,就不能被中断 React 18引入并发模式,它允许你将标记更新作为一个transitions,这会告诉React他们可以被中断执行.这样可以将紧急任务先更新,不紧急任务后更新. 将任务给紧急任务先执行, 优先级低的任务后执行…

windows安装Scala

Windows安装Scala 下载地址&#xff1a;https://downloads.lightbend.com/scala/2.11.11/scala-2.11.11.zip 解压完成之后 配置环境变量

基于Springboot实现的Echarts图表

概述 ECharts是百度开源的一个前端组件。它是一个使用 JavaScript 实现的开源可视化库&#xff0c;可以流畅的运行在 PC 和移动设备上&#xff0c;兼容当前绝大部分浏览器&#xff08;IE8/9/10/11&#xff0c;Chrome&#xff0c;Firefox&#xff0c;Safari等&#xff09;&…

[CISCN 2019初赛]Love Math

文章目录 前言考点解题过程 前言 感慨自己实力不够&#xff0c;心浮气躁根本做不来难题。难得这题对我还很有吸引力&#xff0c;也涉及很多知识。只能说我是受益匪浅&#xff0c;总的来说加油吧ctfer。 考点 利用php动态函数的特性利用php中的数学函数实现命令执行利用php7的特…

学习Bootstrap 5的第二天

​​​​​​​ 目录 前言 网格系统 网格类 网格系统规则 网格的基本结构 网格选项 从堆叠到水平 自动布局列 超小型设备 超小型设备网格实例 自动布局列 小型设备 小型设备网格实例 自动布局列 中型设备 中型设备网格实例 自动布局列 大型设备 大型设备网…

【仿写spring之ioc篇】三、检查是否实现了Aware接口并且执行对应的方法

Aware接口 Aware接口中只是设置了对应的set方法&#xff0c;目前只定义了三个Aware 以BeanNameAware为例 package com.ez4sterben.spring.ioc.factory.aware;/*** bean名字清楚** author ez4sterben* date 2023/08/31*/ public interface BeanNameAware {/*** 设置beanName* …

stable diffusion实践操作-常见lora模型介绍

本文专门开一节写Lora相关的内容&#xff0c;在看之前&#xff0c;可以同步关注&#xff1a; stable diffusion实践操作 模型分两种&#xff0c;一种是sd大模型&#xff0c;一种是类似Lora的小模型 国内的是&#xff1a;https://www.liblibai.com 国外的是&#xff1a;https:/…

【kubernetes】Argo Rollouts -- k8s下的自动化蓝绿部署

蓝绿(Blue-Green)部署简介 在现代软件开发和交付中,确保应用程序的平稳更新和发布对于用户体验和业务连续性至关重要。蓝绿部署是一种备受推崇的部署策略,它允许开发团队在不影响用户的情况下,将新版本的应用程序引入生产环境。 蓝绿部署的核心思想在于维护两个独立的环…

Anaconda Prompt输入jupyter lab无反应

问题&#xff1a;Anaconda Prompt界面输入指令无反应 原因&#xff1a;公司电脑勒索病毒防御工具阻止了进程 解决&#xff1a;找到黑名单恢复进程

three.js(四):react + three.js

绘制多个立方体 1.搭建reactts 项目 npx create-react-app basics-demo --template typescriptreactts 的用法可参考此链接&#xff1a; https://react-typescript-cheatsheet.netlify.app/docs/basic/setup 2.安装three依赖 npm install three types/three --save3.安装路…

antd5:form组件底层封装库field-form-1.37.0启动

一开始node版本是18.16.0 npm install发现安装依赖成功 npm start发现启动出错 node:internal/crypto/hash:71this[kHandle] new _Hash(algorithm, xofLen);^Error: error:0308010C:digital envelope routines::unsupportedat new Hash (node:internal/crypto/hash:71:19)…

Git Bash 和 Git GUI中文汉化

目录 为什么要中文汉化&#xff1f;Git Bash的汉化Git GUI的汉化 为什么要中文汉化&#xff1f; 看到中文大概能猜出是什么意思&#xff0c;便于使用&#xff0c;特别是Git GUI&#xff0c;中文版的菜单很容易理解是要做什么&#xff0c;如下图&#xff1a; Git Bash的汉化 …

开箱报告,Simulink Toolbox库模块使用指南(五)——S-Fuction模块(C MEX S-Function)

文章目录 前言 C MEX S-Function 算法原理 原始信号创建 编写S函数 仿真验证 Tips 分析和应用 总结 前言 见《开箱报告&#xff0c;Simulink Toolbox库模块使用指南&#xff08;一&#xff09;——powergui模块》 见《开箱报告&#xff0c;Simulink Toolbox库模块使用…

Qt —UDP通信QUdpSocket 简介 +案例

1. UDP通信概述 UDP是无连接、不可靠、面向数据报&#xff08;datagram&#xff09;的协议&#xff0c;可以应用于对可靠性要求不高的场合。与TCP通信不同&#xff0c;UDP通信无需预先建立持久的socket连接&#xff0c;UDP每次发送数据报都需要指定目标地址和端口。 QUdpSocket…

CS144环境配置问题

使用wsl来做CS144实验&#xff0c;可能会在编译的时候遇到以下问题&#xff0c;很明显是找不到LIBPCAP&#xff0c;参考链接 使用sudo apt-get install libpcap-dev命令下载该库即可。 CMake Error: The following variables are used in this project, but they are set to N…

大数据HBase学习圣经:一本书实现HBase学习自由

学习目标&#xff1a;三栖合一架构师 本文是《大数据HBase学习圣经》 V1版本&#xff0c;是 《尼恩 大数据 面试宝典》姊妹篇。 这里特别说明一下&#xff1a;《尼恩 大数据 面试宝典》5个专题 PDF 自首次发布以来&#xff0c; 已经汇集了 好几百题&#xff0c;大量的大厂面试…

unity3d:功能验证,收集开源项目的工程合集

unity3d功能验证&#xff0c;和收集开源项目的工程合集 目录持续更新地址 【腾讯文档】UnityForTest目录 https://docs.qq.com/doc/DWm9HSkVhTGdyUUVo 源码 https://github.com/luoyikun/UnityForTest 动画 创建骨骼动画 BoneAnimation场景 代码创建Mesh&#xff0c;骨骼…