Laravel多服务器下数据库事务问题及解决方案咨询

这个场景我碰到过好多次了——多台服务器共享同一数据库，并发请求时总是出现同一条数据被多个用户抢走的情况，核心问题其实是并发读写时的资源竞争没有被正确控制，默认的事务隔离级别和无锁查询根本扛不住这种场景。下面给你几个靠谱的解决办法，都是生产环境验证过的：

一、用悲观锁（Select For Update）强制独占数据 #

这是最直接有效的方案，原理是在查询未分配数据时就把对应的行锁住，其他请求必须等当前事务提交/回滚后才能操作这条数据，从根源上避免了“同时读到同一条未分配数据”的问题。

Laravel中的具体实现 #

一定要把查询和更新放在同一个事务里，不然锁会提前释放：

use Illuminate\Support\Facades\DB;

try {
    $assignedData = DB::transaction(function () use ($userId) {
        // 锁定第一条未分配的data1，其他请求会阻塞直到当前事务完成
        $data = DB::table('your_data_table')
            ->where('status', '=', 'unassigned')
            ->where('data_name', '=', 'data1')
            ->lockForUpdate() // 关键：加行级排他锁
            ->first();

        if (!$data) {
            return null; // 没有可用数据了
        }

        // 执行分配操作
        DB::table('your_data_table')
            ->where('id', '=', $data->id)
            ->update([
                'status' => 'assigned',
                'user_id' => $userId,
                'assigned_at' => now()
            ]);

        return $data;
    });

    if ($assignedData) {
        // 返回成功给用户
        return response()->json(['message' => '分配成功', 'data' => $assignedData]);
    } else {
        return response()->json(['message' => '暂无可用数据'], 404);
    }
} catch (\Exception $e) {
    // 处理事务异常，比如锁超时等
    return response()->json(['message' => '分配失败，请重试'], 500);
}

注意事项 #

• 必须使用InnoDB存储引擎：MyISAM不支持行级锁，会退化成表锁，性能会很差
• 事务要尽可能短：锁会阻塞其他请求，所以别在事务里加无关的操作（比如调用第三方API、大量计算）
• 可以配合skipLocked()（MySQL 8.0+支持）：如果不想让请求阻塞，而是直接跳过被锁定的数据，用skipLocked()代替lockForUpdate()，适合“抢不到就直接返回无数据”的场景

二、乐观锁（Version字段）：高并发场景下的无阻塞方案 #

如果你的并发量特别高，悲观锁的阻塞可能会导致性能瓶颈，那可以用乐观锁。它的原理是给数据加一个版本号，每次更新时验证版本号是否和查询时一致，不一致就说明数据已经被其他请求修改过了。

Laravel中的具体实现 #

首先给你的数据表加一个version字段（int类型，默认值0）：

ALTER TABLE your_data_table ADD COLUMN version INT DEFAULT 0;

然后在代码里实现版本校验：

use Illuminate\Support\Facades\DB;

try {
    $assignedData = null;
    $maxRetries = 3; // 最多重试3次
    $retryCount = 0;

    while ($retryCount < $maxRetries) {
        DB::transaction(function () use ($userId, &$assignedData) {
            // 先查询未分配的数据
            $data = DB::table('your_data_table')
                ->where('status', '=', 'unassigned')
                ->where('data_name', '=', 'data1')
                ->first();

            if (!$data) {
                $assignedData = null;
                return;
            }

            // 更新时验证版本号，只有版本号一致才会执行更新
            $affectedRows = DB::table('your_data_table')
                ->where('id', '=', $data->id)
                ->where('version', '=', $data->version)
                ->update([
                    'status' => 'assigned',
                    'user_id' => $userId,
                    'assigned_at' => now(),
                    'version' => $data->version + 1 // 更新版本号
                ]);

            if ($affectedRows > 0) {
                $assignedData = $data;
            } else {
                // 版本号不一致，说明被其他请求抢了，抛出异常触发重试
                throw new \Exception('Data already taken');
            }
        });

        if ($assignedData) break;
        $retryCount++;
        usleep(100000); // 重试前等待100ms
    }

    if ($assignedData) {
        return response()->json(['message' => '分配成功', 'data' => $assignedData]);
    } else {
        return response()->json(['message' => '暂无可用数据'], 404);
    }
} catch (\Exception $e) {
    return response()->json(['message' => '分配失败，请重试'], 500);
}

注意事项 #

• 适合冲突率较低的场景：如果并发量极高且冲突频繁，重试次数会增加，反而不如悲观锁高效
• 不需要阻塞请求：所有请求都能同时执行，只有在更新时才会验证冲突，性能更好

三、额外的优化建议 #

• 确保数据库隔离级别设置合理：Laravel默认用的是MySQL的REPEATABLE READ，这个级别已经足够应对大部分场景，不需要随便改成更高的级别（比如SERIALIZABLE会导致严重的性能问题）
• 避免长事务：任何事务都要尽可能短，锁的持有时间越短，并发能力越强
• 可以考虑用队列异步分配：如果业务允许，把分配请求放到Laravel队列里，让队列单进程处理分配逻辑，从根本上避免并发竞争（适合不需要实时分配的场景）

内容的提问来源于stack exchange，提问作者Teja