PHP调用ETCD集群gRPC双向流Watch时节点宕机失效问题咨询

实际确实不会自动持续工作——PHP的ETCD gRPC客户端默认没有内置集群节点故障转移的重连逻辑，原因和解决方法如下：

核心原因 #

• gRPC双向流是与单个ETCD节点建立的长连接，当该节点宕机，当前的BiDiStreamingCall流会直接中断，客户端不会自动切换到集群内其他可用节点重建连接。
• 官方或常用的ETCD PHP gRPC客户端（如etcd-php/etcd）并未为Watch流实现集群级的故障转移机制，所有节点切换、重连逻辑需要开发者自行处理。

解决方案 #

你需要手动捕获read()抛出的异常，实现重连逻辑，具体要点：

• 捕获Grpc\Exception\RpcException这类流中断异常，触发重连流程
• 维护ETCD集群节点列表，重连时轮询或选择下一个可用节点
• 恢复Watch时，通过prev_kv或指定start_revision，从上次处理的位置继续监听，避免丢失事件
• 添加指数退避重试，防止频繁重试给集群带来额外压力

简化示例代码 #

function watchEtcdKeys(array $etcdNodes, string $keyPrefix) {
    $nodeCount = count($etcdNodes);
    $currentNodeIdx = 0;
    $retryCount = 0;
    $lastProcessedRevision = 0;

    while (true) {
        try {
            // 选择当前要连接的节点
            $nodeAddr = $etcdNodes[$currentNodeIdx];
            $client = new \Etcd\WatchClient($nodeAddr, [
                'credentials' => \Grpc\ChannelCredentials::createInsecure()
            ]);
            
            $call = $client->Watch();
            $createReq = new \Etcd\WatchCreateRequest();
            $createReq->setKey(grpc_encode_string($keyPrefix));
            $createReq->setRangeEnd(grpc_encode_string($keyPrefix . "\0")); // 前缀范围匹配
            
            // 如果有上次处理的revision，从该位置开始监听
            if ($lastProcessedRevision > 0) {
                $createReq->setStartRevision($lastProcessedRevision);
            }
            
            $call->write($createReq);
            
            // 循环读取事件
            while ($response = $call->read()) {
                $retryCount = 0; // 重置重试计数
                foreach ($response->getEvents() as $event) {
                    // 处理事件逻辑
                    $lastProcessedRevision = $event->getKv()->getModRevision();
                }
            }
        } catch (\Grpc\Exception\RpcException $e) {
            // 切换到下一个节点
            $currentNodeIdx = ($currentNodeIdx + 1) % $nodeCount;
            // 指数退避等待，最多等32秒
            $waitTime = pow(2, min(5, $retryCount));
            sleep($waitTime);
            $retryCount++;
        }
    }
}

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