经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » 程序设计 » PHP » 查看文章
Thinkphp5+Redis实现商品秒杀
来源:cnblogs  作者:下页、再停留  时间:2020/12/22 17:15:03  对本文有异议

环境:wamp,redis

要求:安装WAMP,Redis,以及为PHP安装Redis扩展(怎么安装Redis可以看看我前面写的文章)

秒杀功能大致思路:获取缓存列表的长度,如果长度(llen)等于0,就停止秒杀,即秒杀失败,如果长度大于0,则继续运行,先从缓存中移除一个元素(lpop),再进行数据库操作(添加订单表,商品库存数量减一),如果再进一个人秒杀,就再走一遍流程,循环往复。

一、安装Redis扩展

1.查看PHP版本信息

打开phpinfo.php,查看PHP版本,我的是PHP7.3.4,还有一个需要注意Architecture x64

2.下载扩展文件

https://pecl.php.net/package/redis   

https://pecl.php.net/package/igbinary

根据自己环境,选择合适的版本

3.解压

解压下载的压缩包,并把php_redis.dll、php_redis.pdb和php_igbinary.dll、php_igbinary.pdb四个文件,移至自己PHP版本对应目录下的ext文件夹下 E:\phpstudy_pro\Extensions\php\php7.3.4nts\ext

 

  

4.修改php.ini

添加如下代码:

extension=php_igbinary.dll

extension=php_redis.dll

如果有这两句可以把前面的分号删掉,没有就自己添加上,要注意顺序,php_igbinary.dll 要在 php_redis.dll 前面

 5.重启Apache

重启后,再运行phpinfo.php,查看是否安装成功

二、数据结构

一共三张表,ab_goods商品表,ab_order订单表,ab_log日志表

  • 商品表

 

  •  订单表

  •  日志表   记录秒杀信息

 三、代码

  1. <?php
  2. namespace app\index\controller;
  3. use think\Controller;
  4. use think\Db;
  5. use think\cache\driver\Redis;
  6. class Miaosha extends Controller
  7. {
  8. private $redis = null;
  9. private $cachekey = null; //缓存变量名
  10. private $basket = []; //私有数组,存放商品信息
  11.  
  12. private $store = 50;
  13. /**
  14. * 购物车初始化,传入用户id
  15. */
  16. public function __construct()
  17. {
  18. parent::__construct();
  19. $this->redis = new \Redis(); // 实例化
  20. $this->redis->connect('127.0.0.1','6379');
  21. $this->redis->auth('zxf123456');
  22. }
  23. /**
  24. * 秒杀初始化
  25. */
  26. public function Ms_init()
  27. {
  28. // 删除缓存列表
  29. $this->redis->del($this->cachekey);
  30. $len = $this->redis->llen($this->cachekey);
  31. $count = $this->store - $len;
  32. for ($i=0; $i < $count; $i++) {
  33. // 向库存列表推进50个,模拟50个商品库存
  34. $this->redis->lpush($this->cachekey,1);
  35. }
  36. echo "库存初始化完成:".$this->redis->llen($this->cachekey);
  37. }
  38. /**
  39. * 秒杀入口
  40. */
  41. public function index()
  42. {
  43. $id = 1; //商品编号
  44. if (empty($id)) {
  45. // 记录失败日志
  46. return $this->writeLog(0,'商品编号不存在');
  47. }
  48. // 计算库存列表长度
  49. $count = $this->redis->llen($this->cachekey);
  50. // 先判断库存是否为0,为0秒杀失败,不为0,则进行先移除一个元素,再进行数据库操作
  51. if ($count == 0) { //库存为0
  52.  
  53. $this->writeLog(0,'库存为0');
  54. echo "库存为0";
  55. exit;
  56. }else{
  57. // 有库存
  58. //先移除一个列表元素
  59. $this->redis->lpop($this->cachekey);
  60. $ordersn = $this->build_order_no(); //生成订单
  61. $uid = rand(0,9999); //随机生成用户id
  62. $status = 1;
  63. // 再进行数据库操作
  64. $data = Db::table('ab_goods')->field('count,amount')->where('id',$id)->find(); //查找商品
  65.  
  66. if (!$data) {
  67. return $this->writeLog(0,'该商品不存在');
  68. }
  69. $insert_data = [
  70. 'order_sn' => $ordersn,
  71. 'user_id' => $uid,
  72. 'goods_id' => $id,
  73. 'price' => $data['amount'],
  74. 'status' => $status,
  75. 'addtime' => date('Y-m-d H:i:s')
  76. ];
  77. // 订单入库
  78. $result = Db::table('ab_order')->insert($insert_data);
  79. // 自动减少一个库存
  80. $res = Db::table('ab_goods')->where('id',$id)->setDec('count');
  81. if ($res) {
  82. echo "第".$count."件秒杀成功";
  83. $this->writeLog(1,'秒杀成功');
  84. }else{
  85. echo "第".$count."件秒杀失败";
  86. $this->writeLog(0,'秒杀失败');
  87. }
  88. }
  89. }
  90. /**
  91. * 生成订单号
  92. */
  93. public function build_order_no()
  94. {
  95. return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8);
  96. }
  97. /**
  98. * 生成日志 1成功 0失败
  99. */
  100. public function writeLog($status = 1,$msg)
  101. {
  102. $data['count'] = 1;
  103. $data['status'] = $status;
  104. $data['addtime'] = date('Y-m-d H:i:s');
  105. $data['msg'] = $msg;
  106. return Db::table('ab_log')->insertGetId($data);
  107. }
  108. }

