PHP实现Redis分布式锁的示例代码

<?php

class RedisLock
{
    private $redis;
    private $lockKey;

    public function __construct($lockKey)
    {
        $this->redis = new Redis();
        $this->redis->connect('127.0.0.1', 6379);
        $this->lockKey = $lockKey;
    }

    public function acquireLock()
    {
        // 设置锁的超时时间，防止死锁
        $expire = 10;
        // 生成一个唯一的标识符
        $identifier = uniqid();

        while (!$this->redis->set($this->lockKey, $identifier, ['NX', 'EX' => $expire])) {
            // 如果设置失败，等待一段时间后重试
            usleep(1000);
        }

        return $identifier;
    }

    public function releaseLock($identifier)
    {
        // 释放锁，检查标识符是否匹配，确保只有持有锁的请求才能释放锁
        if ($this->redis->eval("if redis.call('get',KEYS[1]) == ARGV[1] then return redis.call('del',KEYS[1]) else return 0 end", [$this->lockKey, $identifier], 1)) {
            return true;
        }

        return false;
    }
}

// 示例用法
$lock = new RedisLock('my_resource');

// 尝试获取锁
$identifier = $lock->acquireLock();

if ($identifier) {
    // 成功获取锁，执行需要同步的操作

    // 释放锁
    $lock->releaseLock($identifier);
} else {
    // 获取锁失败，处理冲突或重试逻辑
    echo "Failed to acquire lock\n";
}