「java注册zk」java注册中心设计

博主：adminadmin 2023-01-03 18:30:11 736

本篇文章给大家谈谈java注册zk，以及java注册中心设计对应的知识点，希望对各位有所帮助，不要忘了收藏本站喔。

本文目录一览：

利用ZK来实现一个服务的注册和发现

利用ZK来实现一个服务的注册和发现小结

一、服务的注册

1、先来安装zk,这里可以在windows环境下安装即可，我们就用一个单节点做测试。不用建集群或者伪集群

2、启动zk-server

3、在项目工程里引入操作ZK的客户端框架 curator

4、通过curator的操作命令来链接zk-server，并创建节点

5、进行服务提供方所提供的服务接口在第4部上所建节点进行服务接口的注册(即服务的暴露)

6、启动服务提供方的监听(用来监听消费方发送来的消息)

7、补充：服务的监听其实质还是通过ServerSockt来获取消息,但是实际当中的一些消息中间件并不会这样用。我们知道现如今高性能的IO通信框架netty已经被广泛使用，采用了同步非阻塞的设计思想，以及多路复用器来完成高并发下的网络通信

二、服务的发现

1、消费方开始调用提供方的服务接口

2、调用方式：1可以使用jdk动态代理来调用远程方法

2也可以自己实现一个InvocationHandler,其目的就把远程接口加载到本地，当做本地方法来使用

3、serverceLocator方式

3.1 服务发现步骤

3.2 通过curator来链接zk-server

3.3 访问znode是否存在

3.4 通过zk-api 提供PathChildrenCache、PathChildrenCacheListener来监听znode数据是否有变化

3.5 获取zk-server的ip+port

3.6 通过消费方socket来链接 zk-server 并发送消息

总结：这里的服务注册和发现 完全是用了zk的两个非常重要的特性：znode结构以及事件监听通知机制，我们可以看到

在消费方服务发现里，会有一个监听对应znode的watcher实时动态的负责监听。这里可以理解为：只要znode上有

新的服务方接口，就会通知消费方来调用

缺点：实际项目当中我们知道作为服务注册和发现的组件常用的有ZK、Eureka,而我们并不去优先考虑使用ZK,原因何在？

我们知道ZK\Eureka，这两者都是作为分布式系统当中的一种重要的分布式协调器，而我们所知的二者都满足了分布式系统

CAP理论当中的一个侧重点，ZK主要满足CP,而Euraka是满足AP,这就为ZK不能满足A而带来一定程度的影响，比如当ZK中

master节点挂掉之后，因为集群节点过多，从节点的leader选举占据了大量的时间，而导致zk的不可用，反而大大提升了

系统的风险。

优点：ZK的优点也是基于自身的特点，根据他的特点我们可以去实现一个分布式系统当中常用的 配置管理中心，这里就利用

了他的一致性特点

优化方案，如果服务提供房是一个集群，那么消费方请求可以通过负载均衡，来打到不同的节点上，以防止单一节点过载

dubbo注册zk后是内网地址问题

1、查看当前hostname

hostname

2、修改/etc/hosts文件

vim /etc/hosts

将hostname对应的ip地址改为外网地址

3、重启jar包即可

【注】修改/etc/hosts文件 记得将localhost新增为127.0.0.1  本地ip地址，防止tomcat启动不起来（org.apache.catalina.core.StandardServer.await 无法在地址[localhost]和端口[8005]上创建服务器关闭套接字（基本端口[8005]和偏移量[0]）java.net.BindException: 无法指定被请求的地址 (Bind failed)）

【Zookeeper系列】ZK命令基本使用

在了解 ZK 底层原理之前，咱们先简单了解常用的 ZK 命令，熟悉常用 ZK 命令有利于排查相关问题或了解基于 ZK 自研系统等场景。比如在开发的时候，发现有些Dubbo服务无法被调用，这有可能是服务没有注册到ZK或者断开连接；也有可能公司有自研的系统使用 ZK 作为配置中心，熟悉 ZK 命令就能知道是如何做到服务发现注册和配置动态更新。

话不多说，咱们先来了解常见的 ZK 命令吧！

