用redis做秒杀的库存扣除, 限制每个账号只能抢购一次, 这个简单的demo使用了string, hash, list三种基本类型.

• 用string类型的int值来存储剩余库存, 并在抢购成功后减1

• 用hash来存储"已抢购到"的会员的id(可以确保用户id作为field的唯一性). 注意: 这个hash的field对应的uid不一定抢购成功

• 用list来保存真正抢购成功的会员id的列表, 作为后续处理订单的队列

第一次写的时候, 尝试过使用string的bitmap来保存该会员是否抢购成功过, 但是这个在高并发时会出问题, 所以后来换成了唯一field的hash

2个文件:

• init.php: 初始化库存, 统计数据, 抢购成功的会员列表等

• buy.php: 抢购

初始化

ini.php:

$m_redis = new YourRedisClass(); //redis类很多, 可以自己写, 也可以用predis等
$m_redis->set('rush_stock', 20);//int, 可抢购的商品总数
$m_redis->set('rush_success', 0); //int, 成功的数量
$m_redis->set('rush_fail', 0); //int, 失败的数量
$m_redis->expire('rush_queue_h', 0); //hash, 已加入抢购队列的会员的hash记录表(field是唯一的, 可限制每个uid只有一次), 不一定抢购成功
$m_redis->set('rush_got_uid', ''); //string, 抢购成功的会员uid记录, 只是为了能简单的显示抢到的会员.
$m_redis->del('rush_got_uid_l'); //list, 抢购成功的会员uid(方便抢购后的订单批次处理)
echo 'success, '.date('Y-m-d H:i:s');

执行本文件, 初始化数量.

redis-cli 下执行 "mget rush_stock rush_fail rush_success rush_got_uid" 确认初始化数据

秒杀

判断的逻辑:

• 
  

1. 库存是否为0, 库存>0则进入抢购队列

• 
  

1. 抢购队列数据(hash)写入成功, 则准备扣减库存

• 
  

1. 库存扣减成功(余数>=0)则抢购成功, 进入订单处理队列(list)
   目前是用string int存储库存, 也可以用list的item的个数来计数, 但是初始化时没有string类型来得简单.

buy.php

//随机生成会员id
$uid = rand(1,200);

$m_redis = new YourRedisClass(); //redis类很多, 可以自己写, 也可以用predis等

$key = 'rush_stock';
$q = $m_redis->get($key);

//1. 先判断库存数量
//库存为0, 直接无法进入抢购队列
if($q < 1){
    $m_redis->incr('rush_fail');//记录失败的数量
    die($uid.':OutOfStock');
}

//2. 判断该会员是否购买过 => 是否进入过队列
$queued = $m_redis->hSet('rush_queue_h', $uid, $uid);//这里只能判断是否进入了抢购的队列. 如果库存为0则无法进入. 进入了队列后才能抢购
if(!$queued){
    $m_redis->incr('rush_fail');//记录失败的数量
    die($uid.':queue failed');
}

//让cpu飞一会
$n = rand(20000,100000);
for($i=0; $i < $n; $i++){
    $a = rand(1,20000);
    $a = rand(1,30000);
    $a = rand(1,40000);
    $a = rand(1,50000);
    $a = rand(1,60000);
    $a = rand(1,70000);
    $a = rand(1,80000);
    $a = rand(1,90000);
}


//3. 扣减数量
$q = $m_redis->decr($key, 1);//扣减数量后会返回结果值
echo $q.' left:';


////region 如果不判断操作后返回的结果,则可能会造成超发
//$m_redis->incr('q_success');//记录成功的数量  ==>这个是有bug的, 不可取
//die(':success');
////endregion

if($q < 0){
    $m_redis->incr('rush_fail');//记录失败的数量
    die($uid.':decrease fail');
}else{
    //记录成功的数量
    $m_redis->incr('rush_success');
    //记录该会员已购买
    $m_redis->append('rush_got_uid', $uid.','); //字符串追加
    $m_redis->rPush('rush_got_uid_l', $uid); //list
    die($uid.':success');
}

上面的代码中的hash保存的会员uid, 只是进入抢购队列的会员uid, 不一定抢购成功了, 那些根本没有进入抢购队列的, 也不会在这个hash中, 直接因为库存为0而被拒绝了.

AB压力测试:  做一个简单的500个并发并总计尝试2000次的请求(测试时, win10下600个并发Nginx就挂机了)

Apache路径bin>ab -n 2000 -c 500 http://xxx.com/buy.php

redis-cli下执行 "mget rush_stock rush_fail rush_success rush_got_uid" 确认结果, 通过 rush_stock 的值查看可能的超发的数量

执行 "hvals rush_queue_h"可查看进入抢购队列的用户id, 这个数量 >= 抢购成功的用户数量

对于list队列的数据操作, 可以使用 BLPOP 命令, 这样可以实现FIFO的数据处理顺序.