TP5使用Redis处理电商秒杀
1、首先在TP5中创建抢购活动所需要的Redis类库文件,代码如下： <php
namespace appbaseservice;
use mikkletp_redisRedisHashInfoBase;
use thinkException;
class ScheduleDetail extends RedisHashInfoBase
{
protected $table="gopar_schedule_detail"; //数据表的
protected $pk = "id"; //数据表的主键
public function _initialize()
{
//判断数据存在 并设置检查周期10分钟
if (!$this->checkLock("dataExists") && !$this->checkTableDataExists()){
throw new Exception("相关产品数据不存在");
}else{
//设置检查锁10分钟
$this->setLock("dataExists",600);
}
//如果数据不存在 初始化读取数据
if (!$this->checkExists()){
$this->initTableData();
}
}
public function getScheduleCenter()
{
return Schedule::instance( $this->getInfoFieldValue("schedule_id"));
}
public function __destruct()
{
//设置15天自动回收redis
$this->setExpire((int);
$this>getScheduleCenter()->getInfoFieldValue("end_time")+3600*24*15);
}
}
2、在服务层或者控制器处理抢购逻辑,代码如下： public function index($data=["user_id"=>1,"ticket_detail_id"=>1,"buy_num"=>1]){
try {
//检测数据存在
if (!$this->checkArrayValueEmpty($data,["user_id","ticket_detail_id","buy_num"])){
throw new Exception($this->error);
}
$user_id= $data["user_id"] ; //用户Id
$ticket_detail_id = $data["ticket_detail_id"] ; //产品Id
$buy_num = $data["buy_num"] ; //购买数量
$infoCenter= ScheduleDetail::instance( $ticket_detail_id );
$scheduleDetailInfo =$infoCenter->getInfoList();
//修改数据库后 需要运行initTableData()方法重新初始化 推荐写到Hook里
// $infoCenter->initTableData();
if ( $infoCenter->getInfoFieldValue( "hot_schedule")){
//热门抢购随机过滤随机过滤
if (!in_array(rand(100,200) % 11,[1,3,5,7,9])) {
throw new Exception("抢票人数众多,你被挤出抢购队伍,还有余票,请重新再抢");
};
}
// 这里判断 购买数量和销售日期 不符合就 throw new Exception
if (!true){
throw new Exception("这里写不符合原因");
}
if (((int)$infoCenter->getInfoFieldValue("{$user_id}_num")+$buy_num)>$scheduleDetailInfo["limit_num"] ){
throw new Exception("你超过最大购买数量");
}
if ($infoCenter->setInfoFieldIncre("pay_num",$buy_num) >$scheduleDetailInfo["limit_num"] ){
//
$infoCenter->setInfoFieldIncre("pay_num",-$buy_num);
throw new Exception("对不起,票已经卖光了!");
}
//这里写主逻辑 启用事务功能创建订单
//事务参见下节源码
//升级已销售数量
$infoCenter->updateTableData(["pay_num"]);
//在这里推荐埋钩子 处理订单完成的后续事情
//返回结果
} catch (Exception $e) {
Log::error($e->getMessage());
return ShowCode::jsonCodeWithoutData(1008,$e->getMessage());
}
}
}
在处理逻辑中 可以使用随机去除了一部分的购买请求 以保证抢购活动平稳完成 当然也可以同时在前端请求中示例类似方法过滤 可以参照定时队列判断订单是否处理完成 校准剩余库存 推荐教程 基础： 手把手教你写留言板系统av78744637 PHP微信支付从入门到实战教程av83707632 php扩展开发： PHP扩展开发——cookie与session原理实战av83825917 php扩展开发——验证码开发av83864077 tp： TP5开发大型ERP核心系统Auth认证组件av80969844 女神老师讲解thinkphp6支付大通关av79763622 redis： redis从入门到精通实战教程av83679805 swoole： PHP—swoole通往大神修炼之路:av77924246 手把手教你用swoole+websocket实现户外监控直播（总集篇）:av79087951 教你用swoole开发网络游戏:av79264440 PHP高级技术手写swoole分布式框架:av78383962 PHP高级技术手写swoole分布式框架（二）:av78632435 PHP高级技术手写swoole分布式框架（三）:av78748923 PHP高级技术手写swoole分布式框架(框架优化):av78856427 PHP高级技术手写swoole分布式框架(分布式RPC):av79012272 用swoole实现消息推送:av79874641 swoole+docker+redis主从复制及读写分离av78781841 加薪、涨分利器-Swoole-Go协程+Mysql8.0实现高性能数据库连接池：av93991412 更多学习内容请访问： 怎么从一名码农成为架构师的必看知识点：目录大全（不定期更新） （编辑：安卓应用网） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |