php处理抢购类高并发请求实现详解-高并发

... 4.最好不需要推广,用户主动过来使用 5.集群服务器、高并发访问、消息队列 6.有一定的商业价值,以站养站,提高技术 这样的目的是我为了练习 集群、高并发,现在已经开发了一款 分类信息站群系统,...

这次给大家带来php处理抢购类高并发请求实现详解,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 '恭喜你,订单<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+ajax无刷新文件上传实现步骤详解

PHP实现多维数组排序算法有哪些方式

以上就是php处理抢购类高并发请求实现详解的详细内容,更多请关注php中文网其它相关文章!

并发 - PHP项目需求,可以用到下面所有的这些技术

... 4.最好不需要推广,用户主动过来使用 5.集群服务器、高并发访问、消息队列 6.有一定的商业价值,以站养站,提高技术 这样的目的是我为了练习 集群、高并发,现在已经开发了一款 分类信息站群系统,...

php处理抢购类并发请求实现详解

这次给大家带来php处理抢购类高并发请求实现详解,php处理抢购类高并发请求的注意事项有哪些,下面就是实战案例,一起来看一下。本文以抢购、秒杀为例。介绍如何在高并发状况下确保数据正确。 在高并发请求下...

并发的处理

一、什么是高并发(高并发的一系列名词解释)QPS :每秒钟请求或查询的数量,在互联网领域,指每秒钟响应请求数(http请求)。吞吐量:单位时间内处理的请求数量。响应时间:从请求发出到...

php能处理并发吗?php并发解决方案

php在执行的过程中究竟是如何处理高并发问题的,接下来我们具体的来看一下关于PHP高并发的一个解决方案。先来看看php在服务器的执行过程:当用户请求服务器php文件的时候,服务器将对php文件进行语法分析,...

php memcached的并发处理队列实现有关问题

php memcached的高并发处理队列实现问题 刚看了memcached处理抢购问题的队列的一些代码,我理解到的思路有两种 1.使用 $mem->set(LOCK_key,1) 来加锁,入队结束后 $mem->delete(LOCK_key) 解锁 2.使用mem

网络直播开发过程中非常重要的一环

相信大家对高并发这个词并不陌生,现在有很多家科技公司在进行人才招聘时都会问到关于高并发的问题。其实高并发通常指通过设计保证系统能够同时并行处理很多请求,是网络直播开发过程中关于系统架构必须考虑的因素...

怎样学习才能拥有所谓“并发”的经验?

...h2>回复内容: 这个问题完全可以重定向到如何处理高并发业务场景.以下只是我工作一年多接触到的一些基础,也许有偏差,要具备高并发的经验确实需要有实际项目,因为业务逻辑其实很容易理清,但是要在高并发的情况下如...

电商系统领域说的并发是什么意思,YISHOP能达到并发

... 回复讨论(解决方案) 电商领域说的高并发就是指系统面对同一个的时刻诸多请求能够及时处理,并且系统不会瘫痪,数据不会出错。这就很考验系统架构是否合理,代码是否健壮,一处的不合理就很难达到高...

有哪些适合并发流量、性能网站开发的 PHP 框架推荐?

回复内容: 高并发、高流量、高性能?这些问题不是一个php框架就可以解决的,lamp架构,越是接近底层的东西影响力越大,php只是四层架构最上面的一层,如果考虑优化性能先从底层硬件和软件优化吧。 可以了...

如何利用Redis锁解决并发问题

高并发问题是我们经常可以遇到的问题,那么该如何解决高并发这个问题呢?本篇文章介绍的内容就是利用Redis锁解决高并发问题,一起来看看吧。这里我们主要利用Redis的setnx的命令来处理高并发。setnx 有两个参数。...