java中zookeeper如何使用

这篇文章给大家介绍java中zookeeper如何使用，内容非常详细，感兴趣的小伙伴们可以参考借鉴，希望对大家能有所帮助。

1.引入maven依赖

<dependency>
    <groupId>org.apache.zookeeper</groupId>
    <artifactId>zookeeper</artifactId>
    <version>3.4.6</version>
</dependency>

2.ZooKeeper节点操作

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);//获取节点数据

3.为ZooKeeper节点增加授权访问

1. world：创建节点的默认权限，有唯一的id是anyone授权的时候的模式为 world:anyone:rwadc 表示所有人都对这个节点有rwadc的权限。这里用的是id而不是expression

2. auth 不需要id。不过这里应该用expression来表示。即(scheme:expression:perm)

3. digest 使用用户名:密码编码成md5的方式来作为访问控制列表的id。但是这里id不作为授权语句的一部分，这里也是用expression的方式。用户名: 密码先进行sha1编码后再用base64编码

4. host 使用用户主机名作为访问控制列表的id。但是这里需要注意的是表达式用的是主机名的后缀即可

5. ip 跟主机名类似，这里用客户端的ip地址作为访问控制列表的id。表达式可以用 addr/bits这种方式来设置ip白名单。

3.1 digest模式

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);

3.2 ip模式

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);

3.3 host模式

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);

4.watcher

当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如何使用就分享到这里了，希望以上内容可以对大家有一定的帮助，可以学到更多知识。如果觉得文章不错，可以把它分享出去让更多的人看到。