TP5使用Redis处理电商秒杀-长春网站制作【筱航科技】

发布时间:2020-03-13 22:15:23 作者:筱航科技 来源:本站 浏览量(50) 点赞(35)
摘要:本篇文章介绍了ThinkPHP使用Redis实现电商秒杀的处理方法,具有一定的参考价值,希望对学习ThinkPHP的朋友有帮助!

5e6af01d3e03f559.jpg

本篇文章介绍了ThinkPHP使用Redis实现电商秒杀的处理方法,具有一定的参考价值,希望对学习ThinkPHP的朋友有帮助!

TP5使用Redis处理电商秒杀


1、首先在TP5中创建抢购活动所需要的Redis类库文件,代码如下:

<php
    namespace appaseservice;
 
    use mikkle	p_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());
  
    }
  
}
  
}

在处理逻辑中 可以使用随机去除了一部分的购买请求 以保证抢购活动平稳完成

当然也可以同时在前端请求中示例类似方法过滤

可以参照定时队列判断订单是否处理完成 校准剩余库存


筱航科技主营业务: 长春网站建设 - 长春网站制作 -长春网站设计 -长春网站开发 -长春网站优化 -长春网站SEO - 长春网站推广 - 长春网络营销 - 长春网站关键词排名 -长春微信小程序 -长春微信商城 -长春分销商城

二维码

扫一扫,关注我们

声明:本文由【筱航科技】编辑上传发布,转载此文章须经作者同意,并请附上出处【筱航科技】及本页链接。如内容、图片有任何版权问题,请联系我们进行处理。

感兴趣吗?

欢迎联系我们,我们愿意为您解答任何有关网站疑难问题!

筱航科技-您身边的网站建设专家

搜索千万次不如咨询1次

主营项目:网站建设,网络营销,SEO优化,微信小程序开发,LOGO设计,产品包装设计,虚拟主机,域名注册,网站安全检测,微信商城等

立即咨询 184-4312-4181
在线客服
点此联系在线客服!