推荐11-PHP用redis解决超卖的问题
- 2019 年 10 月 5 日
- 筆記
前言
在商品秒杀活动中，比如商品库存只有100，但是在抢购活动中可能有200人同时抢购，这样就出现了并发，在100件商品下单完成库存为0了还有可能继续下单成功，就出现了超卖。
为了解决这个问题，今天我主要讲一下用redis队列的方式处理。redis有list类型，list类型其实就是一个双向链表。通过lpush，pop操作从链表的头部或者尾部添加删除元素。这使得list即可以用作栈，也可以用作队列。先进先出，一端进，一端出，这就是队列。在队列里前一个走完之后，后一个才会走，所以redis的队列能完美的解决超卖并发的问题。
解决秒杀超卖问题的方法还有比如：1.使用mysql的事务加排他锁来解决；2.使用文件锁实现。3.使用redis的setnx来实现锁机制等。
实现原理
将商品库存循环lpush到num里，然后在下单的时候通过rpop每次取出1件商品，当num的值为0时，停止下单。
第1步创建表
一共有三张表，分别是：订单表、商品表、日志表。
1.订单表
CREATE TABLE `ims_order` ( `id` int(11) NOT NULL AUTO_INCREMENT, `order_sn` char(32) NOT NULL, `user_id` int(11) NOT NULL, `status` int(11) NOT NULL DEFAULT '0', `goods_id` int(11) NOT NULL DEFAULT '0', `sku_id` int(11) NOT NULL DEFAULT '0', `number` int(11) NOT NULL, `price` int(10) NOT NULL COMMENT '价格：单位为分', `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=5820 DEFAULT CHARSET=utf8 COMMENT='订单表'
2.商品表
CREATE TABLE `ims_hotmallstore_goods` ( `id` int(11) unsigned NOT NULL AUTO_INCREMENT, `name` varchar(50) NOT NULL COMMENT '商品名称', `type_id` int(11) NOT NULL COMMENT '商品分类', `img` text NOT NULL COMMENT '商品图片', `money` decimal(10,2) NOT NULL COMMENT '售价', `money2` decimal(10,2) NOT NULL COMMENT '原价', `is_show` int(11) NOT NULL DEFAULT '1' COMMENT '1.上架2.下架', `uniacid` int(11) NOT NULL COMMENT '小程序id', `inventory` int(11) NOT NULL COMMENT '库存', `details` text NOT NULL COMMENT '详情', `store_id` int(11) NOT NULL COMMENT '商家id', `sales` int(11) NOT NULL COMMENT '销量', `logo` varchar(100) NOT NULL, `num` int(11) NOT NULL, `is_gg` int(11) NOT NULL DEFAULT '2' COMMENT '是否开启规格', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8
3.日志表
CREATE TABLE `ims_order_log` ( `id` int(11) NOT NULL AUTO_INCREMENT, `status` int(11) NOT NULL DEFAULT '0', `msg` text CHARACTER SET utf8, `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP, PRIMARY KEY (`id`), KEY `status` (`status`) ) ENGINE=InnoDB AUTO_INCREMENT=4562 DEFAULT CHARSET=gb2312 COMMENT='订单日志表'
第2步写代码
class Test { private static $instance = null; // 用单列模式 实例化Redis public static function Redis() { if (self::$instance == null) { $redis=new Redis(); $redis->connect('127.0.0.1',6379); self::$instance = $redis; } return self::$instance; } // 将商品库存循环到lpush的num里 public function doPageSaveNum() { $redis=self::Redis(); $goods_id=1; $sql="select id, num, money from ims_hotmallstore_goods where id=".$goods_id; $goods=pdo_fetch($sql); if(!empty($goods)){ for($i=1; $i<=$goods['num']; $i++){ $redis->lpush('num',$i); } die('成功！'); }else{ $this->echoMsg(0,'商品不存在。'); } } // 抢购下单 public function doPageGoodsStore() { $goods_id=1; $sql="select id, num, money from ims_hotmallstore_goods where id=".$goods_id; $goods=pdo_fetch($sql); $redis=self::Redis(); $count=$redis->rpop('num');//每次从num取出1 if($count==0){ $this->echoMsg(0,'no num redis'); } $this->doPageGoodsOrder($goods,1); } // 保存日志 public function echoMsg($status,$msg,$_data="") { $data=json_encode(array('status'=>$status,'msg'=>$msg,'data'=>$_data),JSON_UNESCAPED_UNICODE); $order_log['status']=$status; $order_log['msg']=$msg; $order_log['create_time']=time(); pdo_insert('order_log',$order_log); die($data); } public function orderNo() { return date('ymd').substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8); } // 下单更新库存 public function doPageGoodsOrder($goods,$goods_number) { $orderNo=$this->orderNo(); $number=$goods['num']-$goods_number; if($number<0){ $this->echoMsg(0,'已没有库存'); } $user_id=rand(1,500); $order['user_id']=$user_id; $order['goods_id']=$goods['id']; $order['number']=$goods_number; $order['price']=$goods['money']; $order['status']=1; $order['sku_id']=2; $order['order_sn']=$orderNo; $order['create_time']=date('Y-m-d H:i:s'); pdo_insert('order',$order); $sql="update ims_hotmallstore_goods set num=num-".$goods_number." where num>0 and id=".$goods['id']; $res=pdo_query($sql); if(!empty($res)){ $this->echoMsg(1,'库存扣减成功'.$number); } $redis=self::Redis(); $redis->lpush('num',$goods_number); $this->echoMsg(0,'库存扣减失败'.$number); } } // 调用--将商品库存循环到lpush的num里 if($_GET['i']==1){ $model = new Test; $model->doPageSaveNum(); } // 调用--高并发抢购下单 if($_GET['i']==2){ $model = new Test; $model->doPageGoodsStore(); }
第3步并发测试
1.先手动执行： http://127.0.0.1/wqchunjingsvn/web/index.php?i=1 ，将商品库存循环保存到lpush的num里。
2.这里我用Apache的ab测试，安装方法本文最后做补充。打开终端，然后执行： ab -n 1000 -c 200 http://127.0.0.1/wqchunjingsvn/web/index.php?i=2 （-n发出1000个请求，-c模拟200并发，请求数要大于或等于并发数。相当1000人同时访问，后面是测试url ）
3.观察是否执行成功，执行结果如下图，说明执行成功。
第4步查看数据表
1.查看订单表，总订单数量为100，如下图，没问题。
2.查看商品库存，已经由原来的100变成0，也没问题。
3.查看日志表，总共137条记录，其中status为1的只有100条，也没问题。
总结分析
1.方案可行，库存为0，没有出现超卖。
2.用Apache的ab测试高并发时需要注意Url地址不能拼接上带&号的参数，否则执行失败。
