秒杀超卖问题，就是有一个商品抢购活动，一个商品假如有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 Home\Controller;
use Think\Cache\Driver\Redis;
use Think\Controller;
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 进行模拟
