分布式锁

如果是强一致性保证，在获取锁或者失败后引入数据库存储扫表、mq 等方式进行补偿

如果可以容忍少量异常就不需要考虑了

像这里的代码，没吃建立一个链接铺货，性能损耗时间延迟也是很大的，也可在一块代码中进行服务，这里是临时修复一个 bug，问题不大

基于 Redis 实现

// 加锁
function acquireLock($lockKey, $lockValue, $expireTime)
{
    return $this->getRedisConnection()->set($lockKey, $lockValue, array('nx', 'ex' => $expireTime));
}

// 释放锁
function releaseLock($lockKey, $lockValue) 
{
    // 使用 Lua 脚本原子性地释放锁
    $script = '
                if redis.call("get", KEYS[1]) == ARGV[1] then
                    return redis.call("del", KEYS[1])
                else
                    return 0
                end
            ';
    return $this->getRedisConnection()->eval($script, array($lockKey, $lockValue), 1);
}

// 重试加锁
function retryAcquireLock($lockKey, $lockValue, $expireTime, $maxRetries, $retryInterval)
{
    for ($i = 0; $i < $maxRetries; $i++) {
        if ($this->acquireLock($lockKey, $lockValue, $expireTime)) {
            return true;
        }
        sleep($retryInterval);
    }
    return false;
} 

使用示例

// 使用示例
$lockKey = 'my_lock_key'; // key 名称
$lockValue = uniqid(); // 值 保证不释放错
$expireTime = 10; // 总体过期时间
$maxRetries =  4; // 最大重试次数
$retryInterval = 2; // 重试间隔
// 重试间隔 * 次数 不能大于整体过期时间
if ($lockManager->retryAcquireLock($lockKey, $lockValue, $expireTime, $maxRetries, $retryInterval)) {
    echo "成功获取锁。\n";
    // 模拟临界区代码执行
    sleep(5);

    $lockManager->releaseLock($lockKey, $lockValue);
    echo "释放锁。\n";
} else {
    echo "无法获取锁。\n";
}

[PHP 实现 redis 分布式锁 |

    Laiyong Wang](http://laiyong.wang/2024/06/15/PHP-实现-redis-分布式加锁/)