zookpeer实现对服务器动态上下线的监听

服务器动态上下线程序的工作机制

服务器代码：
补充：volatile关键字：java中一切都是对象，当多个线程操作同一个对象时候，该对象会放在堆内存中，而多个线程相当于在多个栈中，当A线程想要去除对象中的数据并修改，往往不是直接拿对象的值直接改变其内容，而是先把中的对象赋值一份到A线程栈中，然后再对赋值的对象进行修改，最后把赋值对象与堆中的对象进行比较，不同则修改堆中对象，这样当多个线程访问对象时会存在，当A线程修改了堆中赋值对象的值，但还没来得及修改堆中的对象，而B线程此时拿到的仍然是原对象值并没有发生更改，为了避免这种问题。因此同volatile关键字让线程直接获取对象并修改内容无需赋值一份再去修改。

package cn.itcast.bigdata.zkdist;import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;public class DistributedServer {private static final String connectString = "mini1:2181,mini2:2181,mini3:2181";private static final int sessionTimeout = 2000;private static final String parentNode = "/servers";private ZooKeeper zk = null;/*** 创建到zk的客户端连接* * @throws Exception*/public void getConnect() throws Exception {zk = new ZooKeeper(connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent event) {// 收到事件通知后的回调函数（应该是我们自己的事件处理逻辑）System.out.println(event.getType() + "---" + event.getPath());try {zk.getChildren("/", true);} catch (Exception e) {}}});}/*** 向zk集群注册服务器信息* * @param hostname* @throws Exception*/public void registerServer(String hostname) throws Exception {String create = zk.create(parentNode + "/server", hostname.getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL);//当服务断掉时ZooKeeper将此临时节点删除，这样client就不会得到服务的信息了System.out.println(hostname + "is online.." + create);}/*** 业务功能* * @throws InterruptedException*/public void handleBussiness(String hostname) throws InterruptedException {System.out.println(hostname + "start working.....");Thread.sleep(Long.MAX_VALUE);}public static void main(String[] args) throws Exception {// 获取zk连接DistributedServer server = new DistributedServer();server.getConnect();// 利用zk连接注册服务器信息server.registerServer(args[0]);// 启动业务功能server.handleBussiness(args[0]);}}

输出：当args[0]等于weijie1时候，输出如下

log4j:WARN No appenders could be found for logger (org.apache.zookeeper.ZooKeeper).
log4j:WARN Please initialize the log4j system properly.
45null
weijie1is online/servers/server0000000006
weijie1 is starting

客户端代码：

package com.itcast.zookpeer.zk;import java.io.IOException;
import java.util.ArrayList;
import java.util.List;import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooKeeper;public class DistributedClient {private static final String connectString = "weijie1:2181,weijie2:2181,weijie3:2181";private static final int sessionTimeout = 2000;private static final String parentNode = "/servers";private static volatile List<String> serverList; ZooKeeper zk = null;//创建客户端连接private void getConnection() throws Exception {zk = new ZooKeeper(connectString, sessionTimeout, new Watcher(){@Overridepublic void process(WatchedEvent event) {System.out.println(event.getType()+"--"+event.getPath());try{getServerList();}catch(Exception e){}}});}//获取服务器信息列表private void getServerList() throws Exception {//获取服务器子节点的信息，并且对父节点进行监听List<String> server = zk.getChildren(parentNode, true);//先创建一个list来存储服务器信息List<String> servers = new ArrayList<String>();for (String string : server) {byte[] data = zk.getData(parentNode+"/"+string, false, null);servers.add(new String(data));//new String对data进行解析转成字符串类型}serverList = servers;System.out.println(serverList);}private void BundleBusiness() throws Exception {System.out.println("is starting");Thread.sleep(Long.MAX_VALUE);}public static void main(String[] args) throws Exception {DistributedClient distribute = new DistributedClient();distribute.getConnection();distribute.getServerList();distribute.BundleBusiness();}}

输出：

  1. 当启动一次服务器时候此时输出结果
    log4j:WARN No appenders could be found for logger (org.apache.zookeeper.ZooKeeper).
    log4j:WARN Please initialize the log4j system properly.
    None--null
    [weijie1]
    is starting
    [weijie1]
  2. 再启动一次DistributedServer时候输出
    log4j:WARN No appenders could be found for logger (org.apache.zookeeper.ZooKeeper).
    log4j:WARN Please initialize the log4j system properly.
    None--null
    [weijie1]
    is starting
    [weijie1]
    NodeChildrenChanged--/servers
    [weijie1, weijie1]
    分析：当启动两次服务器此时在servers目录下又创建了一个临时带序号的节点，此时总共有两个临时节点，因此输出主机名两次，因为在List<String> server = zk.getChildren(parentNode, true);中多父节点”/servers”进行了监听。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/news/509679.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

ElasticSearch6.x 7.x Elasticdump 在线安装、离线安装

ElasticSearch6.x 7.x Elasticdump 在线安装、离线安装

官网&#xff1a;elasticdump - npm ElasticDump是一个ElasticSearch的数据导入导出开源工具包&#xff0c;方便使用。 官方地址&#xff1a;官方地址&#xff1a;https://github.com/taskrabbit/elasticsearch-dump 一. 安装npm&#xff0c;node # 下载安装包 wget https:/…
阅读更多...
用LuaBridge为Lua绑定C/C++对象

用LuaBridge为Lua绑定C/C++对象

最近为了总结Lua绑定C/C对象的各种方法、第三方库和原理&#xff0c;学习了LuaBridge库为Lua绑定C/C对象&#xff0c;下面是学习笔记&#xff0c;实质是对该库的 Reference Manual 基本上翻译了一遍&#xff0c;学习过程中测试代码&#xff0c;放在 我的github 上。 LuaBridge的…
阅读更多...
H5动画制作流程没写完。。。

H5动画制作流程没写完。。。

通过 keyframes 规则&#xff0c;您能够创建动画。创建动画的原理是&#xff0c;将一套 CSS 样式逐渐变化为另一套样式。在动画过程中&#xff0c;您能够多次改变这套 CSS 样式。以百分比来规定改变发生的时间&#xff0c;或者通过关键词 "from" 和 "to"&a…
阅读更多...
串的基本操作

串的基本操作

#include <iostream> #include <algorithm> #include <cstring> #define sqtrmax 1000 using namespace std; typedef struct { char *data; int length; } sqtr; void StrAssign (sqtr &S, char *chars); //赋值 void Destroy(sq…
阅读更多...
Result window is too large, from + size must be less than or equal to: [10000] but was [12390]. See

Result window is too large, from + size must be less than or equal to: [10000] but was [12390]. See

ES 查询报错 Caused by: java.lang.IllegalArgumentException: Result window is too large, from size must be less than or equal to: [10000] but was [12390]. See the scroll api for a more efficient way to request large data sets. This limit can be set by chan…
阅读更多...
Delta3d插件机制

Delta3d插件机制

Delta3d插件机制主要通过以下两个类实现&#xff1a; class MainWindow;/**Abstract interface class for STAGE plugins*/class Plugin{public:virtual ~Plugin() {} /** Is called after instantiation */virtual void Create() {}/** Is called before destruction */virt…
阅读更多...
java中泛型学习总结

java中泛型学习总结

为什么需要使用泛型: 1):存储任意类型的数据在集合中 ,但是取出来都是Object类型的,此时就得强转.List list new ArrayList();list.add(1); //Interger类型Object ele list.get(0); //现在需要调用Interger类中的方法I nterger num (Interger) ele;System.out.println(num);…
阅读更多...
数据结构实验之栈：行编辑器

数据结构实验之栈：行编辑器

题目描述 一个简单的行编辑程序的功能是&#xff1a;接受用户从终端输入的程序或数据&#xff0c;并存入用户的数据区。 由于用户在终端上进行输入时&#xff0c;不能保证不出差错&#xff0c;因此&#xff0c;若在编辑程序中&#xff0c;“每接受一个字符即存入用户数据区”的…
阅读更多...
CDH、CM下载403，Cloudera收费无法下载解决，CDH安装包下载

CDH、CM下载403，Cloudera收费无法下载解决，CDH安装包下载

CDH下载 6.3.2 链接: https://pan.baidu.com/s/1e1LmRY7aHQSCMJq3Lz6DtA 密码: 1vje --来自百度网盘超级会员V6的分享6.3.1 链接: https://pan.baidu.com/s/1Xsj_zDvuJ12q3pGTY77BRg 密码: f9h3 --来自百度网盘超级会员V6的分享6.2.1 链接: https://pan.baidu.com/s/10s7…
阅读更多...
别说“我已经很努力了”

别说“我已经很努力了”

转自&#xff1a;http://blog.csdn.net/foruok/article/details/40247543 我们程序员的努力与挣扎有时非常尴尬&#xff0c;如果没有结果&#xff0c;都是徒然&#xff0c;都是说不得说不得…… 我自己做项目经理时&#xff0c;干的项目也经常延期……非常惭愧。而延期其实对研…
阅读更多...
Java集合框架-概述

Java集合框架-概述

Java集合框架的由来: 其实在Java2(jdk1.2)之前&#xff0c;Java是没有完整的集合框架的。它只有一些简单的可以自扩展的容器类&#xff0c;比如Vector&#xff0c;Stack&#xff0c;Hashtable等。 为什么存在容器类: 容器类(集合类)可以存储多个数据,既然数组可以存储多个数据…
阅读更多...
MySQL Binlog增量同步工具go-mysql-transfer实现详解

MySQL Binlog增量同步工具go-mysql-transfer实现详解

go-mysql-transfer产品手册:https://www.kancloud.cn/wj596/go-mysql-transfer/2111996 一、 概述 工作需要研究了下阿里开源的MySQL Binlog增量订阅消费组件canal&#xff0c;其功能强大、运行稳定&#xff0c;但是有些方面不是太符合需求&#xff0c;主要有如下三点&#x…
阅读更多...
数据结构实验之栈五：下一较大值（一）

数据结构实验之栈五：下一较大值（一）

题目描述 对于包含n&#xff08;1<n<1000&#xff09;个整数的序列&#xff0c;对于序列中的每一元素&#xff0c;在序列中查找其位置之后第一个大于它的值&#xff0c;如果找到&#xff0c;输出所找到的值&#xff0c;否则&#xff0c;输出-1。 输入 输入有多组&#xf…
阅读更多...
与 C++11 多线程相关的头文件

与 C++11 多线程相关的头文件

C11 新标准中引入了四个头文件来支持多线程编程&#xff0c;他们分别是<atomic> ,<thread>,<mutex>,<condition_variable>和<future>。 <atomic>&#xff1a;该头文主要声明了两个类, std::atomic 和 std::atomic_flag&#xff0c;另外还…
阅读更多...
数据结构实验之栈二：一般算术表达式转换成后缀式

数据结构实验之栈二：一般算术表达式转换成后缀式

题目描述 对于一个基于二元运算符的算术表达式&#xff0c;转换为对应的后缀式&#xff0c;并输出之。输入 输入一个算术表达式&#xff0c;以‘#’字符作为结束标志。输出 输出该表达式转换所得到的后缀式。示例输入 a*b(c-d/e)*f# 示例输出 ab*cde/-f* #include<stdio.h…
阅读更多...
INFINI GATEWAY 极限网关初体验 ElasticSearch 两个集群数据同步

INFINI GATEWAY 极限网关初体验 ElasticSearch 两个集群数据同步

文章目录极限网关-配置说明配置文件日志、数据目录定义入口定义路由定义流程定义资源使用Demo写入两个ES集群极限网关-常见问题shutdown: ORM handler is not registered极限网关地址极限网关-配置说明 极限网关的大部分配置都可以通过 gateway.yml 来进行配置&#xff0c;配置…
阅读更多...
std::thread详解

std::thread详解

转自&#xff1a;http://www.cnblogs.com/haippy/p/3236136.html 上一篇博客《C11 并发指南一(C11 多线程初探)》中只是提到了 std::thread 的基本用法&#xff0c;并给出了一个最简单的例子&#xff0c;本文将稍微详细地介绍 std::thread 的用法。 std::thread 在 <thread&…
阅读更多...
Kafka 详细配置参数说明

Kafka 详细配置参数说明

参数值参数文件描述auto.create.topics.enableserver.properties【说明】是否允许自动创建Topic&#xff0c;若是false&#xff0c;就需要通过命令创建Topic。【默认值】true【取值范围】true或falselog.cleaner.backoff.msserver.properties【说明】检查是否有日志需要清理的时…
阅读更多...
数据结构实验之栈三：后缀式求值

数据结构实验之栈三：后缀式求值

题目描述 对于一个基于二元运算符的后缀表示式&#xff08;基本操作数都是一位正整数&#xff09;&#xff0c;求其代表的算术表达式的值。输入 输入一个算术表达式的后缀式字符串&#xff0c;以‘#’作为结束标志。输出 求该后缀式所对应的算术表达式的值&#xff0c;并输出之…
阅读更多...
std::mutex详解

std::mutex详解

Mutex 又称互斥量&#xff0c;C 11中与 Mutex 相关的类&#xff08;包括锁类型&#xff09;和函数都声明在 <mutex> 头文件中&#xff0c;所以如果你需要使用 std::mutex&#xff0c;就必须包含 <mutex> 头文件。 <mutex> 头文件介绍 Mutex 系列类(四种) st…
阅读更多...
最新文章

Copyright @ 2022~2023