MySQL技巧(八) :死锁解决与实战案例
在数据库高并发场景下死锁是一个绕不开的经典难题。两个或多个事务相互持有对方需要的锁导致都无法继续执行就像两辆车在狭窄路口互不相让。本文将带你从原理到实战掌握死锁的排查、解决和预防全流程。一、死锁快速定位当应用出现“Deadlock found when trying to get lock”错误时第一时间需要通过数据库日志定位问题。第一步查看最近一次死锁详情在MySQL命令行或IDE的Database Console中执行以下命令sqlSHOW ENGINE INNODB STATUS\G重点关注输出中的LATEST DETECTED DEADLOCK部分它会清晰展示发生死锁的两个事务及其SQL各自持有的锁和等待的锁被回滚的事务第二步查看当前锁等待情况如果死锁正在发生可以通过以下SQL实时监控sqlSELECT r.trx_id AS waiting_trx_id, r.trx_mysql_thread_id AS waiting_thread, r.trx_query AS waiting_query, b.trx_id AS blocking_trx_id, b.trx_mysql_thread_id AS blocking_thread, b.trx_query AS blocking_query FROM information_schema.innodb_lock_waits w INNER JOIN information_schema.innodb_trx b ON b.trx_id w.blocking_trx_id INNER JOIN information_schema.innodb_trx r ON r.trx_id w.requesting_trx_id;找到阻塞源头后可以根据blocking_thread执行KILL操作sqlKILL 123; -- 替换为实际的thread_id二、 经典死锁案例与解决方案案例1双事务交叉更新这是最常见的死锁场景——两个事务以相反的顺序更新相同的两张表。场景重现事务A先更新订单表再更新库存表事务B先更新库存表再更新订单表解决方案统一资源访问顺序最有效的做法是在代码层面约定所有事务都按照相同的顺序操作数据库表或行记录。java// ✅ 好做法统一先处理订单再处理库存 public void updateOrderAndStock(String orderId, String productId) { transactionTemplate.execute(status - { ordersMapper.updateStatus(orderId, PAID); inventoryMapper.reduceStock(productId, 1); return null; }); } // ❌ 坏做法不同事务顺序不一致容易死锁如果业务无法统一顺序可以考虑在应用层引入分布式锁如Redis、ZooKeeper保证同一时间只有一个线程在处理某条关联数据。案例2范围查询导致的间隙锁死锁当使用WHERE条件进行范围更新时InnoDB会添加间隙锁锁住条件范围内的不存在的记录多个事务的范围条件重叠时极易死锁。解决方案缩小锁粒度方案A将范围更新改为单条更新sql-- 原来范围更新 UPDATE user_points SET points points 10 WHERE user_id BETWEEN 2 AND 6; -- 改为逐条更新按固定顺序 UPDATE user_points SET points points 10 WHERE user_id 2; UPDATE user_points SET points points 10 WHERE user_id 3; -- ... 依次执行方案B使用 ORDER BY 确保加锁顺序-- 原来范围更新 UPDATE user_points SET points points 10 WHERE user_id BETWEEN 2 AND 6; -- 改为逐条更新按固定顺序 UPDATE user_points SET points points 10 WHERE user_id 2; UPDATE user_points SET points points 10 WHERE user_id 3; -- ... 依次执行案例3唯一键冲突导致的死锁并发执行INSERT ... ON DUPLICATE KEY UPDATE时如果插入相同的唯一键两个事务会先尝试插入加插入意向锁检测到冲突后转为更新锁容易形成循环等待。解决方案先锁定再操作sql-- 使用 SELECT ... FOR UPDATE 显式锁定行 BEGIN; SELECT * FROM user_account WHERE mobile 13800138000 FOR UPDATE; IF found THEN UPDATE user_account SET balance balance 100 WHERE mobile 13800138000; ELSE INSERT INTO user_account (mobile, balance) VALUES (13800138000, 100); END IF; COMMIT;或者将唯一键冲突的业务逻辑异步化通过消息队列串行处理彻底避免并发冲突。三、 预防死锁的最佳实践死锁无法100%消除但可以通过以下实践大幅降低发生概率。1. 事务设计原则短事务尽量减少事务中SQL的数量不要在事务中执行远程调用、复杂计算等耗时操作低隔离级别如果业务允许使用READ COMMITTED代替默认的REPEATABLE READ减少间隙锁sqlSET SESSION TRANSACTION ISOLATION LEVEL READ COMMITTED;精确更新更新语句尽量使用主键或唯一索引作为条件避免全表扫描或大范围锁表2. 索引优化确保UPDATE和DELETE语句的WHERE条件使用了索引否则行锁可能升级为表锁极大增加死锁概率。sql-- 检查SQL执行计划确保 type 为 ref 或 eq_ref避免 ALL EXPLAIN UPDATE order_detail SET status 1 WHERE order_no ORD123456;如果索引未命中应添加合适的复合索引sqlALTER TABLE order_detail ADD INDEX idx_order_no_status (order_no, status);3. 重试机制即使做好了预防死锁在高并发下仍可能偶发。业务代码中应实现死锁重试机制让被回滚的事务自动重试。python# Python示例带重试的数据库操作 import time from functools import wraps def retry_on_deadlock(max_retries3, delay0.1): def decorator(func): wraps(func) def wrapper(*args, **kwargs): for attempt in range(max_retries): try: return func(*args, **kwargs) except Exception as e: if Deadlock found in str(e) and attempt max_retries - 1: time.sleep(delay * (2 ** attempt)) # 指数退避 continue raise return None return wrapper return decorator retry_on_deadlock(max_retries3) def update_order_status(order_id, status): with db.transaction(): db.execute(UPDATE orders SET status %s WHERE id %s, (status, order_id))四、 总结与快速排查清单当出现死锁时可以按以下步骤快速排查和处理步骤操作目的1SHOW ENGINE INNODB STATUS\G查看最近死锁定位死锁SQL和事务2分析死锁日志中的WAITING FOR THIS LOCK和HOLDS THE LOCK确认锁冲突的资源和顺序3检查涉及的表是否有合适的索引避免锁范围过大4检查事务中SQL的执行顺序是否统一统一访问顺序是核心原则5确认事务大小是否合理拆分大事务缩短锁持有时间6实现业务层重试机制让偶发死锁对用户无感知核心原则死锁是并发场景的正常现象关键在于快速发现、分析原因和优雅重试。通过合理的索引设计、统一的事务顺序和健全的重试机制可以将死锁的影响降到最低。
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/2452758.html
如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!