訂單並發商品超賣問題解決

問題：商品超賣（庫存數出現負數）。

模擬並發：

 

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

 

大佬們輕拍，如果有什么地方講得不對或你有什么好的方案解決謝謝提出。