当前位置：首页 > PHP

php 实现秒杀功能

2026-02-15 08:33:18PHP

PHP实现秒杀功能的核心要点

秒杀场景的特点是高并发、低库存，需解决超卖、性能瓶颈、恶意请求等问题。以下是关键实现方案：

数据库设计优化

使用InnoDB引擎，利用事务和行锁保证数据一致性。商品表需包含stock字段（无符号整型）并设置乐观锁版本号：

php 实现秒杀功能

CREATE TABLE `seckill_goods` (
  `id` int(11) unsigned NOT NULL AUTO_INCREMENT,
  `stock` int(11) unsigned NOT NULL COMMENT '剩余库存',
  `version` int(11) unsigned DEFAULT 0 COMMENT '乐观锁版本号',
  PRIMARY KEY (`id`)
) ENGINE=InnoDB;

悲观锁方案（MySQL行锁）

通过SELECT ... FOR UPDATE锁定记录，适合并发量中等场景：

php 实现秒杀功能

$pdo->beginTransaction();
try {
    $stmt = $pdo->prepare("SELECT stock FROM seckill_goods WHERE id = ? FOR UPDATE");
    $stmt->execute([$goods_id]);
    $stock = $stmt->fetchColumn();

    if ($stock > 0) {
        $pdo->prepare("UPDATE seckill_goods SET stock = stock - 1 WHERE id = ?")->execute([$goods_id]);
        $pdo->commit();
        echo "秒杀成功";
    } else {
        $pdo->rollBack();
        echo "库存不足";
    }
} catch (Exception $e) {
    $pdo->rollBack();
    echo "系统异常";
}

乐观锁方案

通过版本号避免阻塞，适合高并发场景：

$pdo->beginTransaction();
try {
    // 先查询当前版本号
    $stmt = $pdo->prepare("SELECT stock, version FROM seckill_goods WHERE id = ?");
    $stmt->execute([$goods_id]);
    $data = $stmt->fetch(PDO::FETCH_ASSOC);

    if ($data['stock'] > 0) {
        // 带版本号更新
        $affected = $pdo->prepare("UPDATE seckill_goods SET stock = stock - 1, version = version + 1 
                                  WHERE id = ? AND version = ?")->execute([$goods_id, $data['version']]);

        if ($affected) {
            $pdo->commit();
            echo "秒杀成功";
        } else {
            $pdo->rollBack();
            echo "请重试";
        }
    } else {
        $pdo->rollBack();
        echo "库存不足";
    }
} catch (Exception $e) {
    $pdo->rollBack();
    echo "系统异常";
}

Redis原子操作

利用Redis的DECR和WATCH实现原子减库存：

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$redis_key = "seckill:goods:$goods_id";

// 监控库存键
$redis->watch($redis_key);
$stock = $redis->get($redis_key);

if ($stock > 0) {
    $redis->multi();
    $redis->decr($redis_key);
    $result = $redis->exec();

    if ($result) {
        echo "秒杀成功";
        // 异步更新数据库
    } else {
        echo "请重试";
    }
} else {
    $redis->unwatch();
    echo "库存不足";
}

流量削峰策略

前端限流：按钮倒计时+随机延迟提交
令牌桶算法：使用Redis实现请求速率限制
消息队列：将请求写入RabbitMQ/Kafka异步处理

// Redis令牌桶示例
$rate_limit_key = "user_limit:$user_id";
$limit = 10; // 每秒10次

if ($redis->lLen($rate_limit_key) < $limit) {
    $redis->lPush($rate_limit_key, time());
    $redis->expire($rate_limit_key, 1);
    // 处理请求
} else {
    echo "操作过于频繁";
}