如何无错误关闭处于观测状态的Jetcd Election客户端？

问题根源 #

抛出的io.etcd.jetcd.common.exception.EtcdException: Channel shutdownNow invoked异常，是因为调用client.close()时，Election.observe的流式观测请求仍在运行，客户端强制关闭gRPC通道会直接中断这个流，触发错误回调。当前的关闭顺序未先终止观测请求，导致异常触发。

正确的客户端关闭顺序 #

• 优先终止所有选举观测请求：Jetcd的observe方法在多数版本中会返回Closeable实例，关闭前需调用其close()方法终止观测流，这是避免异常的核心操作。如果维护了观测相关的订阅引用，需统一取消这些订阅。
• 异步等待Lease撤销完成：lease.revoke是异步操作，需等待其执行完成后再处理后续步骤，避免资源泄漏。
• 关闭LeaseKeepAliveClient：停止租约保活心跳，释放相关资源。
• 最后关闭Jetcd客户端：此时所有前置请求已终止，不会触发未处理的流异常。

调整后的示例代码 #

public void disconnect() {
    // 1. 终止所有election observe观测请求（需提前维护observe返回的Closeable引用）
    // electionObserveCloseable.close();

    // 2. 异步执行lease撤销，完成后再关闭后续资源
    this.lease.revoke(this.leaseId)
        .whenComplete((revokeResp, revokeErr) -> {
            // 3. 关闭租约保活客户端
            this.leaseKeepAliveClient.close();
            // 4. 关闭etcd客户端
            this.client.close();
        });
}

额外注意事项 #

• 如果observe未返回可关闭对象，可在Listener的onError方法中捕获Channel shutdownNow invoked异常，避免程序崩溃，但这属于兜底方案，优先保证先终止观测流再关闭客户端。
• 若业务不需要立即撤销lease，可跳过lease.revoke步骤，直接关闭保活客户端和etcd客户端，但需确保lease到期后自动释放资源。

内容的提问来源于stack exchange，提问作者Sefa Mert Kaya