使用jetcd-core获取etcd下的文件目录

使用jetcd-core可以通过以下步骤获取etcd下的文件目录：

1. 创建EtcdClient对象，连接到etcd服务器：

EtcdClient etcdClient = new EtcdClient(URI.create("http://localhost:2379"));

2. 使用get方法获取指定key的值，设置withPrefix参数为true可以获取该key的所有子节点：

CompletableFuture<GetResponse> getFuture = etcdClient.get("key", GetOption.newBuilder().withPrefix(true).build());
GetResponse getResponse = getFuture.get();

3. 遍历getResponse.getKvs()，获取所有子节点的key和value：

for (KeyValue keyValue : getResponse.getKvs()) {
    String key = keyValue.getKey().toStringUtf8();
    String value = keyValue.getValue().toStringUtf8();
    System.out.println(key + " -> " + value);
}

完整代码示例：

import io.etcd.jetcd.ByteSequence;
import io.etcd.jetcd.Client;
import io.etcd.jetcd.KV;
import io.etcd.jetcd.KV.GetOption;
import io.etcd.jetcd.KV.GetResponse;
import io.etcd.jetcd.Lease;
import io.etcd.jetcd.LeaseGrantResponse;
import io.etcd.jetcd.Lock;
import io.etcd.jetcd.Txn;
import io.etcd.jetcd.Watch;
import io.etcd.jetcd.auth.Auth;
import io.etcd.jetcd.auth.Permission;
import io.etcd.jetcd.auth.Role;
import io.etcd.jetcd.auth.User;
import io.etcd.jetcd.cluster.Cluster;
import io.etcd.jetcd.launcher.EtcdCluster;
import io.etcd.jetcd.launcher.EtcdClusterFactory;
import io.etcd.jetcd.launcher.EtcdClusterSpec;
import io.etcd.jetcd.lock.LockResponse;
import io.etcd.jetcd.options.PutOption;
import io.etcd.jetcd.support.CloseableClient;
import io.etcd.jetcd.support.Scheduler;
import io.etcd.jetcd.support.Schedulers;
import io.etcd.jetcd.watch.WatchEvent;
import io.etcd.jetcd.watch.WatchResponse;

import java.net.URI;
import java.util.concurrent.CompletableFuture;

public class EtcdExample {

    public static void main(String[] args) throws Exception {
        // 创建EtcdClient对象，连接到etcd服务器
        EtcdClient etcdClient = new EtcdClient(URI.create("http://localhost:2379"));

        // 使用get方法获取指定key的值，设置withPrefix参数为true可以获取该key的所有子节点
        CompletableFuture<GetResponse> getFuture = etcdClient.get("key", GetOption.newBuilder().withPrefix(true).build());
        GetResponse getResponse = getFuture.get();

        // 遍历getResponse.getKvs()，获取所有子节点的key和value
        for (KeyValue keyValue : getResponse.getKvs()) {
            String key = keyValue.getKey().toStringUtf8();
            String value = keyValue.getValue().toStringUtf8();
            System.out.println(key + " -> " + value);
        }

        // 关闭EtcdClient对象
        etcdClient.close();
    }
}