如何使用PHP和Redis实现分布式锁和队列

class RedisLock {
    private $redis;
    private $key;
    private $lock_timeout = 10; //秒

    public function __construct($key) {
        $this->redis = new Redis();
        $this->redis->connect('localhost', 6379); //连接redis
        $this->key = $key;
    }

    public function __destruct() {
        $this->redis->close(); //关闭redis连接
    }

    public function lock() {
        $result = $this->redis->set($this->key, 1, ['NX', 'EX' => $this->lock_timeout]);
        return $result;
    }

    public function unlock() {
        $this->redis->del($this->key);
    }

}

$lock = new RedisLock('test_lock');
if ($lock->lock()) {
    //成功获取锁
    //对资源进行操作
    $lock->unlock();
} else {
    //获取锁失败
}

class RedisQueue {
    private $redis;
    private $key;

    public function __construct($key) {
        $this->redis = new Redis();
        $this->redis->connect('localhost', 6379); //连接Redis
        $this->key = $key;
    }

    public function __destruct() {
        $this->redis->close(); //关闭Redis连接
    }

    public function push($value) {
        $this->redis->lPush($this->key, $value);
    }

    public function pop() {
        $value = $this->redis->rPop($this->key);
        if (!$value) {
            //队列为空
            return false;
        }
        return $value;
    }

}

$queue = new RedisQueue('test_queue');
$queue->push('task1');
$queue->push('task2');

$value = $queue->pop();
if ($value) {
    //处理任务$value
} else {
    //队列为空
}