文章 专题 AI工具 学习 下载 问答 源码 最近更新
PHP
会员中心 讲师中心 微信公众号
首页 > 后端开发 > php教程 > 正文

php和redis实现高并发下的抢购以及秒杀功能示例详解

炎欲天舞
发布： 2017-08-03 14:56:37
原创
2015人浏览过

抢购、秒杀是平常很常见的场景，面试的时候面试官也经常会问到，比如问你淘宝中的抢购秒杀是怎么实现的等等。

抢购、秒杀实现很简单，但是有些问题需要解决，主要针对两个问题：

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

2 竞争状态下如何解决库存的正确减少（"超卖"问题）

第一个问题，对于PHP来说很简单，用缓存技术就可以缓解数据库压力，比如memcache，redis等缓存技术。

立即学习“PHP免费学习笔记（深入）”；

第二个问题就比较复杂点：

常规写法：

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

<?php
$conn=mysql_connect("localhost","big","123456"); 
if(!$conn){ 
    echo "connect failed"; 
    exit; 
} 
mysql_select_db("big",$conn); 
mysql_query("set names utf8");
 
$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;
 
//生成唯一订单
function build_order_no(){
  return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
    global $conn;
    $sql="insert into ih_log(event,type) 
    values('$event','$type')"; 
    mysql_query($sql,$conn); 
}
 
//模拟下单操作
//库存是否大于0
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id'";
//解锁 此时ih_store数据中goods_id='$goods_id' and sku_id='$sku_id' 的数据被锁住(注3)，其它事务必须等待此次事务 提交后才能执行
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
if($row['number']>0){//高并发下会导致超卖
    $order_sn=build_order_no();
    //生成订单 
    $sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price) 
    values('$order_sn','$user_id','$goods_id','$sku_id','$price')"; 
    $order_rs=mysql_query($sql,$conn); 
     
    //库存减少
    $sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
    $store_rs=mysql_query($sql,$conn); 
    if(mysql_affected_rows()){ 
        insertLog('库存减少成功');
    }else{ 
        insertLog('库存减少失败');
    } 
}else{
    insertLog('库存不够');
}
登录后复制

出现这种情况怎么办呢？来看几种优化方法：

优化方案1：将库存字段number字段设为unsigned，当库存为0时，因为字段不能为负数，将会返回false

1 //库存减少
2 $sql="update ih_store set number=number-{$number} where sku_id='$sku_id' and number>0";
3 $store_rs=mysql_query($sql,$conn); 
4 if(mysql_affected_rows()){ 
5     insertLog('库存减少成功');6 }
登录后复制

优化方案2：使用MySQL的事务，锁住操作的行


<?php
$conn=mysql_connect("localhost","big","123456"); 
if(!$conn){ 
    echo "connect failed"; 
    exit; 
} 
mysql_select_db("big",$conn); 
mysql_query("set names utf8");
 
$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;
 
//生成唯一订单号
function build_order_no(){
  return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
    global $conn;
    $sql="insert into ih_log(event,type) 
    values('$event','$type')"; 
    mysql_query($sql,$conn); 
}
 
//模拟下单操作
//库存是否大于0
mysql_query("BEGIN");   //开始事务
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id' FOR UPDATE";//此时这条记录被锁住,其它事务必须等待此次事务提交后才能执行
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
if($row['number']>0){
    //生成订单 
    $order_sn=build_order_no(); 
    $sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price) 
    values('$order_sn','$user_id','$goods_id','$sku_id','$price')"; 
    $order_rs=mysql_query($sql,$conn); 
     
    //库存减少
    $sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
    $store_rs=mysql_query($sql,$conn); 
    if(mysql_affected_rows()){ 
        insertLog('库存减少成功');
        mysql_query("COMMIT");//事务提交即解锁
    }else{ 
        insertLog('库存减少失败');
    }
}else{
    insertLog('库存不够');
    mysql_query("ROLLBACK");
}
登录后复制

优化方案3：使用非阻塞的文件排他锁


 <?php
$conn=mysql_connect("localhost","root","123456"); 
if(!$conn){ 
    echo "connect failed"; 
    exit; 
} 
mysql_select_db("big-bak",$conn); 
mysql_query("set names utf8");
 
$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;
 
//生成唯一订单号
function build_order_no(){
  return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
    global $conn;
    $sql="insert into ih_log(event,type) 
    values('$event','$type')"; 
    mysql_query($sql,$conn); 
}
 
$fp = fopen("lock.txt", "w+");
if(!flock($fp,LOCK_EX | LOCK_NB)){
    echo "系统繁忙，请稍后再试";
    return;
}
//下单
$sql="select number from ih_store where goods_id='$goods_id' and sku_id='$sku_id'";
$rs=mysql_query($sql,$conn);
$row=mysql_fetch_assoc($rs);
if($row['number']>0){//库存是否大于0
    //模拟下单操作 
    $order_sn=build_order_no(); 
    $sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price) 
    values('$order_sn','$user_id','$goods_id','$sku_id','$price')"; 
    $order_rs=mysql_query($sql,$conn); 
     
    //库存减少
    $sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
    $store_rs=mysql_query($sql,$conn); 
    if(mysql_affected_rows()){ 
        insertLog('库存减少成功');
        flock($fp,LOCK_UN);//释放锁
    }else{ 
        insertLog('库存减少失败');
    } 
}else{
    insertLog('库存不够');
}
fclose($fp);
登录后复制

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

