`
qindongliang1922
  • 浏览: 2181082 次
  • 性别: Icon_minigender_1
  • 来自: 北京
博客专栏
7265517b-f87e-3137-b62c-5c6e30e26109
证道Lucene4
浏览量:117401
097be4a0-491e-39c0-89ff-3456fadf8262
证道Hadoop
浏览量:125817
41c37529-f6d8-32e4-8563-3b42b2712a50
证道shell编程
浏览量:59813
43832365-bc15-3f5d-b3cd-c9161722a70c
ELK修真
浏览量:71227
社区版块
存档分类
最新评论

分布式助手Zookeeper(三)

阅读更多
本篇,散仙要介绍一下基于zookeeper的一些API的编程。
在此之前,我们先来熟悉一下相关知识:



Zookeeper的Session:
(1)客户端和server间采用长连接
(2)连接建立后,server产生session ID(64位)返还给客户端
(3)客户端定期发送ping包来检查和保持和server的连接
(4)一旦session结束或超时,所有ephemeral节点会被删除
(5)客户端可根据情况设置合适的session超时时间

Zookeeper的Watchs:
Watch是客户端安装在server的事件侦听方法
(1) 当侦听的变化发生时,server发消息给客户端进行通知
(2) 客户端使用单线程对所有事件按顺序同步回调
(3) 触发回调条件:
• 客户端连接、断开连接
• 节点数据发生改变
• 节点本身发生变化
(4)Watch是单发的,每次触发后会被自动删除
(5)如果需要再次侦听事件,必须重新安装watch
(6)无法保证跟踪到每一个变化
(7)避免安装大量watches侦听在同一个节点

Zookeeper的一些注意事项:
在客户端事件回调实现有阻塞调用
• 试图跟踪每个状态变化
• 大量watch侦听同一个znode的状态变化
• 客户端会有需要长时间处理的GC(garbage collection)
• Session超时后上层应用不进行恢复处理


可以把zookper看成一个文件系统,文件系统中的所有文件形成一个数状结构,zookeeper维护着这样的树形层次结构,树中的节点称为znode。每个znode有一个与之相关联的ACL(Access Control List)
znode通过路径被引用,而且要采用绝对路径,即必须以/开头。znode存储的数据要小于1M,这个可以配置,建议不要存储太大的东西,避免同步操作时间过长。
znode类型
短暂znode:回话结束,zookeeper就会把短暂znode删除,短暂znode不可以有子节点。
持久znode:回话结束也不会被删除,除非客户端明确要删除此znode,持久znode可以有子节点。
对于在特定时刻需要知道有哪些分布式资源可用的应用来说,使用短暂znode比较合适。

znode的观察机制
znode以某种方式发生变化时,“观察”(watch)机制可以让客户端得到通知。可以针对ZooKeeper服务的“操作”来设置观察,该服务的其他操作可以触发观察。比如,客户端可以对某个客户端调用exists操作,同时在它上面设置一个观察,如果此时这个znode不存在,则exists返回false,如果一段时间之后,这个znode被其他客户端创建,则这个观察会被触发,之前的那个客户端就会得到通知。

zookeeper的一些基本操作如下:

操作描述
create创建一个znode(必须有父节点)
delete删除一个znode(该znode不能有任何子节点)
exists测试一个znode是否存在,并且查询它的元数据
getACL,setACL获取/设置一个znode的ACL
getChildren获取一个znode的子节点名字列表
getData,setData获取/设置一个znode所保存的数据
sync将客户端的znode视图与ZooKeeper服务端同步


Zookeeper中的更新操作是有条件的。在使用delete或者setData操作时必须提供被更新znode的版本号,如果版本号不匹配,则更新操作失败。一般情况下设置-1即可。


API
目前主要有java和C两种客户端,每种操作都有同步和异步两种执行方式。
观察触发器
可以设置观察的操作:exists,getChildren,getData
可以触发观察的操作:create,delete,setData
下面给出一些事件截图:









NodeCreated:节点创建事件
NodeDeleted:节点被删除事件
NodeDataChanged:节点数据改变事件
NodeChildrenChanged:节点的子节点改变事件

下面我们再来看下ACL(zookeeper的访问控制列表),每个znode被创建时都会带有一个ACL列表,用于决定谁可以对它执行何种操作。

ACL权限允许的操作
CREATE创建节点create("name")
READgetChildren()  getData()
WRITEsetData
DELETEdelete("name")删除节点
ADMINsetACL()设置权限

每个ACL都是身份验证模式、符合该模式的一个身份和一组权限的组合。身份验证模式有三种:
digest:用户名,密码

host:通过客户端的主机名来识别客户端

ip: 通过客户端的ip来识别客户端

所以我们可以类似这样构建一个ACL类:
new ACL(Perms.READ,new Id("host","example.com"));
这个ACL对应的身份验证模式是host
符合该模式的身份是example.com
权限的组合是:READ

下面给出一个API连接zookeeper的示例:
package com.util;

import java.util.concurrent.CountDownLatch;

import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;

/**
 * 测试zookeeper的连接
 * @author 三劫散仙
 * 
 * ***/
public class Test {
	
	
	
	public static void main(String[] args)throws Exception {
		
		
		
		ZooKeeper  zk=new ZooKeeper("10.2.143.5:2181", 5000, new Watcher() {
			CountDownLatch down=new CountDownLatch(1);//同步阻塞状态
			@Override
			public void process(WatchedEvent event) {
			 if(event.getState()==Event.KeeperState.SyncConnected){
				 down.countDown();//连接上之后,释放计数器
			 }
				
			}
		});
		
		System.out.println("连接成功:"+zk.toString());
		zk.close();//关闭连接
	}

}

打印效果如下:

连接成功:State:CONNECTING sessionid:0x0 local:null remoteserver:null lastZxid:0 xid:1 sent:0 recv:0 queuedpkts:0 pendingresp:0 queuedevents:0


  • 大小: 122.6 KB
  • 大小: 93.4 KB
  • 大小: 72.7 KB
  • 大小: 76.5 KB
分享到:
评论

相关推荐

    zookeeper连接工具zktools

    在实际使用中,ZkTools不仅适用于开发和运维人员日常的Zookeeper管理,也是进行系统故障排查和性能优化的有力助手。通过压缩包中的ZkTools,用户可以快速上手,提升工作效率,更好地驾驭Zookeeper这个强大的分布式...

    zookeeper可视化工具

    **Zookeeper可视化工具详解** Apache ZooKeeper 是一个分布式...总之,Zookeeper可视化工具是管理和维护Zookeeper集群不可或缺的助手,通过它们,我们可以更高效、更安全地操作Zookeeper,实现分布式系统的稳定运行。

    zookeeper-3.4.9.zip

    《Zookeeper:分布式服务治理的重要角色》 Zookeeper,作为Apache的一个开源项目,是分布式应用程序协调服务...它不仅提供了丰富的功能,而且有着成熟的社区支持和广泛的应用实践,是构建大规模分布式应用的得力助手。

    zookeeper客户端.zip

    ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈...它的跨平台性和易用性使得在各种环境下都能灵活应用,是Zookeeper使用者的有力助手。

    zookeeper的myeclipse插件

    ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈进行下...如果你经常处理ZooKeeper相关的工作,这款插件无疑是你不可或缺的得力助手。

    超级好用的zookeeper查看器

    而“Zookeeper查看器”则成为了开发者和运维人员进行故障排查、监控与管理Zookeeper的得力助手。 首先,我们需要理解Zookeeper的核心功能。在分布式系统中,Zookeeper提供了一种名为“ZNode”的数据结构,类似于...

    Ant编译后的zookeeper源码

    Apache ZooKeeper是一个分布式的,开放源码的分布式应用程序协调服务,它是集群的管理者,监视着集群中各个节点的状态根据节点提交的反馈进行下一步合理操作。最终将简单易用的接口和性能高效、功能稳定的系统提供给...

    zookeeper eclipse plugin

    5. **代码助手**:提供ZooKeeper相关的代码提示和自动完成,加速编码过程。 6. **配置向导**:简化ZooKeeper连接设置,只需几步即可连接到本地或远程的ZooKeeper服务器。 7. **版本兼容性**:虽然描述中提到的是...

    zookeeper-web-master.zip

    总的来说,"zookeeper-web"是Zookeeper管理的得力助手,它通过Web界面极大地提升了Zookeeper的易用性,是分布式系统管理员的必备工具之一。掌握"zookeeper-web"的使用,不仅可以提升工作效率,也有助于更好地理解和...

    ZooInspector-for-zookeeper数据查看

    总结起来,ZooInspector是Zookeeper管理员的得力助手,通过其强大的图形界面,用户可以更直观、便捷地管理和监控Zookeeper的数据。了解并熟练使用ZooInspector,对于提升Zookeeper的管理和故障排查能力至关重要。

    zookeepers分布式

    总结来说,ZooKeeper作为分布式系统的协调者,通过提供强一致性、高可用性的服务,极大地简化了分布式环境下的复杂问题,成为大数据和云计算领域的得力助手。理解和掌握ZooKeeper,对于开发和运维分布式系统具有重要...

    zookeeper可视化JAVA工具ZooInspector

    在IT行业中,Zookeeper是Apache软件基金会的一个开源项目,常用于分布式协调服务,确保数据的一致性和高可用性。而ZooInspector则为这个复杂的分布式系统提供了友好的图形用户界面(GUI),极大地简化了开发者和管理...

    ZooInspector:一款ZooKeeper的可视化工具

    ZooKeeper是Apache软件基金会的一个项目,它提供了一个分布式协调服务,广泛应用于分布式系统中,如配置管理、命名服务、分布式同步、组服务等。ZooInspector作为ZooKeeper的可视化界面,极大地简化了用户与...

    开源监控管理zookeeper工具:exhibitor-1.6

    总的来说,Exhibitor是Zookeeper管理员的得力助手,通过它,你可以更高效地管理和维护Zookeeper集群,确保分布式系统的稳定运行。正确配置和使用Exhibitor对于提升Zookeeper的运维效率和系统可靠性具有重要意义。

    zookeeper查看器

    **Zookeeper查看器:ZooInspector详解** ...总结来说,ZooInspector作为Zookeeper的辅助工具,提供了一个图形化的接口,方便用户理解和管理Zookeeper集群,对于开发者和运维人员来说,它是不可或缺的调试和管理助手。

    zookeeper-3.4.6

    《Zookeeper 3.4.6:探索分布式一致性解决...它的设计思路、实现机制以及丰富的API,使其成为分布式系统中的得力助手。通过深入学习和使用,开发者可以有效地构建稳定、高效的分布式应用,应对复杂的分布式环境挑战。

    zookeeper可视化工具安装包

    总之,Zookeeper 可视化工具是管理和维护 Zookeeper 集群的强大助手,能够简化操作流程,提高运维效率,是 IT 专业人士不可或缺的工具之一。通过熟练掌握和使用这些工具,可以更好地管理和优化基于 Zookeeper 的...

    多线程入门,分布式锁,等相关资料

    总结来说,本资源包提供的"多线程入门资料"涵盖了多线程的基本概念、实现方式、线程同步与通信、并发问题及其解决方案,以及分布式锁的原理与实现,是学习Java多线程和分布式系统的好助手。通过深入学习和实践,...

    zookeeper之节点基本操作(一).zip

    在分布式系统领域,ZooKeeper 是一个至关重要的组件,它为分布式应用程序提供了高效且可靠...在实际项目中,ZooKeeper 被广泛应用于配置管理、命名服务、分布式锁、队列等多个场景,是构建高可用分布式系统的得力助手。

Global site tag (gtag.js) - Google Analytics