demo

# 这里的代码和golang客户端基本是对齐的，java使用观察者模式进行数据的监听
KV kvClient = etcdClient.getKVClient();
Lease leaseClient = etcdClient.getLeaseClient();


// Generate a random value for the key
String value = GetIP.getAddress() + ":" + port;
log.info("pod ip: " + value);

// Create a new lease
long leaseId = leaseClient.grant(LEASE_TTL).get().getID();

// signhub.algorithm.{site_name}.{action}/{lease_id}
String[] joinKey = {"signhub", "algorithm", getGroup().toString().toLowerCase(), getAction().toString().toLowerCase()};
String registerKey = String.join(".", joinKey);
System.out.println(registerKey);
ByteSequence key = ByteSequence.from(registerKey + "/" + leaseId, StandardCharsets.UTF_8);
ByteSequence val = ByteSequence.from(value, StandardCharsets.UTF_8);
kvClient.put(key, val).get();

AtomicReference<io.etcd.jetcd.lease.LeaseKeepAliveResponse> resp = new AtomicReference<>();
AtomicReference<Throwable> error = new AtomicReference<>();

StreamObserver<io.etcd.jetcd.lease.LeaseKeepAliveResponse> observer = Observers.<LeaseKeepAliveResponse>builder()
        .onNext(resp::set)
        .onError(error::set)
        .build();

long leaseID = leaseClient.grant(5, 10, TimeUnit.SECONDS).get().getID();

kvClient.put(key, val, PutOption.newBuilder().withLeaseId(leaseID).build()).get();

leaseClient.keepAlive(leaseID, observer);

# etcd官方demo
https://github.com/etcd-io/jetcd/blob/main/jetcd-core/src/test/java/io/etcd/jetcd/impl/LeaseTest.java

# 文档
https://github.com/kekingcn/kkbinlog/blob/master/%E6%B5%85%E6%9E%90jetcd%E4%B8%AD%E7%9A%84KeepAlive%E5%AE%9E%E7%8E%B0.md