本文解决上文第一个问题，即超卖问题，主要是通过redis锁机制控制并发
只有获得锁的进程才能进行商品秒杀活动，否则都排队等待，所有的操作（锁机制，用户购买记录等）都基于redis实现，最后再持久化到数据库中
php代码更改如下
/**
* 开始抢购
* @author jinanav 2021年10月5日21:54:07
* @return
*/
public function index(){
//持久化数据
$this->persistence();exit();
$redis = new \Redis();
$redis->connect("127.0.0.1");
//初始化数据
// for ($i = 0; $i < 10;$i++){
// $redis->lPush("orderseckill",1);
// }
// $redis->set("seckillTotal",10);
// $redis->del("lock");
//var_dump($redis->get("seckillTotal"));
//登录流程假定统
$uid = Request::get("uid");
//固定商品id
$gId = 1;
$lockId = md5(uniqid().rand(100,999));
//监听key
$redis->watch("seckillTotal");
//循环抢锁,进行并发控制
while (($total = intval($redis->get("seckillTotal"))) > 0){
//开启redis事务
$redis->multi();
//开始上锁
if($redis->set("lock",$lockId, array('nx', 'ex' => 10))){
//讲商品id与用户id写入到队列中
$guid = $gId."_".$uid;
//推入到队列中（也可以用rabbitMQ实现）
$redis->lPush("seckill",$guid);
$redis->set("seckillTotal",$total - 1);
//解锁
// if($redis->get("lock") == $lockId){
// $redis->del("lock");
// }
//为了保证解锁过程的原子性，推荐使用以下方式释放锁
$script = 'if redis.call("get","lock") == "'.$lockId.'"
then
return redis.call("del","lock")
else
return 0
end ';
$redis->eval($script);
//提交redis事务
if( $redis->exec()){
$this->success("抢购成功");
}
}
//睡眠50毫秒
usleep(50000);
}
$this->error("没有抢到任何商品");
}
/**
* 数据持久化
* @author jinanav 2021/10/6 1:07
* @return
*/
public function persistence(){
$redis = new \Redis();
$redis->connect("127.0.0.1");
$queue = "seckill";
while($redis->lLen($queue)){
$guid = $redis->rPop($queue);
if(!empty($guid)){
$dataArray = explode("_",$guid);
$uid = $dataArray[1];
$goods = Db::name("goods")->where(['id'=>$dataArray[0]])->find();
try {
Db::startTrans();
Db::name('order')->insert([
'order_num' => md5(uniqid().time().rand(10,99)),
'total_cash'=> $goods['price'],
'user_id' => $uid,
'title' => $goods['goods_title'],
'g_u_id' => $guid
]);
Db::name("goods")->where(['id'=>$goods['id']])->update(['seckill_inventory'=>$goods['seckill_inventory']-1]);
Db::commit();
}catch (\Exception $e){
Db::rollback();
}
}
}
$this->success("入库成功");
}
看go并发1000个用户进行秒杀活动
image.png
查看数据库结果
10条数据，，没有超卖
image.png
利用redis锁机制实现了并发控制，但是，明显编码程度略复杂，下一文将用go的协成实现并发控制，编码更简单，更易理解
其实也可以通过redis的队列实现并发控制，由于队列的操作是原子性的(可以提前生成令牌列表总数，令牌消耗尽了说明商品也抢购完了)，一堆请求过来依旧是要排队的，代码如下
/**
* 开始抢购
* @author jinanav 2021年10月5日21:54:07
* @return
*/
public function index(){
//持久化数据
//$this->persistence();exit();
$redis = new \Redis();
$redis->connect("127.0.0.1");
//初始化数据
// for ($i = 0; $i < 10;$i++){
// $redis->lPush("orderseckill",1);
// }
// var_dump($redis->lLen("orderseckill"));
// exit();
//登录流程假定统
$uid = Request::get("uid");
//固定商品id
$gId = 1;
if($redis->lPop("orderseckill")){
//讲商品id与用户id写入到队列中
$guid = $gId."_".$uid;
//推入到队列中（也可以用rabbitMQ实现）
$redis->lPush("seckill",$guid);
$this->success("抢购成功");
}else{
$this->error("没有抢到任何商品");
}
$this->error("没有抢到任何商品");
}
go模仿100个用户进行请求
image.png
数据库结果
image.png
