(编辑：jimmy 日期: 2026/1/13 浏览：2)
本文实例为大家分享了php+redis消息队列实现抢购的具体代码，供大家参考，具体内容如下
实现功能：
1. 基于redis队列，防止高并发的超卖
2. 基于mysql的事务加排它锁，防止高并发的超卖
基于redis队列工作流程：
1. 管理员根据goods表中的库存，创建redis商品库存队列
2. 客户端访问秒杀API
3. web服务器先从redis的商品库存队列中查询剩余库存重点内容
4. redis队列中有剩余，则在mysql中创建订单，去库存，抢购成功
5. redis队列中没有剩余，则提示库存不足，抢购失败重点内容
基于mysql事务和排它锁工作流程：
1. 开启事务
2. 查询库存，并显示的设置写锁（排他锁）：SELECT * FROM goods WHERE id = 1 FOR UPDATE
3. 生成订单
4. 去库存，隐示的设置写锁（排他锁）：UPDATE goods SET counts = counts – 1 WHERE id = 1
5. commit，释放锁
注意：第二步步可以设置共享锁，不然有可能会造成死锁。
代码：
<"'.$data['order_id'].'","'.$data['goods_id'].'","'.$data['uid'].'","'.$data['addtime'].'")';
$result = $pdo->exec($sql);
if(!$result){
$pdo->rollBack();
$this->_error = '订单创建失败';
return false;
}
$pdo->commit();//提交
$this->_error = '购买成功';
return true;
}else{
$this->_error = '库存不足';
return false;
}
}catch(PDOException $e){
echo $e->getMessage();
$pdo->rollBack();
}
}
/*
* 创建订单
* mysql 事物处理，也可以用存储过程
*
*/
private function create_order($goodsInfo){
//生成订单
$data = [];
$data['order_id'] = $this->_orderModel->buildOrderNo();
$data['goods_id'] = $goodsInfo['id'];
$data['addtime'] = time();
$data['uid'] = 1;
$order_rs = $this->_orderModel->create_order($data);
//库存减少
$gid = $goodsInfo['id'];
$sql = 'UPDATE goods SET counts = counts - 1 WHERE id = '.$gid;
$result = $this->_goodsModel->exect($sql);
return true;
}
}
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。