求助php竞拍功能实现的思路
发布网友
发布时间：2022-04-06 01:31
共2个回答
懂视网
时间：2022-04-06 05:52
推荐：《PHP视频教程》
一、秒杀业务为什么难做
1）im系统，例如qq或者微博，每个人都读自己的数据（好友列表、群列表、个人信息）；
2）微博系统，每个人读你关注的人的数据，一个人读多个人的数据；
3）秒杀系统，库存只有一份，所有人会在集中的时间读和写这些数据，多个人读一个数据。
例如：小米手机每周二的秒杀，可能手机只有1万部，但瞬时进入的流量可能是几百几千万。
又例如：12306抢票，票是有限的，库存一份，瞬时流量非常多，都读相同的库存。读写冲突，锁非常严重，这是秒杀业务难的地方。那我们怎么优化秒杀业务的架构呢？
二、优化方向
优化方向有两个（今天就讲这两个点）：
（1）将请求尽量拦截在系统上游（不要让锁冲突落到数据库上去）。传统秒杀系统之所以挂，请求都压倒了后端数据层，数据读写锁冲突严重，并发高响应慢，几乎所有请求都超时，流量虽大，下单成功的有效流量甚小。以12306为例，一趟火车其实只有2000张票，200w个人来买，基本没有人能买成功，请求有效率为0。
（2）充分利用缓存，秒杀买票，这是一个典型的读多些少的应用场景，大部分请求是车次查询，票查询，下单和支付才是写请求。一趟火车其实只有2000张票，200w个人来买，最多2000个人下单成功，其他人都是查询库存，写比例只有0.1%，读比例占99.9%，非常适合使用缓存来优化。好，后续讲讲怎么个“将请求尽量拦截在系统上游”法，以及怎么个“缓存”法，讲讲细节。
三、常见秒杀架构
常见的站点架构基本是这样的（绝对不画忽悠类的架构图）
（1）浏览器端，最上层，会执行到一些JS代码
（2）服务端，这一层会访问后端数据，拼html页面返回给浏览器
（3）服务层（web服务器），向上游屏蔽底层数据细节，提供数据访问
（4）数据层，最终的库存是存在这里的，mysql是一个典型（当然还有会缓存）
这个图虽然简单，但能形象的说明大流量高并发的秒杀业务架构，大家要记得这一张图。
后面细细解析各个层级怎么优化。
四、各层次优化细节
第一层，客户端怎么优化（浏览器层，APP层）
问大家一个问题，大家都玩过微信的摇一摇抢红包对吧，每次摇一摇，就会往后端发送请求么？回顾我们下单抢票的场景，点击了“查询”按钮之后，系统那个卡呀，进度条涨的慢呀，作为用户，我会不自觉的再去点击“查询”，对么？继续点，继续点，点点点。。。有用么？平白无故的增加了系统负载，一个用户点5次，80%的请求是这么多出来的，怎么整？
（a）产品层面，用户点击“查询”或者“购票”后，按钮置灰，禁止用户重复提交请求；
（b）JS层面，限制用户在x秒之内只能提交一次请求；
APP层面，可以做类似的事情，虽然你疯狂的在摇微信，其实x秒才向后端发起一次请求。这就是所谓的“将请求尽量拦截在系统上游”，越上游越好，浏览器层，APP层就给拦住，这样就能挡住80%+的请求，这种办法只能拦住普通用户（但99%的用户是普通用户）对于群内的高端程序员是拦不住的。firebug一抓包，http长啥样都知道，js是万万拦不住程序员写for循环，调用http接口的，这部分请求怎么处理？
第二层，服务端层面的请求拦截
怎么拦截？怎么防止程序员写for循环调用，有去重依据么？ip？cookie-id？…想复杂了，这类业务都需要登录，用uid即可。在服务端层面，对uid进行请求计数和去重，甚至不需要统一存储计数，直接服务端内存存储（这样计数会不准，但最简单）。一个uid，5秒只准透过1个请求，这样又能拦住99%的for循环请求。
5s只透过一个请求，其余的请求怎么办？缓存，页面缓存，同一个uid，限制访问频度，做页面缓存，x秒内到达服务端的请求，均返回同一页面。同一个item的查询，例如车次，做页面缓存，x秒内到达服务端的请求，均返回同一页面。如此限流，既能保证用户有良好的用户体验（没有返回404）又能保证系统的健壮性（利用页面缓存，把请求拦截在服务端了）。
页面缓存不一定要保证所有服务端返回一致的页面，直接放在每个站点的内存也是可以的。优点是简单，坏处是http请求落到不同的服务端，返回的车票数据可能不一样，这是服务端的请求拦截与缓存优化。
好，这个方式拦住了写for循环发http请求的程序员，有些高端程序员（黑客）控制了10w个肉鸡，手里有10w个uid，同时发请求（先不考虑实名制的问题，小米抢手机不需要实名制），这下怎么办，服务端按照uid限流拦不住了。
第三层 服务层来拦截（反正就是不要让请求落到数据库上去）
服务层怎么拦截？大哥，我是服务层，我清楚的知道小米只有1万部手机，我清楚的知道一列火车只有2000张车票，我透10w个请求去数据库有什么意义呢？没错，请求队列！
对于写请求，做请求队列，每次只透有限的写请求去数据层（下订单，支付这样的写业务）
1w部手机，只透1w个下单请求去db
3k张火车票，只透3k个下单请求去db
如果均成功再放下一批，如果库存不够则队列里的写请求全部返回“已售完”。
对于读请求，怎么优化？cache抗，不管是memcached还是redis，单机抗个每秒10w应该都是没什么问题的。如此限流，只有非常少的写请求，和非常少的读缓存mis的请求会透到数据层去，又有99.9%的请求被拦住了。
当然，还有业务规则上的一些优化。回想12306所做的，分时分段售票，原来统一10点卖票，现在8点，8点半，9点，...每隔半个小时放出一批：将流量摊匀。
其次，数据粒度的优化：你去购票，对于余票查询这个业务，票剩了58张，还是26张，你真的关注么，其实我们只关心有票和无票？流量大的时候，做一个粗粒度的“有票”“无票”缓存即可。
第三，一些业务逻辑的异步：例如下单业务与 支付业务的分离。这些优化都是结合 业务 来的，我之前分享过一个观点“一切脱离业务的架构设计都是耍流氓”架构的优化也要针对业务。
好了，最后是数据库层
浏览器拦截了80%，服务端拦截了99.9%并做了页面缓存，服务层又做了写请求队列与数据缓存，每次透到数据库层的请求都是可控的。db基本就没什么压力了，闲庭信步，单机也能扛得住，还是那句话，库存是有限的，小米的产能有限，透这么多请求来数据库没有意义。
全部透到数据库，100w个下单，0个成功，请求有效率0%。透3k个到数据，全部成功，请求有效率100%。
五、总结
上文应该描述的非常清楚了，没什么总结了，对于秒杀系统，再次重复下我个人经验的两个架构优化思路：
（1）尽量将请求拦截在系统上游（越上游越好）；
（2）读多写少的常用多使用缓存（缓存抗读压力）；
浏览器和APP：做限速
服务端：按照uid做限速，做页面缓存
服务层（web服务器）：按照业务做写请求队列控制流量，做数据缓存
数据层：闲庭信步
并且：结合业务做优化
六、Q&A
问题1、按你的架构，其实压力最大的反而是服务端，假设真实有效的请求数有1000万，不太可能限制请求连接数吧，那么这部分的压力怎么处理？
答：每秒钟的并发可能没有1kw，假设有1kw，解决方案2个：
（1）服务层（web服务器）是可以通过加机器扩容的，最不济1k台机器来呗。
（2）如果机器不够，抛弃请求，抛弃50%（50%直接返回稍后再试），原则是要保护系统，不能让所有用户都失败。
问题2、“控制了10w个肉鸡，手里有10w个uid，同时发请求” 这个问题怎么解决哈？
答：上面说了，服务层（web服务器）写请求队列控制
问题3：限制访问频次的缓存，是否也可以用于搜索？例如A用户搜索了“手机”，B用户搜索“手机”，优先使用A搜索后生成的缓存页面？
答：这个是可以的，这个方法也经常用在“动态”运营活动页，例如短时间推送4kw用户app-push运营活动，做页面缓存。
问题4：如果队列处理失败，如何处理？肉鸡把队列被撑爆了怎么办？
答：处理失败返回下单失败，让用户再试。队列成本很低，爆了很难吧。最坏的情况下，缓存了若干请求之后，后续请求都直接返回“无票”（队列里已经有100w请求了，都等着，再接受请求也没有意义了）
问题5：服务端过滤的话，是把uid请求数单独保存到各个站点的内存中么？如果是这样的话，怎么处理多台服务器集群经过负载均衡器将相同用户的响应分布到不同服务器的情况呢？还是说将服务端的过滤放到负载均衡前？
答：可以放在内存，这样的话看似一台服务器限制了5s一个请求，全局来说（假设有10台机器），其实是限制了5s 10个请求，解决办法：
1）加大限制（这是建议的方案，最简单）
2）在nginx层做7层均衡，让一个uid的请求尽量落到同一个机器上
问题6：服务层（web服务器）过滤的话，队列是服务层（web服务器）统一的一个队列？还是每个提供服务的服务器各一个队列？如果是统一的一个队列的话，需不需要在各个服务器提交的请求入队列前进行锁控制？
答：可以不用统一一个队列，这样的话每个服务透过更少量的请求（总票数/服务个数），这样简单。统一一个队列又复杂了。
问题7：秒杀之后的支付完成，以及未支付取消占位，如何对剩余库存做及时的控制更新？
答：数据库里一个状态，未支付。如果超过时间，例如45分钟，库存会重新会恢复（大家熟知的“回仓”），给我们抢票的启示是，开动秒杀后，45分钟之后再试试看，说不定又有票哟~
问题8：不同的用户浏览同一个商品 落在不同的缓存实例显示的库存完全不一样 请问老师怎么做缓存数据一致或者是允许脏读？
答：目前的架构设计，请求落到不同的站点上，数据可能不一致（页面缓存不一样），这个业务场景能接受。但数据库层面真实数据是没问题的。
问题9：就算处于业务把优化考虑“3k张火车票，只透3k个下单请求去db”那这3K个订单就不会发生拥堵了吗？
答：（1）数据库抗3k个写请求还是ok的；（2）可以数据拆分；（3）如果3k扛不住，服务层（web服务器）可以控制透过去的并发数量，根据压测情况来吧，3k只是举例；
问题10；如果在服务端或者服务层（web服务器）处理后台失败的话，需不需要考虑对这批处理失败的请求做重放？还是就直接丢弃？
答：别重放了，返回用户查询失败或者下单失败吧，架构设计原则之一是“fail fast”。
问题11.对于大型系统的秒杀，比如12306，同时进行的秒杀活动很多，如何分流？
答：垂直拆分
问题12、额外又想到一个问题。这套流程做成同步还是异步的？如果是同步的话，应该还存在会有响应反馈慢的情况。但如果是异步的话，如何控制能够将响应结果返回正确的请求方？
答：用户层面肯定是同步的（用户的http请求是夯住的），服务层（web服务器）面可以同步可以异步。
问题13、秒杀群提问：减库存是在那个阶段减呢？如果是下单锁库存的话，大量恶意用户下单锁库存而不支付如何处理呢？
答：数据库层面写请求量很低，还好，下单不支付，等时间过完再“回仓”，之前提过了。
技巧：值的我们注意的地方
1、脱离原站点部署（秒杀功能用的服务器和商城服务器不要放在同一个服务器，防止秒杀崩咯，商城也不能访问...）
2、多监控、注意监控、找个人盯着看
秒杀的关键点：
1、高可用：双活
2、高并发：负载均衡、安全过滤
设计思路：
1、静态页面：cdn（使用各大厂商现成的）、网址隐藏、页面压缩、缓存机制
2、动态页面：排队、异步、资质抢购
其他建议：
1、百度的建议：opcode缓存、cdn、更大的服务器实例
2、阿里的建议：云监控、云盾、ecs、oss、rds、cdn
cdn的使用思路：
1、将静态资源（图片、js、css等）上传到cdn
2、缺点：但要注意，更新时cdn更新不及时，这时就要推了
认清当前环境、形式：
1、用户：超大量、正常/坏人（cdn加速也是一种分流，因为他就近访问cdn的节点）
2、地域：全国各地（延迟1、2s也不行，因为延迟1s可能秒杀就结束了，需要cdn让用户就近选择节点）
3、业务流程：前台商品展示、登记。后台数据接入、数据处理
在秒杀前加个页面，可以分流、推广其他商品
商品展示层架构
页面的3个状态：
1、商品展示：倒计时页面
2、秒杀进行中：点击进入秒杀页面
3、秒杀活动结束：提示活动已结束
新思路：以时间线来思考问题
假设我们看见的就是秒杀进行中，往前推就是倒计时，往后推就是结束了
下图是从用户的角度看问题：
代码：
静态资源，存到oss里部署
先删除倒计时页面，马上给秒杀中页面复制过来
然后用coretab定时执行这个脚本
总结：
从倒计时到抢购中：是用linux的定时任务和shell脚本来做
抢购中倒抢购结束：php来做，查表没了就结束
用户登记层架构
代码：
$.cookie的封装
数据接入层
代码：
第2层到第3层的时候怎么计算？？
第2层发送数据到第3层 + 网络传输dns解析等因素总共造成的延时大概是多长时间，这样就可以评估，需要配置服务器的数量
总结为2句话：
1、在关键点上不通过，直接返回上一层（用户登记层）
2、在关键点通过，就会通知其他层
效验：类似于微软序列号的加密解密
队列：使用redis的有序集合
上限：技术标志位
数据处理层
热心网友
时间：2022-04-06 03:00
转载请注明来源：在线竞拍系统的PHP实现框架（一）
前面我给了一个分页显示mysql记录的类，却没给出使用的例子，现在，我整理了我刚写的一个在线竞拍系统框架程序，来说明这个类的使用方法，而且也就在线竞拍的实现方法与大家一起来讨论一下。
首先声明，我不是高手，也不是行家，只是一个fans，所以这个程序肯定有不少漏洞，但我之所以敢拿出来，是因为我很希望能自由地与大家分享PHP带给我们的快乐。（其实是想多加点分好弄个支持mysql的空间^_^）
我觉得竞拍系统与一般的供求信息发布系统相比，最大的不同有两点，一点是出价者开的新价要及时地反映在商品的价格上，另一点是有时间的*，在竞标结束后，就要停止出价。并且给出最后中标者。
其它的我还没想到呢，有行家给点介绍吧。
所以，我想把一个供求信息发布系统做成一个竞拍系统应是不困难的事吧。
下面先把新版的TViewPage类和数据库结构给出来吧。
＜?php
/*********************************************
TViewPage v 1.2
分页显示Mysql数据库记录的类
作者：sharetop
E-mail:ycshowtop@21cn.com
时间：2000-8-31
[2000-9-6] 1.2
修正了readlist()的一个bug，将验证offset放入类中。
增加add() delete() modify()三个基本操作函数。
本类没有提供连接数据库的功能，所以需在外部打开相应的数据库。
本类也没有提供显示记录的功能，只是分页读取记录至 Result二维数组中。
需在外部自定义数据显示格式。
***********************************************/
class TViewPage {
var $Table; //表名
var $MaxLine; //每页显示行数
var $Offset; //记录偏移量
var $Total; //记录总数
var $Number; //本页读取的记录数
var $Result; //读出的结果
var $TPages; //总页数
var $CPages; //当前页数
var $Condition; //显示条件 如：where id='$id' order by id desc
var $PageQuery; //分页显示要传递的参数
//******构造函数*************
//参数：表名、最大行数、偏移量
function TViewPage($TB,$ML){
global $offset;
$this->Table=$TB;
$this->MaxLine=$ML;
if(isset($offset)) $this->Offset=$offset;
else $this->Offset=0;
$this->Condition="";
}
//********设置显示条件*********
//如：where id='$id' order by id desc
//要求是字串，符合SQL语法（本字串将加在SQL语句后）
function SetCondition($s){
$this->Condition=$s;
}
//******设置传递参数************
// key参数名 value参数值
// 如：setpagequery("id",$id);如有多个参数要传递，可多次调用本函数。
function SetPageQuery($key,$value){
$tmp[key]=$key; $tmp[value]=$value;
$this->PageQuery[]=$tmp;
}
//********读取记录***************
// 主要工作函数，根据所给的条件从表中读取相应的记录
// 返回值是一个二维数组，Result[记录号][字段名]
function ReadList() {
$SQL="SELECT Count(*) AS total FROM ".$this->Table." ".$this->Condition;
$result=mysql_query($SQL) or die(mysql_error());
$row=mysql_fetch_Array($result);
$this->Total=$row[total];
if($this->Total>0) { //根据条件 Condition
$SQL="SELECT * FROM ".$this->Table." ".$this->Condition.
" LIMIT ".$this->Offset." , ".$this->MaxLine;
$result=mysql_query($SQL) or die(mysql_error());
$this->Number=mysql_num_rows($result);
$i=0;
while($row=mysql_fetch_Array($result)){
$this->Result[$i]=$row;
$i ;
}
}
return $this->Result;
}
//*******加入新记录**********
//$str为加入的值，如 "'$id','$name','$class'"等
function Add($str){
$SQL="INSERT INTO ".$this->Table." VALUES(".$str.")";
mysql_query($SQL) or die(mysql_error());
}
//*********删除记录**********
//先调用SetCondition()来确定条件。
function Delete(){
$SQL="DELETE FROM ".$this->Table." ".$this->Condition;
mysql_query($SQL) or die(mysql_error());
}
//********修改记录************
//$field 字段名 $value新值
//如要修改多个字段可重复调用来函数。
function Modify($field,$value){
$SQL="UPDATE FROM ".$this->Table." SET ".$field."=".$value." ".$this->Condition;
mysql_query($SQL) or die(mysql_error());
}
//**********显示页数*************
//显示当前页及总页数
function ThePage() {
$this->TPages=ceil($this->Total/$this->MaxLine);
$this->CPages=$this->Offset/$this->MaxLine 1;
echo "第".$this->CPages."页/共".$this->TPages."页";
}
//**********显示翻页按钮*************
//此函数要在ThePage()函数之后调用！！！
//显示首页、下页、上页、未页，并加上要传递的参数
function Page() {
$first=0;
$next=$this->Offset $this->MaxLine;
$prev=$this->Offset-$this->MaxLine;
$last=($this->TPages-1)*$this->MaxLine;
$k=count($this->PageQuery);
$strQuery=""; //生成一个要传递参数字串
for($i=0;$i＜$k;$i ){
$strQuery.="&".$this->PageQuery[$i][key]."=".$this->PageQuery[$i][value];
}
if($this->Offset>=$this->MaxLine)
echo "＜A href="http://www.php1.cn/"> if($prev>=0)
echo "＜A href="http://www.php1.cn/"> if($next＜$this->Total)
echo "＜A href="http://www.php1.cn/"> if($this->TPages!=0 && $this->CPages＜$this->TPages)
echo "＜A href="http://www.php1.cn/"> }
//******end class
}
?>
//************************
ebid.sql文件(我是用phpmyadmin导出的)
# phpMyAdmin MySQL-Dump
# http://www.htmlwizard.net/phpMyAdmin/
#
# Host: localhost Database : ebid
# --------------------------------------------------------
# Table structure for table 'reply'
# id,商品id，出价人，出价人的email，出价。
CREATE TABLE reply (
id varchar(16) NOT NULL,
parentid varchar(16) NOT NULL,
buyer varchar(12) NOT NULL,
email varchar(32) NOT NULL,
price float(10,2) DEFAULT '0.00' NOT NULL,
PRIMARY KEY (id, price)
);
# --------------------------------------------------------
# Table structure for table 'shop'
# id,商品名，介绍，原始价，加价单位，结束时间，竞标数，当前价，是否有照片
CREATE TABLE shop (
id varchar(16) NOT NULL,
name varchar(50) NOT NULL,
description text,
price float(10,2) DEFAULT '0.00' NOT NULL,
unit tinyint(2) unsigned NOT NULL,
endtime varchar(16) DEFAULT '0000-00-00 00:00' NOT NULL,
reply int(4) unsigned NOT NULL,
curprice float(10,2) DEFAULT '0.00' NOT NULL,
photo tinyint(1) unsigned NOT NULL,
PRIMARY KEY (id),
KEY kreply (reply)
);
配置文件如下：
//**************
//config.inc.php
＜?php
$HOST="localhost"; //主机名
$DATABASE="ebid"; //数据库名
$WARE_TABLE="shop"; //商品表
$BID_TABLE="reply"; //回应表
$USER="root"; //用户
$PASSWD="9999"; //密码
$PAGE_MAX_LINE=20; //每页显示行数
//打开数据库
$LinkID=mysql_connect($HOST,$USER,$PASSWD);
mysql_select_db($DATABASE,$LinkID) or die(mysql_error());
?>
以下是显示商品及TOP10商品的函数
//*****************
//
＜?php
include "config.inc.php";
include "tview.class.php"; //类文件
//*****显示商品列表********
function PrintList(){
global $view;
$ct=time();
//设置条件的句子！要满足SQL语法哦。只显示没有结束竞标的商品
$view->SetCondition("where endtime>'$ct' order by id desc");
//调用成员函数来读记录
//结果$result[记录号][字段名] 是二维数组。
$result=$view->ReadList();
if($view->Number==0) {echo "＜tr>＜td colspan=4> ＜/td>＜/tr>"; return;}
for($i=0;$i＜$view->Number;$i ){
if(ceil($i/2)*2==$i) $bgc="#ffffff";
else $bgc="#f3f3f3";
echo "＜tr bgcolor=$bgc>＜td width=60% >";
echo "＜a href="http://www.php1.cn/"> echo "＜/td>＜td width=15% >";
echo date("Y-m-j 24:00:00",$result[$i][endtime]);
echo "＜/td>＜td width=15% align=right>￥";
echo $result[$i][curprice];
echo "＜/td>＜td width=10% align=right>";
echo $result[$i][reply];
echo "＜/td>＜/tr>";
}
}
//*********显示最热的10条记录**********
function ListTopHot(){
global $view;
//同样先设置条件
$view->SetCondition("order by reply desc");
//读记录
$result=$view->ReadList();
$k=(count($result)>10)? '10':(count($result));
for($i=0;$i＜$k;$i ){
echo "＜tr>＜td>";
echo "＜a href="http://www.php1.cn/"> echo "＜/td>＜/tr>";
}
}
//*********显示最新10条记录***********
function ListTopNew(){
global $view;
$view->SetCondition("order by id desc");
$result=$view->ReadList();
$k=(count($result)>10)? '10':(count($result));
for($i=0;$i＜$k;$i ){
echo "＜tr>＜td>";
echo "＜a href="http://www.php1.cn/"> echo "＜/td>＜/tr>";
}
}
//**********<结束函数定义，主程序体*************
//构造这个viewpage类，给出商品表及每页显示行数
$view=new TViewPage($WARE_TABLE,$PAGE_MAX_LINE);
?>
下面给出用到的一个js函数吧，很简单，就是打开一个新窗口：
＜script>
function showdetail(str){
window.open(str,"newwin","top=20,left=20,width=600,height=400,
location=no,toolbar=no,status=no,resizable=no,scrollbars=yes");
}
＜/script>
