MySQL数据库限时秒杀

基础概念

MySQL数据库限时秒杀是指在特定时间段内，允许用户以极低的价格购买商品或服务的活动。这种活动通常伴随着高并发访问，对数据库的性能和稳定性提出了极高的要求。

类型

普通秒杀：在规定时间内，所有用户都可以参与抢购。
预约秒杀：用户需要提前预约，然后在规定时间内进行抢购。
分组秒杀：将用户分成若干组，每组轮流进行抢购。

应用场景

电商平台的促销活动：如双十一、618等大型购物节。
新品发布：新商品上市时的限时抢购活动。
节日促销：如情人节、圣诞节等特殊节日的促销活动。

遇到的问题及原因

1. 数据库压力过大

原因：大量用户同时访问数据库，导致数据库服务器负载过高。 解决方法：

使用缓存技术（如Redis）减轻数据库压力。
数据库读写分离，提高并发处理能力。
分库分表，分散数据库负载。

2. 超卖现象

原因：在高并发情况下，多个请求同时读取并修改同一商品库存，导致库存数据不一致。 解决方法：

使用乐观锁或悲观锁机制，确保同一时间只有一个请求能修改库存。
在更新库存时，使用事务保证操作的原子性。

3. 页面加载缓慢

原因：用户请求过多，服务器响应速度下降。 解决方法：

使用CDN加速静态资源的加载。
前端页面进行优化，减少不必要的请求。
后端服务进行负载均衡，分散请求压力。

示例代码

以下是一个简单的MySQL秒杀系统示例，使用乐观锁机制防止超卖：

-- 创建商品表
CREATE TABLE products (
    id INT PRIMARY KEY AUTO_INCREMENT,
    name VARCHAR(255) NOT NULL,
    stock INT NOT NULL,
    version INT NOT NULL DEFAULT 0
);

-- 插入商品数据
INSERT INTO products (name, stock) VALUES ('秒杀商品', 100);

-- 秒杀逻辑（PHP示例）
<?php
$productId = 1;
$userId = 123;

// 开启事务
$conn->begin_transaction();

try {
    // 查询商品信息
    $stmt = $conn->prepare("SELECT stock, version FROM products WHERE id = ?");
    $stmt->bind_param("i", $productId);
    $stmt->execute();
    $result = $stmt->get_result();
    $product = $result->fetch_assoc();

    if ($product['stock'] > 0) {
        // 更新库存（乐观锁）
        $newVersion = $product['version'] + 1;
        $stmt = $conn->prepare("UPDATE products SET stock = stock - 1, version = ? WHERE id = ? AND version = ?");
        $stmt->bind_param("iii", $newVersion, $productId, $product['version']);
        $stmt->execute();

        if ($stmt->affected_rows > 0) {
            // 秒杀成功，记录订单
            $stmt = $conn->prepare("INSERT INTO orders (user_id, product_id) VALUES (?, ?)");
            $stmt->bind_param("ii", $userId, $productId);
            $stmt->execute();

            // 提交事务
            $conn->commit();
            echo "秒杀成功！";
        } else {
            // 版本不一致，秒杀失败
            $conn->rollback();
            echo "秒杀失败，商品已被抢光！";
        }
    } else {
        // 库存不足，秒杀失败
        $conn->rollback();
        echo "秒杀失败，商品已被抢光！";
    }
} catch (Exception $e) {
    // 异常处理
    $conn->rollback();
    echo "秒杀失败：" . $e->getMessage();
}
?>