php使用redis锁

封面图 • 2025-11-04 • PHP

在 PHP 中使用 Redis 实现分布式锁是一种常见的做法，尤其是在多进程、多线程或微服务架构中，用来保证同一时间只有一个进程可以执行某个关键操作。

下面是使用 Redis 实现分布式锁的常见方法和示例代码。

---

## ✅ 一、Redis 分布式锁原理

Redis 的 `SET` 命令支持设置键值对，并且可以带超时时间（TTL），因此可以用它来实现一个简单的分布式锁。

### 使用 `SET key value [EX seconds] [NX]` 命令：

- `NX`：仅当 key 不存在时才设置。
- `EX seconds`：设置键的过期时间（秒）。

这样就可以确保只有第一个获取到锁的客户端才能执行任务，其他客户端会等待或失败。

---

## ✅ 二、PHP 使用 Redis 锁的示例

```php
<?php

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

// 定义锁的 key 和过期时间（单位：秒）
$lockKey = 'my_lock_key';
$expireTime = 10; // 锁的过期时间

// 尝试获取锁
$acquired = $redis->set($lockKey, 'locked', ['nx', 'ex' => $expireTime]);

if ($acquired) {
    echo "成功获取锁，开始执行任务...\n";

// 模拟任务执行
    sleep(5);

// 释放锁
    $redis->del($lockKey);
    echo "任务完成，已释放锁。\n";
} else {
    echo "未能获取锁，可能已被其他进程占用。\n";
}
```

---

## ✅ 三、注意事项

1. **锁的唯一性**：
   - 每个客户端应该使用唯一的标识（比如 UUID 或进程 ID）作为锁的值，以防止误删别人的锁。
   
   ```php
   $uniqueId = uniqid();
   $acquired = $redis->set($lockKey, $uniqueId, ['nx', 'ex' => $expireTime]);
   if ($acquired && $redis->get($lockKey) === $uniqueId) {
       // 执行任务
   }
   ```

2. **避免死锁**：
   - 设置合理的过期时间，防止因为程序异常导致锁无法释放。

3. **锁的释放**：
   - 必须确保只释放自己的锁，可以通过检查锁的值是否为当前客户端的标识来实现。

---

## ✅ 四、更高级的实现（使用 Lua 脚本）

为了保证原子性，推荐使用 Lua 脚本来进行锁的获取和释放，避免竞态条件。

### 获取锁的 Lua 脚本：

```lua
local key = KEYS[1]
local value = ARGV[1]
local expire = tonumber(ARGV[2])

if redis.call("SET", key, value, "NX", "EX", expire) then
    return 1
else
    return 0
end
```

### 释放锁的 Lua 脚本：

```lua
local key = KEYS[1]
local value = ARGV[1]

if redis.call("GET", key) == value then
    redis.call("DEL", key)
    return 1
else
    return 0
end
```

### 在 PHP 中调用 Lua 脚本：

```php
$luaScriptAcquire = <<<LUA
local key = KEYS[1]
local value = ARGV[1]
local expire = tonumber(ARGV[2])
if redis.call("SET", key, value, "NX", "EX", expire) then
    return 1
else
    return 0
end
LUA;

$luaScriptRelease = <<<LUA
local key = KEYS[1]
local value = ARGV[1]
if redis.call("GET", key) == value then
    redis.call("DEL", key)
    return 1
else
    return 0
end
LUA;

$uniqueId = uniqid();
$acquired = $redis->eval($luaScriptAcquire, [$lockKey, $uniqueId, $expireTime], 1);

if ($acquired) {
    // 执行任务...
    $redis->eval($luaScriptRelease, [$lockKey, $uniqueId], 1);
}
```

---

## ✅ 五、推荐库（可选）

如果你不想手动处理这些细节，可以使用一些封装好的 PHP Redis 锁库，例如：

- [predis/predis](https://github.com/nrk/predis)（推荐）
- [symfony/lock](https://symfony.com/doc/current/components/lock.html)

---

## ✅ 总结

| 功能 | 说明 |
|------|------|
| 获取锁 | 使用 `SET key value NX EX` |
| 释放锁 | 确保只释放自己的锁 |
| 避免死锁 | 设置合理超时时间 |
| 推荐方式 | 使用 Lua 脚本保证原子性 |

如需进一步优化，可以考虑使用 Redis 的 `RedLock` 算法，但一般情况下普通的 `SET NX EX` 已足够使用。

需要我帮你封装成类或者工具函数吗？