深入探索Zookeeper：从客户端使用到集群特性的全面指南资源-CSDN文库

需积分: 1 56 浏览量 2023-12-16 20:35:18 上传评论收藏 1005KB PDF 举报

资源推荐

资源详情

资源评论

ZookeeperJava客户端

ApacheCurator开源客户端

Zookeeper集群&不停机动态扩容/缩容

Zookeeper经典应用场景

ZookeeperJava客户端

项目构建

zookeeper官方的客户端没有和服务端代码分离，他们为同一个jar文件，所以我们直接引入

zookeeper的maven即可，这里版本请保持与服务端版本一致，不然会有很多兼容性的问题

1 <dependency>

2 <groupId>org.apache.zookeeper</groupId>

3 <artifactId>zookeeper</artifactId>

4 <version>3.5.8</version>

5 </dependency>

创建客户端实例：

为了便于测试，直接在初始化方法中创建zookeeper实例

1 @Slf4j

2 publicclassZookeeperClientTest{

4 privatestaticfinalStringZK_ADDRESS="192.168.109.200:2181";

6 privatestaticfinalintSESSION_TIMEOUT=5000;

8 privatestaticZooKeeperzooKeeper;

10 privatestaticfinalStringZK_NODE="/zk‐node";

13 @Before

14 publicvoidinit()throwsIOException,InterruptedException{

15 finalCountDownLatchcountDownLatch=newCountDownLatch(1);

16 zooKeeper=newZooKeeper(ZK_ADDRESS,SESSION_TIMEOUT,event‐>{

17 if(event.getState()==Watcher.Event.KeeperState.SyncConnected&&

18 event.getType()==Watcher.Event.EventType.None){

19 countDownLatch.countDown();

20 log.info("连接成功！");

21 }

22 });

23 log.info("连接中....");

24 countDownLatch.await();

25 }

26 }

创建Zookeeper实例的方法：

1 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher)

2 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher,ZKClientC

onfig)

3 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher,booleanc

anBeReadOnly,HostProvider)

4 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher,booleanc

anBeReadOnly,HostProvider,ZKClientConfig)

5 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher,booleanc

anBeReadOnly)

6 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher,booleanc

anBeReadOnly,ZKClientConfig)

7 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher,long,byt

e[])

8 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher,long,byt

e[],boolean,HostProvider)

9 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher,long,byt

e[],boolean,HostProvider,ZKClientConfig)

10 ZooKeeper(StringconnectString,intsessionTimeout,Watcherwatcher,long,by

te[],boolean)

参数名称含义

connectString

ZooKeeper服务器列表，由英文逗号分开的host:port字符串组成，

每一个都代表一台ZooKeeper机器，如，

host1:port1,host2:port2,host3:port3。另外，也可以在connectString中设

置客户端连接上ZooKeeper

后的根目录，方法是在host:port字符串之后添加上这个根目录，例

如,host1:port1,host2:port2,host3:port3/zk-base,这样就指定了该客户端连

接上ZooKeeper服务器之后,所有对ZooKeeper

的操作，都会基于这个根目录。例如，客户端对/sub-node的操作，最终创建

/zk-node/sub-node,这个目录也叫Chroot，即客户端隔离命名空间。

sessionTimeout 会话的超时时间，是一个以“毫秒”为单位的整型值。在ZooKeeper中有

会话的概念，在一个会话周期内，ZooKeeper客户端和服务器之间会通过心跳

检

测机制来维持会话的有效性，一旦在sessionTimeout时间内没有进行有效

的心跳检测，会话就会失效。

watcher

ZooKeeper允许

客户端在构造方法中传入一个接口watcher(org.apache.zookeeper.

Watcher)的实现类对象来作为默认的Watcher事件通知处理器。当然，该参

数可以设置为null以表明不需要设置默认的Watcher处理器。

canBeReadOnly

这是一个boolean类型的参数，用于标识当前会话是否支持“read-only(只

读)”模式。默认情况下，在ZooKeeper集群中，一个机器如果和集群中过半

及

以上机器失去了网络连接，那么这个机器将不再处理客户端请求（包括读写请

求)。但是在某些使用场景下，当ZooKeeper服务器发生此类故障的时候，我

们

还是希望ZooKeeper服务器能够提供读服务（当然写服务肯定无法提供）——

这就是ZooKeeper的“read-only”模式。

sessionId和ses

sionPasswd

分别代表会话ID和会话秘钥。这两个参数能够唯一确定一个会话，同时客户

端使用这两个参数可以实现客户端会话复用，从而达到恢复会话的效果。具体

使用方法是，第一次连接上ZooKeeper服务器时，通过调用ZooKeeper对象

实

例的以下两个接口，即可获得当前会话的ID和秘钥:

longgetSessionId();

byte[]getSessionPasswd();

荻取到这两个参数值之后，就可以在下次创建ZooKeeper对象实例的时候传

