资料课件11 hdfs_mr_zk知识串讲3 ZooKeeper应用介绍

ZooKeeper应用介绍,ZooKeeper集群环境搭建ZooKeeper客户端命令ZooKeeperJavaAPIZooKeeper第三方客户端框架：ZkClient和Curator,本次课内容,系统的各组件分布于网络上多台计算机，各组件彼此直接仅仅通过消息传递来通信并协调行动,什么是分布式系统,分布式协调服务，它解决分布式数据一致性问题原子性顺序一致性单一视图可靠性实时性应用场景数据发布/订阅、负载均衡、命名服务、分布式协调通知（心跳检测）,ZooKeeper,ZooKeeper由ZNode组成，类似文件系统目录核心概念ZNodeSessionWatch：监听机制ACL：如（IP：/16，READ）,ZooKeeper目录结构,伪分布式集群安装环境变量创建三个dataDir与dataLogDir配置zoo1.cfg、zoo2.cfg、zoo3.cfg分别启动第1、2、3号服务器zkServer.shstartzoo1.cfgzkServer.shstartzoo2.cfgzkServer.shstartzoo3.cfg客户端连接zkCli.sh-serverIP:port,ZooKeeper集群环境安装,命令行zkCli.shzkCli.sh-serverip:porth：显示所有命令lspathwatch：查看某个节点下的所有子节点信息statpathwatch：获取指定节点的状态信息ls2pathwatch：是ls和stat两个命令的结合getpathwatch：获取当前节点的数据内容create-s-epathdataacl：创建结点setpathdataversion：修改当前节点的数据内容deletepathversion删除指定路径的节点rmrpath删除当前路径节点及其所有子节点quit:退出客户端,ZooKeeper客户端命令,maven连接,ZooKeeperJavaAPI2-1,org.apache.zookeeperzookeeper3.4.6,StringconnectionString=:2181;intsessionTimeout=30000;ZooKeeperzk=newZooKeeper(connectionString,sessionTimeout,null);,创建节点获取、修改节点数据获取子节点、删除节点,ZooKeeperJavaAPI2-2,zk.create(/testRoot,testRoot.getBytes(),ZooDefs.Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);,Statstat=newStat();zk.getData(/testRoot,true,stat);zk.setData(/testRoot,testRoot_modified.getBytes(),-1);,ZooKeeper的Watcher是一次性的Session超时之后没有实现重连机制异常处理繁琐只提供了简单的byte数组的接口，没有提供针对对象级别的序列化创建节点时如果节点存在抛出异常，需要自行检查节点是否存在删除节点无法实现级联删除,ZooKeeperJavaAPI不足之处,ZkClient特点：Session超时重连、Watcher反复注册等不足：文档少、异常处理过于简化、重试机制难用、没有应用场景实现示例CuratorNetflix公司开源的一套ZooKeeper客户端框架，和ZkClient一样，解决了非常底层的细节开发工作，包括连接重连、反复注册Watcher和NodeExistsException异常等目前已经成为Apache的顶级项目一套易用性和可读性更强的Fluent风格的客户端API框架提供了Zookeeper各种应用场景（Recipe，如共享锁服务、Master选举机制和分布式计算器等）的抽象封装,第三方客户端框架,ZooKeeper是