php高并发秒杀解决方案

至于本人为啥会写这篇文章主要是因为本人几次面试中都被问到这个问题，其实这个问题答案不是唯一的，每次我答完面试官没有评价，只是说你还能说得具体点吗？有的时候感觉他们自己估计都不清楚，只是在套面试者的答案的。

那说到秒杀大家就先要清楚业务场景，然后分析会产生的问题，最后是找到合适的解决方案。

1.秒杀业务场景

比如某个淘宝商城中某家商店的一款新手机低价出售，很多人都会去购买，但是数量有限比如只有1000部，那也就是最后只有1000个人能买到。

2.多个用户同时去抢购会产生什么问题？

在说会产生什么问题前，我们先来看下当用户点击抢购按钮后的一系列操作。
（1）先判断库存是否足够
（2）如果库存不足，提示库存不足
（3）库存足够的情况下，就会更新库存信息然后创建订单，完成后返回给用户购买成功。
如果所有的操作都是有序的，那这样是不会产出什么问题的，但是我们是秒杀，同一时刻会有多个用户操作，这个时候假如这款秒杀的手机只有一部了，因为是同时操作的故多个用户都会走到第三部操作，这个时候就会导致超卖。

3. 那怎么解决超卖的问题？

（一）既然是库存不能为负数，那我们可能马上会想到给库存那个字段加个uunsigned属性或者在update 库存的时候加个 where storge > 0 （假设库存字段是storge）就可以了,这确实是一种解决方案。
（二） 我们可以利用悲观锁
我们先来看下正常情况下的代码
goods.php

<?php
$conn=mysqli_connect("127.0.0.1","root","123456",'blog'); 
if(!$conn){ 
    echo "connect failed"; 
    exit; 
} 

mysqli_query($conn,"set names utf8");
 
$user_id = 342523;
$goods_id = 200;
$price = 98.44;
$number = 1;

//模拟下单操作
mysqli_query($conn,'begin'); //为了数据一致性开启事务
$sql="select storge from store where goods_id={$goods_id} ";
$res=mysqli_query($conn,$sql);
$row=mysql_fetch_assoc($res);
if($row['number']>0){//高并发下会导致超卖
    $order_sn=build_order_no();//生成订单
    $sql="insert into order(order_sn,user_id,goods_id,price) 
    values('$order_sn',{$user_id},{$goods_id},{$price})"; 
    $order_rs=mysqli_query($conn,$sql); 
    //库存减少
    $sql="update store set number=number-{$number} where goods_id={$goods_id}";
    $store_rs=mysqli_query($conn,$sql); 
    if(mysql_affected_rows()){ 
        
        mysqli_query($conn,'commit');
        echo '购买成功';
    }else{ 
        
        mysqli_query($conn,'rollback');
    } 
}else{
     echo '库存不足';
}

 //生成唯一订单
function build_order_no(){
  return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}

如果同一时间有多个客户端查到库存大于零的话，那上面这个代码在高并发的情况下就会产生超卖的问题，那怎么解决呢？上代码

<?php
$sql="select storge from store where goods_id={$goods_id} for update ";

我这里只展示不一样的代码，其他的都一样。我们知道for update 是给查询的数据行加上了锁(当然for update 在事务中使用才有用)，当别人要去读取或者修改这行数据的时候就必须获得这个锁，事务提交或者回滚后才释放该锁，那也就是说在另外一个事务中想要读取或者修改这个数据，必须等前一个事务处理完成，这样也能解决超卖的问题,顺便提下lock()方法也是一样的效果，这里就不展示了。

但是我们前面提到的两种方法都不是最佳的方法，为什么呢？
答：在高并发下会有性能问题，尤其是第二种方法，我们使用了事务和悲观锁，可想而知当并发量很大的时候势必会导致严重的阻塞，那我们再来介绍下另外一种方法，也是本人推荐的一种方法。

（三）使用redis队列
我们先看代码是如何实现的，再来看看为啥要用到这种实现方式
1.我们先向redis里面存入秒杀的产品数量1000（这里假设为1000）

<?php
$store=1000;
$redis=new Redis();
$result=$redis->connect('127.0.0.1',6379);
$res=$redis->llen('goods_store');
$count=$store-$res;
for($i=0;$i<$count;$i++){
    $redis->lpush('goods_store',1);
}

2.我们看具体的逻辑实现,我们把之前从数据库里面读取库存数量改为从redis里面拉取
goods_redis.php

<?php
$redis=new Redis();
$result=$redis->connect('127.0.0.1',6379);
$count=$redis->lpop('goods_store');
if(!$count){
    return;
}

这里只展示不一样的代码，我们知道redis的所有操作都是原子性的，即使有两个操作同时到达也是按照顺序来执行的，那这样就有效的避免了超卖的问题，那口说无凭，我来分别对原来没有改进的代码和改进后的代码做下压力测试。
ab -r -n 3000 -c 2000 http://114.116.243.161/goods.php 我们看下数据库里面的信息

1.png

发现超卖了22个，我们再来测试下改进后的代码,为了更清楚的看到结果我先复原下原来的数据。
ab -r -n 3000 -c 2000 http://114.116.243.161/goods_redis.php 看下结果：

1.png

我们发现没有超卖，说明这种方法可用。

可能有小伙伴会问这里为啥要使用队列，使用普通的key value 来存储商品数据不行么？笔者认为如果使用普通的key/value 如果不做特殊处理有可能会导致库存为负数；
当然，今天讲的这个高并发解决方案准确的来说是解决超卖的问题，实际的高并发处理远不止这些，它包含了各个环节的优化，后续我也会持续更新相关的文章。