PHP는 Redis 메시지 구독의 지속적인 모니터링 및 처리를 어떻게 구현합니까?

$ pecl install redis

<?php
    // 引入Redis扩展
    extension_loaded('redis') || dl('redis.so');
?>

<?php
    // 连接Redis服务器
    $redis = new Redis();
    $redis->connect('127.0.0.1', 6379);

    // 订阅频道
    $redis->subscribe(['channel'], function ($redis, $channel, $message) {
        // 处理消息
        echo "收到来自频道 {$channel} 的消息：{$message}
";

        // 当收到"quit"消息时结束订阅
        if ($message == 'quit') {
            $redis->unsubscribe();
        }
    });

    // 关闭连接
    $redis->close();
?>

$redis->subscribe(['channel1', 'channel2'], function ($redis, $channel, $message) {
    // 处理消息
});

<?php
    // 创建子进程
    $pid = pcntl_fork();

    if ($pid == -1) {
        // 创建失败
        die('Fork failed');
    } elseif ($pid == 0) {
        // 子进程
        $redis = new Redis();
        $redis->connect('127.0.0.1', 6379);

        $redis->subscribe(['channel'], function ($redis, $channel, $message) {
            // 处理消息
            echo "子进程收到来自频道 {$channel} 的消息：{$message}
";

            // 当收到"quit"消息时结束订阅
            if ($message == 'quit') {
                $redis->unsubscribe();
            }
        });

        $redis->close();
    } else {
        // 父进程
        pcntl_waitpid($pid, $status);
    }
?>