subscribe.php

<?php
ini_set('default_socket_timeout', -1);  // 方式一：php配置设置不超时
$redis = new Redis();
$redis->connect("127.0.0.1",6379);
//$redis->setOption(Redis::OPT_READ_TIMEOUT, -1); //方式二：redis方式设置不超时，推荐

// 此方法将会挂起程序
$redis->subscribe(['chan-1', 'chan-2'], 'task');  // 第一个参数为订阅哪个频道，第二个参数为响应回调函数名称

// 回调函数,这里写处理逻辑
function task($instance, $channelName, $message)
{
    $newredis = new Redis();
    $newredis->connect("127.0.0.1", 6379);
    echo $newredis->get('key_1') . PHP_EOL; // 也可操作操作redis
    $newredis->close();
    switch($channelName) {
         case 'chan-1':
            var_dump('chan-1'.$message);
            break;
         case 'chan-2':
            var_dump('chan-2'.$message);
            break;
    }
}

publish.php

<?php
$redis = new Redis();
$redis->connect("127.0.0.1",6379);

$redis->publish('chan-2','this is a message by chan2');
$redis->publish('chan-1','this is a message by chan1');

运行测试即可

与专门的订阅系统对比

和RabbitMQ比一比