在PHP业务开发中，当我们需要对多张表或者大量数据进行批量操作时，很容易写出执行时间很长的事务。这类长事务会长时间持有数据库的行锁，导致其他请求无法操作被锁定的数据，最终引发业务阻塞甚至系统卡顿。
长事务导致行锁占用的原因
数据库的行锁是在事务执行过程中对操作的数据加锁，只有事务提交或者回滚之后才会释放锁。如果事务执行时间过长，锁的持有时间就会同步变长，其他需要操作同一批数据的事务就会被阻塞，直到锁被释放才能继续执行。常见的长事务场景包括批量更新上万条数据、在事务中调用外部接口、在事务中执行复杂的查询逻辑等。
如何识别数据库中的长事务和行锁占用
我们可以通过数据库自带的诊断命令来查看当前运行的事务情况，以MySQL为例，可以执行以下语句查看运行时间超过60秒的事务：
-- 查看当前运行的事务，TRX_STARTED是事务开始时间，通过计算可得运行时长 SELECT trx_id, trx_state, trx_started, trx_mysql_thread_id FROM information_schema.INNODB_TRX WHERE TIMESTAMPDIFF(SECOND, trx_started, NOW()) > 60;
如果需要查看当前的行锁等待情况，可以执行以下语句：
-- 查看行锁等待关系
SELECT r.trx_id waiting_trx_id, r.trx_mysql_thread_id waiting_thread,
b.trx_id blocking_trx_id, b.trx_mysql_thread_id blocking_thread
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;
拆分大事务的核心思路
拆分大事务的核心原则是减少单个事务的操作范围和执行时长，让锁尽可能快地释放，具体可以从以下几个方向入手：
- 按业务维度拆分：如果事务中包含多个独立的业务操作，把每个业务操作拆成独立的事务，避免所有操作放在同一个事务中执行。
- 按数据量拆分：如果是批量操作大量数据，把批量操作拆成多次小批量操作，每次操作少量数据就提交一次事务。
- 减少事务内的非必要操作：把查询、外部接口调用、日志写入等不需要加锁的操作移到事务外部，只把必须加锁的写操作放在事务里。
PHP中拆分大事务的代码示例
场景1：批量更新用户积分
假设我们需要给10万用户增加积分，原来的长事务写法会把所有更新放在一个事务里：
<?php
// 原来的长事务写法，风险很高
$pdo = new PDO('mysql:host=127.0.0.1;dbname=test;charset=utf8', 'root', '123456');
$pdo->beginTransaction();
try {
$userIds = range(1, 100000); // 假设要更新的用户ID列表
$sql = 'UPDATE user SET score = score + 10 WHERE id = :id';
$stmt = $pdo->prepare($sql);
foreach ($userIds as $userId) {
$stmt->execute([':id' => $userId]);
}
$pdo->commit();
} catch (Exception $e) {
$pdo->rollBack();
echo '更新失败：' . $e->getMessage();
}
?>
拆分后的写法，每次更新1000条就提交一次事务：
<?php
// 拆分后的小事务写法，每次处理1000条数据
$pdo = new PDO('mysql:host=127.0.0.1;dbname=test;charset=utf8', 'root', '123456');
$userIds = range(1, 100000);
$batchSize = 1000; // 每批处理的数据量
$total = count($userIds);
for ($i = 0; $i < $total; $i += $batchSize) {
$batchIds = array_slice($userIds, $i, $batchSize);
$pdo->beginTransaction();
try {
$sql = 'UPDATE user SET score = score + 10 WHERE id = :id';
$stmt = $pdo->prepare($sql);
foreach ($batchIds as $userId) {
$stmt->execute([':id' => $userId]);
}
$pdo->commit();
echo '第' . ($i / $batchSize + 1) . '批更新完成' . PHP_EOL;
} catch (Exception $e) {
$pdo->rollBack();
echo '第' . ($i / $batchSize + 1) . '批更新失败：' . $e->getMessage() . PHP_EOL;
// 可以根据需要决定是否继续处理下一批
}
}
?>
场景2：多业务操作拆分
假设一个事务中需要完成用户余额扣减、订单创建、库存扣减三个操作，原来的写法是三个操作放在同一个事务里：
<?php
// 原来的合并事务写法
$pdo = new PDO('mysql:host=127.0.0.1;dbname=test;charset=utf8', 'root', '123456');
$pdo->beginTransaction();
try {
// 扣减用户余额
$pdo->exec('UPDATE user SET balance = balance - 100 WHERE id = 1');
// 创建订单
$pdo->exec('INSERT INTO order (user_id, amount) VALUES (1, 100)');
// 扣减库存
$pdo->exec('UPDATE goods SET stock = stock - 1 WHERE id = 1');
$pdo->commit();
} catch (Exception $e) {
$pdo->rollBack();
}
?>
拆分后每个业务操作独立成事务，减少锁占用时间：
<?php
// 拆分后的独立事务写法
$pdo = new PDO('mysql:host=127.0.0.1;dbname=test;charset=utf8', 'root', '123456');
// 1. 扣减用户余额，独立事务
$pdo->beginTransaction();
try {
$pdo->exec('UPDATE user SET balance = balance - 100 WHERE id = 1');
$pdo->commit();
} catch (Exception $e) {
$pdo->rollBack();
die('余额扣减失败');
}
// 2. 创建订单，独立事务
$pdo->beginTransaction();
try {
$pdo->exec('INSERT INTO order (user_id, amount) VALUES (1, 100)');
$pdo->commit();
} catch (Exception $e) {
$pdo->rollBack();
die('订单创建失败');
}
// 3. 扣减库存，独立事务
$pdo->beginTransaction();
try {
$pdo->exec('UPDATE goods SET stock = stock - 1 WHERE id = 1');
$pdo->commit();
} catch (Exception $e) {
$pdo->rollBack();
die('库存扣减失败');
}
?>
注意事项
拆分事务之后需要注意数据一致性的问题，如果多个事务之间有强依赖关系，拆分后可能需要增加额外的校验逻辑，比如扣减库存之前再次检查订单是否创建成功。另外批量拆分的时候，建议给每批操作增加重试机制，避免某一批操作失败导致整体任务中断。如果业务上必须保证多个操作的原子性，不能拆分事务，那么可以优化事务内的逻辑，把不必要的操作移出去，尽量缩短事务的执行时间。