开发者学堂课程【分布式协调系统 Zookeeper 快速入门:服务器节点动态上下线案例注册代码】学习笔记,与课程紧密联系,让用户快速学习知识。
课程地址:https://developer.aliyun.com/learning/course/97/detail/1596
服务器节点动态上下线案例注册代码
(0)先在集群上创建 severs 节点
(zk: localhost:2101 (CONNGCTED) 10] create /servers "selvers".Created /servers.
(1) 服务器端向 Zookeeper 注册代码
package com. atguigu. zkcase;
import java. io. IOException;
import org.apache. zookeeper CreateMode ;
import orq.apache. zookeeper .WatchedEvent;
import org. apache. zookeeper .Watcher;
import org . apache . zookeeper . ZooKeeper;
import org.apache. zookeeper . ZooDefs.Ids;
public class Distributeserver (
private
I static string connectstring
"hadoop102 :2181, hadoop103:2181, hadoop104:21811
private static int sessionTimeout = 200
0
private ZooKeeperzk = null;·
private string parentNode"/servers";.
//创建到 zk 的客户端连接。
public void getConnecto()throws
IOException(
具体有三大步骤:
11 1 连接 zookeeper 集群
server . getConnect();
1/ 2注册节点
server.regist()
{
// 3业务逻辑处理
private String connectString = "hadoop102:2181 , hadoop103:2181, hadoop104:2181"
;private int sessionTimeout = 2000;
private ZooKeeper zkClient;
private void getConnect() throws IOException
zkClient = new ZooKeeper connecttring , sessionTimeout , new Watcher()
@Override
public void process (WatchedEvent event)
{
11 TODO Auto- generated method stub
注册完之后正常的业务还会有正常的逻辑