ZkClient 简单使用API

ZkClient 简单使用API

  • 创建链接 new ZkClient()
  • 节点是否存在 exists()
  • 删除节点 delete()
  • 创建临时节点 createPersistent()
  • 创建临时有序节点 createPersistentSequential()
  • 创建持久化节点 createEphemeral()
  • 创建持久化有序节点 createEphemeralSequential()

import org.I0Itec.zkclient.IZkDataListener;
import org.I0Itec.zkclient.ZkClient;

/**
 * zkClient 客户端简单api操作
 * 
 * @author hui2.chen
 * @date 2019/8/23
 */
public class ZkClientDemo {
    public static void main(String[] args) {
        String zkString = "127.0.0.1:2181";
        int connectTimeout = 3000;

        ZkClient zkClient = new ZkClient(zkString, connectTimeout);
        String path = "/zk-data-201908";

        //若节点已经存在,则删除
        if (zkClient.exists(path)) {
            zkClient.delete(path);
        }

        //创建节点
        zkClient.createPersistent(path);
        //写入数据
        zkClient.writeData(path, "test_data_1");
        //节点读取数据
        String data_1 = zkClient.readData(path);

        //创建节点并写入数据
//        zkClient.createPersistent(path,"test_data_2");

        System.out.println(data_1);

        /**
         * 监听节点数据变动
         */
        zkClient.subscribeDataChanges(path, new IZkDataListener(){
            @Override
            public void handleDataChange(String path, Object data) throws Exception {
                System.out.println("data [change] path=" + path + ", data="+data);
            }

            @Override
            public void handleDataDeleted(String path) throws Exception {
                System.out.println("data [delete] path=" + path);
            }
        });

        zkClient.writeData(path, "new_date");
        zkClient.delete(path);
        zkClient.createPersistent(path+"_1", "new_date");
        try {
            Thread.sleep(Integer.MAX_VALUE);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

ZK 实现注册中心

服务的注册

  • 服务启动的同时, 将服务提供者信息(主机IP地址, 服务端口, 服务接口类路径)组成的znode路径写入Zookeeper. 写入叶子节点的临时节点.

服务的发现

  • 服务的消费端在发起调用之前, 先连接到zk获取服务提供者节点路径注册监听, 同时获取服务提供者信息缓存到本地, 发起调用时, 调用者从服务端提供本地缓存列表中, 通过某种负载均衡策略获取某一个服务提供者, 对该服务提供者发起调用, 完成本次调用. 这样就完成了服务发现动作.
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • ... 一、相关概念 中间件:为分布式系统提供协调服务的组件,如专门用于计算服务的机器就是一个计算型中间件,还有专...
    帅可儿妞阅读 3,335评论 0 0
  • 前言 这篇文章主要记录学习Dubbo注册中心的相关内容,包括:注册中心的工作原理;注册中心的数据结构;订阅发布的实...
    程序员网址导航阅读 7,797评论 0 2
  • 一、系统模型 1、数据模型 zk结构视图与unix的文件系统有点类似,但是没有目录和文件的相关概念。而是使用特有的...
    小manong阅读 6,551评论 0 3
  • 在耶鲁萨尔举办的婚礼如期举行,新郎达塔尔和主婚人廖尔正在入口处焦灼地交谈。一向谨慎、镇静自若的廖尔表现的无比慌张,...
    a0f7f44d6111阅读 2,540评论 0 0
  • 山腰雾气弥漫,我们不清楚前方的路是否正确。我停下脚步努力让自己镇静,此刻越是焦躁越容易判断错误。深呼吸,除了清晰感...
    白菜兔兔阅读 1,339评论 0 1