公司网站域名查询,海外域名注册网站,网络广告推广策划书,炫酷业务网站Zookeeper简介Zookeeper是Hadoop的一个子项目#xff0c;它是分布式系统中的协调系统。简单来说就是一个Zookeeper注册同步中心#xff0c;内部结构为一个树形目录#xff0c;每个节点上可以存放一定量(默认的数据量上限是1M#xff0c;但是可以通过调整参数修改)的数据它是分布式系统中的协调系统。简单来说就是一个Zookeeper注册同步中心内部结构为一个树形目录每个节点上可以存放一定量(默认的数据量上限是1M但是可以通过调整参数修改)的数据客户端(一段通过Zookeeperapi编写的程序或者一个cmd和shell窗口)连接Zookeeper后可以在任何节点上注册监听(watcher)当节点被删除或者节点上的数据有变化时Zookeeper会主动触发注册在当前节点上的监听程序。同时Zookeeper类似于文件系统各个节点都可以配置不同的读写访问权限。zookeeper本身是支持多个zookeeper组成集群利用选举机制选出负责不同职责的角色本文暂不涉及。案例备注由于全文粘贴代码实在不好排版本文代码相关部分只介绍了相关片段完整的请下载后查看。界面示例(动效)本文利用Zookeeper节点可存放数据以及节点可监听的机制借助WebSocket实现对多个服务器的实时监控。具体web端效果如下(由于是模拟界面略显粗糙)可以同时打开多个浏览器接收WebSocket推送的实时监控数据。实现逻辑实现过程本文用到maven以及websocket这两部分内容本文只做配置介绍相关知识需自己提前掌握。同时zookeeper的详细命令和api也不做详细解释可自己试验。环境eclispe Oxygen Release (4.7.0)maven 3.2.2Zookeeper3.4.13win10环境(一般线上都是linux环境这里为了省事所有都在自己的笔记本上折腾的所以用了win环境)1、Zookeeper的安装安装比较简单这里略过下载后解压配置zoo.cfg里面的目录参数完后就可以启动了。2、启动Zookeeper打开cmd窗口运行Zookeeper安装目录bin下的zkServer.cmd即可。也可写个bat文件方便每次使用内容(保存即可其中d:zookeeper-3.4.13bin是我的zookeeper的bin目录)如下cd d:zookeeper-3.4.13bind:zkServer.cmdpause3、创建根目录通过cmd连接到Zookeeper创建更目录/servers也可通过java代码来创建。client的bat启动内容参考如下cd d:zookeeper-3.4.13bind:zkCli.cmd -server 127.0.0.1:2181pause回车之后通过命令create /server serverlist 完成根节点的创建 后面所有待监控的服务器都在此节点下创建子节点(临时节点)。关于zookeeper节点的类型也请自行脑补。这里根节点为持久化节点服务器数据节点为临时节点是因为服务器程序在于zookeeper断开后需要删除节点这样才监控程序才能知道服务器下线了。当然实际线上应该都会采用持久化节点然后通过状态数据来判断这里就偷懒了。3、代码编写maven配置整个示例有2个项目组成一个是模拟服务器的程序(定时采集监控指标把指标数据更新到node上)一个是监控程序(用于监控zookeeper节点变化并获取节点数据计算阈值并通过Websocket推送数据到浏览器)。business-server(服务器指标采集程序)的maven配置只依赖zookeeper的jarbusiness-server-monitor(监控程序)的maven配置由于有web界面所以需依赖Servlet、JavaEE相关包同时容器采用了maven的jetty插件关于maven配置jetty以及如何启动可以参考上一篇文章中的相关介绍模块化编程及Maven配置最佳实践之一。当然实现Websocket的方式有很多比如SpringMvcSpringBoot等等这里为了防止太多干扰就用了原生写法。具体maven配置如下1、business-server(服务器指标采集程序) 代码片段代码逻辑为启动后(main方法)连接zookeeper并建立临时节点同时初始化数据之后启动模拟指标采集的线程间隔一段时间生成随机指标数据。创建临时节点代码片段其中ACL是zookeeper的节点访问权限配置也需要自行脑补。模拟指标变化并将数据更新到节点上其中ServerData是我自己创建的bean对象用于存放服务器指标如下主要包含3个模拟指标cpu内存磁盘可自己添加。指标和zookeeper无关。至此采集程序代码就结束了。2、business-server-monitor(监控程序)实时监控zookeeper节点变化并推送数据的代码片段项目启动采用了JavaEE的ServletContextListener监听启动的方式来启动和Zookeeper的连接需要在web.xml配置这个Listener。继承ServletContextListener当jetty容器初始化后触发建立和zookeeper的连接并注册监听然后通过Zookeeper api中的的getChildren获取节点数据并启动监听List servers zk.getChildren(ServerData.serverRootNode, true);当节点发生数据变化时触发监听的process方法process方法获取根节点下的所有子节点的数据并封装成ServerData对象列表用于websocket推送。之后通过Websocket推送到浏览器Websocket配置很简单只需要注释上先关annotation(ServerEndpoint)即可无需其他配置容器启动时会自行扫描到此类。推送数据这里就简单了拼接成了html界面上就直接放在div就行了。3、monitor.jsp获取实时监控数据以上便是这个例子的完成介绍过程。
