当前位置：首页 > PHP

php实现秒杀

2026-02-27 14:25:23PHP

PHP 实现秒杀功能的关键技术

秒杀功能的核心在于高并发场景下的库存准确性和系统稳定性。PHP 实现秒杀需要结合多种技术手段确保性能和数据一致性。

使用 Redis 预减库存

Redis 的高性能特性适合处理高并发请求。在秒杀开始前将商品库存加载到 Redis 中，通过原子操作保证库存准确性。

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

// 预减库存
$remaining = $redis->decr('seckill_stock:product_id');
if ($remaining < 0) {
    $redis->incr('seckill_stock:product_id'); // 回滚
    return '秒杀已结束';
}

消息队列异步处理

将实际订单创建操作放入消息队列，缓解数据库压力，提高系统吞吐量。

// 使用 RabbitMQ 示例
$connection = new AMQPStreamConnection('localhost', 5672, 'guest', 'guest');
$channel = $connection->channel();
$channel->queue_declare('seckill_orders', false, true, false, false);

$msg = new AMQPMessage(json_encode([
    'user_id' => $userId,
    'product_id' => $productId
]));

$channel->basic_publish($msg, '', 'seckill_orders');

数据库最终一致性

消息队列消费者处理实际订单创建，保证最终数据一致性。

// 消费者端处理
$callback = function ($msg) {
    $data = json_decode($msg->body, true);
    // 数据库事务处理
    try {
        $db->beginTransaction();
        // 检查库存
        // 创建订单
        // 扣减库存
        $db->commit();
    } catch (Exception $e) {
        $db->rollBack();
        // 重新入队或记录失败
    }
};

限流措施

使用令牌桶或漏桶算法限制请求流量，防止系统过载。

// 使用 Redis 实现简单限流
$key = 'seckill_rate_limit:' . $userId;
$limit = 1; // 每秒1次
if ($redis->exists($key) && $redis->incr($key) > $limit) {
    return '操作过于频繁';
}
$redis->expire($key, 1);

缓存预热与静态化

提前将商品详情页静态化，使用 CDN 分发，减少服务器压力。

分布式锁

确保关键操作在分布式环境中的原子性。

// Redis 分布式锁实现
$lockKey = 'seckill_lock:' . $productId;
$lockExpire = 10; // 秒

if ($redis->set($lockKey, 1, ['NX', 'EX' => $lockExpire])) {
    try {
        // 执行关键操作
    } finally {
        $redis->del($lockKey);
    }
}