PHP高并发情况下防止商品库存超卖

分类：NoSQL作者：wwwarewow

商城系统中，抢购和秒杀是很常见的营销场景，在一定时间内有大量的用户访问商场下单，主要需要解决的问题有两个：

1. 高并发对数据库产生的压力；

2. 竞争状态下如何解决商品库存超卖；

高并发对数据库产生的压力

对于第一个问题，使用缓存来处理，避免直接操作数据库，例如使用 Redis。

竞争状态下如何解决商品库存超卖

对于第二个问题，需要重点说明。

常规写法：查询出对应商品的库存，判断库存数量否大于 0，然后执行生成订单等操作，但是在判断库存是否大于 0 处，如果在高并发下就会有问题，导致库存量出现负数。

测试表 sql
把如下表数据导入到数据库中

/*
Navicat MySQL Data Transfer

Source Server         : 01 本地localhost
Source Server Version : 50553
Source Host           : localhost:3306
Source Database       : test

Target Server Type    : MYSQL
Target Server Version : 50553
File Encoding         : 65001

Date: 2020-11-06 14:31:35
*/

SET FOREIGN_KEY_CHECKS=0;

-- ----------------------------
-- Table structure for products
-- ----------------------------
DROP TABLE IF EXISTS `products`;
CREATE TABLE `products` (
  `id` int(10) NOT NULL AUTO_INCREMENT COMMENT 'ID',`title` varchar(50) DEFAULT NULL COMMENT '货品名称',`store` int(11) DEFAULT '0' COMMENT '货品库存',PRIMARY KEY (`id`)
) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8mb4 COMMENT='货品表';

-- ----------------------------
-- Records of products
-- ----------------------------
INSERT INTO `products` VALUES ('1','稻花香大米','20');