先将商品库存如队列


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

抢购、描述逻辑


 <?php
$conn=mysql_connect("localhost","big","123456"); 
if(!$conn){ 
    echo "connect failed"; 
    exit; 
} 
mysql_select_db("big",$conn); 
mysql_query("set names utf8");
 
$price=10;
$user_id=1;
$goods_id=1;
$sku_id=11;
$number=1;
 
//生成唯一订单号
function build_order_no(){
  return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
}
//记录日志
function insertLog($event,$type=0){
    global $conn;
    $sql="insert into ih_log(event,type) 
    values('$event','$type')"; 
    mysql_query($sql,$conn); 
}
 
//模拟下单操作
//下单前判断redis队列库存量
$redis=new Redis();
$result=$redis->connect('127.0.0.1',6379);
$count=$redis->lpop('goods_store');
if(!$count){
    insertLog('error:no store redis');
    return;
}
 
//生成订单 
$order_sn=build_order_no();
$sql="insert into ih_order(order_sn,user_id,goods_id,sku_id,price) 
values('$order_sn','$user_id','$goods_id','$sku_id','$price')"; 
$order_rs=mysql_query($sql,$conn); 
 
//库存减少
$sql="update ih_store set number=number-{$number} where sku_id='$sku_id'";
$store_rs=mysql_query($sql,$conn); 
if(mysql_affected_rows()){ 
    insertLog('库存减少成功');
}else{ 
    insertLog('库存减少失败');
}
登录后复制

上述只是简单模拟高并发下的抢购，真实场景要比这复杂很多，很多注意的地方

如抢购页面做成静态的，通过ajax调用接口

再如上面的会导致一个用户抢多个，思路：

需要一个排队队列和抢购结果队列及库存队列。高并发情况，先将用户进入排队队列，用一个线程循环处理从排队队列取出一个用户，判断用户是否已在抢购结果队列，如果在，则已抢购，否则未抢购，库存减1，写数据库，将用户入结果队列。

我之间做商城项目的时候，在秒杀这一块我直接用的redis，这段时间看了看上面的几种方法，虽然各有不同，但是实现目的都一样的，各位自己选择，开心就好。

 

以上就是php和redis实现高并发下的抢购以及秒杀功能示例详解的详细内容，更多请关注php中文网其它相关文章！

PHP速学教程(入门到精通)
PHP速学教程(入门到精通)

PHP怎么学习？PHP怎么入门？PHP在哪学？PHP怎么学才快？不用担心，这里为大家提供了PHP速学教程(入门到精通)，有需要的小伙伴保存下载就能学习啦！

