订单并发商品超卖问题解决

Posted 2021-12-02 qq260101081

问题：商品超卖（库存数出现负数）。

模拟并发：

 

goods商品表：

/**
 * 下单
 * @return string
 * @throws \\yii\\db\\Exception
 */
public function actionIndex()
{
    $redis = Yii::$app->redis; // 使用redis做一些统计
    $redis->incr(‘total‘); // 自增（记录一共成功进来了多少个请求）

    //$redis->del(‘total‘);
    //$redis->del(‘update‘);
    //$redis->del(‘success‘);
    //$redis->del(‘faild‘);die;
    //var_dump(‘total:‘ . $redis->get(‘total‘));
    //var_dump(‘success: ‘ . $redis->get(‘success‘));
    //var_dump(‘faild:‘ . $redis->get(‘faild‘));
    //var_dump(‘update:‘ . $redis->get(‘update‘));die;

    $model = Goods::find()->where([‘id‘ => 1])->one(); // 购买的商品信息
    if ($model->number > 0) { // 判断库存是否大于0
        $redis->incr(‘update‘); // 记录并发时进来的请求数

        $result = Yii::$app->getDb()->createCommand("UPDATE goods SET     number = number - 1 WHERE id = 1 LIMIT 1")->execute(); // 更新库存

        if($result){ // 更新成功插入订单数据， 这里应该是要写事务的

            $orderModel = new Orders();
            $orderModel->price = $model->price;
            $orderModel->name = $model->name;
            $orderModel->create_time = time();
            $orderModel->save(false);

            $redis->incr(‘success‘); // 记录更新成功数

        }else{
            $redis->incr(‘faild‘); // 记录更新成功数
        }
    }
    die(‘成功‘);
    return $this->render(‘index‘);
}

k6压测：

最后商品库存变成了 -3 （超卖了3）

 

压测记录结果： 

压测并发有点少，因为我机子最大打开2048个文件，网络用的4g，也受网络影响等因素，如果压测的本地机器和网络好更准些。

回顾：如果 $result = Yii::$app->getDb()->createCommand("UPDATE goods SET number = number - 1 WHERE id = 1 LIMIT 1")->execute(); // 更新库存 这一句不是这么更新 set `库存字段` = `库存字段` - 1 ，而是计算好再更新进去 $number = $number -1 就不会出现负数或设置库存字段属性为UNSINGED,但不能真正解决掉问题，因为实际还是多执行3次，这么写是为了测试负数，也就是这句里面

if ($model->number > 0) { 实际执行了103次，超出100的库存, 也就是说当 库存$model->number等于1时 同时并发3请求执行到这里，这3个并发查询出来的库存都为1的时候都执行了更新库存导致的。

解决超卖问题：

　　/**
     * 提前把商品库存入队列
     */
    public function actionSetStore()
    {
        $redis = Yii::$app->redis;
	    $model = Goods::find()->where([‘id‘ => 1])->one(); //商品信息
        
        for ($i = 0; $i < $model->number; $i++)
        {
            $redis->lpush(‘goods_store‘, 1);
        }
    }

    /**
     * 下单
     * @return string
     * @throws \\yii\\db\\Exception
     */
    public function actionIndex()
    {
        $redis = Yii::$app->redis; // 使用redis做一些统计
        $count = $redis->lpop(‘goods_store‘); // 出队列
        
        if ($count) { // 判断库存是否出完队列
            // 更新库存等逻辑
            $result = Yii::$app->getDb()->createCommand("UPDATE goods SET number = number - 1 WHERE id = 1 LIMIT 1")->execute(); 

        }
        else {
            die(‘卖完了‘);
        }
        die(‘成功‘);
    }

 

大佬们轻拍，如果有什么地方讲得不对或你有什么好的方案解决谢谢提出。