首页 > 编程语言 >Java中使用etcd,包括基本的set、get、超时设置,watch监听等

Java中使用etcd,包括基本的set、get、超时设置,watch监听等

时间:2023-02-05 22:01:14浏览次数:64  
标签:key set Java String get value etcd import public


etcd的使用文章。

etcd来zookeeper类似,常用的主要有set,get,getPrefix:获取指定前缀的所有数据,grant:key的超时设置,watch:监听回调事件,watchPrefix:监听某个前缀的事件,keepAlive:为某个key设置自动续约、自动刷新过期时间。

zk的大部分功能,etcd都有。但有一个,譬如虚拟节点,zk可以做到当客户端断开时,立马监听到,etcd要靠keepAlive续约机制,超过几秒不续约了,则认为掉线了。

还有etcd的超时时间,是需要先新建一个lease,再把这个lease在put时,作为参数传过去。

别的不多讲,直接上使用指南。

引入pom.xml,​​https://github.com/IBM/etcd-java​​  这是一个etcd的java客户端。

<dependency>
<groupId>com.ibm.etcd</groupId>
<artifactId>etcd-java</artifactId>
<version>0.0.13</version>
</dependency>

自行下载etcd,并启动它。

定义一个常用的客户端工具类的接口

import com.ibm.etcd.api.KeyValue;
import com.ibm.etcd.client.kv.KvClient;

import java.util.List;

/**
* @author wuweifeng wrote on 2019-12-09
* @version 1.0
*/
public interface IConfigCenter {
/**
* 存入key,value
*/
void put(String key, String value);

/**
* 存入key、value,和租约id
*/
void put(String key, String value, long leaseId);

/**
* 存入key、value,和过期时间,单位是秒
*/
void putAndGrant(String key, String value, long ttl);

/**
* 根据key,获取value
*/
String get(String key);

/**
* 获取指定前缀的所有key-value
*/
List<KeyValue> getPrefix(String key);

/**
* 监听key
*/
KvClient.WatchIterator watch(String key);

/**
* 监听前缀为key的
*/
KvClient.WatchIterator watchPrefix(String key);

/**
* 自动续约
* @param frequencySecs 续约频率,最小是4秒,默认是5秒
* @param minTtl 最小存活时间,最小是2秒,默认是10秒
* @return 返回leaseId
*/
long keepAlive(String key, String value, int frequencySecs, int minTtl) throws Exception;

/**
* 判断剩余的过期时间
*/
long timeToLive(long leaseId);
}

实现这个接口

import com.google.protobuf.ByteString;
import com.ibm.etcd.api.KeyValue;
import com.ibm.etcd.api.LeaseGrantResponse;
import com.ibm.etcd.api.RangeResponse;
import com.ibm.etcd.client.KvStoreClient;
import com.ibm.etcd.client.kv.KvClient;
import com.ibm.etcd.client.lease.LeaseClient;
import com.ibm.etcd.client.lease.PersistentLease;
import com.ibm.etcd.client.lock.LockClient;

import org.springframework.util.CollectionUtils;

import java.util.List;
import java.util.concurrent.ExecutionException;

import static java.util.concurrent.TimeUnit.SECONDS;

/**
* etcd客户端
*
* @author wuweifeng wrote on 2019-12-06
* @version 1.0
*/
public class JdEtcdClient implements IConfigCenter {

private KvClient kvClient;
private LeaseClient leaseClient;
private LockClient lockClient;

public JdEtcdClient(KvStoreClient kvStoreClient) {
this.kvClient = kvStoreClient.getKvClient();
this.leaseClient = kvStoreClient.getLeaseClient();
this.lockClient = kvStoreClient.getLockClient();
}

@Override
public void put(String key, String value) {
kvClient.put(ByteString.copyFromUtf8(key), ByteString.copyFromUtf8(value)).sync();
}

@Override
public void put(String key, String value, long leaseId) {
kvClient.put(ByteString.copyFromUtf8(key), ByteString.copyFromUtf8(value), leaseId).sync();
}

@Override
public void putAndGrant(String key, String value, long ttl) {
LeaseGrantResponse lease = leaseClient.grant(ttl).sync();
put(key, value, lease.getID());
}

@Override
public String get(String key) {
RangeResponse rangeResponse = kvClient.get(ByteString.copyFromUtf8(key)).sync();
List<KeyValue> keyValues = rangeResponse.getKvsList();
if (CollectionUtils.isEmpty(keyValues)) {
return null;
}
return keyValues.get(0).getValue().toStringUtf8();
}

@Override
public List<KeyValue> getPrefix(String key) {
RangeResponse rangeResponse = kvClient.get(ByteString.copyFromUtf8(key)).asPrefix().sync();
return rangeResponse.getKvsList();
}

@Override
public KvClient.WatchIterator watch(String key) {
return kvClient.watch(ByteString.copyFromUtf8(key)).start();
}

@Override
public KvClient.WatchIterator watchPrefix(String key) {
return kvClient.watch(ByteString.copyFromUtf8(key)).asPrefix().start();
}

@Override
public long keepAlive(String key, String value, int frequencySecs, int minTtl) throws Exception {
//minTtl秒租期,每frequencySecs秒续约一下
PersistentLease lease = leaseClient.maintain().leaseId(SystemClock.now()).keepAliveFreq(frequencySecs).minTtl(minTtl).start();
long newId = lease.get(3L, SECONDS);
put(key, value, newId);
return newId;
}

@Override
public long timeToLive(long leaseId) {
try {
return leaseClient.ttl(leaseId).get().getTTL();
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
return 0L;
}
}
}

