PHP高并发实例解决超卖商品库存问题的讲解

在上一篇文章《PHP高并发实例解决超卖商品库存问题的讲解》中，我们谈到了在高并发情况下防止商品超卖库存的相关问题。 下面我们来看看防止库存超卖的并发性。 测试的相关内容，希望对大家有所帮助。

基于《PHP高并发实例详解解决商品库存超卖问题》测试用例

一、 普通下单

并发测试时，product table id = 1 name = Dao Huaxiang Rice store = 15

请求总数30个，每次并发10个

ab -n 30 -c 10 http://www.mageym.com/code/the_limit/add_order.php

结果：

减库存成功15次，店铺库存有负数-7 8次判断库存不足（负库存不正确，不允许）

二、unsigned 模式

调整回product table id = 1 name = Daohuaxiang Rice store = 15

请求总数30个，每次并发10个

ab -n 30 -c 10 http://www.mageym.com/code/the_limit/unsigned.php

结果：

减库存成功15次，店铺库存负数-6 9次判断库存不足（负数不正确，不允许）

只在查询语句中加入for update影响不大

三、mysql 的事务，锁住操作的行

调整回product table id = 1 name = Daohuaxiang Rice store = 15

请求总数30个，每次并发10个

ab -n 30 -c 10 http://www.mageym.com/code/the_limit/ACID.php

结果：

减库存成功15次，店铺库存15次没有出现负数，判断库存不足（负数不正确，不允许）

添加事务的效果很好 ab -n 3000 -c 1000 也能承受并发

四、 非阻塞的文件排他锁阻止形式

非阻塞形式

效果不是负面的，但性能是事务>阻塞>非阻塞

五、 redis 队列

代码与之前的乐观锁版本略有调整

<?php
$redis =new Redis();
$redis->connect("127.0.0.1", 6379);
$redis->auth('PASSWORD');
$redis->watch('sales');//乐观锁 监视作用 set()  初始值0
$sales = $redis->get('sales');
//var_dump($sales); exit;
db();
global $con;
// 查询商品信息
//$product_id = 1;
//$sql = "select * from products where id={$product_id}";
//$result = mysqli_query($con, $sql);
//$row = mysqli_fetch_assoc($result);
//$store = $row['store'];
// 库存
$n = 15;
if ($sales >= $n) {
    insertLog('库存为0 秒杀失败');
    exit('秒杀结束');
}
//redis开启事务
$redis->multi();
$redis->incr('sales'); //将 key 中储存的数字值增一 ,如果 key 不存在，那么 key 的值会先被初始化为 0 ，然后再执行 INCR 操作。
$res = $redis->exec(); //成功1 失败0
if ($res) {
    //秒杀成功
    $con = new mysqli('localhost','root','PASSWORD','dev');
    if (!$con) {
        echo "数据库连接失败";
    }
    $product_id = 1;// 商品ID
    $buy_num = 1;// 购买数量
    sleep(1);
    $sql = "update products set store=store-{$buy_num} where id={$product_id}";
    if (mysqli_query($con, $sql)) {
        echo "秒杀完成";
        insertLog('恭喜 秒杀成功');
    }
} else {
    insertLog('抱歉 秒杀失败');
    exit('抢购失败');
}
function db()
{
    global $con;
    $con = new mysqli('localhost','root','WOrd1234.*','dev');
    if (!$con) {
        echo "数据库连接失败";
    }
}
/**
 * 记录日志
 */
function insertLog($content)
{
    global $con;
    $sql = "INSERT INTO `order_log` (content) values('$content')";
    mysqli_query($con, $sql);
}
ab -n 30 -c 10 http://www.mageym.com/code/the_limit/optimistic\ _redis_lock.php

最终结论并发挑战优先redis性能好

注意：上面有网址的地方要更换成自己的