php如何使用Redis实现分布式锁 php Redis分布式锁实现方案

SET

NX

EX

SET key value NX EX seconds

key

value

NX

key

EX seconds

<?php

class RedisDistributedLock
{
    private $redis;
    private $lockPrefix = 'lock:';

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

    /**
     * 尝试获取分布式锁
     * @param string $resourceName 资源名称，例如 'product_stock_update'
     * @param int $expireSeconds 锁的过期时间（秒），防止死锁
     * @param int $timeout 获取锁的等待时间（毫秒），0表示非阻塞
     * @return string|false 成功获取锁时返回唯一的锁值，否则返回false
     */
    public function acquire(string $resourceName, int $expireSeconds = 30, int $timeout = 0)
    {
        $lockKey = $this->lockPrefix . $resourceName;
        $lockValue = uniqid('', true) . mt_rand(100000, 999999); // 生成一个足够独特的锁值

        $startTime = microtime(true);
        do {
            // 使用 SET NX EX 命令原子性地获取锁
            $acquired = $this->redis->set($lockKey, $lockValue, ['NX', 'EX' => $expireSeconds]);

            if ($acquired) {
                return $lockValue; // 成功获取锁
            }

            // 如果设置了等待超时，则等待一段时间再重试
            if ($timeout > 0) {
                usleep(50 * 1000); // 等待50毫秒
            }
        } while ($timeout > 0 && (microtime(true) - $startTime) * 1000 < $timeout);

        return false; // 获取锁失败
    }

    /**
     * 释放分布式锁
     * @param string $resourceName 资源名称
     * @param string $lockValue 之前获取锁时返回的唯一锁值
     * @return bool 成功释放锁返回true，否则返回false
     */
    public function release(string $resourceName, string $lockValue): bool
    {
        $lockKey = $this->lockPrefix . $resourceName;

        // 使用Lua脚本原子性地检查并删除锁，防止误删
        $luaScript = <<<LUA
            if redis.call("get", KEYS[1]) == ARGV[1] then
                return redis.call("del", KEYS[1])
            else
                return 0
            end
        LUA;

        // eval方法执行Lua脚本，KEYS数组和ARGV数组是传递给脚本的参数
        $result = $this->redis->eval($luaScript, [$lockKey, $lockValue], 1);

        return (bool)$result;
    }

    // 实际使用示例：
    /*
    $redisClient = new Redis();
    $redisClient->connect('127.0.0.1', 6379);

    $lockManager = new RedisDistributedLock($redisClient);
    $resource = 'order_processing_123';
    $lockValue = $lockManager->acquire($resource, 60, 5000); // 尝试获取锁，最长等待5秒，锁过期时间60秒

    if ($lockValue) {
        echo "成功获取到锁：{$lockValue}\n";
        try {
            // 执行需要同步的关键业务逻辑
            echo "正在处理订单...\n";
            sleep(rand(1, 5)); // 模拟业务处理时间
            echo "订单处理完成。\n";
        } finally {
            // 确保锁最终被释放
            if ($lockManager->release($resource, $lockValue)) {
                echo "锁已成功释放。\n";
            } else {
                echo "锁释放失败或已被其他进程释放/过期。\n";
            }
        }
    } else {
        echo "未能获取到锁，资源正在被占用。\n";
    }
    */
}

RedisDistributedLock

acquire

uniqid('', true) . mt_rand(...)

release

GET

DEL

GET

SET key value NX EX seconds

true

value

value

DEL

EX seconds