在高并发场景下，PHP可通过数据库行锁、唯一索引、Redis分布式锁和乐观锁防止重复操作。1. 使用SELECT ... FOR UPDATE在事务中对数据加排他锁，确保读写一致性；2. 利用数据库唯一索引约束，避免重复插入，如用户领取优惠券时通过(user_id, coupon_id)联合唯一键防止重复发放；3. 借助Redis的SET NX EX命令实现分布式锁，控制多实例间的互斥访问，并在finally块中释放锁；4. 采用乐观锁机制，通过版本号字段检查更新时数据是否被修改，提升读性能并减少阻塞。实际应用中常组合使用，如Redis锁限流+唯一索引兜底，以保障数据一致性和系统可靠性。
在高并发环境下，多个请求同时访问和操作同一数据时，容易出现重复读取或重复处理的问题。尤其是在订单创建、库存扣减、优惠券领取等场景中，若不加以控制，会导致数据不一致、超卖、重复发放等严重后果。PHP作为常用的后端语言，需要结合数据库机制与锁策略来有效防止重复读取。
1. 使用数据库行锁（FOR UPDATE）
在InnoDB存储引擎中，支持行级锁，可通过SELECT ... FOR UPDATE对查询的数据加排他锁，防止其他事务读取并修改。
适用场景：需要读取数据后立即进行更新操作，确保期间无其他事务干扰。
示例代码：
立即学习“PHP免费学习笔记（深入）”；
// 开启事务 mysqli_begin_transaction($connection);// 加锁读取库存 $sql = "SELECT stock FROM products WHERE id = ? FOR UPDATE"; $stmt = mysqli_prepare($connection, $sql); mysqli_stmt_bind_param($stmt, 'i', $product_id); mysqli_stmt_execute($stmt); $result = mysqli_stmt_get_result($stmt); $row = mysqli_fetch_assoc($result);
if ($row['stock'] > 0) { // 扣减库存 $update_sql = "UPDATE products SET stock = stock - 1 WHERE id = ?"; $update_stmt = mysqli_prepare($connection, $update_sql); mysqli_stmt_bind_param($update_stmt, 'i', $product_id); mysqli_stmt_execute($update_stmt); }
// 提交事务释放锁 mysqli_commit($connection);
注意：必须在事务中使用FOR UPDATE才生效，否则锁会立即释放。
2. 利用唯一索引防止重复插入
数据库层面设置唯一约束，是防止重复最直接有效的方式。
常见做法：在用户领取优惠券的表中，将(user_id, coupon_id)设为联合唯一索引。
当多个请求同时插入相同记录时，数据库会抛出唯一键冲突异常，程序捕获后可提示“已领取”而非重复发放。
优点：简单高效，无需复杂逻辑控制。
示例SQL：
ALTER TABLE user_coupon ADD UNIQUE KEY uk_user_coupon (user_id, coupon_id);
3. 使用Redis实现分布式锁
在多服务器部署的PHP应用中，本地锁无效，需借助Redis实现跨进程、跨机器的互斥访问。
核心思路：在操作关键数据前，先尝试获取Redis锁，成功则执行，失败则放弃或重试。
推荐使用SET key value NX EX命令实现原子性加锁：
- NX：仅当key不存在时设置
- EX：设置过期时间，防止死锁
PHP示例：
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$lock_key = "lock:coupon:" . $user_id;
$expire_time = 5; // 锁过期时间（秒）
// 尝试加锁
$is_lock = $redis->set($lock_key, 1, ['NX', 'EX' => $expire_time]);
if (!$is_lock) {
echo "操作过于频繁，请稍后再试";
exit;
}
try {
// 检查是否已领取（查库）
// 执行领取逻辑（写库）
} finally {
// 释放锁
$redis->del($lock_key);
}
注意：finally中释放锁，确保异常时也能清理资源。
4. 乐观锁机制（版本号控制）
适用于读多写少的场景，通过版本号或时间戳字段避免并发更新问题。
每次更新时检查版本是否变化，若被其他请求修改，则当前操作失败。
示例：
UPDATE products SET stock = stock - 1, version = version + 1 WHERE id = ? AND version = ?
PHP中判断影响行数：
$affected = mysqli_affected_rows($connection);
if ($affected == 0) {
// 更新失败，可能已被其他请求处理
echo "库存扣减失败，请重试";
}
优点：不阻塞读操作，性能好；缺点：需业务层处理失败重试逻辑。
基本上就这些方法，根据实际业务选择合适策略，通常组合使用效果更佳。比如先用Redis锁限制入口，再用数据库唯一索引兜底，能最大程度保障数据一致性。
