问题:商品超卖(库存数出现负数)。
模拟并发:
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(‘成功‘); }
大佬们轻拍,如果有什么地方讲得不对或你有什么好的方案解决谢谢提出。
原文地址:https://www.cnblogs.com/qq260101081/p/10897599.html
时间: 2024-10-09 10:12:19