thinkphp6使用mysql悲观锁解决商品超卖问题的实现

1. 什么是商品超卖问题

商品超卖是指在电商平台上，某一商品因为系统处理不当或是数据同步问题，导致超过实际库存数量的商品被售卖出去，给商家和买家带来了困扰。

在进行电商开发时，商品超卖问题是一个常见而且严重的挑战。当多个用户同时购买同一商品，并行访问数据库进行购买操作时，如果没有良好的控制机制，就很容易发生超卖情况。

悲观锁是一种解决并发问题的常用方式，通过对数据操作加锁来保证数据的一致性，下面我们将使用thinkphp6框架来演示如何使用悲观锁来解决商品超卖问题。

2. 实现悲观锁的准备工作

2.1 创建商品表

首先，我们需要创建一个商品表，用来存储商品的库存信息。在MySQL数据库中执行以下SQL语句：

CREATE TABLE `goods` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) DEFAULT NULL,
  `stock` int(11) DEFAULT NULL,
  PRIMARY KEY (`id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

2.2 添加测试数据

为了方便演示，我们在商品表中添加一些测试数据，可以执行以下SQL语句插入几条商品记录：

INSERT INTO `goods` (`name`, `stock`) VALUES
('商品A', 10),
('商品B', 20),
('商品C', 30);

3. 使用悲观锁解决商品超卖问题

3.1 获取商品信息并加锁

在进行商品购买操作前，我们需要先获取商品的信息，并对该条商品记录进行加锁，以确保在购买过程中其他用户无法对该商品进行操作。

use think\facade\Db;
public function buyGoods($goodsId, $uid) {
    // 开启事务
    Db::startTrans();
    try {
        // 获取商品信息并加锁
        $goods = Db::name('goods')->where('id', $goodsId)->lock(true)->find();
        
        // 判断商品库存
        if ($goods['stock'] > 0) {
            // 执行购买操作
            // ...
            // ...
            // 更新商品库存
            Db::name('goods')->where('id', $goodsId)->update(['stock' => $goods['stock'] - 1]);
            // 提交事务
            Db::commit();
            return '购买成功';
        } else {
            // 库存不足
            // ...
            // ...
            return '库存不足';
        }
    } catch (\Exception $e) {
        // 回滚事务
        Db::rollback();
        return '购买失败';
    }
}

3.2 释放商品锁

在购买操作完成后，需要手动释放商品的锁，以允许其他用户对该商品进行操作。

Db::name('goods')->where('id', $goodsId)->lock(false)->find();

3.3 示意图

下面是一个购买流程的示意图，帮助理解悲观锁的使用：

4. 总结

通过使用悲观锁，我们可以有效避免商品超卖问题的发生。在购买商品前，通过加锁确保当前用户能够独占地访问该商品，并在购买完成后释放锁，使其他用户可以继续对该商品进行操作。

需要注意的是，在使用悲观锁时，要确保加锁的范围不要过大，以免影响系统的并发性能。同时，由于悲观锁需要等待其他锁的释放，可能造成一定的请求阻塞，所以需要合理设置数据库连接池的大小和超时时间。

总的来说，悲观锁是解决商品超卖问题的一种有效方式，在实际开发中可以根据具体需求选择合适的锁机制。