下载
相关标签：
redis
来源：php中文网
收藏 点赞
上一篇：php如何开启GD库？ 下一篇：投机型：如何利用PHP将数据导出到Excel表中(图文解说)
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系admin@php.cn
作者最新文章
最新问题
PHP如何保存Session值 PHP Session操作的5个技巧 Session过期后数据会丢失，因为默认存储在服务器上并由垃圾回收机制清理；防止Session劫持需使用HTTPS、设置Cookie属性、定期更换SessionID、验证用户信息、缩短过期时间及使用Token；跨域共享Session可通过设置Cookie域、JSONP、CORS、PostMessage或SSO实现；Session数据默认存于服务器文件中，也可存入数据库或缓存系统如Redis；销毁Session需依次执行session_unset()、删除Cookie及session_destro
2025-06-12 23:27:01
868
PHP如何获取传感器数据 读取传感器数据的3种采集方式 PHP获取传感器数据的核心在于通过中间硬件设备实现数据采集与传输。首先需选择如Arduino或树莓派等硬件接口读取传感器数据；其次通过HTTP/HTTPS、MQTT或串行通信等协议将数据传至服务器；最后由PHP脚本接收并处理数据。数据采集可采用定时轮询、事件触发或长连接等方式。选择硬件平台时应根据需求权衡功能与开发难度。MQTT协议因轻量级和良好的扩展性适用于物联网场景。为保障安全，应使用HTTPS或MQTT的TLS/SSL加密传输，并加强硬件固件安全防护措施。
2025-06-12 23:21:01
828
PHP怎样防止SQL注入 PHP防SQL注入的5个关键措施 防止SQL注入的核心方法是使用预处理语句和参数化查询，结合输入验证、输出编码、最小权限原则等措施。1.使用预处理语句（如PDO或MySQLi）将SQL结构与数据分离，防止恶意数据被当作SQL执行；2.对所有用户输入进行严格验证，确保其格式、类型和长度符合预期，例如使用intval()或filter_var()函数；3.在输出前对数据进行编码，如使用htmlspecialchars()防止XSS攻击；4.数据库连接使用最小权限账户，避免使用高权限账户；5.使用ORM框架自动处理SQL构建，降低注入
2025-06-12 23:15:01
756
php 向文章的随机段落插入图片，文章的是以p标签分割段落的 如果文章是以标签分割段落的，可以使用正则表达式来分割段落，并在随机段落中插入图片。以下是一个示例代码，演示如何实现这一过程：解释：读取文章内容：这里用一个示例字符串表示文章内容。使用正则表达式分割段落：使用 preg_match_all('/.*?/',$article,$matches) 将文章按  标签分割成段落数组。获取所有段落：$matches[0] 包含所有匹配的段落。选择随机段落：使用 rand(0,count($paragraphs)-1) 生成一个随机索引。插
2025-06-12 22:44:25
544
PHP如何压缩图片大小 PHP图片压缩的3种优化方案 在PHP中压缩图片需借助GD库或Imagick库，具体步骤如下：1.使用GD库通过imagecreatefromjpeg/imagecreatefromgif/imagecreatefrompng读取图片，再用imagejpeg或imagepng按指定质量保存；2.使用Imagick库创建对象后调用setImageCompressionQuality设置质量并保存；3.对PNG图片可调用optipng等工具优化。注意选择60-80的合理质量区间，并结合分辨率、颜色深度等因素综合优化效果。
2025-06-12 22:36:01
336
20 个 Laravel Eloquent 必备的实用技巧 EloquentORM看似简单，但在底层却隐藏着许多不为人知的技巧和功能。这篇文章将带你了解一些实用的小窍门。1.增加与减少字段值代替传统方式：$article=Article::find($article_id);$article->read_count++;$article->save();可以使用更简洁的方法：$article=Article::find($article_id);$article->increment('read_count');更多用法示例：
2025-06-12 22:30:01
289
PHP怎样处理RSA加密解密 PHP实现RSA加密解密的实战代码 在PHP中处理RSA加密解密主要通过OpenSSL扩展实现，具体步骤包括生成密钥对、使用公钥加密数据、使用私钥解密数据。1.首先确保启用OpenSSL扩展，未启用则修改php.ini并重启服务器；2.使用PHP代码生成2048位RSA密钥对，并分别提取公钥和私钥；3.通过openssl_public_encrypt函数使用公钥加密数据，并进行Base64编码以便传输；4.通过openssl_private_decrypt函数使用私钥解密经过Base64解码的加密数据。应用场景包括安全传输数据、数
2025-06-12 22:27:01
554
如何在 PHP 中实现多线程来执行任务 在PHP开发中，实现任务的并发处理是一项具有一定挑战性但又非常有价值的技术手段。下面将详细介绍在PHP环境下如何通过多线程方式来执行任务。一、理解多线程及其应用场景多线程意味着在一个应用程序内部能够同时运行多个执行流，每个线程可独立完成特定的工作。PHP默认是以单线程模式运行的，但借助某些扩展机制，可以模拟出多线程的行为。这种技术常用于应对一些耗时较长的操作，例如文件传输、数据库交互、远程调用等，从而提升整体效率和用户体验。二、利用PHP扩展实现并发执行PCNTL扩展：PCNTL是一个支
2025-06-12 21:36:01
156
PHP怎样解析RSS订阅 PHP解析RSS订阅源详细教程 解析PHP中RSS订阅的方法主要有SimpleXML、DOMDocument和第三方库。1.SimpleXML适合快速解析简单结构，如标题和链接；2.DOMDocument功能强大，可处理复杂结构如CDATA；3.第三方库如ZendFeed提供高级功能但增加依赖。根据需求选择：轻量需求用SimpleXML，复杂场景用DOMDocument或第三方库。
2025-06-12 20:12:01
430
PHP怎样处理LDAP分页查询 LDAP分页查询技巧高效获取目录数据 PHP处理LDAP分页查询的核心在于控制每次获取的数据量以避免性能问题。1.使用ldap_control_paged_result函数配合偏移量和限制参数逐步获取数据。2.通过ldap_set_option设置LDAP_OPT_SIZELIMIT和LDAP_OPT_TIMELIMIT限制结果大小和查询时间。3.确保查询条件属性已被索引，如uid属性，以提升查询速度。4.对不常变化的数据使用缓存机制减少直接访问。5.若服务器不支持分页控制可降级非分页查询并手动实现分页。6.优化过滤器如使用精确匹配
2025-06-12 19:45:01
626
相关专题
更多>
热门推荐
开源免费商场系统广告
热门教程
更多>
相关推荐
热门推荐
最新课程
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 意见反馈 讲师合作 广告合作 最新更新
php中文网：公益在线php培训，帮助PHP学习者快速成长！
关注服务号 技术交流群
app下载
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习
PHP中文网抖音号
发现有趣的

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号

  • PHP学习

  • 技术支持

  • 返回顶部