博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Zookeeper_阅读源码第一步_在 IDE 里启动 zkServer(单机版)
阅读量:5330 次
发布时间:2019-06-14

本文共 2065 字,大约阅读时间需要 6 分钟。

 
Zookeeper是开源的,如果想多了解Zookeeper或看它的源码,最好是能找到它的源码并在 IDE 里启动,可以debug看它咋执行的,能够帮助你理解其原理。

准备源码

所以我们很容易搞到它的源码,例如我们从 源码 或 从 获取可运行版本的压缩包(内含源码)。这里我下载的是3.4.13版本的,从GitHub拉取源码在idea运行时,编译不能通过,缺少类,原因是有些类需要data包下的类,但是没有这个data包,所以编译过不了,也就无法测试。

 
所以选择第二种,下载到 zookeeper-3.4.13.tar.gz 然后解压,和从GitHub上下载的还是有些差别的。
 

导入到IDE

然后将下载好的源码导入到idea。需创建resources目录把 conf 目录下的 log4j.properties 复制到该目录下,否则启动异常报找不到log4j.properties的错。

准备启动

然后我们找到 org.apache.zookeeper.server.quorum.QuorumPeerMain 这个类,这个是 zookeeper 的主入口,当你用脚本启动时其实运行的也是这个类。
 
题外话,看看启动脚本。
 
zkCli.sh脚本文件
 

 

zkCli.cmd

 

回来,我们打开这个类会看到有个main方法,看注释,我们需要在启动时指定配置文件。
 
/**     * To start the replicated server specify the configuration file name on     * the command line.要启动复制的服务器,请在命令行上指定配置文件名。     * @param args path to the configfile 配置文件的路径     */    public static void main(String[] args) {        QuorumPeerMain main = new QuorumPeerMain();        try {            main.initializeAndRun(args);        } //some catchs...          //some codes ...      }        LOG.info("Exiting normally");        System.exit(0);    }

配置启动参数

首先运行这个类的main方法,会报错,说非法参数哦,如下

 

配置一下,在 Program arguments里添加配置文件的路径。

 

正式启动

再启动就成功了

测试是否启动成功

我们开启客户端连一下

 

连上了,并且有三个节点。

这段代码是一些初始化,并判断是单机启动还是集群启动

protected void initializeAndRun(String[] args) throws ConfigException, IOException {
QuorumPeerConfig config = new QuorumPeerConfig(); if (args.length == 1) {
config.parse(args[0]); } // Start and schedule the the purge task   DatadirCleanupManager purgeMgr = new DatadirCleanupManager(config     .getDataDir(), config.getDataLogDir(), config     .getSnapRetainCount(), config.getPurgeInterval()); purgeMgr.start(); if (args.length == 1 && config.servers.size() > 0) {
System.out.println("=======集群模式======="); runFromConfig(config); } else {
System.out.println("=======单机模式======="); LOG.warn("Either no config or no quorum defined in config, running "           + " in standalone mode"); ZooKeeperServerMain.main(args); } }

 

 
 

单机版启动,到这里就结束了。篇幅原因,集群版下一篇再见。


转载请注明出处

 

转载于:https://www.cnblogs.com/ibigboy/p/11353031.html

你可能感兴趣的文章
iOS block 基本用法及代替代理
查看>>
jQuery中$.ajax知识点总结
查看>>
iphone 弹出键盘,文本框自动向上移动。
查看>>
微信小程序开发7-JavaScript脚本
查看>>
leetcode-78-子集
查看>>
Kotlin 字符模板
查看>>
模仿mybatis,用jdk proxy实现接口
查看>>
LINUX进程小结
查看>>
公告会看门道:四个不同的厨师和史蒂夫·乔布斯
查看>>
HDU 1983 BFS&&DFS
查看>>
c++开源项目汇总
查看>>
python yield返回多个值
查看>>
每日站立会议及今日份任务
查看>>
R12 付款过程请求-功能和技术信息 (文档 ID 1537521.1)
查看>>
洛谷 4364 [九省联考2018]IIIDX
查看>>
洛谷 3870 [TJOI2009]开关
查看>>
【牛客-16643】统计数字(简单排序)
查看>>
www.aaa.com/index.html跳转www.aaa.com设置
查看>>
ssdb binlog机制 存疑
查看>>
Vue 2.0 组件库总结
查看>>