Laravel调用Redis subscribe方法出现127.0.0.1:6379连接读取错误

1. subscribe 为阻塞方法触发超时 #

• Redis的subscribe方法调用后，当前连接会进入订阅者阻塞模式，进程会持续挂起监听频道消息，不会继续向下执行后续的publish代码，也不会主动结束运行。
• PHP默认配置了socket读超时限制，当订阅阻塞时长超过default_socket_timeout或者Redis连接配置的read_timeout阈值后，连接会被主动断开，抛出你遇到的read error on connection报错。

2. 订阅/发布不能复用同一个连接 #

进入订阅者模式的连接只能执行订阅类命令（subscribe/psubscribe/unsubscribe/punsubscribe），无法执行publish等其他Redis命令，就算绕过超时限制，后续的发布逻辑也会执行失败。

拆分订阅发布逻辑 #

订阅逻辑需要单独放在常驻进程运行（比如单独写一个Artisan命令专门处理订阅监听），发布逻辑放在其他业务进程/其他请求中执行，二者不要共用同一个Redis连接。

调整超时适配长监听场景 #

如果需要长时间保持订阅连接，可以在订阅前修改读超时配置，禁用超时限制：

// 禁用当前Redis连接的读超时
$client->setOption(\Redis::OPT_READ_TIMEOUT, -1);

本地测试参考样例 #

如果要在同一个命令内测试pub/sub逻辑，可以通过多进程实现，避免阻塞：

public function callback(){
    print_r(func_get_args());
}

public function handle(): int
{
    // 单独初始化发布用的连接
    $publishClient = Redis::connection()->client();
    // 单独初始化订阅用的连接
    $subscribeClient = Redis::connection()->client();
    // 禁用订阅连接的读超时
    $subscribeClient->setOption(\Redis::OPT_READ_TIMEOUT, -1);

    if($subscribeClient->isConnected()){
        $this->line('Connected');
    }

    // 开启子进程执行发布逻辑
    $pid = pcntl_fork();
    if ($pid === 0) {
        // 等待1秒保证主进程先完成订阅动作
        sleep(1);
        $publishClient->publish('exchanges', json_encode($this->getExchanges()));
        exit(0);
    }

    // 主进程执行订阅监听
    $subscribeClient->subscribe(['exchanges'], [$this, 'callback']);
 
    return 0;
}

内容的提问来源于stack exchange，提问作者ymakux