TP5使用Redis处理电商秒杀

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

TP5使用Redis处理电商秒杀

TP5使用redis处理电商秒杀

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

<php>checkLock("dataExists") &amp;&amp; !$this-&gt;checkTableDataExists()){                   throw new Exception("相关产品数据不存在");               }else{                   //设置检查锁10分钟                   $this-&gt;setLock("dataExists",600);               }               //如果数据不存在 初始化读取数据               if (!$this-&gt;checkExists()){                   $this-&gt;initTableData();               }           }            public function getScheduleCenter()           {               return Schedule::instance( $this-&gt;getInfoFieldValue("schedule_id"));           }          public function __destruct()           {               //设置15天自动回收redis               $this-&gt;setExpire((int);   $this&gt;getScheduleCenter()-&gt;getInfoFieldValue("end_time")+3600*24*15);           }       }</php>

2、在服务层或者控制器处理抢购逻辑,代码如下:

public function index($data=["user_id"=&gt;1,"ticket_detail_id"=&gt;1,"buy_num"=&gt;1]){       try {           //检测数据存在           if (!$this-&gt;checkArrayValueEmpty($data,["user_id","ticket_detail_id","buy_num"])){               throw new Exception($this-&gt;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-&gt;getInfoList();           //修改数据库后 需要运行initTableData()方法重新初始化 推荐写到Hook里        // $infoCenter-&gt;initTableData();           if ( $infoCenter-&gt;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-&gt;getInfoFieldValue("{$user_id}_num")+$buy_num)&gt;$scheduleDetailInfo["limit_num"] ){               throw new Exception("你超过最大购买数量");           }           if ($infoCenter-&gt;setInfoFieldIncre("pay_num",$buy_num) &gt;$scheduleDetailInfo["limit_num"] ){               //               $infoCenter-&gt;setInfoFieldIncre("pay_num", -$buy_num);               throw new Exception("对不起,票已经卖光了!");           }           //这里写主逻辑 启用事务功能创建订单           //事务参见下节源码           //升级已销售数量           $infoCenter-&gt;updateTableData(["pay_num"]);           //在这里推荐埋钩子 处理订单完成的后续事情            //返回结果       } catch (Exception $e) {           Log::error($e-&gt;getMessage());           return ShowCode::jsonCodeWithoutData(1008, $e-&gt;getMessage());       }   }   }

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

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

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

(推荐教程:thinkphp教程

© 版权声明
THE END
喜欢就支持一下吧
点赞5 分享