PHP秒杀系统中的并发控制策略

<?php
$db = new PDO('mysql:host=localhost;dbname=test', 'root', '');

// 开始事务
$db->beginTransaction();

try {
    $stmt = $db->prepare('SELECT * FROM goods WHERE id = 1 FOR UPDATE');
    $stmt->execute();
    
    $result = $stmt->fetch(PDO::FETCH_ASSOC);
    
    if ($result['stock'] > 0) {
        $stmt = $db->prepare('UPDATE goods SET stock = stock - 1 WHERE id = 1');
        $stmt->execute();
        
        // 提交事务
        $db->commit();
        
        echo '秒杀成功！';
    } else {
        echo '商品已售罄！';
    }
} catch (Exception $e) {
    // 回滚事务
    $db->rollBack();
    
    echo '秒杀失败！';
}
?>

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

$stock = $redis->get('goods_stock');

if ($stock > 0) {
    $redis->multi();
    $redis->decr('goods_stock');
    $result = $redis->exec();
    
    if ($result) {
        echo '秒杀成功！';
    } else {
        echo '秒杀失败！';
    }
} else {
    echo '商品已售罄！';
}
?>