PHP并发抢购解决方案

• 2021 年 3 月 29 日
• 笔记
• php, SQL, 学习笔记, 并发

Mysql版

逻辑步骤

1. mysql存储引擎使用Innodb
2. 开始事务,查询商品库存并加上共享锁
3. 判断库存是否足够,进行商品/订单/用户等操作
4. 提交事务,完成下单抢购

代码参考

    // 关闭自动提交
	$this->db_conn->autocommit(FALSE);//开启事务
	// 	//获取商品库存
	$query_sql = 'select stock from goods where id ='.$goods_id .' lock in share mode'; //加mysql共享锁[提交前不允许其他事务修改]
	$stock = $this->query($query_sql);
	if ($stock < $num) {
		return $this->log('库存不足_'.$stock);
	}
	//减库存
	$sql1 = 'update goods set stock = stock-'.$num.' where id='.$goods_id;
	if (!$this->db_conn->query($sql1)) {
		$this->db_conn->rollback();
		return $this->log('商品库存更新失败sql: '.$sql1.'==>stock: '.$stock);
	}
	//创建订单
	$order_sn = date('YmdHis') . rand(1000,9999);
	$sql2 = 'insert into `order` (order_sn,goods_id,goods_num,user_id) values ("'.$order_sn.'",'.$goods_id.','.$num.','.$user_id.')';
	if (!$this->db_conn->query($sql2)) {
		$this->db_conn->rollback();
		return $this->log('创建订单失败: '.$sql2.'==>stock: '.$stock);
	}
	//提交事务
	$this->db_conn->commit();
	return true;

Redis版

redis事务/watch/setnx (不限购)

逻辑步骤

1. 以商品id生成key,redis获取库存,开启redis监控key和redis事务
   • 首次获取失败: 数据查询商品库存存入redis,$redis->set($key,$stock,['nx','ex'=>60])',(nx参数: 不存在时才设置,ex: 时效)
   • 非首次获取成功: 判断库存是否足够
2. 开启数据库事务,减去库存,创建订单
3. $redis->exec();redis执行,失败数据库rollback;成功数据库commit;

代码参考

	//连接redis
	$redis = new Redis();
   	$redis->connect('127.0.0.1', 6379);
   	$redis->auth('zylwan@Redis123'); //密码验证
   	if (!$redis) {
		return $this->log('redis连接失败');
   	}
   	$redis->select(9);//选择数据库9

   	$stock_key = 'goods_id_stock_'.$goods_id; //商品库存key
   	$stock = $redis->get($stock_key);

	//监控key
	$redis->watch($stock_key); //监控下单过程中key是否被修改
	//开启事务
	$redis->multi();

	if ($stock === false) { //首次设置key
		$query_sql = 'select stock from goods where id='.$goods_id;
		stock = $this->query($query_sql);
   		$redis->set($stock_key,$stock,['nx','ex'=>60]); //nx参数: 当key不存在时才设置
	}

	if ($stock < $num) {
		return $this->log('商品库存不足num: '.$num.'==>stock: '.$stock);
	}

	$redis->decr($stock_key);//redis减库存

	// 关闭mysql自动提交
	$this->db_conn->autocommit(FALSE);//开启sql事务
	$sql1 = 'update goods set stock = stock-'.$num.' where id='.$goods_id; //减mysql库存
	if (!$this->db_conn->query($sql1)) {
		$this->db_conn->rollback();
		return $this->log('商品库存更新失败sql: '.$sql1.'==>stock: '.$stock);
	}
	//开单
	$order_sn = date('YmdHis') . rand(1000,9999);
	$sql2 = 'insert into `order` (order_sn,goods_id,goods_num,user_id) values ("'.$order_sn.'",'.$goods_id.','.$num.','.$user_id.')';
	if (!$this->db_conn->query($sql2)) {
		$this->db_conn->rollback();
		return $this->log('创建订单失败: '.$sql2.'==>stock: '.$stock);
	}
	$res = $redis->exec(); //执行redis事务
    if ($res === false) { //watch监控到key被修改,redis操作没有执行==>mysql操作回滚
		$this->db_conn->rollback();
		return $this->log('redis操作失败: '.'==>stock: '.$stock);
    }
    // 都成功执行,提交事务
	$this->db_conn->commit();
	return true;

redis list/hash (限购)

逻辑步骤

1. 抢购前将商品库存放到队列list中[库存队列] (库存=队列长度)
2. 抢购开始,将用户id放到hash队列中[排队hash队列],已存在:跳过.不存在:继续
3. 减库存操作lpop(list):
   • 成功=>数据库下单等,存储用户id到抢购成功list队列中[抢购成功hash队列]
   • 失败=>无库存,抢光了

代码参考

    $user_id = 1;
   	$wait_key = "user_wait";//用户抢购请求hash队列
	$user_key = "user";//用户抢购成功list队列
	$stock_key = "goods_stock";//商品库存队列[在抢购开始前生成]

	$result =$redis->hset($wait_key, $user_id, $user_id); //抢购用户排队,user_id去重
	if ($result) { //排队成功 => 开始抢购
    	$count = $redis->lpop($stock_key); //扣减库存
    	/**
    	 * list列表的原子性确保了此处并发时的串行
    	 * 即: 确保了下面if判断中只有与库存数量相等的人数可以进入到else中抢购下单
    	 */
    	if (!$count) { //扣减失败 => 抢光了
        	z_log('已经抢光了哦_'.$user_id);
    	} else { //扣减成功
    		$redis->lpush($user_key, $user_id);
        	$result =$redis->hset($user_key, $user_id, $user_id);
			//
			//.....数据库下单操作...
			//
    	    echo'抢购成功';
   		}
	} else { // 重复排队=>排队失败 
    	echo'请勿重复请求';
	}

原文地址: //www.zhuyilong.我爱你/tech/php_concurrent_buying.html