实际上，ZK并没有help命令，你可以随意敲一两个字符也会这样显示，只不过基于使用Linux的习惯，姑且认为输入help能打印出ZK支持的命令吧。

ls 命令可以查看指定目录下的节点，使用可选的参数，能够更加详细的看到节点的相关信息

stat / 等价于 ls -s /

和 ls 命令相似的，加上-w参数添加监听

在ZK 3.5版本之后，新增了容器和TTL节点，分别是使用 -c 和 -t 创建。所以读者们要注意你当前使用的版本，如果版本低于3.5的，是没有容器和TTL节点。

特别说明一下容器节点和TTL节点的使用：

另外关于 TTL节点 的使用，需要特别注意的是，如果使用默认的配置文件启动zk，想创建有存活时间的节点，比如执行 create -t 10 /test 是会报 KeeperErrorCode = Unimplemented for XXX 这样的错误。解决办法是需要在ZK启动前，先在配置文件加上 extendedTypesEnabled=true 然后重启ZK（集群部署的话，所有ZK都需要修改配置文件再重启）

配置后重启，执行 create -t 10 /test 这样的命令就不会报错啦

例子：get -s /demo

例子：先查询节点版本号，模拟并发下修改同一节点

get -s /demo 可知当前 dataVersion = 1

客户端1：set -v 1 /demo demo-data1

客户端2：set -v 1 /demo demo-data2

客户端1比客户端2先执行，客户端2再执行的话，这时显示报错

-v version：和 set 命令相似，-v 参数用于判断当前操作的版本

例子：先创建一个delNode节点，然后删除

在前面使用create命令的时候，有一个acl参数是设置节点权限的，那么我们应该怎么设置？

举个例子： create /testAcl demo world:anyone:crwda

这行命令的意思是，创建 testAcl 这个节点，节点值为demo，其权限策略是所有人都可以执行 crwda 操作。那么接下来，咱们先看下 ACL 是什么东东？

ACL 全称是 Access Control List ，也就是访问控制列表，ACL可以设置节点的操作权限。那么控制权限的粒度是怎样呢？

对于节点 ACL 权限控制，是通过使用： scheme:id:perm 来标识（也就是例子中的格式 - world:anyone:crwda），其含义是：

Scheme 有哪些授权策略？

ID 授权对象有哪些？

Permission 权限有哪些？

根据上面的参数可知，我们可以通过给所有人、特定的账号密码、特定的 ip 设置节点权限，这样能够更加方面地管理节点的访问。

值得注意的是，节点可以设置多种授权策略，但对于上下节点而言，权限的设置只对当前节点有效。换言之，权限不存在继承关系，即使节点被设置权限，但不会影响上下节点原来的权限！

上面执行了 create /testAcl demo world:anyone:crwda 命令给节点设置权限，那怎么看节点的权限咧？

很简单，执行 getAcl 节点路径 就可以查看对应节点的权限，比如 getAcl /testAcl，执行结果如下

除了在执行create命令创建节点的时候设置权限，还可以通过 setAcl 指定节点设置权限，比如我想指定/testAcl这个节点只可以通过特定 IP操作，并且限制执行权限为crdw，那么可以执行 setAcl /testAcl ip:127.0.0.1:crwd ，再次执行 getAcl /testAcl 结果如下：

ZK 的命令还有部分没有演示，这并不阻碍咱们学习ZK的原理，先掌握常见的命令，如果日后有其他场景的话，再根据特定的命令学习就可以啦。

无意中发现有 Zookeeper的客户端，感兴趣的读者可以玩一下～ 友情提醒，可能在节点数量很多的时候，打开很慢，甚至卡死，所以这个可视化工具可以在自己本地玩玩，不建议应用在生产上哈。这也侧面的说明，学会 ZK 命令的重要性（认真脸.jpg）

解压缩后，进入ZooInspector的build目录，执行 java -jar zookeeper-dev-ZooInspector.jar 就可以启动工具。

连接上 ZK 后，就可以看到节点的信息和节点的ACL，具体玩法，可以再自己摸索哈～

