重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
这篇文章给大家介绍java中zookeeper如何使用,内容非常详细,感兴趣的小伙伴们可以参考借鉴,希望对大家能有所帮助。
目前创新互联公司已为成百上千的企业提供了网站建设、域名、网页空间、网站托管、服务器租用、企业网站设计、沧源网站维护等服务,公司将坚持客户导向、应用为本的策略,正道将秉承"和谐、参与、激情"的文化,与客户和合作伙伴齐心协力一起成长,共同发展。
org.apache.zookeeper zookeeper 3.4.6
ZooKeeper zooKeeper = new ZooKeeper("127.0.0.1:2181", 4000, null);//连接zookeeper服务 zooKeeper.create("/test", "20190725", ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);//创建名称是test的节点 zooKeeper.setData("/test", "20190726", -1);//更新节点的数据 zooKeeper.delete("/test", -1);//删除节点Stat stat = zooKeeper.exists(path, false);//查看节点是否存在 zooKeeper.getData("/test", false, stat);//获取节点数据
world:创建节点的默认权限,有唯一的id是anyone授权的时候的模式为 world:anyone:rwadc
表示所有人都对这个节点有rwadc的权限。这里用的是id
而不是expression
auth 不需要id。不过这里应该用expression
来表示。即(scheme:expression:perm)
digest 使用用户名:密码
编码成md5的方式来作为访问控制列表的id。但是这里id不作为授权语句的一部分,这里也是用expression
的方式。用户名: 密码先进行sha1编码后再用base64编码
host 使用用户主机名作为访问控制列表的id。但是这里需要注意的是表达式用的是主机名的后缀即可
ip 跟主机名类似,这里用客户端的ip地址作为访问控制列表的id。表达式可以用 addr/bits
这种方式来设置ip白名单。
Id id = new Id("digest", DigestAuthenticationProvider.generateDigest("zookeeper:123456")); ACL acl = new ACL(); acl.setPerms(Perms.ALL); acl.setId(id); zooKeeper.setACL("/test", Lists.newArrayList(acl), -1);
Id id = new Id("ip", "198.16.1.25");//支持ip段,如:198.16.1.25/16 ACL acl = new ACL(); acl.setPerms(Perms.ALL); acl.setId(id); zooKeeper.setACL(path, Lists.newArrayList(acl), -1);
Id id = new Id("host", "baidu.com"); ACL acl = new ACL(); acl.setPerms(Perms.ALL); acl.setId(id); zooKeeper.setACL(path, Lists.newArrayList(acl), -1);
当zookeeper节点发生变化时,执行监听事件
public class ZkWatcher implements Watcher { private static Logger logger = LoggerFactory.getLogger(ZkWatcher.class); @Override public void process(WatchedEvent watchedEvent) { if (watchedEvent.getType() == EventType.NodeDeleted) { logger.info("删除节点" + watchedEvent.getPath()); } if (watchedEvent.getType() == EventType.NodeCreated) { logger.info("创建节点" + watchedEvent.getPath()); } if (watchedEvent.getType() == EventType.NodeDataChanged) { logger.info("更新节点" + watchedEvent.getPath()); } if (watchedEvent.getType() == EventType.NodeChildrenChanged) { logger.info("子节点发生变化" + watchedEvent.getPath()); } } } 第一种方式:zookeeper.register(new ZkWatcher()); 第二种方式:ZooKeeper zk = new ZooKeeper("127.0.0.1:2181", 4000, new ZkWatcher());
关于java中zookeeper如何使用就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。