php 和mysql实现抢购功能_php处理抢购类功能的高并发请求
本文以抢购、秒杀为例。介绍如何在高并发状况下确保数据正确。
在高并发请求下容易参数两个问题
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 '恭喜你,订单'.$order.'抢购成功';
}
}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 '恭喜你,订单'.$order.'抢购成功';
}
}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 '恭喜你,订单'.$order.'抢购成功';
}
}
// 给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 和mysql实现抢购功能_php处理抢购类功能的高并发请求相关推荐
- php处理抢购类功能的高并发请求,php处理抢购类
...d> 最近在做抢购系统,但头疼的是,在多用户高并发的情况下经常会库存出现问题.排查到,在同一时间内多用户同时下单导致查询和插入不同步了,而查询中跟插入又有时间差而在高并发的情况下导致库存问 ...
- php同时抢购 代码,php如何处理抢购类功能的高并发请求
在高并发请求下容易参数两个问题 1.数据出错,导致产品超卖. 2.频繁操作数据库,导致性能下降. 本文主要和大家详细介绍了php处理抢购类功能的高并发请求,具有一定的参考价值,感兴趣的小伙伴们可以参考 ...
- Web大规模高并发请求和抢购的解决方案
电商的秒杀和抢购,对我们来说,都不是一个陌生的东西.然而,从技术的角度来说,这对于Web系统是一个巨大的考验.当一个Web系统,在一秒钟内收到数以万计甚至更多请求时,系统的优化和稳定至关重要.这次我们 ...
- mysql 保证事物完整性_数据库高并发请求,如何保证数据完整性?详解MySQL/InnoDB的加锁...
本文是对MySQL/InnoDB中,乐观锁.悲观锁.共享锁.排它锁.行锁.表锁.死锁概念的理解,这些在面试中也经常遇到,如数据库高并发请求,如何保证数据完整性?今天我查阅资料进行了MySQL/Inno ...
- 分布式锁和mysql事物扣库存_这个是真的厉害,高并发场景下的订单和库存处理方案,讲的很详细了!...
前言 之前一直有小伙伴私信我问我高并发场景下的订单和库存处理方案,我最近也是因为加班的原因比较忙,就一直没来得及回复.今天好不容易闲了下来想了想不如写篇文章把这些都列出来的,让大家都能学习到,说一千道 ...
- mysql乐观锁 秒杀_使用数据库乐观锁解决高并发秒杀问题,以及如何模拟高并发的场景,CyclicBarrier和CountDownLatch类的用法...
数据库:mysql 数据库的乐观锁:一般通过数据表加version来实现,相对于悲观锁的话,更能省数据库性能,废话不多说,直接看代码 第一步: 建立数据库表: CREATE TABLE `skill_ ...
- php实现小说字典功能_PHP实现生成数据字典功能示例
本文实例讲述了PHP实现生成数据字典功能.分享给大家供大家参考,具体如下: 最近时间紧迫,没有时间发博客,趁现在有点时间向大家分享一个知识点.在咱们做开发的时候 ,也许经常会遇到对数据库分析,做一个数 ...
- php聊天功能_php实现简单聊天功能
搜索热词 1.创建聊天消息表,其表的字段有消息内容,发送时间和发送者的名称: CREATE TABLE `guanhui`.`message` ( `id` INT(10) NOT NULL AUTO ...
- php加入语音播报功能_PHP实现语音播报功能
大家估计都知道现在很多AI音响能够给你播报天气,叫你起床...甚至能够接受语音指令!所谓的人工智能音响,听起来很高大上,都说PHP是最好的编程语言,今天我就带大家来实现一个语音播报功能!先大体说一个思 ...
最新文章
- laravel 重写以及500错误
- C#设计模式之享元模式(Flyweight)
- Subversion For Windows的安装与使用
- 小调查:足足两周了,下周你上班否?
- 全国大学生数学建模2014年A题嫦娥三号软着陆轨道设计与控制策略论文与代码
- c++清空输入缓冲区_干货 | C++的输入输出方法
- python对象使用
- 1286:怪盗基德的滑翔翼-2019-07-03(《信息学奥赛一本通》)
- 未找到适用于完成此操作的图像处理组件_一张图片竟带来如此风险?苹果操作系统多媒体处理组件暗含严重隐患...
- 安装Jaspersoft Studio
- django高级应用(分页功能)
- SQL“多字段模糊匹配关键字查询”
- 百度初级认证考试知识点
- 超市火灾烟气蔓延及人员疏散的matlab仿真模拟
- 对 Go2 错误处理提案的批判
- word2010中设置页码起始页从任意一页开始
- 创业之前你要先了解3大要点!!
- 颈椎病及腰椎间盘突出病因病理
- 今天女神打了个电话让我去修电脑,无数次戳中笑点
- doctor技术基础
热门文章
- python以下是变量合法命名的是_Python超级详细的变量命名规则
- 查看systemctl或service启动服务日志
- Mac OS 软件包管理器Homebrew
- Android自定义属性 format详解
- mkdir 创建多级目录_linux中的目录功能和文件文件管理
- javascript 本地对象和内置对象_JavaScript 的面向对象
- powerdesigner mysql 反引号_PowerDesigner实用技巧小结 及 导出word,想字段顺序跟模型中一致,如何设置...
- linux显卡烤机操作,显卡拷机必备:FurMark时隔一年全新升级
- 乾云服务器虚拟化,乾云服务器虚拟化系统
- c语言ecit,Arthritis Rheumatol:新型JAK3/TEC抑制剂PF-06651600(ritlecitinib)对中重度类风湿性关节炎的疗效和安全性...