其中的SystemClock类,就在网上找一下吧,就是一个获取系统当前时间戳的工具类。

创建这个Client

/**
* @param endPoints 如https://127.0.0.1:2379 有多个时逗号分隔
*/
public static JdEtcdClient build(String endPoints) {
return new JdEtcdClient(EtcdClient.forEndpoints(endPoints).withPlainText().build());
}

之后就可以使用这个etcd客户端工具类了。

Java中使用etcd,包括基本的set、get、超时设置,watch监听等_ide

 

 

 

标签:key,set,Java,String,get,value,etcd,import,public
From: https://blog.51cto.com/u_13706148/6038489

相关文章

  • DaemonSet方式部署nginx-ingress
    前言nginx-ingress是k8s官方维护的一个IngressController,具体使用,官方有详细的文档:https://kubernetes.github.io/ingress-nginx/deploy/直接按照官方文档进行安装,一般......
  • Java JDK1.5: 泛型 新特性的讲解说明
    JavaJDK1.5:泛型新特性的讲解说明每博一文案听到过这样一句话:“三观没有标准。在乌鸦的世界里,天鹅也有罪。”环境、阅历的不同,造就了每个人独有的世界观、人生观、价......
  • vue项目中图片放在public?还是assets?
    首先,要知道,public的资源要用绝对路径/访问,打包时不会被编译,所以我们可以随时替换;assets的资源要用相对路径./访问,打包时会被编译,所以打包之后我们不能替换;所以,使用随时要......
  • 看一遍就懂,详解java多线程——volatile
    多线程一直以来都是面试必考点,而volatile、synchronized也是必问点,这里我试图用容易理解的方式来解释一下volatile。来看一下它的最大特点和作用:一使变量在多个线程间可见......
  • Java简单实现滑动窗口
    由于最近有一个统计单位时间内某key的访问次数的需求,譬如每5秒访问了redis的某key超过100次,就取出该key单独处理。这样的单位时间统计,很明显我们都知道有个边界问题,譬如5秒......
  • JavaScript学习笔记—DOM:操作class
    element.classList是一个对象,对象中提供了对当前元素的类的各种操作方法element.classList.add()向元素中添加一个或多个classelement.classList.remove()移除元素中......
  • 我的Java设计模式-责任链模式
    今天来说说程序员小猿和产品就关于需求发生的故事。前不久,小猿收到了产品的需求。产品经理:小猿,为了迎合大众屌丝用户的口味,我们要放一张图,要露点的。小猿:......露点?你大......
  • 【JavaScript】3_深挖数据类型
    4、其他的数据类型布尔值(Boolean)-布尔值主要用来进行逻辑判断-布尔值只有两个true和false-使用typeof检查......
  • PHP中 empty() 和 isset() 的区别介绍
    目录二者共同点二者区别1、对于未设置的变量的判断2、对于""(空字符串)的判断3、对于0(作为整数的0)的判断4、对于0.0(作为浮点数的0)的判断5、对于"0"......
  • 面试题-java
    目录基础概念什么是java?什么是面向对象?java三大特性this,super关键字抽象类、接口抽象类abstract接口共同点区别抽象类能使用final修饰吗?==和equalsfinal关键字数据类型字......