MySQL怎样处理并发写入冲突乐观锁与悲观锁实现方案-mysql教程-PHP中文网

MySQL怎样处理并发写入冲突乐观锁与悲观锁实现方案

冰火之心

发布： 2025-06-30 11:01:01

原创

268人浏览过

mysql处理并发写入冲突的核心在于锁机制和事务控制。主要采用乐观锁与悲观锁两种机制，悲观锁通过select ... for update在读取时锁定数据，保证事务一致性，适合并发量低、一致性要求高的场景；乐观锁则在更新时检查版本号，适合并发量高、一致性要求相对较低的场景。此外，可通过缩短事务时间、固定访问顺序、设置锁超时等方式避免死锁，并结合队列、分库分表、缓存等策略缓解冲突。监控方面需关注活跃连接数、锁等待时间、慢查询、死锁数量、qps与tps等指标，使用show命令或第三方工具进行监控。

MySQL怎样处理并发写入冲突乐观锁与悲观锁实现方案

并发写入冲突，MySQL的处理方式核心在于锁机制和事务控制。简单来说，就是让多个用户或程序在修改同一数据时，能够有序进行，避免数据错乱。

解决方案

MySQL处理并发写入冲突，主要依赖于两种锁机制：乐观锁和悲观锁。选择哪种锁，取决于具体的应用场景和并发程度。

悲观锁

悲观锁，顾名思义，假定会发生并发冲突，因此在读取数据时，就立即锁定数据，防止其他事务修改。MySQL中，可以通过SELECT ... FOR UPDATE来实现悲观锁。

例如：

START TRANSACTION;
SELECT * FROM products WHERE id = 1 FOR UPDATE;
-- 执行更新操作
UPDATE products SET quantity = quantity - 1 WHERE id = 1;
COMMIT;

登录后复制

这段代码中，SELECT ... FOR UPDATE会锁定products表中id为1的记录，直到事务提交或回滚。其他事务如果尝试修改该记录，会被阻塞，直到锁释放。

悲观锁的优点是：简单直接，能够有效防止并发冲突，保证数据的一致性。缺点是：并发性能较低，因为锁定了资源，其他事务需要等待，可能导致死锁。适用于并发量不高，但对数据一致性要求极高的场景，例如金融交易。

乐观锁

乐观锁，则认为并发冲突的概率较低，因此在读取数据时，不加锁。而是在更新数据时，检查数据是否被其他事务修改过。常见的实现方式是使用版本号或时间戳。

例如，在products表中增加一个version字段：

CREATE TABLE products (
  id INT PRIMARY KEY,
  name VARCHAR(255),
  quantity INT,
  version INT DEFAULT 0
);

登录后复制

更新数据时，先读取version，然后在UPDATE语句中比较version：

START TRANSACTION;
SELECT id, quantity, version FROM products WHERE id = 1;
-- 假设读取到的 version = 1, quantity = 10
-- 执行更新操作
UPDATE products SET quantity = quantity - 1, version = version + 1 WHERE id = 1 AND version = 1;
-- 检查更新是否成功
SELECT ROW_COUNT();
COMMIT;

登录后复制

如果ROW_COUNT()返回0，说明更新失败，因为version已经被其他事务修改过。此时，需要重新读取数据，再次尝试更新。

乐观锁的优点是：并发性能较高，因为不需要锁定资源，多个事务可以同时读取数据。缺点是：需要应用程序处理并发冲突，例如重试。适用于并发量较高，但对数据一致性要求不是特别高的场景，例如电商平台的商品库存更新。

如何选择乐观锁还是悲观锁？

这是一个需要权衡的问题。如果并发量低，数据一致性要求高，选择悲观锁；如果并发量高，数据一致性要求相对较低，选择乐观锁。当然，也可以结合使用，例如在某些关键业务流程中使用悲观锁，而在其他流程中使用乐观锁。

副标题1 MySQL死锁是如何产生的？如何避免？

死锁是指两个或多个事务互相等待对方释放资源，导致所有事务都无法继续执行的状态。举个例子，事务A锁定了表1，等待表2；事务B锁定了表2，等待表1。这样就形成了死锁。

避免死锁的一些方法：