php处理抢购类功能的高并发请求

作者:春风不及你的笑 时间:2023-11-21 01:30:54 

本文以抢购、秒杀为例。介绍如何在高并发状况下确保数据正确。
在高并发请求下容易参数两个问题
1.数据出错,导致产品超卖。
2.频繁操作数据库,导致性能下降。

测试环境

Windows7
apache2.4.9
php5.5.12
php框架 yii2.0
工具 apache bench (apache自带高并发请求工具)。

通常处理方法

从控制器可以看出代码思路。先查询商品库存。如果库存大于0 ,则库存减少1,同时生产订单,录入抢购者数据。


// 常规代码处理高并发
 public function actionNormal(){
   // 查询库存
   $stock = Goods::find()->select('stock')->where(['goods_id'=>100001])->asArray()->one();
   // 判断该商品是否还有库存
   if ($stock['stock']>0) {
     // 库存减一
     Goods::updateAllCounters(['stock' => -1],['goods_id'=>100001]);

// 生产订单(另外功能,暂且随机赋值)
     $order = $this->build_order();

// 秒杀信息入库
     $model = new Highly();
     $model->order_id = $order;
     $model->goods_name = '秒杀商品';
     $model->buy_time = date('Y-m-d H:i:s',time());
     $model->mircrotime = microtime(true);
     if($model->save()===false){
       echo '未能成功抢购!';
     }else{
       echo '恭喜你,订单<b>'.$order.'</b>抢购成功';
     }

}else{
     echo '已被抢购一空!';
   }
 }

将商品库存设置为20后,通过ab 配置200的并发请求。


ab -n 200 -c 200 http//localhost/highly/normal

执行结果发现库存变成了负值,商品超卖了。

php处理抢购类功能的高并发请求

原因比较简单,在高并发请求下。在生产订单,减少库存之前,会优先查询到库存结果。

优化一:修改库存数据类型

第一种优化方法,从数据库入手。既然查询到的结果不准确,那我就在库存减少上做手脚。将库存的数据类型改成无符号(不能有负值)。

代码还是跟上面差不多,只是在库存减1的地方做了个判断。避免报错。


public function actionNormal(){
   // 查询库存
   $stock = Goods::find()->select('stock')->where(['goods_id'=>100001])->asArray()->one();
   // 判断该商品是否还有库存
   if ($stock['stock']>0) {
     // 库存减一
     if(Goods::updateAllCounters(['stock' => -1],['goods_id'=>100001])===false){
       echo "已被抢购一空!";
       return false;
     }

// 生产订单(另外功能,暂且随机赋值)
     $order = $this->build_order();

// 秒杀信息入库
     $model = new Highly();
     $model->order_id = $order;
     $model->goods_name = '秒杀商品';
     $model->buy_time = date('Y-m-d H:i:s',time());
     $model->mircrotime = microtime(true);
     if($model->save()===false){
       echo '未能成功抢购!';
     }else{
       echo '恭喜你,订单<b>'.$order.'</b>抢购成功';
     }

}else{
     echo '已被抢购一空!';
   }
 }

这一次同样200的并发,执行结果发现。数据正确,并不会出现超卖的情况。
思路其实也比较简单。因为库存不能为负值,当库存等于0时,如果还有值传进来,则会报错。请求被终止。

这种优化方式,虽然避免了商品超卖的情况。但是在另一方面,请求仍然会对数据库造成压力。如果多个功能使用此数据库,会造成性能下降厉害。

优化二:redis

利用 redis list类型的pop的原子性。在操作数据库前,做一个验证。当商品卖完后,就不允许再继续进行数据库操作。



// redis list 高并发测试
 public function actionRedis(){
   $redis = \Yii::$app->redis;
   // $redis->lpush('mytest',1);
   $order = $this->build_order();
   // echo $order;die;
   // echo $redis->llen('mytest');
   $reg = $redis->lpop('mytest');
   if (!$reg) {
     echo "笨蛋!已经被抢光啦!";
     return false;
   }
   $redis->close();
   $model = new Highly();
   $model->order_id = $order;
   $model->goods_name = '秒杀商品';
   $model->buy_time = date('Y-m-d H:i:s',time());
   $model->mircrotime = microtime(true);

if($model->save()===false){
     echo '未能成功抢购!';
   }else{
     echo '恭喜你,订单<b>'.$order.'</b>抢购成功';
   }
 }
 // 给redis添加商品
 public function actionInsertgoods(){
   $count = yii::$app->request->get('count',0);
   if (empty($count)) {
     echo '大兄弟,你还没告诉我需要上架多少商品呢!';
     return false;
   }
   $redis = \Yii::$app->redis;
   for ($i=0; $i < $count; $i++) {
     $redis->lpush('mytest',1);
   }
   echo '成功添加了'.$redis->llen('mytest').'件商品。';
   $redis->close();

}

这点的代码,我写了两个方法。第一个方法是秒杀的代码,第二个方法是给秒杀的商品设置数量。为了方便测试,我这里处理的比较简单。

通过测试,数据库生产的订单数量正常,并没有出现问题。而又避免了请求数据库造成性能下降的问题。同时内存数据库redis查询的速度要比mysql快很多。

来源:http://blog.csdn.net/u011061889/article/details/77417739

标签:php,抢购
0
投稿

猜你喜欢

  • Python的numpy库中将矩阵转换为列表等函数的方法

    2021-06-19 12:18:21
  • 简单解析Django框架中的表单验证

    2023-09-07 04:51:05
  • Golang 按行读取文件的三种方法小结

    2024-02-20 18:45:29
  • 详解opencv中画圆circle函数和椭圆ellipse函数

    2023-08-10 22:11:40
  • python复制文件的方法实例详解

    2021-12-22 11:43:45
  • openCV-Python笔记之解读图像的读取、显示和保存问题

    2022-04-26 19:46:02
  • MySQL中SQL命令语句条件查询实例详解

    2024-01-12 19:45:48
  • javascript实现计算器功能详解流程

    2024-04-23 09:27:00
  • Python 内存管理机制全面分析

    2021-07-17 07:21:17
  • python获取磁盘号下盘符步骤详解

    2022-10-05 08:32:32
  • django settings.py 配置文件及介绍

    2022-01-17 12:52:44
  • python实现在函数中修改变量值的方法

    2023-12-15 04:15:02
  • php字符串函数学习之strstr()

    2024-05-11 10:02:07
  • python生成tensorflow输入输出的图像格式的方法

    2021-03-20 05:21:08
  • PyQtGraph在pyqt中的应用及安装过程

    2022-02-27 17:00:14
  • Vue下滚动到页面底部无限加载数据的示例代码

    2024-06-05 15:31:44
  • Python标准库之循环器(itertools)介绍

    2023-09-16 02:41:43
  • Python简单获取网卡名称及其IP地址的方法【基于psutil模块】

    2022-10-07 19:52:15
  • 交互设计师心得——核心竞争力

    2010-01-19 13:45:00
  • Python threading中lock的使用详解

    2023-01-16 08:32:26
  • asp之家 网络编程 m.aspxhome.com