PHP实现Redis分布式锁的正确方式：Lua原子性释放

花开有时

发布时间：2026-10-13 | 4人浏览过

原创

在分布式系统和高并发场景下，共享资源的安全访问至关重要。简单的加锁机制容易导致数据不一致或死锁。本文演示如何使用PHP结合Redis的SETNX、EXPIRE以及Lua脚本来实现具备原子性和安全性的分布式锁，确保同一时刻仅有一个请求能执行关键操作。

为什么需要分布式锁

在高并发环境下，多个请求可能同时到达并试图修改同一资源（如库存扣减、计数器等）。如果没有适当的互斥控制，会导致覆盖写入、数据丢失或不一致。分布式锁通过在关键代码段前“申请锁”，确保同一时刻只有一个请求能够执行写入或修改操作，其他请求则需要等待或重试。

Redis分布式锁简介

Redis提供了一种简单而高效的分布式锁机制，核心依赖于两个命令：

SETNX（Set if Not eXists）：仅在键不存在时设置值。这用于判断当前锁是否已被占用。
EXPIRE：设置键的过期时间，防止持有锁的服务宕机后导致锁永远无法释放（死锁）。

然而，仅使用SETNX和EXPIRE存在风险：如果设置过期时间的命令在执行前服务崩溃，锁将永远存在。此外，直接删除锁可能导致释放了不属于当前请求的锁（例如A获取锁后执行超时，B获取了同一个锁并执行完毕，此时A醒来删除了B的锁）。

第1步：构建基础的Redis连接

首先，初始化Redis客户端并建立连接。为了便于测试和管理，通常建议配置独立的锁Key前缀。

<?php
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
// 建议使用唯一的Key前缀避免冲突
$lockKey = 'my_resource_lock';

第2步：获取锁（Acquire Lock）

获取锁时，必须生成一个全局唯一的标识符（Identifier），通常是UUID或随机字符串。该标识符将用于后续验证所有权并释放锁。使用SET key value NX EX seconds组合命令可以一次性完成“检查是否存在”和“设置过期时间”，保证操作的原子性。

第3步：安全释放锁（Release Lock with Lua）

这是最关键的一步。为了防止误删，释放锁的逻辑必须是：先获取当前值，判断是否等于我们持有的标识符，如果相等则删除。为了保证这两步操作的原子性，必须使用Lua脚本。

<?php
class RedisLock
{
    private $redis;
    private $lockKey;

    public function __construct($redis, $lockKey)
    {
        $this->redis = $redis;
        $this->lockKey = $lockKey;
    }

    // 尝试获取锁，最大等待时间（秒）
    public function acquireLock(int $maxWaitTime = 10, int $expireSeconds = 10): ?string
    {
        $identifier = uniqid(mt_rand(), true); // 生成唯一标识
        $acquired = false;
        $startTime = microtime(true);

        while (!microtime(true) - $startTime > $maxWaitTime) {
            // SET key identifier NX EX expireSeconds
            // NX: 键不存在才设置, EX: 指定过期时间(秒)
            $result = $this->redis->set($this->lockKey, $identifier, ['NX', 'EX' => $expireSeconds]);

            if ($result) {
                $acquired = true;
                break;
            }
            
            // 短暂休眠后重试，避免频繁查询
            usleep(100000); // 0.1秒
        }

        return $acquired ? $identifier : null;
    }

    // 释放锁
    public function releaseLock(string $identifier): bool
    {
        // 使用Lua脚本保证原子性：只有当value匹配时才删除
        $luaScript = '
            if redis.call("get", KEYS[1]) == ARGV[1] then
                return redis.call("del", KEYS[1])
            else
                return 0
            end
        ';

        // 参数: 脚本内容, key数量, key名, 标识符
        $result = $this->redis->eval($luaScript, [$this->lockKey, $identifier], 1);

        return $result === 1;
    }
}

// 使用示例
$lock = new RedisLock($redis, 'order_count');
$identifier = $lock->acquireLock();

if ($identifier !== null) {
    try {
        // 执行业务逻辑...
        echo "Processing order...\n";
    } finally {
        // 无论成功与否，最终都需要释放锁
        $lock->releaseLock($identifier);
    }
} else {
    echo "Failed to acquire lock within timeout.\n";
}

参考Hyperf框架中的实现策略

在实际生产环境中，直接使用上述基础类往往不够健壮。许多现代PHP框架（如Hyperf）对分布式锁进行了更完善的封装，主要考虑以下几点：

重试机制与指数退避：不仅等待固定时间，而是根据等待次数增加休眠间隔，减少服务器压力。
看门狗机制（Watchdog）：如果业务逻辑执行时间超过锁的过期时间，后台线程会自动延长锁的有效期，直到任务完成。
红锁算法（RedLock）：针对单点故障风险，可以在多个独立的Redis实例上分别加锁，只有多数派成功才算加锁成功（注：RedLock存在争议，视具体架构而定）。

Hyperf等框架提供了可插拔的锁驱动，允许开发者根据实际需求选择轻量级实现或高级容错实现。