Laravel配送应用接单环节是否存在竞态条件及规避方案咨询

是否存在竞态条件？ #

肯定存在。

当前的接单逻辑是“先查询订单的courier_id是否为null，再赋值”，这是典型的“读-改-写”非原子操作。当多个配送员同时抢同一订单时，极有可能出现以下情况：

1. 配送员A和B的请求同时查询到该订单的courier_id为null；
2. 两人的请求都进入“赋值”环节；
3. 最终订单的courier_id会被其中一人覆盖，甚至因数据库执行顺序问题出现数据异常，导致多个配送员被标记为同一订单的接单者。

如何规避？ #

1. 核心方案：使用原子更新语句（推荐） #

把“检查+赋值”合并成一条数据库原子操作，让数据库层面保证操作的唯一性。Laravel中可直接执行以下代码：

$affectedRows = DB::table('orders')
    ->where('id', $orderId)
    ->whereNull('courier_id')
    ->update([
        'courier_id' => $courierId,
        'assigned_at' => now() // 可选：记录接单时间
    ]);

if ($affectedRows === 1) {
    // 接单成功逻辑
    return response()->json(['status' => 'success', 'msg' => '接单成功']);
} else {
    // 接单失败，订单已被抢
    return response()->json(['status' => 'fail', 'msg' => '订单已被其他配送员接单']);
}

原理：这条UPDATE语句是原子执行的，数据库会在同一时间只允许一个请求匹配id = $orderId AND courier_id IS NULL的条件并完成更新，其他请求的更新操作会返回0行受影响，以此彻底避免竞态。

2. 使用悲观锁（适合并发量适中的场景） #

在事务中使用悲观锁锁定订单，确保同一时间只有一个请求能修改该订单：

DB::transaction(function () use ($orderId, $courierId) {
    // 锁定订单，其他请求会被阻塞直到当前事务提交
    $order = Order::where('id', $orderId)
        ->whereNull('courier_id')
        ->lockForUpdate()
        ->first();

    if (!$order) {
        throw new \RuntimeException('订单已被接单');
    }

    $order->courier_id = $courierId;
    $order->assigned_at = now();
    $order->save();
});

注意：悲观锁会阻塞其他请求，若并发量极高，可能导致数据库连接排队，需根据业务场景评估使用。

3. 使用乐观锁（适合高并发场景） #

给订单表新增一个version字段（整数类型，默认值为1），每次更新时校验版本号，确保只有匹配当前版本的请求能修改数据：

1. 先给订单表加字段：

ALTER TABLE orders ADD COLUMN version INT DEFAULT 1;

2. Laravel中的接单逻辑：

$currentOrder = Order::where('id', $orderId)->whereNull('courier_id')->first();

if (!$currentOrder) {
    return response()->json(['status' => 'fail', 'msg' => '订单已被接单']);
}

$affectedRows = Order::where('id', $orderId)
    ->where('version', $currentOrder->version)
    ->whereNull('courier_id')
    ->update([
        'courier_id' => $courierId,
        'assigned_at' => now(),
        'version' => $currentOrder->version + 1
    ]);

if ($affectedRows === 1) {
    // 接单成功逻辑
} else {
    // 版本不匹配，订单已被修改
    return response()->json(['status' => 'fail', 'msg' => '订单已被其他配送员接单']);
}

原理：乐观锁不阻塞请求，而是通过版本号判断数据是否被并发修改，适合高并发、冲突概率较低的场景。

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