PHP 实现 redis 分布式锁

分布式锁

如果是强一致性保证，在获取锁或者失败后引入数据库存储扫表、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] thenreturn redis.call("del", KEYS[1])elsereturn 0end';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-分布式加锁/)