码迷,mamicode.com
首页 > 其他好文 > 详细

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

时间:2019-05-21 21:16:42      阅读:301      评论:0      收藏:0      [点我收藏+]

标签:his   订单   throws   插入   文件   redis   mic   inf   return   

问题:商品超卖(库存数出现负数)。

模拟并发

 

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(‘成功‘);
    }

 

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


 

 

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

标签:his   订单   throws   插入   文件   redis   mic   inf   return   

原文地址:https://www.cnblogs.com/qq260101081/p/10897599.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!