Java에서 ZooKeeper 사용에 대한 자세한 설명-java지도 시간-php.cn

ZooKeeper는 분산형 오픈소스 분산 애플리케이션 조정 서비스로, Google의 Chubby를 오픈소스로 구현한 것이며 Hadoop 및 Hbase의 중요한 구성 요소입니다. 이 글을 통해 자바에서 Zookeeper의 간단한 사용법을 공유하겠습니다. 필요한 친구들은 참고하세요

1. Zookeeper의 기본 원리

데이터 모델은 다음과 같습니다.

ZooKeeper 데이터 모델의 구조와 구조 Unix 파일 시스템은 전체적으로 트리로 간주할 수 있으며 각 노드를 ZNode라고 합니다. 각 ZNode는 해당 경로로 고유하게 식별될 수 있습니다. 예를 들어 위 그림에서 세 번째 계층의 첫 번째 ZNode에는 /app1/c1 경로가 있습니다. 각 ZNode에는 소량의 데이터를 저장할 수 있습니다(기본값은 1M이며 구성을 통해 수정할 수 있습니다. 일반적으로 ZNode에 많은 양의 데이터를 저장하는 것은 권장되지 않습니다). 또한 각 ZNode는 Acl 정보도 저장합니다. ZNode의 트리 구조는 Unix 파일 시스템과 매우 유사하지만 Acl은 Unix 파일 시스템과 완전히 다릅니다. . , 하위 노드는 상위 노드를 상속하지 않습니다.

ZooKeeper 기능:

1. 읽기, 쓰기(업데이트) 모드

ZooKeeper 클러스터에서는 모든 ZooKeeperServer에서 읽기를 읽을 수 있어 ZooKeeper의 더 나은 읽기 성능이 보장됩니다. 쓰기 요청은 먼저 리더에게 전달된 다음 리더는 ZooKeeper의 원자 브로드캐스트 프로토콜을 통해 모든 팔로어에게 요청을 브로드캐스트합니다. 리더는 성공적인 쓰기 승인의 절반 이상을 받은 후 쓰기가 완료된 것으로 간주합니다. 성공하면 쓰기가 유지되고 클라이언트에 쓰기가 성공했다는 알림이 전달됩니다.

2. WAL 및 스냅샷

대부분의 분산 시스템과 마찬가지로 ZooKeeper에는 WAL(Write-Ahead-Log)도 있습니다. 모든 업데이트 작업에 대해 ZooKeeper는 먼저 WAL을 작성한 다음 메모리에 데이터를 업데이트합니다. 업데이트 결과를 클라이언트에게 알립니다. 또한 ZooKeeper는 정기적으로 메모리에 있는 디렉터리 트리의 스냅샷을 찍어 디스크에 저장합니다. 이는 HDFS의 FSImage와 유사합니다. 이렇게 하는 주요 목적은 물론 데이터의 지속성이며 두 번째는 다시 시작한 후 복구 속도를 높이는 것입니다. ReplayWAL을 통해 모두 복원하면 속도가 느려집니다.

3. FIFO

각 ZooKeeper 클라이언트에 대해 모든 작업은 다음 두 가지 기본 기능으로 보장됩니다. 첫째, ZooKeeper 클라이언트와 서버 간 네트워크 통신은 TCP를 기반으로 합니다. 클라이언트/서버 간 전송 패킷 순서 둘째, ZooKeeperServer는 FIFO 순서에 따라 클라이언트 요청을 실행합니다.

4. 선형성

ZooKeeper에서는 모든 업데이트 작업이 엄격한 부분 순서 관계를 가지며 업데이트 작업은 순차적으로 실행됩니다. 이는 ZooKeeper 기능의 정확성을 보장하는 핵심입니다.

2. Zookeeper의 일반적인 명령

Zookeeper-client를 실행하거나 /opt/cloudera/parcels/CDH-5.0.0-1.cdh5.0.0.p0.47/lib/zookeeper/bin을 실행할 수 있습니다. /zkCli.sh-server localhost에서 다음과 같이 Zookeeper 명령줄을 입력합니다.

그런 다음 ls /를 실행하면 다음을 볼 수 있습니다.

그런 다음 create /qyktest를 실행할 수 있습니다. 'qyktest' 다음과 같이 노드를 생성합니다.

그런 다음 get /qyktest를 실행하여 다음과 같이 노드 값을 가져옵니다.

그런 다음 set /qyktest를 실행할 수 있습니다. 111' 노드 값을 수정하려면 다음과 같이

마지막으로 delete /qyktest를 실행하여 이 노드를 삭제할 수 있습니다.

또한 이 qyktest 노드 아래에 하위 노드를 계속 생성할 수도 있습니다.

그렇습니다. 몇 가지 기본 명령어로 이 사람에 대한 정보를 확인할 수 있습니다.

3. Zookeeper의 javaapi 작업

