当前位置:

首页 > 编程开发 > MySQL死锁是什么及怎么掌握

MySQL死锁是什么及怎么掌握

1、什么是死锁?死锁指的是在两个或两个以上不同的进程或线程中,由于存在共同资源的竞争或进程(或线程)间的通讯而导致各个线程间相互挂起等待,如果没有外力作用,最终会引发整个系统崩溃。2、Mysql出现死锁的必要条件资源独占条件指多个事务在竞争同一个资源时存在互斥性,即在一段时间内某资源只由一个事务占用,也可叫独占资源(如行锁)。请求和保持条件指在一个事务a中已经获得锁A,但又提出了新的锁B请求,而该锁B已被其它事务b占有,此时该事务a则会阻塞,但又对自己已获得的锁A保持不放。不剥夺条件指一个事务a中已经获得

本文目录

    MySQL死锁是什么及怎么掌握

    1、什么是死锁?

    死锁指的是在两个或两个以上不同的进程或线程中,由于存在共同资源的竞争或进程(或线程)间的通讯而导致各个线程间相互挂起等待,如果没有外力作用,最终会引发整个系统崩溃。

    2、Mysql出现死锁的必要条件

    • 资源独占条件

    指多个事务在竞争同一个资源时存在互斥性,即在一段时间内某资源只由一个事务占用,也可叫独占资源(如行锁)。

    • 请求和保持条件

    指在一个事务a中已经获得锁A,但又提出了新的锁B请求,而该锁B已被其它事务b占有,此时该事务a则会阻塞,但又对自己已获得的锁A保持不放。

    • 不剥夺条件

    指一个事务a中已经获得锁A,在未提交之前,不能被剥夺,只能在使用完后提交事务再自己释放。

    1. 相互获取锁条件

    指在发生死锁时,必然存在一个相互获取锁过程,即持有锁A的事务a在获取锁B的同时,持有锁B的事务b也在获取锁A,最终导致相互获取而各个事务都阻塞。

    3、 Mysql经典死锁案例

    假设存在一个转账情景,A账户给B账户转账50元的同时,B账户也给A账户转账30元,那么在这过程中是否会存在死锁情况呢?

    3.1 建表语句

    CREATE TABLE `account` (
      `id` int(11) NOT NULL COMMENT '主键',
      `user_id` varchar(56) NOT NULL COMMENT '用户id',
      `balance` float(10,2) DEFAULT NULL COMMENT '余额',
      PRIMARY KEY (`id`),
      UNIQUE KEY `idx_user_id` (`user_id`) USING BTREE
    ) ENGINE=InnoDB DEFAULT CHARSET=utf8 COMMENT='账户余额表';

    3.2 初始化相关数据

    INSERT INTO `test`.`account` (`id`, `user_id`, `balance`) VALUES (1, 'A', 80.00);
    INSERT INTO `test`.`account` (`id`, `user_id`, `balance`) VALUES (2, 'B', 60.00);

    MySQL死锁是什么及怎么掌握

    3.3 正常转账过程

    在说死锁问题之前,咱们先来看看正常的转账过程。
    正常情况下,A用户给B用户转账50元,可在一个事务内完成,需要先获取A用户的余额和B用户的余额,因为之后需要修改这两条数据,所以需要通过写锁(for UPDATE)锁住他们,防止其他事务更改导致我们的更改丢失而引起脏数据。
    相关sql如下:

    开启事务之前需要先把mysql的自动提交关闭

    set autocommit=0;
    # 查看事务自动提交状态状态

    show VARIABLES like 'autocommit';![在这里插入图片描述](https://img-blog.csdnimg.cn/a486a4ed5c9d4240bd115ac7b3ce5a39.png?x-oss-process=image/watermark,type_d3F5LXplbmhlaQ,shadow_50,text_

    Q1NETiBA6ZqQIOmjjg==,size_20,color_FFFFFF,t_70,g_se,x_16)

    # 转账sql
    START TRANSACTION;
    # 获取A 的余额并存入A_balance变量:80
    SELECT user_id,@A_balance:=balance from account where user_id = 'A' for UPDATE;
    # 获取B 的余额并存入B_balance变量:60
    SELECT user_id,@B_balance:=balance from account where user_id = 'B' for UPDATE;
    
    # 修改A 的余额
    UPDATE account set balance = @A_balance - 50 where user_id = 'A';
    # 修改B 的余额
    UPDATE account set balance = @B_balance + 50 where user_id = 'B';
    COMMIT;

    执行后的结果:

    MySQL死锁是什么及怎么掌握

    可以看到数据更新都是正常的情况

    3.4 死锁转账过程

    初始化的余额为:

    MySQL死锁是什么及怎么掌握

    假设在高并发情况下存在这种场景,A用户给B用户转账50元的同时,B用户也给A用户转账30元。

    那么我们的java程序操作的过程和时间线如下:

    1、A用户给B用户转账50元,需在程序中开启事务1来执行sql,并获取A的余额同时锁住A这条数据。

    # 事务1
    set autocommit=0;
    START TRANSACTION;
    # 获取A 的余额并存入A_balance变量:80
    SELECT user_id,@A_balance:=balance from account where user_id = 'A' for UPDATE;

    2、B用户给A用户转账30元,需在程序中开启事务2来执行sql,并获取B的余额同时锁住B这条数据。

    # 事务2
    set autocommit=0;
    START TRANSACTION;
    # 获取A 的余额并存入A_balance变量:60
    SELECT user_id,@A_balance:=balance from account where user_id = 'B' for UPDATE;

    3、在事务1中执行剩下的sql

    # 获取B 的余额并存入B_balance变量:60
    SELECT user_id,@B_balance:=balance from account where user_id = 'B' for UPDATE;
    
    # 修改A 的余额
    UPDATE account set balance = @A_balance - 50 where user_id = 'A';
    # 修改B 的余额
    UPDATE account set balance = @B_balance + 50 where user_id = 'B';
    COMMIT;

    MySQL死锁是什么及怎么掌握

    可以看到,在事务1中获取B数据的写锁时出现了超时情况。为什么会这样呢?主要是因为我们在步骤2的时候已经在事务2中获取到B数据的写锁了,那么在事务2提交或回滚前事务1永远都拿不到B数据的写锁。

    4、在事务2中执行剩下的sql

    # 获取A 的余额并存入B_balance变量:60
    SELECT user_id,@B_balance:=balance from account where user_id = 'A' for UPDATE;
    
    # 修改B 的余额
    UPDATE account set balance = @A_balance - 30 where user_id = 'B';
    # 修改A 的余额
    UPDATE account set balance = @B_balance + 30 where user_id = 'A';
    COMMIT;

    MySQL死锁是什么及怎么掌握

    同理可得,在事务2中获取A数据的写锁时也出现了超时情况。因为步骤1的时候已经在事务1中获取到A数据的写锁了,那么在事务1提交或回滚前事务2永远都拿不到A数据的写锁。

    5、 为什么会出现这种情况呢?

    主要是因为事务1和事务2存在相互等待获取锁的过程,导致两个事务都挂起阻塞,最终抛出获取锁超时的异常。

    MySQL死锁是什么及怎么掌握

    3.5 死锁导致的问题

    众所周知,数据库的连接资源是很珍贵的,如果一个连接因为事务阻塞长时间不释放,那么后面新的请求要执行的sql也会排队等待,越积越多,最终会拖垮整个应用。一旦你的应用部署在微服务体系中而又没有做熔断处理,由于整个链路被阻断,那么就会引发雪崩效应,导致很严重的生产事故。

    4、如何解决死锁问题?

    要想解决死锁问题,我们可以从死锁的四个必要条件入手。
    由于资源独占条件和不剥夺条件是锁本质的功能体现,无法修改,所以咱们从另外两个条件尝试去解决。

    4.1 打破请求和保持条件

    根据上面定义可知,出现这个情况是因为事务1和事务2同时去竞争锁A和锁B,那么我们是否可以保证锁A和锁B一次只能被一个事务竞争和持有呢?
    答案是肯定可以的。下面咱们通过伪代码来看看:

    /**
    * 事务1入参(A, B)
    * 事务2入参(B, A)
    **/
    public void transferAccounts(String userFrom, String userTo) {
         // 获取分布式锁
         Lock lock = Redisson.getLock();
         // 开启事务
         JDBC.excute("START TRANSACTION;");
         // 执行转账sql
         JDBC.excute("# 获取A 的余额并存入A_balance变量:80\n" +
                 "SELECT user_id,@A_balance:=balance from account where user_id = '" + userFrom + "' for UPDATE;\n" +
                 "# 获取B 的余额并存入B_balance变量:60\n" +
                 "SELECT user_id,@B_balance:=balance from account where user_id = '" + userTo + "' for UPDATE;\n" +
                 "\n" +
                 "# 修改A 的余额\n" +
                 "UPDATE account set balance = @A_balance - 50 where user_id = '" + userFrom + "';\n" +
                 "# 修改B 的余额\n" +
                 "UPDATE account set balance = @B_balance + 50 where user_id = '" + userTo + "';\n");
         // 提交事务
         JDBC.excute("COMMIT;");
         // 释放锁
         lock.unLock();
    }

    上面的伪代码显而易见可以解决死锁问题,因为所有的事务都是通过分布式锁来串行执行的。

    那么这样就真的万事大吉了吗?

    在小流量情况下看起来是没问题的,但是在高并发场景下这里将成为整个服务的性能瓶颈,因为即使你部署了再多的机器,但由于分布式锁的原因,你的业务也只能串行进行,服务性能并不因为集群部署而提高并发量,完全无法满足分布式业务下快、准、稳的要求,所以咱们不妨换种方式来看看怎么解决死锁问题。

    4.2 打破相互获取锁条件(推荐)

    要打破这个条件其实也很简单,那就是事务再获取锁的过程中保证顺序获取即可,也就是锁A始终在锁B之前获取。
    我们来看看之前的伪代码怎么优化?

    /**
    * 事务1入参(A, B)
    * 事务2入参(B, A)
    **/
    public void transferAccounts(String userFrom, String userTo) {
         // 对用户A和B进行排序,让userFrom始终为用户A,userTo始终为用户B
         if (userFrom.hashCode() > userTo.hashCode()) {
             String tmp = userFrom;
             userFrom = userTo;
             userTo = tmp;
         }
         // 开启事务
         JDBC.excute("START TRANSACTION;");
         // 执行转账sql
         JDBC.excute("# 获取A 的余额并存入A_balance变量:80\n" +
                 "SELECT user_id,@A_balance:=balance from account where user_id = '" + userFrom + "' for UPDATE;\n" +
                 "# 获取B 的余额并存入B_balance变量:60\n" +
                 "SELECT user_id,@B_balance:=balance from account where user_id = '" + userTo + "' for UPDATE;\n" +
                 "\n" +
                 "# 修改A 的余额\n" +
                 "UPDATE account set balance = @A_balance - 50 where user_id = '" + userFrom + "';\n" +
                 "# 修改B 的余额\n" +
                 "UPDATE account set balance = @B_balance + 50 where user_id = '" + userTo + "';\n");
         // 提交事务
         JDBC.excute("COMMIT;");
     }

    假设事务1的入参为(A, B),事务2入参为(B, A),由于我们对两个用户参数进行了排序,所以在事务1中需要先获取锁A在获取锁B,事务2也是一样要先获取锁A在获取锁B,两个事务都是顺序获取锁,所以也就打破了相互获取锁的条件,最终完美解决死锁问题。

    本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系bd@zhengruan.com
    作者最新文章
    编程开发 MySQL
    相关文章 更多
    navicat导入数据库步骤详解及常见问题处理教程
    navicat导入数据库步骤详解及常见问题处理教程

    详解Navicat导入数据库的标准步骤,涵盖SQL脚本执行与CSV数据导入两种核心场景。针对导入过程中常见的字符集乱码、主键冲突及外键约束错误,提供具体的设置方法与修复建议,确保数据迁移准确无误。

    SQL主键约束和唯一约束有什么区别
    SQL主键约束和唯一约束有什么区别

    深入理解SQL PRIMARY KEY与UNIQUE约束的区别。文章从行标识与重复限制的目标出发,详解主键的非空特性、外键引用角色以及多数据库对NULL值的处理差异。结合users表实战示例,指导开发者如何根据字段稳定性与业务语义合理选择约束类型,避免设计误区。

    SQL约束有哪些类型及作用
    SQL约束有哪些类型及作用

    刚开始设计关系型数据库?了解PRIMARY KEY、FOREIGN KEY、UNIQUE、NOT NULL、CHECK、DEFAULT等约束的作用、语法和排错方法。本文以PostgreSQL语法为主,结合用户订单场景,清晰展示如何防止脏数据并处理常见约束冲突。

    SQL游标常见错误排查:死锁与资源未释放问题
    SQL游标常见错误排查:死锁与资源未释放问题

    深入解析SQL游标导致的死锁与资源未释放问题。通过PostgreSQL与MySQL语法对比,展示如何识别长事务持锁、分析锁等待链,并提供短事务提交、异常清理及批量处理的最佳实践,确保数据库连接与锁资源及时释放。

    SQL中怎么创建和删除约束
    SQL中怎么创建和删除约束

    后端开发者在维护数据库时,常需对现有表添加主键、唯一或外键约束。若直接执行ADD CONSTRAINT,往往因存量数据不合规导致报错。本文详解操作前的数据清洗步骤、标准SQL语法及MySQL等特殊写法,帮助你在生产环境安全完成结构变更。

    SQL分组统计查询:GROUP BY与HAVING子句用法示例
    SQL分组统计查询:GROUP BY与HAVING子句用法示例

    针对 SQL 初学者的分组统计实战指南。深入解析 GROUP BY 分组机制、WHERE 与 HAVING 的执行时机差异,以及 COUNT 函数对 NULL 值的处理逻辑。通过具体代码示例演示如何正确筛选聚合结果,并排查因 JOIN 连接导致的统计数据异常,提升报表准确性。

    SQL Server与MySQL游标基本语法及完整代码示例
    SQL Server与MySQL游标基本语法及完整代码示例

    本文详细对比SQL Server和MySQL中游标的基本用法。从DECLARE声明到FETCH遍历,再到CLOSE关闭与DEALLOCATE/Handler清理,解析两者在语法结构、变量接收及异常处理上的核心差异。通过标准代码示例展示如何安全使用游标,避免资源泄漏,适用于需要进行数据库存储过程开发或跨平台迁移的开发者。

    SQL多表连接区别:INNER JOIN与LEFT JOIN的使用场景
    SQL多表连接区别:INNER JOIN与LEFT JOIN的使用场景

    深入解析SQL中INNER JOIN与LEFT JOIN的核心区别。通过users和orders表实例,展示匹配行保留与NULL补位机制,重点讲解ON与WHERE子句中放置右表过滤条件的不同后果,提供防止LEFT JOIN退化的实战技巧及行数异常排查步骤。

    SQL CHECK约束的用法与取值范围限制
    SQL CHECK约束的用法与取值范围限制

    深入理解 SQL CHECK 约束在 PostgreSQL、MySQL 等数据库中的实现差异。文章通过订单业务场景,讲解如何定义单列范围与多列逻辑约束,分析 NULL 值对布尔条件的影响,并提供修改已有表结构时的安全操作建议,帮助开发者构建更健壮的数据完整性防线。

    SQL外键约束怎么用及级联操作说明
    SQL外键约束怎么用及级联操作说明

    后端开发中,如何正确使用 SQL 外键约束来维护订单与明细表的关系?本文通过 PostgreSQL 示例,深入讲解外键的创建语法、插入顺序要求,以及 ON DELETE CASCADE、RESTRICT、SET NULL 等策略的实际影响与风险控制,助你构建健壮的数据库结构。

    查看更多
    精品专题 更多
    装机必备
    装机必备

    正软商城装机必备专区,精选办公、浏览器、安全防护、影音播放、压缩解压、设计创作和系统工具等电脑常用正版软件,帮助用户快速完成新电脑软件配置。

    Windows
    Windows

    正软商城Windows软件专区,汇集适用于Windows电脑的办公、设计、安全防护、影音播放、开发工具和系统优化软件,提供软件介绍、系统要求、正版授权及购买下载服务。

    PDF教程
    PDF教程

    正软商城PDF教程频道提供PDF编辑、转换、合并、拆分、压缩及格式处理方法,同时介绍常用PDF软件和工具的使用技巧。

    Mac软件 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    Aperty macOS版
    Aperty macOS版
    macOS

    Aperty 是 Skylum 推出的 AI 人像修图软件,支持自然肤质修饰、瑕疵处理、面部与身体调整、预设及批量同步。

    WINDOWS 更多
    讯飞智作 网页版
    讯飞智作 网页版
    Windows/ macOS/ Linux

    讯飞智作是一款基于语音合成技术、虚拟人驱动技术与数字人形象声音构建能力的 AI 数字人音视频创作平台。

    火山引擎 网页版
    火山引擎 网页版
    Windows/ macOS/ Linux

    火山引擎是字节跳动旗下企业级云与AI服务平台。聚焦大模型核心能力,依托字节自研豆包多模态大模型,凭借火山方舟一站式平台,提供模型精调、推理部署、智能应用搭建等全链路服务,结合高性能AI算力,助力各行业快速落地大模型数字化与智能化应用。

    PixTV 网页版
    PixTV 网页版
    Windows

    PixTV 是一款在浏览器中使用的 AI 视觉内容创作平台,提供图片、视频、音频、文字生成、AI 分镜、局部重绘、提示词反推和无限画布等工具,适合短剧、漫剧、广告及社交媒体内容制作。