秒杀超卖问题，就是有一个商品抢购活动，一个商品假如有100件库存，但是在抢购时有200人来抢购，这时就会并发，原本只有100的库存但是抢购的人过多，就会发生数据库里原本只有100的库存但是库存为0的时候还会有人提交成功，这就是超卖。
今天简单的用redis的队列来解决超卖问题。因为redis有list类型，list类型其实就是一个双向链表。通过push,pop操作从链表的头部或者尾部添加删除元素。这使得list既可以用作栈，也可以用作队列。先进先出 一端进 一端出这就是队列。这里用redis就解决了并发的问题，在队列里前一个走完之后，后一个才会走。
实现原理
将库存循环lpush进一个redis值goods_number里去，然后在下单的时候依次rpop出来。这样就是下一个单取出来一个，然后等goods_number的值为0时，停止下单。
首先建立三个表 store商品表 order订单表 log日志表
CREATE TABLE `store` ( `id` int(11) NOT NULL AUTO_INCREMENT, `goods_id` int(11) NOT NULL, `sku_id` int(10) unsigned NOT NULL DEFAULT '0', `number` int(10) NOT NULL DEFAULT '0', `freez` float(11,2) NOT NULL DEFAULT '0.00' COMMENT '虚拟库存', `price` int(10) NOT NULL COMMENT '价格：单位为分', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8 COMMENT='库存'; CREATE TABLE `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=4743 DEFAULT CHARSET=utf8 COMMENT='订单表'; CREATE TABLE `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=4743 DEFAULT CHARSET=utf8 COMMENT='订单表';代码如下：
<?php namespace HomeController; use ThinkCacheDriverRedis; use ThinkController; class TestController extends Controller { public function index() { $wheres = array(); $wheres['goods_id'] = 1; $number = M('store')->where($wheres)->getField('number'); $redis = new Redis(); for ($i = 0; $i < $number; $i++) { $redis->lpush('goods_number', 1); } echo $redis->llen('goods_number'); } //生成唯一订单号 function build_order_no() { return date('ymd') . substr(implode(NULL, array_map('ord', str_split(substr(uniqid(), 7, 13), 1))), 0, 8); } //记录日志 function insertLog($event, $type = 0) { $data['event'] = $event; $data['type'] = $type; $res = M('log')->add($data); } //模拟下单操作 //下单前判断redis队列库存量 function order() { $sku_id = 11; //传入已知的sku_id; $wheres = array(); $wheres['sku_id'] = $sku_id; $good_info = M('store')->where($wheres)->find(); $user_id = rand(1, 200); $goods_id = $good_info['goods_id']; $price = $good_info['price']; $number = 1; //抢购时每次买一件商品 $redis = new Redis(); $count = $redis->rpop('goods_number'); //下单时做rpop 从goods_number中取出1 if ($count == 0) { $this->insertLog('error:no goods_number redis'); return; } if (($good_info['number'] - $number) <= 0) { $this->insertLog('商品售罄'); //如果库存为0写入日志 并停止下单操作 return; } //生成订单 $order_sn = $this->build_order_no(); $data = array(); $data['order_sn'] = $order_sn; $data['user_id'] = $user_id; $data['goods_id'] = $goods_id; $data['sku_id'] = $sku_id; $data['number'] = $number; $data['price'] = $price; $order_rs = M('order')->add($data); //库存减少 $wheres['sku_id'] = $sku_id; $store_rs = M('store')->where($wheres)->setDec('number', $number); if ($store_rs) { $this->insertLog('库存减少成功'); } else { $this->insertLog('库存减少失败'); } } } 先访问：/test/index 将redis的list初始化
然后可以访问：/test/order 进行模拟