好了，以上是 ZK 常见命令的基本使用和可视化工具的基本使用。

参考资料：

《从Paxos到Zookeeper分布式一致性原理与实践》

如果觉得文章不错的话，麻烦点个赞哈，你的鼓励就是我的动力！对于文章有哪里不清楚或者有误的地方，欢迎在评论区留言~

利用java+zk做一个登陆界面，怎么样将zk界面获取的用户名，密码等信息导入到Java的包中。

我就学过spring 不过应该差不多 你给用户名和密码加name 然后在MyEclipse中request.get 就能接收到

zk是什么意思？

1、ZK是一套以 AJAX/XUL/Java 为基础的网页应用程序开发框架，用于丰富网页应用程序的使用界面。

2、ZK是科视界股份有限公司注册申请的品牌，品牌产品有光导电子液位仪。

3、zk电影网，主要为广大影视迷提供最新最好看的电视剧、电影、动画片及播放服务。网站内容绿色健康，页面简洁大方。无广告无弹窗，24小时安全监控，保证没病毒没不良内容。

ZK发展理念

zk电影网自2012年07月上线以来，经历了种种不同在困难，在风格设计与内容发布方面我投入了不少成本与精力之外，更是网站管理人员对网站的精心维护，然而，网站的日流量正在日益飙升，努力打造成为一个广大网民喜欢的无广告弹窗、绿色安全的电影体验网站。

ZK程序包含了一个以AJAX为基础、事件驱动（event-driven）、高互动性的引擎。

以上内容参考：百度百科-ZK （程序）、百度百科-ZK （商标）、百度百科-zk电影网

zookeeper怎么用java创建临时节点

基本操作

下面给出基本的操作 ZooKeeper 的示例代码，这样你就能对 ZooKeeper 有直观的认识了。下面的清单包括了创建与 ZooKeeper 服务器的连接以及最基本的数据操作：

ZooKeeper 基本的操作示例

// 创建一个与服务器的连接

ZooKeeper zk = new ZooKeeper("localhost:" + CLIENT_PORT,

ClientBase.CONNECTION_TIMEOUT, new Watcher() {

// 监控所有被触发的事件

public void process(WatchedEvent event) {

System.out.println("已经触发了" + event.getType() + "事件！");

}

});

// 创建一个目录节点

zk.create("/testRootPath", "testRootData".getBytes(), Ids.OPEN_ACL_UNSAFE,

CreateMode.PERSISTENT);

// 创建一个子目录节点

zk.create("/testRootPath/testChildPathOne", "testChildDataOne".getBytes(),

Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);

System.out.println(new String(zk.getData("/testRootPath",false,null)));

// 取出子目录节点列表

System.out.println(zk.getChildren("/testRootPath",true));

// 修改子目录节点数据

zk.setData("/testRootPath/testChildPathOne","modifyChildDataOne".getBytes(),-1);

System.out.println("目录节点状态：["+zk.exists("/testRootPath",true)+"]");

// 创建另外一个子目录节点

zk.create("/testRootPath/testChildPathTwo", "testChildDataTwo".getBytes(),

Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);

System.out.println(new String(zk.getData("/testRootPath/testChildPathTwo",true,null)));

// 删除子目录节点

zk.delete("/testRootPath/testChildPathTwo",-1);

zk.delete("/testRootPath/testChildPathOne",-1);

// 删除父目录节点

zk.delete("/testRootPath",-1);

// 关闭连接

zk.close();

输出的结果如下：

已经触发了 None 事件！

testRootData

[testChildPathOne]

目录节点状态：[5,5,,,0,1,0,0,12,1,6]

已经触发了 NodeChildrenChanged 事件！

testChildDataTwo

已经触发了 NodeDeleted 事件！

已经触发了 NodeDeleted 事件！

当对目录节点监控状态打开时，一旦目录节点的状态发生变化，Watcher 对象的 process 方法就会被调用。

关于java注册zk和java注册中心设计的介绍到此就结束了，不知道你从中找到你需要的信息了吗 ？如果你还想了解更多这方面的信息，记得收藏关注本站。

标签：