DDR爱好者之家

php+redis消息队列实现抢购功能
站长资源 2025/10/27 佚名
77 1538
DDR爱好者之家 Design By 杰米

本文实例为大家分享了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;
 }
}

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

DDR爱好者之家 Design By 杰米
广告合作：本站广告合作请联系QQ：858582 申请时备注：广告合作（否则不回）
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！
DDR爱好者之家 Design By 杰米
ddrfans.com DDR爱好者之家
8,675无损音乐
1,324高清电影
213破解软件
70,141收录资讯

更新日志

友情链接

杰晶网络 DDR爱好者之家 南强小屋 黑松山资源网 白云城资源网
DDR爱好者之家 Design By 杰米