`
san_yun
  • 浏览: 2654562 次
  • 来自: 杭州
文章分类
社区版块
存档分类
最新评论

zookeeper入门 code

 
阅读更多

一些测试:

	String path = "/tlog2/test/fuck";
		boolean exists = zkClient.exists(path);

		CuratorFramework zkClient = CuratorFrameworkFactory.newClient(
				"10.232.31.216:3325,10.232.31.215:3325,10.232.31.219:3325", new RetryPolicy() {

					@Override
					public boolean allowRetry(int retryCount, long elapsedTimeMs) {
						return false;
					}

				});

		Watcher watcher = new Watcher() {

			@Override
			public void process(WatchedEvent event) {
				System.out.println(event.getType());
				//client.checkExists().usingWatcher(watcher).inBackground(backgroundCallback).forPath(path)
			}
		};

		BackgroundCallback callback = new BackgroundCallback() {

			@Override
			public void processResult(CuratorFramework client, CuratorEvent event) throws Exception {

				switch (event.getType()) {
				case GET_DATA: {
					if (event.getResultCode() == KeeperException.Code.OK.intValue()) {
						//logger.trace("GET_DATA: {}", event);
						//setNewData(event.getData());
						System.out.println("GET_DATA: "+ event);
					}
					break;
				}

				case EXISTS: {
					if (event.getResultCode() == KeeperException.Code.NONODE.intValue()) {
						//logger.trace("EXISTS=>NONODE: {}", event);
						System.out.println("EXISTS=>NONODE: "+ event);
						//setNewData(null);
					} else if (event.getResultCode() == KeeperException.Code.OK.intValue()) {
						System.out.println("EXISTS=>OK: "+event);
						//client.getData().inBackground(backgroundCallback).forPath(path);
					}
					break;
				}

				default:
					System.out.println("Unknown CuratorEvent: " + event.getType());
					break;
				}
			}

		};

		zkClient.checkExists().usingWatcher(watcher).inBackground(callback).forPath(path);

 

 

分享到:
评论

相关推荐

    zookeeper 入门到精通

    ### Zookeeper 入门到精通 #### 一、Zookeeper 概述 ##### 1.1 什么是 Zookeeper? Zookeeper 是一个分布式的协调服务框架,最初由雅虎实验室开发,后来成为 Apache 的顶级项目。它是 Google Chubby 的一种开源...

    HstarDoc-zookeeper入门-初体验

    My blogs write with markdown. zookeeper入门-初体验 zookeeper入门-初体验 zookeeper入门-初体验 zookeeper入门-初体验 zookeeper入门-初体验

    le1024-zookeeper入门-初体验

    https://helele.top zookeeper入门-初体验 zookeeper入门-初体验 zookeeper入门-初体验 zookeeper入门-初体验 zookeeper入门-初体验

    zookeeper系列1:入门

    **Zookeeper系列1:入门** Zookeeper是一款分布式协调服务,由Apache基金会开发,广泛应用于分布式系统中的数据共享、配置管理、命名服务、集群同步等场景。它的设计目标是简化分布式环境下的复杂问题,提供高可用...

    zookeeper入门练习demo

    **Zookeeper入门练习Demo** Zookeeper是一个分布式协调服务,由Apache Hadoop项目开发,广泛应用于分布式计算、配置管理、命名服务、分布式锁等场景。这个"Zookeeper入门练习Demo"旨在帮助初学者快速掌握Zookeeper...

    CS-Wiki-zookeeper入门-初体验

    Java . Not only an Interview-Guide, but also a Learning-Direction. zookeeper入门-初体验 zookeeper入门-初体验 zookeeper入门-初体验 zookeeper入门-初体验 zookeeper入门-初体验

    Zookeeper入门到精通

    ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,是Google的Chubby一个开源的实现,是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件,提供的功能包括:配置维护、域名服务、...

    ZooKeeper入门简介及配置使用

    ZooKeeper入门简介及配置使用 ZooKeeper 是⼀一个为分布式应⽤用所设计的分布的、开源的协调服务。分布式的应⽤用 可以建⽴立在同步、配置管理、分组和命名等服务的更⾼高级别的实现的基础之上。 ZooKeeper 意欲设计...

    Zookeeper入门到精通 教学视频及文档

    《Zookeeper入门到精通》教学视频及文档涵盖了分布式协调服务Zookeeper的核心概念、安装配置、基本操作以及在实际应用中的高级技巧。Zookeeper是Apache Hadoop项目的一个子项目,它为分布式应用程序提供高效且可靠的...

    zookeeper入门-初体验

    zookeeper入门-初体验

    zookeeper 入门到精通视频

    zookeeper 入门到精通视频 包含项目实战 分布式事务 leader 选举 视频

    zookeeper入门-初体验.zip

    zookeeper入门-初体验

    dubbo+zookeeper入门资源

    【标题】"dubbo+zookeeper入门资源"涵盖了两个核心概念:Dubbo和Zookeeper,它们在分布式系统中扮演着重要角色。Dubbo是中国阿里巴巴开源的一款高性能、轻量级的Java服务治理框架,它提供了服务注册、服务发现、调用...

    zookeeper入门-初体验.txt

    zookeeper入门-初体验

    Dubbo+zookeeper 入门简单实例

    【标题】"Dubbo+zookeeper 入门简单实例"揭示了如何在Java环境中结合Dubbo和Zookeeper构建一个基础的服务治理框架。Dubbo是阿里巴巴开源的一款高性能、轻量级的Java服务治理框架,而Zookeeper则是一个分布式协调服务...

    zookeeper入门-初体验案例

    zookeeper入门-初体验,简单易上手

    zookeeper 入门学习(PPT)

    ### Zookeeper 入门知识点详解 #### 一、Zookeeper 是什么? Zookeeper是一个用于分布式应用协调服务的软件。它可以维护配置信息、提供命名服务、实现分布式同步,并且支持组服务功能。简单来说,Zookeeper就是一...

    ZooKeeper入门-使用 ZooKeeper 的分布式应用程序开发.pdf

    zookeeper入门-初体验,使用 ZooKeeper 的分布式应用程序开发

    dubbo+zookeeper入门实例

    【标题】"dubbo+zookeeper入门实例"是一个关于使用Dubbo框架与Zookeeper结合实现服务发现和服务调用的基础教程。Dubbo是阿里巴巴开源的一款高性能、轻量级的Java分布式服务框架,而Zookeeper则是一个分布式服务协调...

Global site tag (gtag.js) - Google Analytics