php秒杀功能

封面图 • 2025-10-14 • PHP

PHP 实现秒杀功能是一个常见的高并发场景问题，尤其是在电商、抢购等场景中。由于 PHP 本身是单线程的（虽然可以配合多进程或协程），在高并发下容易出现超卖、性能瓶颈等问题。下面我将从**设计思路、技术实现、优化策略**等方面来讲解如何用 PHP 实现一个基本的秒杀功能。

---

## 一、秒杀功能的核心问题

1. **超卖问题**：同一商品被多个用户同时抢购。
2. **性能瓶颈**：大量请求同时访问数据库，导致数据库压力大。
3. **用户体验**：用户抢购时响应慢，甚至页面卡死。

---

## 二、基本实现思路

### 1. 数据库设计（以 MySQL 为例）

```sql
CREATE TABLE `products` (
  `id` int(11) NOT NULL AUTO_INCREMENT,
  `name` varchar(255) NOT NULL,
  `stock` int(11) NOT NULL DEFAULT '0',
  PRIMARY KEY (`id`)
);

-- 示例数据：
INSERT INTO products (name, stock) VALUES ('iPhone', 10);
```

### 2. PHP 秒杀逻辑（基础版本）

```php
<?php
// 连接数据库
$pdo = new PDO("mysql:host=localhost;dbname=test", "root", "");

// 获取商品 ID
$product_id = $_GET['product_id'];

// 查询商品库存
$stmt = $pdo->prepare("SELECT * FROM products WHERE id = ?");
$stmt->execute([$product_id]);
$product = $stmt->fetch();

if ($product['stock'] > 0) {
    // 扣减库存
    $stmt = $pdo->prepare("UPDATE products SET stock = stock - 1 WHERE id = ?");
    $stmt->execute([$product_id]);

echo "恭喜你，抢购成功！";
} else {
    echo "库存不足，已售完！";
}
?>
```

---

## 三、问题与优化方向

### 1. 超卖问题（事务 + 锁）

上面的代码在高并发下可能出现超卖问题，因为多个请求可能同时读取到相同的库存值。

#### 解决方案：使用事务和行锁

```php
$pdo->beginTransaction();

$stmt = $pdo->prepare("SELECT * FROM products WHERE id = ? FOR UPDATE");
$stmt->execute([$product_id]);
$product = $stmt->fetch();

if ($product['stock'] > 0) {
    $stmt = $pdo->prepare("UPDATE products SET stock = stock - 1 WHERE id = ?");
    $stmt->execute([$product_id]);
    $pdo->commit();
    echo "抢购成功！";
} else {
    $pdo->rollBack();
    echo "库存不足！";
}
```

> `FOR UPDATE` 是 MySQL 的行级锁，防止其他事务修改该行。

---

### 2. 性能瓶颈（缓存 + 队列）

PHP 处理高并发效率低，建议引入缓存（如 Redis）和异步队列（如 RabbitMQ、Kafka）。

#### 使用 Redis 缓存库存

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

$product_id = $_GET['product_id'];
$key = 'product:' . $product_id;

// 从 Redis 获取库存
$stock = $redis->get($key);

if ($stock > 0) {
    $redis->decr($key); // 库存减一
    // 将订单写入队列（异步处理）
    $queue = new Queue();
    $queue->push(['product_id' => $product_id, 'user_id' => 123]);
    echo "抢购成功！";
} else {
    echo "库存不足！";
}
```

#### 异步处理订单（后台 worker 消费队列）

可以用 Laravel 的 Queue、或者自己写个 PHP 脚本定时从 Redis 中消费任务，然后写入数据库。

---

## 四、进一步优化建议

| 优化点 | 说明 |
|--------|------|
| **Redis 缓存库存** | 高并发下减少对数据库的直接访问 |
| **分布式锁（Redis 分布式锁）** | 防止多实例下并发操作 |
| **限流机制** | 使用 Nginx 或 PHP 限制请求频率 |
| **预加载库存** | 在秒杀开始前将库存加载到 Redis |
| **前端控制** | 用 JavaScript 控制点击次数，避免重复提交 |

---

## 五、完整示例（简化版）

### 1. Redis 缓存库存 + PHP 扣减

```php
<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

$product_id = $_GET['product_id'];
$key = 'product:' . $product_id;

// 预加载库存（秒杀前）
$redis->set($key, 10);

$stock = $redis->get($key);

if ($stock > 0) {
    $redis->decr($key);
    echo "抢购成功！";
} else {
    echo "库存不足！";
}
?>
```

---

## 六、推荐架构（高并发场景）

```
[用户] --> [Nginx] --> [PHP 服务] --> [Redis] --> [消息队列] --> [DB]
```

- Nginx 做负载均衡和限流
- PHP 服务处理请求，Redis 管理库存
- 消息队列异步写入数据库，避免阻塞

---

## 七、总结

PHP 实现秒杀功能的关键在于：

- 使用 **Redis 缓存库存**
- 使用 **事务 + 行锁** 避免超卖
- 引入 **异步队列** 提升性能
- 做好 **限流、防刷、缓存预热**

如果你有具体的业务场景（比如商品数量、并发量、是否需要登录等），我可以帮你定制更详细的方案。

需要我提供完整的项目结构或 Laravel/ThinkPHP 的实现吗？