当前位置：首页 > PHP

php实现抢购

2026-02-27 21:35:37PHP

PHP实现抢购功能的关键要点

抢购功能的核心在于解决高并发下的数据一致性和系统性能问题。以下是实现抢购功能的几个关键方面：

数据库设计优化

商品表和订单表需要合理设计，商品表需包含库存字段并设置乐观锁。示例商品表结构：

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

使用MySQL事务和乐观锁保证数据一致性：

$pdo->beginTransaction();
try {
    $stmt = $pdo->prepare("SELECT stock, version FROM product WHERE id = ? FOR UPDATE");
    $stmt->execute([$productId]);
    $product = $stmt->fetch(PDO::FETCH_ASSOC);

    if ($product['stock'] > 0) {
        $update = $pdo->prepare("UPDATE product SET stock = stock - 1, version = version + 1 
                               WHERE id = ? AND version = ?");
        $affected = $update->execute([$productId, $product['version']]);

        if ($affected) {
            // 创建订单
            $orderStmt = $pdo->prepare("INSERT INTO orders (...) VALUES (...)");
            $orderStmt->execute([...]);
            $pdo->commit();
            return true;
        }
    }
    $pdo->rollBack();
    return false;
} catch (Exception $e) {
    $pdo->rollBack();
    throw $e;
}

缓存层设计

采用Redis预减库存避免直接访问数据库：

$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 初始化商品库存到Redis
$redis->set("product_{$productId}_stock", 100);

// 抢购时原子操作
$remaining = $redis->decr("product_{$productId}_stock");
if ($remaining >= 0) {
    // 进入订单创建流程
} else {
    // 库存不足
}

限流与队列

使用消息队列缓解瞬间压力：

// 使用Redis列表作为队列
$redis->lPush('seckill_queue', json_encode([
    'user_id' => $userId,
    'product_id' => $productId,
    'time' => time()
]));

// 后台worker处理队列
while (true) {
    $task = $redis->rPop('seckill_queue');
    if ($task) {
        $data = json_decode($task, true);
        // 处理订单创建
    }
    usleep(100000); // 100ms间隔
}

接口防刷

实施多种防护措施：

验证码机制分散请求

IP限流（Redis实现）：

$key = 'ip_'.$_SERVER['REMOTE_ADDR'];
$count = $redis->incr($key);
$redis->expire($key, 10); // 10秒窗口
if ($count > 5) { // 限制10秒内5次请求
  die('请求过于频繁');
}