etcd: java连接

悠悠 2022-11-15 05:58 165阅读 0赞

1.修改pom.xml

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

2.代码

package cisdi.cisdidatatransfer.service;
    
    
    
    import com.google.common.util.concurrent.ListenableFuture;
    import com.google.protobuf.ByteString;
    import com.ibm.etcd.api.KeyValue;
    import com.ibm.etcd.api.RangeResponse;
    import com.ibm.etcd.client.EtcdClient;
    import com.ibm.etcd.client.KvStoreClient;
    import com.ibm.etcd.client.kv.KvClient;
    import org.springframework.stereotype.Service;
    import org.w3c.dom.ranges.Range;
    
    import java.util.List;
    
    @Service
    public class EtcdService {
    
        private static String connectionString="81.70.228.185";
        public KvClient getEtcdClient(){
    
            KvStoreClient client = EtcdClient.forEndpoint(connectionString, 2379).withPlainText().build();
            KvClient kvClient = client.getKvClient();
            return kvClient;
        }
       
        public int getNumberOfLocalSasacIndex(){
            int numberOfLocalSasacIndex=0;
            KvClient kvClient=getEtcdClient();
            ByteString bs=ByteString.copyFrom("numberOfLocal".getBytes());
            ListenableFuture<RangeResponse> result = kvClient.get(bs).timeout(5000).async();
            RangeResponse rangeResponse=null;
            try {
                rangeResponse = result.get();
            }catch (Exception ex){
            	System.out.println(ex.getMessage());
                return 0;
    
            }
            List<KeyValue> lst=rangeResponse.getKvsList();
            for(KeyValue kv: lst) {
                ByteString numberOfLocalSasacIndexString=kv.getValue();
                numberOfLocalSasacIndex=Integer.parseInt(numberOfLocalSasacIndexString.toStringUtf8());
            }
            return numberOfLocalSasacIndex;
        }
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，165人围观）

还没有评论，来说两句吧...

相关阅读

相关 etcd 入门

目录 1.基本功能 2.安装与配置下载解压缩启动etcd服务 3.使用查看版本号

Love The Way You Lie/ 2022年12月13日 11:19/ 0 赞/ 406 阅读

相关 etcd 服务

在应用中ETCD做以下几个方面的功能：服务发现，配置分发，core↔burner心跳，多core选主(cluster实现）。一、etcd 服务发现 ice

Myth丶恋晨/ 2022年11月29日 00:55/ 0 赞/ 328 阅读

相关 etcd: java连接

1.修改pom.xml <dependency> <groupId>com.ibm.etcd</groupId> <artifactI

悠悠/ 2022年11月15日 05:58/ 0 赞/ 166 阅读

相关 Etcd: 设置远程连接

1.下载etcd3.4 2.带配置文件启动etcd : nohup ./etcd --config-file=etcd.conf & 配置文件内容： \{“

淡淡的烟草味﹌/ 2022年11月15日 05:55/ 0 赞/ 627 阅读

相关 Etcd介绍

一、Etcd是什么（what）（一）概述 etcd is a distributed, consistent key-value store for shared

布满荆棘的人生/ 2022年06月13日 11:23/ 0 赞/ 325 阅读

相关 etcd 原理

etcd 原理数据模型 etcd设计是可靠地存储经常更新的数据提供可靠的表的查询。etcd将键值对以前版本支持廉价的快照和监控历史事件（”time travel

朴灿烈づ我的快乐病毒、/ 2022年06月03日 05:50/ 0 赞/ 327 阅读

相关剖析etcd

![70][] ![70 1][] ![70 2][] ![70 3][] ![70 4][] ![70 5][] ![70 6][]

川长思鸟来/ 2022年05月23日 07:54/ 0 赞/ 274 阅读

相关 etcd网络层(六)——模拟etcd网络层的stream通道维护长连接

代码如下： package main import ( "io" "log" "net" "fmt"

- 日理万妓/ 2021年12月20日 13:05/ 0 赞/ 249 阅读

相关 ETCD 简介

随着CoreOS和Kubernetes等项目在开源社区日益火热，它们项目中都用到的etcd组件作为一个高可用强一致性的服务发现存储仓库，渐渐为开发人员所关注。在云计

ゝ一世哀愁。/ 2021年12月10日 03:29/ 0 赞/ 397 阅读

相关 etcd sh

etcdctl `etcdctl` is a command line client for [etcd][]. It can be used in scripts

谁借莪１个温暖的怀抱￠/ 2021年09月01日 03:15/ 0 赞/ 463 阅读