当前位置：首页 > PHP

商品秒杀实现php

2026-01-29 02:57:39PHP

商品秒杀系统的PHP实现要点

商品秒杀系统需要解决高并发、数据一致性、系统稳定性等问题。以下是关键实现方案：

系统架构设计

采用分层架构：前端展示层、逻辑处理层、数据访问层。使用Redis作为缓存数据库，MySQL作为持久化存储。引入消息队列（如RabbitMQ）处理异步任务。

数据库设计

创建商品表和订单表，商品表需包含库存字段并设置乐观锁。例如：

CREATE TABLE `seckill_goods` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(100) NOT NULL,
  `stock` int(11) NOT NULL,
  `version` int(11) NOT NULL DEFAULT 0,
  PRIMARY KEY (`id`)
);

前端优化

静态资源使用CDN加速，页面元素尽量减少HTTP请求。秒杀按钮在活动开始前禁用，通过JavaScript定时启用。

后端逻辑实现

使用Redis预减库存避免直接访问数据库。PHP代码示例：

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

// 预减库存
$stock = $redis->decr('goods_stock');
if ($stock < 0) {
    $redis->incr('goods_stock'); // 恢复库存
    return '秒杀失败';
}

// 生成订单
$orderId = uniqid();
$data = [
    'user_id' => $userId,
    'goods_id' => $goodsId,
    'order_id' => $orderId
];

// 加入消息队列
$queue->push(json_encode($data));

消息队列处理

消费者从队列获取消息并处理订单：

while ($msg = $queue->pop()) {
    $data = json_decode($msg, true);

    // 数据库操作
    $pdo->beginTransaction();
    try {
        $stmt = $pdo->prepare("UPDATE seckill_goods SET stock = stock - 1, version = version + 1 WHERE id = ? AND version = ?");
        $stmt->execute([$data['goods_id'], $currentVersion]);

        if ($stmt->rowCount() > 0) {
            // 创建订单
            $orderStmt = $pdo->prepare("INSERT INTO orders (...) VALUES (...)");
            $orderStmt->execute([...]);
            $pdo->commit();
        } else {
            $pdo->rollBack();
        }
    } catch (Exception $e) {
        $pdo->rollBack();
    }
}

限流措施

使用Redis实现简单限流：

$key = 'user_limit_' . $userId;
$limit = 10; // 限制次数

if ($redis->exists($key)) {
    $count = $redis->incr($key);
    if ($count > $limit) {
        return '操作过于频繁';
    }
} else {
    $redis->setex($key, 60, 1); // 60秒过期
}

数据一致性保障

采用分布式锁确保关键操作原子性。Redis实现示例：

$lockKey = 'seckill_lock_' . $goodsId;
$lockValue = uniqid();
$locked = $redis->set($lockKey, $lockValue, ['NX', 'EX' => 10]);

if ($locked) {
    try {
        // 执行核心业务逻辑
    } finally {
        // 释放锁
        if ($redis->get($lockKey) == $lockValue) {
            $redis->del($lockKey);
        }
    }
}