ZOOKEEPER集群搭建及测试

①. zk是由java编写的需要java运行环境,所以大家首先要安装JDK

具体安装步骤,不再赘述

     ②. 首先进入zk的conf目录,将zoo_sample.cfg文件改名为zoo.cfg,并修改内容

tickTime=2000 #ZK中的一个时间单元。ZK中所有时间都是以这个时间单元为基础,进行整数倍配置的。例如,session的最小超时时间是2*tickTime。
initLimit=5 #Leader允许Follower在 initLimit 时间内完成这个工作
syncLimit=2 #心跳检测,Leader发出心跳包在syncLimit之后,还没有从F那里收到响应,那么就认为这个F已经不在线了
dataDir=/usr/local/zookeeper/data #我们需要在此目录下创建myid用于标识zk节点,对应server.x,事务日志也会存储在这里
dataLogDir=/usr/local/zookeeper/logs #事务日志输出目录
clientPort=2181 #对外提供的端口号,默认2181
server.1=zk1:2888:3888 #server.x跟myid对应,两个通信端口第一个端口用于F和L之间的数据同步和其它通信,第二个端口用于Leader选举过程中投票通信。
server.2=zk2:2888:3888
server.3=zk3:2888:3888

      ③. 设置myid, 在zk根目录创建前面zoo.cfg中配置的dataDir指定的文件夹,创建myid,myid中的值需与server.x保持一致

    ④. 都设置完之后,记得检查一下各节点端口是否打通,并且关闭防火墙

     ⑤. 进入bin目录,执行 sh zkServer.sh start &  命令,通过JPS检查是否启动,并且查看日志:

  tail -fn 100 zookeeper.out,第一个节点启动,会报如下异常:

此时不做理会,当所有节点启动完成之后即恢复正常

2017-09-14 14:50:24,993 [myid:2] - INFO  [QuorumPeer[myid=2]/0:0:0:0:0:0:0:0:2181:QuorumPeer$QuorumServer@149] - Resolved hostname: 192.168.116.127 to address: /zk2
2017-09-14 14:50:24,995 [myid:2] - WARN  [QuorumPeer[myid=2]/0:0:0:0:0:0:0:0:2181:QuorumCnxManager@400] - Cannot open channel to 3 at election address /zk2:3888
java.net.ConnectException: 拒绝连接
	at java.net.PlainSocketImpl.socketConnect(Native Method)
	at java.net.AbstractPlainSocketImpl.doConnect(AbstractPlainSocketImpl.java:339)
	at java.net.AbstractPlainSocketImpl.connectToAddress(AbstractPlainSocketImpl.java:200)
	at java.net.AbstractPlainSocketImpl.connect(AbstractPlainSocketImpl.java:182)
	at java.net.SocksSocketImpl.connect(SocksSocketImpl.java:392)
	at java.net.Socket.connect(Socket.java:579)
	at org.apache.zookeeper.server.quorum.QuorumCnxManager.connectOne(QuorumCnxManager.java:381)
	at org.apache.zookeeper.server.quorum.QuorumCnxManager.connectAll(QuorumCnxManager.java:426)
	at org.apache.zookeeper.server.quorum.FastLeaderElection.lookForLeader(FastLeaderElection.java:843)
	at org.apache.zookeeper.server.quorum.QuorumPeer.run(QuorumPeer.java:822)

,使用 sh zkServer.sh status检查节点状态,一般myid大的为leader

    客户端验证是否成功:

private final static String CONNECT_STRING = "zk1:2181,zk2:2181,zk3:2181";
	private final static int SESSION_TIMEOUT = 2000;
	private ZooKeeper zk = null;

	@Before
	public void init() throws Exception {
		zk = new ZooKeeper(CONNECT_STRING, SESSION_TIMEOUT, new ZKWatcher());
	}

	@Test
	public void create() throws Exception {
		String cResponse = zk.create("/app-01", "hello this is app-01 node".getBytes(),
		        Ids.OPEN_ACL_UNSAFE,
		        CreateMode.PERSISTENT);
		Thread.sleep(1000);
		System.out.println("--->create:" + cResponse);
	}

	@Test
	public void get() throws Exception {
		System.out.println(zk.getChildren("/", new ZKWatcher()));
	}

	@Test
	public void set() throws Exception {
		System.out.println(zk.setData("/app-01", "this is app-01 node.update count 4".getBytes(), -1));
	}

	@Test
	public void getData() throws Exception {
		System.out.println(new String(zk.getData("/app-01/hello", new ZKWatcher(), null)));
//		Thread.sleep(Long.MAX_VALUE);
	}

或使用工具:ZooInspector连接,检查使用情况以及服务端状态

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏惨绿少年

AWStats日志分析系统

AWStats是一款功能强大且功能强大的免费工具,可以图形方式生成高级Web,流媒体,ftp或邮件服务器统计信息。此日志分析器用作CGI或命令行, 并在几个图形...

1341
来自专栏菩提树下的杨过

gradle项目中profile的实现

gradle中并没有直接类似maven中的profile支持,只能变通的用其它方法来处理,在打包不同环境的应用时,通常会遇到二类问题: 一、不同的环境依赖的ja...

2136
来自专栏FreeBuf

使用fuzzDB进行web安全测试

写在前面: fuzzDB看字面意思就知道,他是一个用于fuzz网站的库。类似于wwwscan之类工具的字典,但是他的过人之处是他是“开源”的,会有很多大神帮你维...

3168
来自专栏SpringBoot 核心技术

SpringCloud组件:Eureka服务注册中心内置的REST节点列表

你有没有考虑过Eureka Client与Eureka Server是通过什么方式进行通讯的? 为什么Client启动成功后Server就会被注册到Serve...

5432
来自专栏小白安全

SQLMAP命令中文注释

sqlmap常用命令大全 sqlmap -u “http://url/news?id=1″ –current-user #获取当前用户名称sqlmap...

3065
来自专栏JetpropelledSnake

RESTful源码学习笔记之RPC和Restful深入理解

RPC 即远程过程调用(Remote Procedure Call Protocol,简称RPC),像调用本地服务(方法)一样调用服务器的服务(方法)。通常的实...

913
来自专栏Felix的技术分享

用Android Studio调试Framework层代码

3325
来自专栏行者常至

idea Java 代码编写规范

920
来自专栏北京马哥教育

史上最全Linux命令科普 | 常见命令的名称是怎么来的?

1 目录缩写 缩写 | 全称 | 说明 --- | --- | --- | /bin | BINaries | 二进制可执行命令 /dev | DEVices...

3115
来自专栏北京马哥教育

搭建高性能的 Django 服务器栈

本文针对裸机 Linux 搭建 Django 的服务器栈,可直接应用在Linode等VPS上。 Linux:Ubuntu 12.04 + ,其他版本类似 说明:...

3967

扫码关注云+社区