Zookeeper의 Javaapi 작업에 대해서는 다음과 같이 저자가 직접 코드를 게시했습니다.

packageorg.zookeeper.demo;
importjava.io.IOException;
importjava.util.concurrent.CountDownLatch;
importorg.apache.zookeeper.CreateMode;
importorg.apache.zookeeper.KeeperException;
importorg.apache.zookeeper.WatchedEvent;
importorg.apache.zookeeper.Watcher;
importorg.apache.zookeeper.Watcher.Event.KeeperState;
importorg.apache.zookeeper.ZooDefs.Ids;
importorg.apache.zookeeper.ZooKeeper;
publicclassZookeeperClientimplementsWatcher{
//连接超时时间,10s
privatestaticfinalintSESSION_TIMEOUT= 10000;
//连接的zookeeperserver
privatestaticfinalStringCONNECTION_STRING = "172.31.25.8:2181";
privatestaticfinalStringZK_PATH = "/qyktest";
privateZooKeeperzk = null;
privateCountDownLatchconnectedSemaphore = newCountDownLatch(1);
publicvoidcreateConnection(StringconnectString, intsessionTimeout){
this.releaseConnection();
try{
zk= newZooKeeper(connectString,sessionTimeout, this);
connectedSemaphore.await();
}catch(InterruptedExceptione) {
System.out.println("连接创建失败，发生InterruptedException");
e.printStackTrace();
}catch(IOExceptione) {
System.out.println("连接创建失败，发生IOException");
e.printStackTrace();
}
}
publicvoidreleaseConnection(){
if(this.zk!= null){
try{
this.zk.close();
}catch(InterruptedExceptione) {
e.printStackTrace();
}
}
}
publicbooleancreatePath(Stringpath, String data) {
try{
Stringresult = this.zk.create(path,data.getBytes(), Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);
System.out.println("节点创建成功,Path: "+result + ", content: "+data);
}catch(KeeperExceptione) {
System.out.println("节点创建失败，发生KeeperException");
e.printStackTrace();
}catch(InterruptedExceptione) {
System.out.println("节点创建失败，发生InterruptedException");
e.printStackTrace();
}
returntrue;
}
publicStringreadData(Stringpath) {
try{
System.out.println("获取数据成功，path："+path);
returnnewString(this.zk.getData(path,false,null));
}catch(KeeperExceptione) {
System.out.println("读取数据失败，发生KeeperException，path:"+path);
e.printStackTrace();
return"";
}catch(InterruptedExceptione) {
System.out.println("读取数据失败，发生InterruptedException，path: "+path);
e.printStackTrace();
return"";
}
}
publicbooleanwriteData(Stringpath, String data) {
try{
System.out.println("更新数据成功，path："+path + ", stat: "+this.zk.setData(path,data.getBytes(), -1));
}catch(KeeperExceptione) {
System.out.println("更新数据失败，发生KeeperException，path:"+path);
e.printStackTrace();
}catch(InterruptedExceptione) {
System.out.println("更新数据失败，发生InterruptedException，path: "+path);
e.printStackTrace();
}
returnfalse;
}
publicvoiddeleteNode(Stringpath) {
try{
this.zk.delete(path,-1);
System.out.println("删除节点成功，path："+path);
}catch(KeeperExceptione) {
System.out.println("删除节点失败，发生KeeperException，path:"+path);
e.printStackTrace();
}catch(InterruptedExceptione) {
System.out.println("删除节点失败，发生InterruptedException，path: "+path);
e.printStackTrace();
}
}
publicstaticvoidmain(String[]args) {
ZookeeperClientsample = newZookeeperClient();
//获取连接
sample.createConnection(CONNECTION_STRING,SESSION_TIMEOUT);
//读数据
Stringqyk = sample.readData("/qyktest");
System.out.println("qyk:"+qyk);
Stringurl = sample.readData("/qyk/db/url");
System.out.println("url"+url);
Stringdriver = sample.readData("/qyk/db/driver");
System.out.println("driver"+driver);
StringuserName = sample.readData("/qyk/db/userName");
System.out.println("userName"+userName);
Stringpassword = sample.readData("/qyk/db/password");
System.out.println("password"+password);
//创建节点
sample.createPath(ZK_PATH,"我是节点初始内容");
System.out.println("数据内容:"+sample.readData(ZK_PATH) + "\n");
//更新节点
sample.writeData(ZK_PATH,"更新后的数据");
System.out.println("数据内容:"+sample.readData(ZK_PATH) + "\n");
//删除节点
sample.deleteNode(ZK_PATH);
//释放连接
sample.releaseConnection();
}
@Override
publicvoidprocess(WatchedEventevent) {
System.out.println("收到事件通知："+event.getState() + "\n");
if(KeeperState.SyncConnected== event.getState()) {
connectedSemaphore.countDown();
}
}
}

로그인 후 복사

그런 다음 실행하면 다음과 같이 콘솔 출력이 나오는 것을 확인할 수 있습니다.