基于PHP+Redis实现分布式锁

轻心小站关注 LV.19 运营

发表于php技术学习版块教程

在分布式系统中，为了保证操作的原子性，我们通常会使用分布式锁。Redis是一个高性能的键值存储系统，它支持多种数据结构，非常适合用来实现分布式锁。以下是使用PHP和Redis实现分布式锁的基本步骤：1

在分布式系统中，为了保证操作的原子性，我们通常会使用分布式锁。Redis是一个高性能的键值存储系统，它支持多种数据结构，非常适合用来实现分布式锁。以下是使用PHP和Redis实现分布式锁的基本步骤：

1. 安装和配置Redis

确保你的系统上安装了Redis，并且PHP可以连接到Redis服务器。在php.ini中启用Redis扩展，或者使用 predis 这样的PHP Redis客户端库。

2. 设置锁的键名

定义一个锁的键名，这个键名应该是唯一的，以避免与其它锁冲突。例如，如果你的锁是为了保护某个特定的资源，可以将资源的ID作为键名的一部分。

$lockKey = 'distributed_lock:' . $resourceId;

3. 获取锁

使用Redis的SET命令结合NX（如果不存在则设置）和PX（设置键的过期时间）选项来尝试获取锁。

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

// 尝试获取锁，如果锁不存在则设置锁，并设置过期时间为30秒
$lockAcquired = $redis->set($lockKey, 'locked', Redis::OPT_NX, Redis::OPT_EX(30));

if ($lockAcquired) {
    // 锁获取成功，执行业务逻辑
    // ...
    // 释放锁
    $redis->del($lockKey);
} else {
    // 锁获取失败，处理错误或者等待
}

4. 释放锁

业务逻辑执行完毕后，使用DEL命令删除锁键，释放锁。

$redis->del($lockKey);

5. 锁的续期

如果业务逻辑执行时间可能会超过锁的过期时间，你需要在业务逻辑执行期间定期续期锁。

// 尝试获取锁后，如果成功，定期续期
while ($redis->ttl($lockKey) < 0) {
    $redis->expire($lockKey, 30); // 续期30秒
}

6. 错误处理

在尝试获取锁的过程中，如果发现锁已经被其他进程持有，你需要决定是立即返回错误，还是等待一段时间后重试。

// 等待直到获取锁
do {
    usleep(100000); // 等待100毫秒
    $lockAcquired = $redis->set($lockKey, 'locked', Redis::OPT_NX, Redis::OPT_EX(30));
} while (!$lockAcquired);