安装配置、api如何进行调用sean-zookeeper所有预习课程讲义2基础

动脑学院【Sean老师】CC01 生产环境中有 üüü

üdist-mavenmavenüüüü

02Zookeeper序参数说12快照文件snapshot的。默认情况下，事务日志也会在这里。建议同时配置参数dataLogDir,事务日志的写性能直接影响34 5溢出，这个请求堆积数还是需要限制下的。(Javasystemproperty:zookeeper.globalOutstandingLimit.)6这个参数。(Javasystemproperty:zookeeper.preAllocSize)02Zookeeper序 参数

说所有服务器在同一时间进行快照而影响性能）(Javasystemproperty: clientPort指定的端口。Newin3.3.0 *tickTime~20*tickTimeNewin序参数志中输出警告信息。默认是1000ms。(Javasystemproperty:fsync.warningthresholdms)Newin照文件的功能，这个参数指定了清理频率，单位是小时，需要配置一个1或更大的整数，默认是0，表示不开启自动清理功能。(NoJavasystemproperty)Newin默认是保留3个。(NoJavasystemproperty)Newin3.4.0由于在以后的版本中，只会留下一种“TCP-basedversionoffast细展开说了。(NoJavasystem变长，因此在这种情况下，有必要适当调大这个参数了。(NoJavasystem02Zookeeper序 参数

说 (NoJavasystem设置为no，这样一来，会大大提高写操作的性能。(Javasystemproperty:zookeeper.leaderServes)。于Leader过程中投票通信。(NoJavasystemproperty)

systemproperty:xTimeout)02Zookeeper序参数说操作》和《ZooKeeper权限控制》一旦服务器上打开这个开头，那么也将失效。(Javasystemproperty:property:端都进行设置才会生效。(Javasystempropertyjute.maxbuffer)CCn会话n数据节点nn nnn会话 ü在Zookeeper中，znode是一个跟以往这个节点或获取数据ü通过客户端可对znode进行增删改查的操作，还可以watcher监ü持久节点ü持久顺序节点ü临时节点ü临时顺序节点

1123456789ACL保障数据的安üworld它下面只有一个id叫anyoneworld:anyone代表任何人，zookeeper üauth:它不需要id,只要是通过authentication的user都 rberos来进行authencation,也支持username/password形式的authentication)üdigest它对应的id为username:BASE64(SHA1(password))，它需要先通过usernamüip它对应的id为客户机的IP地址，设置的时候可以设置一个ip段，比如0/16,表示匹配前16个bit的IPüsuper在这种scheme情况下，对应的id拥有超级权限，可以做任何事情CC shbin/zkServer.sh查看ZKshbin/zkServer.sh

shbin/zkServer.shshbin/zkServer.shzkCli.shserver:2181ZooKeeper输出ZooKeeper的相关环境以及配置信息。命令行工具的一些简单操作如下： 下、文件：ls/使用ls命令来查看当前ZooKeeper中所包含的内 create/zktest"znodezkget/zkznodeset/zk"zkbak"zk递归删除：rmr/zkznodeACL命令常用命nnn ZooKeeper支持某些特定的四字命令字母与其的交互。用来获取ZooKeeper服务的当前状态及相关 net或nc向ZooKeeper提交相应 令：echostat|nc2181来查看哪个节点被选择作为follower或者使用echoruok|nc2181测试是否启动了该Server，若回复imok表示已经启动echodump|nc2181,列 处理的会话和临时节点echokill|nc2181关掉echoreqs|nc2181,列 处理的请求echowchs|nc2181列出服务watch详细信息echowchc|nc2181通session出服务watch详细信息，它的输出是一个相关的会话的列表echowchp|nc2181watchsession径ZooKeepern事务日志可视化java-cp../../zookeeper-3.4.6.jar;../../lib/slf4j-api-1.6.1.jarorg.apache.zookeeper.server.LogFormatterlog.xxxxn数据快照可视化java-cp../../zookeeper-3.4.6.jar;../../lib/slf4j-api-1.6.1.jar CCnZookeeper nnGuavaistojavawhatCuratoristopublicZooKeeper(StringconnectString,intsessionTimeout,WatcherlongsessionId,byte[]sessionPasswd,booleanpublicString/voidcreate(finalStringpath,bytedata[],List<ACL>CreateModecreateMode,StringCallbackcb,ObjectpublicList<String>/voidgetChildren(finalStringpath,WatcherStatstat,Children2Callbackcb,ObjectpublicList<String>/voidgetData(finalStringpath,Watcherwatcher,Statstat,D allbackcb,Objectctx)publicStat/voidsetData(finalStringpath,bytedata[],intStatCallbackcb,Object02ZookeeperpublicStat/voidexists(finalStringpath,WatcherStatCallbackcb,ObjectpublicvoidaddAuthInfo(Stringscheme,byte 02Zookeeper 03ZkClient的mavenzkclient03ZkClient的创建会话（同步，重试publicZkClient(finalStringzkServers,finalintfinalintconnectionTimeout,finalZkSerializerfinallong创建节点（同步，递归创建publicStringcreate(Stringpath,Objectdata,finalList<ACL>acl,CreateModemopublicvoidcreatePersistent(Stringpath,booleancreateParents,List<ACL>acl)publicvoidcreatePersistent(Stringpath,Objectdata,List<ACL>acl)publicStringcreatePersistentSequential(Stringpath,Objectdata,List<ACL>aclpublicvoidcreateEphemeral(Stringpath,Objectdata,List<ACL>acl)删除节点（同步,递归删除publicbooleandelete(Stringpath,intpublicbooleandeleteRecursive(String03ZkClient的获取节点（同步，避免不存在异常publicList<String>getChildren(Stringpublic<T>TreadData(Stringpath,booleanpublic<T>TreadData(Stringpath,StatpublicvoidwriteData(Stringpath,Objectdatat,intpublicStatwriteDataReturnStat(Stringpath,Objectdatat,int检测节点存在（同步publicbooleanexists(String03ZkClient的权限控制（同步publicvoidaddAuthInfo(Stringscheme,finalbyte[]auth);publicvoidsetAcl(finalStringpath,finalList<ACL>acl);1序器 istener1序器 isteneristener istener2304Curator的maven curatorØ对序列化支持不太 04Curator的创建会话（同步，重试 intconnectionTimeoutMs,RetryPolicy ØretryPolicy RetryOneTime:只重连一次 RetryNTime:指定重连的次数 RetryUtilElapsed:指定最大重连超时时间和重连时间间隔,间歇性重连直到超时或 成功 ExponentialBackoffRetry:基于"backoff"方式重连,和RetryUtilElapsed的区别是重连的时间间隔是动 BoundedExponentialBackoffRetry:同ExponentialBackoffRetry,增加了最大重试次数的控04Curator的

.forPath(path, o,04Curator的 Cache是curator中对事 的包装，对事件 可以近似看做是本地缓存视图 zk视图的对比过 NodeCache节点缓存用于处理节点本身的变化，回调接口 PathChildrenCache子节点缓存