-- ----------------------------
-- Table structure for order_log
-- ----------------------------
DROP TABLE IF EXISTS `order_log`;
CREATE TABLE `order_log` (
  `id` int(10) unsigned NOT NULL AUTO_INCREMENT,`content` varchar(255) CHARACTER SET utf8mb4 DEFAULT NULL COMMENT '日志内容',`c_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '创建时间',PRIMARY KEY (`id`)
) ENGINE=MyISAM DEFAULT CHARSET=latin1;

-- ----------------------------
-- Table structure for order
-- ----------------------------
DROP TABLE IF EXISTS `order`;
CREATE TABLE `order` (
  `oid` bigint(20) unsigned NOT NULL DEFAULT '0' COMMENT '订单号',`product_id` int(11) DEFAULT '0' COMMENT '商品ID',`number` int(11) DEFAULT '0' COMMENT '购买数量',PRIMARY KEY (`oid`)
) ENGINE=MyISAM DEFAULT CHARSET=latin1 COMMENT='订单表';

下单处理代码

<?php

db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

//step2 查询商品信息
$sql = "select * from products where id={$product_id}";
$result = mysqli_query($con,$sql);
$row = mysqli_fetch_assoc($result);

//step3 判断商品下单数量是否大于商品库存数量
//此处在高并发下，可能出现上一个下单后还没来得及更新库存，下一个下单判断库存数不是最新的库存
if ($row['store'] > 0) {

    sleep(1);
    //step4 更新商品库存数量（减去下单数量）
    $sql = "update products set store=store-{$buy_num} where id={$product_id}";
    if (mysqli_query($con,$sql)) {
        echo "更新成功";
        //step5 生成订单号创建订单
        $oid = build_order_no();
        create_order($oid,$product_id,$buy_num);
        insertLog('库存减少成功，下单成功');
    } else {
        echo "更新失败";
        insertLog('库存减少失败');
    }

} else {
    echo "没有库存";
    insertLog('库存不够');
}

function db()
{
    global $con;
    $con = new mysqli('localhost','root','test');
    if (!$con) {
        echo "数据库连接失败";
    }
}

/**
 * 生成唯一订单号
 */
function build_order_no()
{
    return date('Ymd') . str_pad(mt_rand(1,99999),5,'0',STR_PAD_LEFT);
}

function create_order($oid,$number)
{
    global $con;
    $sql = "INSERT INTO `order` (oid,product_id,number) values('$oid','$product_id','$number')";
    mysqli_query($con,$sql);
}

/**
 * 记录日志
 */
function insertLog($content)
{
    global $con;
    $sql = "INSERT INTO `order_log` (content) values('$content')";
    mysqli_query($con,$sql);
}

 将库存字段字段设为 unsigned

因为库存字段不能为负数，在下单后更新商品库存时，如果出现负数将返回 false

<?php
db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

//step2 查询商品信息
$sql = "select * from products where id={$product_id} for UPDATE";//利用for update 开启行锁
$result = mysqli_query($con,$sql);
$row = mysqli_fetch_assoc($result);

//step3 判断商品下单数量是否大于商品库存数量
if ($row['store'] > 0) {

    sleep(1);
    //step4 更新商品库存数量（减去下单数量）
    $sql = "update products set store=store-{$buy_num} where id={$product_id}";
    if (mysqli_query($con,$buy_num);
        insertLog('库存减少成功，下单成功');
    } else {
        // 如果出现负数将返回false
        echo "更新失败";
        insertLog('库存减少失败');
    }
} else {
    //商品已经抢购完
    echo "没有库存";
    insertLog('库存不够');
}

function db()
{
    global $con;
    $con = new mysqli('localhost',$sql);
}

使用 mysql 的事务，锁住操作的行

在下单处理过程中，使用 mysql 的事务将正在下单商品行数据锁定

<?php
db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

mysqli_query($con,"BEGIN"); //开始事务

//step2 查询商品信息
$sql = "select * from products where id={$product_id} for UPDATE";//利用for update 开启行锁
$result = mysqli_query($con,$buy_num);
        insertLog('库存减少成功，下单成功');
        mysqli_query($con,"COMMIT");//事务提交即解锁
    } else {
        echo "更新失败";
        insertLog('库存减少失败');
        mysqli_query($con,"ROLLBACK");//事务回滚即解锁
    }
} else {
    //商品已经抢购完
    echo "没有库存";
    insertLog('库存不够');
    mysqli_query($con,"ROLLBACK");//事务回滚即解锁
}

function db()
{
    global $con;
    $con = new mysqli('localhost',$sql);
}

使用非阻塞的文件排他锁
在处理下单请求的时候，用 flock 锁定一个文件，如果锁定失败说明有其他订单正在处理，此时要么等待要么直接提示用户” 服务器繁忙”，计数器存储抢购的商品数量，避免查询数据库。

阻塞 (等待) 模式：并发时，当有第二个用户请求时，会等待第一个用户请求完成、释放锁，获得文件锁之后，程序才会继续运行下去。

<?php
db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

$fp = fopen('lock.txt','w');
if (flock($fp,LOCK_EX)) {   //文件独占锁,阻塞
    //step2 查询商品信息
    $sql = "select * from products where id={$product_id}";
    $result = mysqli_query($con,$sql);
    $row = mysqli_fetch_assoc($result);

    //step3 判断商品下单数量是否大于商品库存数量
    if ($row['store'] > 0) {
        //处理订单
        sleep(1);
        //step4 更新商品库存数量（减去下单数量）
        $sql = "update products set store=store-{$buy_num} where id={$product_id}";
        if (mysqli_query($con,$sql)) {
            echo "更新成功";
            //step5 生成订单号创建订单
            $oid = build_order_no();
            create_order($oid,$buy_num);
            insertLog('库存减少成功，下单成功');
        } else {
            echo "更新失败";
            insertLog('库存减少失败');
        }
    } else {
        //商品已经抢购完
        echo "没有库存";
        insertLog('库存不够');
    }
    flock($fp,LOCK_UN); //释放锁

}
fclose($fp);

function db()
{
    global $con;
    $con = new mysqli('localhost',$sql);
}

 非阻塞模式：并发时，第一个用户请求，拿得文件锁之后。后面请求的用户直接返回系统繁忙，请稍后再试

<?php
db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

$fp = fopen('lock.txt',LOCK_EX|LOCK_NB)) {   //文件独占锁,非阻塞
    //step2 查询商品信息
    $sql = "select * from products where id={$product_id}";
    $result = mysqli_query($con,LOCK_UN); //释放锁

} else {
    //系统繁忙，请稍后再试
    echo "系统繁忙，请稍后再试";
    insertLog('系统繁忙，请稍后再试');
}
fclose($fp);

function db()
{
    global $con;
    $con = new mysqli('localhost',$sql);
}

使用 redis 队列

  • 因为 pop 操作是原子的，即使有很多用户同时到达，也是依次执行，推荐使用
  • mysql 事务在高并发下性能下降很厉害，文件锁的方式也是

  1. 先将商品库存到 redis 队列

<?php

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'];

// 获取商品在redis缓存的库存
$redis = new Redis();
$result = $redis->connect('127.0.0.1',6379);
$key = 'goods_store_' . $product_id;
$res = $redis->llen($key);
$count = $store - $res;

for ($i=0; $i<$count; $i++) {
    $redis->lpush($key,1);
}
echo $redis->llen($key);

function db()
{
    global $con;
    $con = new mysqli('localhost','test');
    if (!$con) {
        echo "数据库连接失败";
    }
}

2. 抢购、秒杀逻辑

<?php

db();
global $con;

//step1 接收下单参数
$product_id = 1;// 商品ID
$buy_num = 1;// 购买数量

//step2 下单前判断redis队列库存量
$redis = new Redis();
$result = $redis->connect('127.0.0.1',6379);
$count = $redis->lpop('goods_store_' . $product_id);
if (!$count) {
    insertLog('error:no store redis');
    return '秒杀结束，没有商品库存了';
}

sleep(1);
//step3 更新商品库存数量（减去下单数量）
$sql = "update products set store=store-{$buy_num} where id={$product_id}";
if (mysqli_query($con,$sql)) {
    echo "更新成功";
    //step4 生成订单号创建订单
    $oid = build_order_no();
    create_order($oid,$buy_num);
    insertLog('库存减少成功，下单成功');
} else {
    echo "更新失败";
    insertLog('库存减少失败');
}

function db()
{
    global $con;
    $con = new mysqli('localhost',$sql);
}

3.redis 乐观锁防止超卖

<?php

$redis =new Redis();
$redis->connect("127.0.0.1",6379);
$redis->watch('sales');//乐观锁 监视作用 set()  初始值0
$sales = $redis->get('sales');

$n = 20;// 库存
if ($sales >= $n) {
    exit('秒杀结束');
}

//redis开启事务
$redis->multi();
$redis->incr('sales'); //将 key 中储存的数字值增一,如果 key 不存在，那么 key 的值会先被初始化为 0 ，然后再执行 INCR 操作。
$res = $redis->exec(); //成功1 失败0

if ($res) {
    //秒杀成功
    $con = new mysqli('localhost','test');
    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 "秒杀完成";
    }

} else {
    exit('抢购失败');
}

原文地址：https://blog.csdn.net/JSPSEO/article/details/125050175

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 dio@foxmail.com 举报，一经查实，本站将立刻删除。

相关推荐

Redis与非关系数据库
文章浏览阅读752次。关系型数据库关系型数据库是一个结构化的数据库，创建在关系模型（二维表模型）基础上，一般面向于记录SQL语句（标准数据查询语言）就是一种基于关系型数据库的语言，用于执行对关系型数据库中数据的检索和操作主流的关系数据库包括Oracle、Mysql、SQL Server、Microsoft Access、DB2等非关系型数据库NoSQL(nOSQL=Not Only SQL)，意思是“不仅仅是SQL”，是非关系型数据库的总称。除了主流的关系型数据库外的数据库，都认为是非关系型主流的NoSQ.._redis是非关系型数据库吗
PHP高并发情况下防止商品库存超卖
文章浏览阅读687次，点赞2次，收藏5次。商城系统中，抢购和秒杀是很常见的营销场景，在一定时间内有大量的用户访问商场下单，主要需要解决的问题有两个：1. 高并发对数据库产生的压力；2. 竞争状态下如何解决商品库存超卖；高并发对数据库产生的压力对于第一个问题，使用缓存来处理，避免直接操作数据库，例如使用 Redis。竞争状态下如何解决商品库存超卖对于第二个问题，需要重点说明。常规写法：查询出对应商品的库存，判断库存数量否大于 0，然后执行生成订单等操作，但是在判断库存是否大于 0 处，如果在高并发下就会有问题，导致库存_php库存结余并发
SpringBoot操作MongoDB数据库
文章浏览阅读1.4k次。MongoTemplate开发spring-data-mongodb提供了MongoTemplate和MongoRepository两种方式访问MongoDB，MongoRepository的方式访问较为简单，MongoTemplate方式较为灵活，这两种方式在Java对于MongoDB的运用中相辅相成。_springboot插入指定的mongodb数据库
HBase与NoSQL：HBase与其他NoSQL数据库的比较
文章浏览阅读887次，点赞10次，收藏19次。1.背景介绍1. 背景介绍NoSQL数据库是一种非关系型数据库，它的特点是可以存储非结构化的数据，并且可以处理大量的数据。HBase是一个分布式、可扩展的列式存储系统，它是基于Google的Bigtable设计的。HBase是一个开源的NoSQL数据库，它的核心功能是提供高性能的随机读写访问。在本文中，我们将对比HBase与其他NoSQL数据库，例如Redis、MongoDB、Cass...
C#连接MongoDB连接失败，提示连接超时或者SCRAM-SHA-1报错
文章浏览阅读819次。MongoDB连接失败记录_edentialmechanisn-scram-sha-1
mongo monstache部署
文章浏览阅读470次。mongodb抽取数据到ES，使用ELK内部插件无法获取数据，只能试试monstache抽取mongodb数据，但是monstache需要mongodb replica set 模式才能采集数据。############monstache-compose文件。#replicas set 启动服务。# 默认备份节点不能读写，可以设置。# mydb指的是需要同步的数据库。#登录主mongodb初始化rs。#primary 创建用户。# ip地址注意要修改。# ip地址注意要修改。_monstache csdn
MongoDB5安装部署和使用介绍
文章浏览阅读913次，点赞4次，收藏5次。storage:fork: trueadmin登录切换数据库注意: use 代表创建并使用,当库中没有数据时默认不显示这个库删除数据库查看表清单> show tables # 或者 > show collections表创建db.createCollection('集合名称', [options])table1字段类型描述capped布尔（可选）如果为 true，则创建固定集合。固定集合是指有着固定大小的集合，当达到最大值时，它会自动覆盖最早的文档。_mongodb5
Centos7.9设置MongoDB开机自启
文章浏览阅读862次。Centos7.9设置MongoDB开机自启（超全教程，一条龙）_mongodb centos开机启动脚本
NoSQL数据库使用场景以及架构介绍
文章浏览阅读1.3k次，点赞6次，收藏21次。NoSQL数据库使用场景以及架构介绍
第四十四章:NoSQL数据库的监控与管理
文章浏览阅读856次，点赞21次，收藏20次。1.背景介绍1. 背景介绍NoSQL数据库是一种非关系型数据库，它的设计目标是为了解决传统关系型数据库(如MySQL、Oracle等)在处理大量不结构化数据方面的不足。NoSQL数据库可以处理大量数据，具有高性能、高可扩展性和高可用性。但是，与关系型数据库不同，NoSQL数据库没有固定的模式，数据结构也不一定是表格。在NoSQL数据库中，数据存储和查询都是基于键值对、列族、图形等不同的...
nosql
文章浏览阅读416次。NoSQL定义：非关系型、分布式、开放源码和具有横向扩展能力的下一代数据库。由c++编写的开源、高性能、无模式的基于分布式文件存储的文档型数据库特点：高性能、高可用性、高扩展性、丰富的查询支持、可替换已完场文档某个指定的数据字段应用场景：社交场景:使用mongodb存储用户信息游戏场景：用户信息，装备积分物流场景：订单信息，订单状态场景操作特点：数据量大；读写操作频繁；价值较低的数据，对事物性要求不高开源、c语言编写、默认端口号6379、key-value形式存在，存储非结构化数据。_nosql
【错误记录】使用 Jedis 操作 Redis 数据库报错 ( JedisConnectionException | Redis 连接超时故障排查点 | 绑定配置 | 保护模式 | 防火墙 )
文章浏览阅读1.5k次，点赞3次，收藏2次。Exception in thread "main" redis.clients.jedis.exceptions.JedisConnectionException: Failed to create socket. at redis.clients.jedis.DefaultJedisSocketFactory.createSocket(DefaultJedisSocketFactory.java:110) at redis.clients.jedis.Connection.connect(Conne_redis.clients.jedis.exceptions.jedisconnectionexception: failed to create so
MongoDB设置登录账号，密码及权限
文章浏览阅读6.5k次，点赞3次，收藏12次。readAnyDatabase（在所有数据库上都有读取数据的权限）、readWriteAnyDatabase（在所有数据库上都有读写数据的权限）、userAdminAnyDatabase（在所有数据库上都有管理user的权限）、dbAdminAnyDatabase（管理所有数据库的权限）；：clusterAdmin（管理机器的最高权限）、clusterManager（管理和监控集群的权限）、clusterMonitor（监控集群的权限）、hostManager（ 管理Server）；_mongodb创建用户密码并授权
【Redis】概述&环境搭建(一)
文章浏览阅读593次。Redis是一个基于内存的键值型NoSQL数据库，在实际生产中有着非常广泛的用处_搭建本地redis
Redis高级篇之最佳实践
文章浏览阅读919次。Key 的最佳实践[业务名]:[数据名]:[id]足够简短：不超过 44 字节不包含特殊字符Value 的最佳实践：合理的拆分数据，拒绝 BigKey选择合适数据结构Hash 结构的 entry 数量不要超过 1000（默认是 500，如果达到上限则底层会使用哈希表而不是 ZipList，内存占用较多）设置合理的超时时间批量处理的方案：原生的 M 操作Pipeline 批处理注意事项：批处理时不建议一次携带太多命令。Pipeline 的多个命令之间不具备原子性。_redis高级实战
MongoDB 递归查询
文章浏览阅读1.2k次。MongoDB 递归查询_mongodb数据库 递归
在Spring-boot中操作MongoDB
文章浏览阅读1.2k次。通过实际代码例子介绍:如何通过MongoTemplate和MongoRepository操作数据库数据_springboot操作mongodb
Redis下载—可视化—配置主从模式(超详细)——测试木头人
文章浏览阅读687次，点赞7次，收藏2次。首先欢迎大家阅读此文档，本文档主要分为三个模块分别是：Redis的介绍及安装、RedisDesktopManager可视化工具的安装、主从(哨兵)模式的配置。_redis 主从配置工具
Redis 7.0 源码调试环境搭建与源码导读技巧
文章浏览阅读764次。天下武功，无坚不摧，唯快不破！我的名字叫 Redis，全称是 Remote Dictionary Server。有人说，组 CP，除了要了解她外，还要给机会让她了解你。那么，作为开发工程师的你，是否愿意认真阅读此心法抓住机会来了解我，运用到你的系统中提升性能。我遵守 BSD 协议，由意大利人 Salvatore Sanfilippo 使用 C 语言编写的一个基于内存实现的键值型非关系（NoSQL）..._redis 7.2 源码
Mongodb学习笔记
文章浏览阅读2k次。MongoDB 的增删改查【1】_mongodb $inc
pythonJavaScriptjavaHTMLPHPreactjsC#AndroidCSSNode.jssqlrpython-3.xMysqLjQueryc++pandasFlutterangularIOSdjangolinuxswifttypescript路由器JSON路由器设置无线路由器h3c华三华三路由器设置华三路由器电脑软件教程arraysdocker软件图文教程Cvue.jslaravelspring-boot