php处理抢购类功能的高并发请求
2017-08-19 22:25
323 查看
本文以抢购、秒杀为例。介绍如何在高并发状况下确保数据正确。
在高并发请求下容易参数两个问题
1.数据出错,导致产品超卖。
2.频繁操作数据库,导致性能下降。
apache2.4.9
php5.5.12
php框架 yii2.0
工具 apache bench (apache自带高并发请求工具)。
,则库存减少1,同时生产订单,录入抢购者数据。
将商品库存设置为20后,通过ab 配置200的并发请求。
执行结果发现库存变成了负值,商品超卖了。
原因比较简单,在高并发请求下。在生产订单,减少库存之前,会优先查询到库存结果。
代码还是跟上面差不多,只是在库存减1的地方做了个判断。避免报错。
这一次同样200的并发,执行结果发现。数据正确,并不会出现超卖的情况。
思路其实也比较简单。因为库存不能为负值,当库存等于0时,如果还有值传进来,则会报错。请求被终止。
这种优化方式,虽然避免了商品超卖的情况。但是在另一方面,请求仍然会对数据库造成压力。如果多个功能使用此数据库,会造成性能下降厉害。
这点的代码,我写了两个方法。第一个方法是秒杀的代码,第二个方法是给秒杀的商品设置数量。为了方便测试,我这里处理的比较简单。
通过测试,数据库生产的订单数量正常,并没有出现问题。而又避免了请求数据库造成性能下降的问题。同时内存数据库redis查询的速度要比mysql快很多。
在高并发请求下容易参数两个问题
1.数据出错,导致产品超卖。
2.频繁操作数据库,导致性能下降。
测试环境
Windows7apache2.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
执行结果发现库存变成了负值,商品超卖了。
原因比较简单,在高并发请求下。在生产订单,减少库存之前,会优先查询到库存结果。
优化一:修改库存数据类型
第一种优化方法,从数据库入手。既然查询到的结果不准确,那我就在库存减少上做手脚。将库存的数据类型改成无符号(不能有负值)。代码还是跟上面差不多,只是在库存减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快很多。
相关文章推荐
- php处理抢购类功能的高并发请求
- PHP中利用redis实现消息队列处理高并发请求
- 一. Volley简介 Volley的中文翻译为“齐射、并发”,是在2013年的Google大会上发布的一款Android平台网络通信库,具有网络请求的处理、小图片的异步加载和缓存等功能,能够帮助
- 备忘:Windows下php-cgi不能处理并发PHP请求
- PHP中利用redis实现消息队列处理高并发请求
- PHP中利用redis实现消息队列处理高并发请求--简洁代码实现效果
- php结合redis实现高并发下的抢购、秒杀功能的实例
- PHP处理客户端数据请求
- PHP实现表单提交数据的验证处理功能【防SQL注入和XSS攻击等】
- PHP ADODB生成HTML表格函数rs2html功能【附错误处理函数用法】
- 高并发重复请求的去重处理(转)
- IIS处理并发请求时出现的问题及解决
- 小谈php处理 大并发 大流量 大存储
- JS中如何处理多个ajax并发请求?
- 从并发处理谈PHP进程间通信(二)System V IPC
- js 处理form表单整理成数组,结合php 完成排序功能的实现
- 解读PHP的Yii框架中请求与响应的处理流程
- php结合redis实现高并发下的抢购、秒杀功能
- 使用fork并发处理多个client的请求和对等通信p2p
- 查看httpd进程数(即prefork模式下Apache能够处理的并发请求数)