laravel日常使用的中间件

doublefacekill 的个人博客 / 0 / 7 / 创建于 9个月前 / 更新于 9个月前

在以往的开发过程中遇到这样一个问题，用户下单后，后台要分配一个对接的业务人员二维码展示给用户。有一次业务人员反馈系统显示分配给了A业务人员他却加了B业务人员的微信。查看数据库发现，这个用户下了一个订单，同一个订单却有两条分配记录，而且是同一秒。很显然这是一个并发问题。

$orderTeacher = OrderTeacher::where('order_id', $orderId)->find();
if ($orderTeacher) {
    return $orderTeacher->qr_code;
}
$teacher = Teacher::find();//这里是实际的业务不详细描述
$orderTeacher = OrderTeacher::create([
    'order_id' => $orderId,
    'teacher_id' => $teacher['id'],
    'qr_code' => $teacher['qr_code'],
]);

return $teacher['qr_code'];

前端不知道发生了什么未知的原因，同一时刻请求了两次这个接口。

$orderTeacher = OrderTeacher::where('order_id', $orderId)->find();

两次请求这一段代码都没有查询到这个订单有分配记录，就走一下步创建分配记录返回二维码，前端收到了两次，用第二次收到的二维码替换了第一次。然后产生了一个订单分配两个业务人员的bug。
面对这类问题有很多结果方案，redis锁、给对应的mysql表加锁。这种做成中间件的方式是比较好的，可以把非业务逻辑的代码分离开。

class LockWaitMiddleware implements MiddlewareInterface
{
    public function handle(Request $request, \Closure $next, $scene = '', $maxLockTime = 5)
    {
        if ($request->isLogin()) {
            $uid = $request->uid();
        } else {
            $uid = $request->ip();
        }
        if ($scene === '') {
            $scene = $request->method() . ':' . $request->url();
        }
        $lockKey = "learnku:{$scene}wait_lock:{$uid}";
        $waitSecond = 0;
        $waitEveryTime = 0.2;
        while (true) {
            $acquired = CacheRedis()->exists($lockKey);
            if (!$acquired) {
                CacheRedis()->setex($lockKey, $maxLockTime, '1');
                break;
            }

            $waitSecond += $waitEveryTime;
            if ($waitSecond >= $maxLockTime) {
                break;
            }
            sleep($waitEveryTime);
        }

        $response = call_user_func($next, $request);

        CacheRedis()->del($lockKey);

        return $response;
    }
}

本来设置redis锁是用setnx + expire来实现

while(true) {
    $acquired = CacheRedis()->setnx($lockKey, 1);
    if ($acquired) {
        CacheRedis()->expire($lockKey, $maxLockTime);
        break;
    }
}