Zookeeper 允许客户端向服务端的某个 Znode 注册一个 Watcher 监听,当服务 端的一些指定事件触发了这个 Watcher,服务端会向指定客户端发送一个事件通 知来实现分布式的通知功能,然后客户端根据 Watcher 通知状态和事件类型做出 业务上的改变。 工作机制: 1、客户端注 ...
分类:
其他好文 时间:
2020-07-20 10:45:05
阅读次数:
72
NameNode和Zookeeper的format
分类:
其他好文 时间:
2020-07-19 11:56:56
阅读次数:
99
一、下载及安装配置 JDK (Kafka依赖于Zookeeper服务,而Zookeeper的运营依赖JDK) 1.地址:https://www.oracle.com/java/technologies/javase-jdk14-downloads.html 下载windows可执行文件,直接点击安装 ...
前提:需要提前下载JDK 1.下载地址:https://kafka.apache.org/ 2.需要先启动ZooKeeper服务器(可以通过与kafka打包在一起的便捷脚本来快速简单地创建一个单节点ZooKeeper实例。) 命令: bin\windows\zookeeper-server-star ...
zookeeper目前是构建分布式系统的重要组件 #进入zookeeper命令行 zkCli.sh #查看子节点 ls / #创建临时master节点,创建临时workers节点 create -e /master "master2.example.com:2223" create /workers ...
分类:
其他好文 时间:
2020-07-18 19:59:42
阅读次数:
61
背景: 使用脚本ssh tuge2 ""/opt/zookeeper/apache-zookeeper-3.5.5-bin/bin/zkServer.sh start""的时候,报了如下异常: Exception in thread "main" java.lang.UnsupportedClass ...
分类:
Web程序 时间:
2020-07-18 16:02:45
阅读次数:
122
1.完成环境准备 a.开启hadoop服务 b.开启Mysql服务进入HIVE命令行界面 c.开启zookeeper服务 d.开启hbase服务进入命令行界面 ...
分类:
其他好文 时间:
2020-07-17 11:26:18
阅读次数:
54
1.先看入口在哪里,我们加载自定义的扩展都会写这行代码,那么就从分析ExtensionLoader开始了 ExtensionLoader.getExtensionLoader(XXX.class).getExtension("diyExtension"); 1.1 getExtensionLoade ...
分类:
其他好文 时间:
2020-07-16 21:52:16
阅读次数:
59