代做外国空间网站,杭州的地区代码,江苏宏远建设集团网站,免费的国产cadZookeeper是什么 官方文档上这么解释zookeeper#xff0c;它是一个分布式服务框架#xff0c;是Apache Hadoop 的一个子项目#xff0c;它主要是用来解决分布式应用中经常遇到的一些数据管理问题#xff0c;如#xff1a;统一命名服务、状态同步服务、集群管理、分布式应用…Zookeeper是什么 官方文档上这么解释zookeeper它是一个分布式服务框架是Apache Hadoop 的一个子项目它主要是用来解决分布式应用中经常遇到的一些数据管理问题如统一命名服务、状态同步服务、集群管理、分布式应用配置项的管理等。 上面的解释有点抽象简单来说zookeeper文件系统监听通知机制。 1、 文件系统 Zookeeper维护一个类似文件系统的数据结构 每个子目录项如 NameService 都被称作为 znode(目录节点)和文件系统一样我们能够自由的增加、删除znode在一个znode下增加、删除子znode唯一的不同在于znode是可以存储数据的。
有四种类型的znode PERSISTENT-持久化目录节点 客户端与zookeeper断开连接后该节点依旧存在 PERSISTENT_SEQUENTIAL-持久化顺序编号目录节点 客户端与zookeeper断开连接后该节点依旧存在只是Zookeeper给该节点名称进行顺序编号 EPHEMERAL-临时目录节点 客户端与zookeeper断开连接后该节点被删除 EPHEMERAL_SEQUENTIAL-临时顺序编号目录节点 客户端与zookeeper断开连接后该节点被删除只是Zookeeper给该节点名称进行顺序编号
2、 监听通知机制
客户端注册监听它关心的目录节点当目录节点发生变化数据改变、被删除、子目录节点增加删除时zookeeper会通知客户端。
就这么简单下面我们看看Zookeeper能做点什么呢
Zookeeper能做什么
zookeeper功能非常强大可以实现诸如分布式应用配置管理、统一命名服务、状态同步服务、集群管理等功能我们这里拿比较简单的分布式应用配置管理为例来说明。
假设我们的程序是分布式部署在多台机器上如果我们要改变程序的配置文件需要逐台机器去修改非常麻烦现在把这些配置全部放到zookeeper上去保存在 zookeeper 的某个目录节点中然后所有相关应用程序对这个目录节点进行监听一旦配置信息发生变化每个应用程序就会收到 zookeeper 的通知然后从 zookeeper 获取新的配置信息应用到系统中。 如上你大致应该了解zookeeper是个什么东西大概能做些什么了我们马上来学习下zookeeper的安装及使用并开发一个小程序来实现zookeeper这个分布式配置管理的功能。
Zookeeper单机模式安装
Step1配置JAVA环境检验环境java -version
Step2下载并解压zookeeper # cd /usr/local # wget http://mirror.bit.edu.cn/apache/zookeeper/stable/zookeeper-3.4.12.tar.gz # tar -zxvf zookeeper-3.4.12.tar.gz # cd zookeeper-3.4.12 Step3重命名配置文件zoo_sample.cfg
# cp conf/zoo_sample.cfg conf/zoo.cfg Step4启动zookeeper
# bin/zkServer.sh start Step5检测是否成功启动用zookeeper客户端连接下服务端
# bin/zkCli.sh Zookeeper使用
使用客户端命令操作zookeeper
1、使用 ls 命令来查看当前 ZooKeeper 中所包含的内容 2、创建一个新的 znode 使用 create /zkPro myData 3、再次使用 ls 命令来查看现在 zookeeper 中所包含的内容 4、下面我们运行 get 命令来确认第二步中所创建的 znode 是否包含我们所创建的字符串 5、下面我们通过 set 命令来对 zk 所关联的字符串进行设置 6、下面我们将刚才创建的 znode 删除 使用Java API操作zookeeper
使用Java API操作zookeeper需要引用下面的包 下面我们来实现上面说的分布式配置中心
1、在zookeeper里增加一个目录节点并且把配置信息存储在里面 2、启动两个zookeeper客户端程序代码如下所示 import java.util.concurrent.CountDownLatch; import org.apache.zookeeper.WatchedEvent; import org.apache.zookeeper.Watcher; import org.apache.zookeeper.Watcher.Event.EventType; import org.apache.zookeeper.Watcher.Event.KeeperState; import org.apache.zookeeper.ZooKeeper; import org.apache.zookeeper.data.Stat; /** * 分布式配置中心demo * author * */ public class ZooKeeperProSync implements Watcher { private static CountDownLatch connectedSemaphore new CountDownLatch(1); private static ZooKeeper zk null; private static Stat stat new Stat(); public static void main(String[] args) throws Exception { //zookeeper配置数据存放路径 String path /username; //连接zookeeper并且注册一个默认的监听器 zk new ZooKeeper(192.168.31.100:2181, 5000, // new ZooKeeperProSync()); //等待zk连接成功的通知 connectedSemaphore.await(); //获取path目录节点的配置数据并注册默认的监听器 System.out.println(new String(zk.getData(path, true, stat))); Thread.sleep(Integer.MAX_VALUE); } public void process(WatchedEvent event) { if (KeeperState.SyncConnected event.getState()) { //zk连接成功通知事件 if (EventType.None event.getType() null event.getPath()) { connectedSemaphore.countDown(); } else if (event.getType() EventType.NodeDataChanged) { //zk目录节点数据变化通知事件 try { System.out.println(配置已修改新值为 new String(zk.getData(event.getPath(), true, stat))); } catch (Exception e) { } } } } } 两个程序启动后都正确的读取到了zookeeper的/username目录节点下的数据qingfeng
3、我们在zookeeper里修改下目录节点/username下的数据 修改完成后我们看见两个程序后台都及时收到了他们监听的目录节点数据变更后的值如下所示 Zookeeper集群模式安装
本例搭建的是伪集群模式即一台机器上启动三个zookeeper实例组成集群真正的集群模式无非就是实例IP地址不同搭建方法没有区别
Step1配置JAVA环境检验环境java -version
Step2下载并解压zookeeper # cd /usr/local # wget http://mirror.bit.edu.cn/apache/zookeeper/stable/zookeeper-3.4.12.tar.gz # tar -zxvf zookeeper-3.4.12.tar.gz # cd zookeeper-3.4.12 Step3重命名 zoo_sample.cfg文件
# cp conf/zoo_sample.cfg conf/zoo-1.cfg Step4修改配置文件zoo-1.cfg原配置文件里有的修改成下面的值没有的则加上 # vim conf/zoo-1.cfg dataDir/tmp/zookeeper-1 clientPort2181 server.1127.0.0.1:2888:3888 server.2127.0.0.1:2889:3889 server.3127.0.0.1:2890:3890 配置说明
tickTime这个时间是作为 Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔也就是每个 tickTime 时间就会发送一个心跳。initLimit这个配置项是用来配置 Zookeeper 接受客户端这里所说的客户端不是用户连接 Zookeeper 服务器的客户端而是 Zookeeper 服务器集群中连接到 Leader 的 Follower 服务器初始化连接时最长能忍受多少个心跳时间间隔数。当已经超过 10个心跳的时间也就是 tickTime长度后 Zookeeper 服务器还没有收到客户端的返回信息那么表明这个客户端连接失败。总的时间长度就是 10*200020 秒syncLimit这个配置项标识 Leader 与 Follower 之间发送消息请求和应答时间长度最长不能超过多少个 tickTime 的时间长度总的时间长度就是 5*200010秒dataDir顾名思义就是 Zookeeper 保存数据的目录默认情况下Zookeeper 将写数据的日志文件也保存在这个目录里。clientPort这个端口就是客户端连接 Zookeeper 服务器的端口Zookeeper 会监听这个端口接受客户端的访问请求。server.ABCD其中 A 是一个数字表示这个是第几号服务器B 是这个服务器的 ip 地址C 表示的是这个服务器与集群中的 Leader 服务器交换信息的端口D 表示的是万一集群中的 Leader 服务器挂了需要一个端口来重新进行选举选出一个新的 Leader而这个端口就是用来执行选举时服务器相互通信的端口。如果是伪集群的配置方式由于 B 都是一样所以不同的 Zookeeper 实例通信端口号不能一样所以要给它们分配不同的端口号。
Step4再从zoo-1.cfg复制两个配置文件zoo-2.cfg和zoo-3.cfg只需修改dataDir和clientPort不同即可 # cp conf/zoo-1.cfg conf/zoo-2.cfg # cp conf/zoo-1.cfg conf/zoo-3.cfg # vim conf/zoo-2.cfg dataDir/tmp/zookeeper-2 clientPort2182 # vim conf/zoo-2.cfg dataDir/tmp/zookeeper-3 clientPort2183 Step5标识Server ID
创建三个文件夹/tmp/zookeeper-1/tmp/zookeeper-2/tmp/zookeeper-2在每个目录中创建文件myid 文件写入当前实例的server id即1.2.3 # cd /tmp/zookeeper-1 # vim myid 1 # cd /tmp/zookeeper-2 # vim myid 2 # cd /tmp/zookeeper-3 # vim myid 3 Step6启动三个zookeeper实例 # bin/zkServer.sh start conf/zoo-1.cfg # bin/zkServer.sh start conf/zoo-2.cfg # bin/zkServer.sh start conf/zoo-3.cfg Step7检测集群状态也可以直接用命令“zkCli.sh -server IP:PORT”连接zookeeper服务端检测 至此我们对zookeeper就算有了一个入门的了解当然zookeeper远比我们这里描述的功能多比如用zookeeper实现集群管理分布式锁分布式队列zookeeper集群leader选举等等
推荐阅读https://www.roncoo.com/course/view/255bac222b1b4300b42838b58fea3a2e
文章来源https://my.oschina.net/u/3796575/blog/1845035 --------------------- 作者java_66666 来源CSDN 原文https://blog.csdn.net/java_66666/article/details/81015302 版权声明本文为作者原创文章转载请附上博文链接 内容解析ByCSDN,CNBLOG博客文章一键转载插件
