使用jetcd构建客户端时无法检测etcd未运行，该如何实现检测？

使用jetcd（etcd的Java客户端）时，etcd正常运行时可正常建立客户端并执行put/get操作，但etcd未运行时，调用Client.builder().endpoints(connections).build()仍能获取到有效的客户端实例，不会抛出异常。希望在构建客户端阶段就检测etcd是否可用，以便做日志记录或等待重连，目前只能通过执行put/get操作触发异常，想找更优方案。

当前代码：

import io.etcd.jetcd.Client;
// ...
String[] connections = {"http://etcd-1:2379", "http://etcd-2:2379", "http://etcd3:2379"};
Client client = Client.builder().endpoints(connections).build();
log.debug("client: {}", client);

jetcd的客户端构建采用懒加载模式，build()方法不会立即建立与etcd的连接，因此不会直接抛出异常。以下是几种更优的检测方案：

1. 主动触发轻量级集群查询 #

利用jetcd的ClusterClient执行获取成员列表的操作，该操作会触发实际的连接尝试，且不会修改集群数据，适合作为初始化检测：

import io.etcd.jetcd.Cluster;
import io.etcd.jetcd.cluster.MemberListResponse;
import java.util.concurrent.TimeUnit;

// 构建客户端后立即执行检测
Cluster clusterClient = client.getClusterClient();
try {
    // 同步调用并设置超时时间，避免无限等待
    MemberListResponse response = clusterClient.listMembers().get(5, TimeUnit.SECONDS);
    log.info("etcd集群连接正常，成员数量: {}", response.getMembers().size());
} catch (Exception e) {
    log.error("etcd集群不可达，初始化检测失败", e);
    // 此处可添加重试、等待或降级逻辑
    throw new RuntimeException("etcd客户端初始化失败", e);
}

2. 配置超时并监听连接状态 #

通过配置连接超时参数，结合ConnectionManager监听连接状态变化，既能在初始化时检测可用性，也能实时感知集群连接变化：

import io.etcd.jetcd.Client;
import io.etcd.jetcd.common.exception.EtcdException;
import io.etcd.jetcd.support.ConnectionManager;
import java.time.Duration;

// 构建客户端时设置连接超时
Client client = Client.builder()
        .endpoints(connections)
        .connectTimeout(Duration.ofSeconds(5))
        .build();

// 获取连接管理器并添加状态监听
ConnectionManager connectionManager = client.getConnectionManager();
connectionManager.addListener(new ConnectionManager.Listener() {
    @Override
    public void onConnect(String endpoint) {
        log.info("成功连接至etcd节点: {}", endpoint);
    }

    @Override
    public void onDisconnect(String endpoint, Throwable cause) {
        log.error("与etcd节点断开连接: {}", endpoint, cause);
    }

    @Override
    public void onError(String endpoint, EtcdException exception) {
        log.error("etcd节点连接出错: {}", endpoint, exception);
    }
});

// 初始连接检测
if (!connectionManager.isConnected()) {
    log.warn("etcd集群当前未连接，等待重连...");
    // 可添加循环等待逻辑，直到连接成功或触发超时
}

3. 预检测etcd健康接口 #

在构建jetcd客户端前，直接调用etcd的/healthHTTP接口做健康检查，无需依赖jetcd客户端即可判断集群可用性：

import java.net.URI;
import java.net.http.HttpClient;
import java.net.http.HttpRequest;
import java.net.http.HttpResponse;
import java.time.Duration;

boolean isClusterAvailable = false;
HttpClient httpClient = HttpClient.newHttpClient();

for (String endpoint : connections) {
    try {
        URI healthUri = URI.create(endpoint + "/health");
        HttpRequest request = HttpRequest.newBuilder(healthUri)
                .timeout(Duration.ofSeconds(3))
                .GET()
                .build();
        HttpResponse<String> response = httpClient.send(request, HttpResponse.BodyHandlers.ofString());
        
        if (response.statusCode() == 200) {
            isClusterAvailable = true;
            log.info("etcd节点 {} 健康状态正常", endpoint);
            break;
        }
    } catch (Exception e) {
        log.warn("etcd节点 {} 健康检查失败", endpoint, e);
    }
}

if (!isClusterAvailable) {
    log.error("所有etcd节点均不可达");
    // 执行错误处理逻辑，比如终止初始化或进入重试流程
} else {
    // 健康检查通过后再构建客户端
    Client client = Client.builder().endpoints(connections).build();
}

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