入构造方法了

同步创建节点：

1 @Test

2 publicvoidcreateTest()throwsKeeperException,InterruptedException{

3 Stringpath=zooKeeper.create(ZK_NODE,"data".getBytes(),ZooDefs.Ids.OPEN_A

CL_UNSAFE,CreateMode.PERSISTENT);

4 log.info("createdpath:{}",path);

5 }

异步创建节点：

1 @Test

2 publicvoidcreateAsycTest()throwsInterruptedException{

3 zooKeeper.create(ZK_NODE,"data".getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,

4 CreateMode.PERSISTENT,

5 (rc,path,ctx,name)‐>log.info("rc{},path{},ctx{},name

{}",rc,path,ctx,name),"context");

6 TimeUnit.SECONDS.sleep(Integer.MAX_VALUE);

7 }

修改节点数据

1 @Test

2 publicvoidsetTest()throwsKeeperException,InterruptedException{

4 Statstat=newStat();

5 byte[]data=zooKeeper.getData(ZK_NODE,false,stat);

6 log.info("修改前:{}",newString(data));

7 zooKeeper.setData(ZK_NODE,"changed!".getBytes(),stat.getVersion());

8 byte[]dataAfter=zooKeeper.getData(ZK_NODE,false,stat);

9 log.info("修改后:{}",newString(dataAfter));

10 }

什么是Curator

Curator是一套由netflix公司开源的，Java语言编程的ZooKeeper客户端框架，Curator项目

是现在ZooKeeper客户端中使用最多，对ZooKeeper版本支持最好的第三方客户端，并推荐使

用，Curator把我们平时常用的很多ZooKeeper服务开发功能做了封装，例如Leader选举、

分布式计数器、分布式锁。这就减少了技术人员在使用ZooKeeper时的大部分底层细节开发工

作。在会话重新连接、Watch反复注册、多种异常处理等使用场景中，用原生的ZooKeeper

处理比较复杂。而在使用Curator时，由于其对这些功能都做了高度的封装，使用起来更加简

单，不但减少了开发时间，而且增强了程序的可靠性。

Curator实战

这里我们以Maven工程为例，首先要引入Curator框架相关的开发包，这里为了方便测试引入

了junit，lombok，由于Zookeeper本身以来了log4j日志框架，所以这里可以创建对应的

log4j配置文件后直接使用。如下面的代码所示，我们通过将Curator相关的引用包配置到

Maven工程的pom文件中，将Curaotr框架引用到工程项目里，在配置文件中分别引用了两

个Curator相关的包，第一个是curator-framework包，该包是对ZooKeeper底层API的一

些封装。另一个是curator-recipes包，该包封装了一些ZooKeeper服务的高级特性，如：

Cache事件监听、选举、分布式锁、分布式Barrier。

1 <dependency>

2 <groupId>org.apache.curator</groupId>

3 <artifactId>curator‐recipes</artifactId>

4 <version>5.0.0</version>

5 <exclusions>

6 <exclusion>

7 <groupId>org.apache.zookeeper</groupId>

剩余20页未读，继续阅读

评论收藏

内容反馈

光芒软件工匠

粉丝: 789
资源: 64

深入探索Zookeeper：从客户端使用到集群特性的全面指南

第二课：zookeeper客户端使用与集群特性.docx

第二课：zookeeper客户端使用与集群特性.md

深入探索Zookeeper：实战应用与高效策略

从Paxos到Zookeeper：分布式一致性原理与实践

zookeeper客户端连接工具: zktools

深入解析Zookeeper：核心特性与节点类型全景剖析

zookeeper的客户端使用，图形化界面查看节点信息

zookeeper服务和客户端工具

深入探索Zookeeper的ZAB协议：分布式系统的核心解析深入探索Zookeeper的ZAB协议：分布式系统的核心解析

Paxos到Zookeeper：分布式一致性原理与实践

ZooKeeper 客户端的使用(二).

prettyZoo，zookeeper window客户端

zookeeper数据迁移从单例到集群linux命令过程

Zookeeper可视化客户端-ZooInspector

从Paxos到Zookeeper：分布式一致性原理与实践源码

Zookeeper图形化客户端工具ZooInspector

从Paxos到Zookeeper : 分布式一致性原理与实践 -文字可复制.

Java第十五届蓝桥杯大赛软件JavaB组真题

SwitchHosts

安卓期末大作业（AndroidStudio开发），垃圾分类助手app，分为前台后台，代码有注释，均能正常运行

Notepad++安装包

2024北森能力测评题库.7z

微信小程序源码-合集1.rar

Java面试八股文2023最新版

Linux Centos7 升级最新版OpenSSH-9.6p1 有脚本（支持离线）

ruoyi-vue-pro 芋道源码项目的表结构

JDK1.8 windows 64位

myeclipse 10.7.1 windows 安装包

ruoyi-vue-pro开发指南PDF下载

最新资源