四、压力测试

使用apache压力测试工具 AB 测试,模拟多用户秒杀商品,模拟60秒内发起3000个请求,并发600次,秒杀50个库存商品

AB测试相关参数说明

  1. -r 指定接收到错误信息时不退出程序
  2. -t 等待响应的最大时间
  3. -n 指定压力测试总共的执行次数
  4. -c 用于指定压力测试的并发数

  1.初始化50个库存,运行ms_init方法

  2.测试   命令行:E:\phpstudy_pro\Extensions\Apache2.4.39\bin>ab -r -t 60 -n 3000 -c 1000 http://gouwuche.zxf/index/miaosha/index  

需要先进入apache的bin目录下执行命令

 

   3.检测数据库数据

 

 日志表状态为1(秒杀成功)的数据有50人,订单表里的订单数也是50条,商品表里的商品数量变成了0(测试之前是50),商品秒杀成功完成!

如果不用redis而是直接用mysql的话,商品表订单的数量count会变成负数,而秒杀成功的人数也多余50人,订单表里的订单数量也多余50条(新测),下面是直接用Mysql的例子;

  1. public function sqlMs()
  2. {
  3. $id = 1; //商品编号
  4.  
  5. $count = 50;
  6. $ordersn = $this->build_order_no(); //生成订单
  7. $uid = rand(0,9999); //随机生成用户id
  8. $status = 1;
  9. // 再进行数据库操作
  10. $data = Db::table('ab_goods')->field('count,amount')->where('id',$id)->find(); //查找商品
  11. // 查询还剩多少库存
  12. $rs = Db::table('ab_goods')->where('id',$id)->value('count');
  13. if ($rs <= 0) {
  14. $this->writeLog(0,'库存为0');
  15. }else{
  16. $insert_data = [
  17. 'order_sn' => $ordersn,
  18. 'user_id' => $uid,
  19. 'goods_id' => $id,
  20. 'price' => $data['amount'],
  21. 'status' => $status,
  22. 'addtime' => date('Y-m-d H:i:s')
  23. ];
  24. // 订单入库
  25. $result = Db::table('ab_order')->insert($insert_data);
  26. // 自动减少一个库存
  27. $res = Db::table('ab_goods')->where('id',$id)->setDec('count');
  28. if ($res) {
  29. echo "第".$data['count']."件秒杀成功";
  30. $this->writeLog(1,'秒杀成功');
  31. }else{
  32. echo "第".$data['count']."件秒杀失败";
  33. $this->writeLog(0,'秒杀失败');
  34. }
  35. }
  36. }

 

原文链接:http://www.cnblogs.com/zxf100/p/14173899.html

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号