第一种使用Redis LIST做队列(List的Lpop操作是原子性的)
- 思路:先在Redis中根据商品数量生成相应的库存队列,当用户抢购商品时先从队列中获取商品,然后再进行下单等相关逻辑处理
- 实践
生成库存队列
<?php public function fillStock(){ $redis = new Redis(); $redis->connect("redis",6379); $redis->auth("hengda"); $redis->select(1); for ($i = 0;$i < 1000;$i++){ $redis->lPush("shop_list",rand(1000000000,99999999999999)); } }
抢购消费队列
<?php public function purchase(){ $redis = new Redis(); $redis->connect("redis",6379); $redis->auth("hengda"); $redis->select(1); if(!$redis->lPop("shop_list")){ return response_json(1,["msg"=>"已结束"],"success"); } //TODO 生成订单队列 }
第二种使用Redis执行Lua脚本(执行脚本的eval操作是原子性的)
- 思路:在redis库中存储库存数,当用户抢购时先将库存减1然后再生成订单对列
- 实践
<?php public function purchaseLua(){ $redis = new Redis(); $redis->connect("redis",6379); $redis->auth("hengda"); $redis->select(1); $lua_script = <<<LUA local shop_num_exit = redis.call("get","shop_num"); if shop_num_exit == "0" then return false; else return redis.call("decr","shop_num"); end LUA; $result = $redis->eval($lua_script); if($result === false){ return response_json(1,["msg"=>"已结束"],"success"); } //TODO 生成订单对列 }