1 集群角色
Zookeeper 集群模式一共有三种类型的角色:
- Leader: 处理所有的事务请求(写请求),可以处理读请求,集群中只能有一个Leader。
- Follower:只能处理读请求,同时作为Leader的候选节点,即如果Leader宕机,Follower节点要参与到新的Leader选举中,有可能成为新的Leader节点。
- Observer:只能处理读请求。不能参与选举。
2 环境说明
本例搭建的是伪集群模式,即一台机器上启动四个zookeeper实例组成集群,真正的集群模式无非就是实例IP地址不同,搭建方法没有区别。
其中1个leader,2个follower,1个observer。
3 配置JAVA环境
检验环境:保证是jdk7 及以上即可:
代码语言:javascript复制[root@zookeeper1 ~]# java -version
openjdk version "1.8.0_222"
OpenJDK Runtime Environment (build 1.8.0_222-b10)
OpenJDK 64-Bit Server VM (build 25.222-b10, mixed mode)
4 下载zookeeper安装包
下载链接:https://zookeeper.apache.org/releases.html
代码语言:javascript复制tar -xzvf apache-zookeeper-3.5.8-bin.tar.gz
5 创建相应目录
代码语言:javascript复制mkdir -p /root/zookeeper-cluster/zk1
mkdir -p /root/zookeeper-cluster/zk2
mkdir -p /root/zookeeper-cluster/zk3
mkdir -p /root/zookeeper-cluster/zk4
6 编辑配置文件
这里只列出zk1的配置文件,其余3个配置文件只需要修改dataDir和clientPort即可。
代码语言:javascript复制tickTime=2000
initLimit=10
syncLimit=5
dataDir=/root/zookeeper-cluster/zk1 #根据实例修改zk1,zk2,zk3,zk4
clientPort=2181 #根据实例修改2181,2182,2183,2184
server.1=127.0.0.1:2001:3001:participant
server.2=127.0.0.1:2002:3002:participant
server.3=127.0.0.1:2003:3003:participant
server.4=127.0.0.1:2004:3004:observer
配置说明:
- tickTime:用于配置Zookeeper中最小时间单位的长度,单位是毫秒,很多运行时的时间间隔都是使用tickTime的倍数来表示的。
- initLimit:该参数用于配置Leader服务器等待Follower启动,并完成数据同步的时间。Follower服务器在启动过程中,会与Leader建立连接并完成数据的同步,从而确定自己对外提供服务的起始状态。Leader服务器允许Follower在initLimit时间内完成这个工作。
- syncLimit:Leader与Follower心跳检测的最大延时时间。
- dataDir:顾名思义就是 Zookeeper保存数据的目录,默认情况下,Zookeeper 将写数据的日志文件也保存在这个目录里。
- clientPort:这个端口就是客户端连接Zookeeper服务器的端口,Zookeeper会监听这个端口,接受客户端的访问请求。
- server.A=B:C:D:E:
- A 是一个数字,表示这个是第几号服务器;
- B 是这个服务器的ip地址;
- C 表示的是这个服务器与集群中的 Leader 服务器交换信息的端口;
- D 表示的是万一集群中的 Leader 服务器挂了,需要一个端口来重新进行选举,选出一个新 的 Leader,而这个端口就是用来执行选举时服务器相互通信的端口。如果是伪集群的配置方式,由于B都是一样,所以不同的 Zookeeper 实例通信端口号不能一样,所以要给 它们分配不同的端口号。
- E 如果需要通过添加不参与集群选举Observer节点,可以在E的位置,添加observer标识。
7 标识Server ID
在前面指定的dataDir目录下,根据不同的实例添加名为myid的文件,内容为实例ID。
代码语言:javascript复制echo 1 > /root/zookeeper-cluster/zk1/myid
echo 2 > /root/zookeeper-cluster/zk2/myid
echo 3 > /root/zookeeper-cluster/zk3/myid
echo 4 > /root/zookeeper-cluster/zk4/myid
8 查看目录结构
代码语言:javascript复制[root@zookeeper1 zookeeper-cluster]# tree /root/zookeeper-cluster
.
├── zk1
│ ├── myid
│ └── zoo.cfg
├── zk2
│ ├── myid
│ └── zoo.cfg
├── zk3
│ ├── myid
│ └── zoo.cfg
└── zk4
├── myid
└── zoo.cfg
4 directories, 8 files
9 启动4个zookeeper实例
启动之前可以先将zookeeper脚本的目录添加到PATH路径,目的是可以在任意目录下运行zookeeper脚本。编辑/etc/profile,添加如下内容:
代码语言:javascript复制export ZK_HOME=/root/apache-zookeeper-3.5.8-bin/bin
export PATH=$PATH:$ZK_HOME
编辑完成后source /etc/profile使其生效。
代码语言:javascript复制zkServer.sh start /root/zookeeper-cluster/zk1/zoo.cfg
zkServer.sh start /root/zookeeper-cluster/zk2/zoo.cfg
zkServer.sh start /root/zookeeper-cluster/zk3/zoo.cfg
zkServer.sh start /root/zookeeper-cluster/zk4/zoo.cfg
10 查看集群角色
可以看到此时zk2为leader,zk1和zk3为follower,zk4为observer。
代码语言:javascript复制[root@zookeeper1 zookeeper-cluster]# zkServer.sh status zk1/zoo.cfg
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: zk1/zoo.cfg
Client port found: 2181. Client address: localhost.
Mode: follower
[root@zookeeper1 zookeeper-cluster]# zkServer.sh status zk2/zoo.cfg
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: zk2/zoo.cfg
Client port found: 2182. Client address: localhost.
Mode: leader
[root@zookeeper1 zookeeper-cluster]# zkServer.sh status zk3/zoo.cfg
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: zk3/zoo.cfg
Client port found: 2183. Client address: localhost.
Mode: follower
[root@zookeeper1 zookeeper-cluster]# zkServer.sh status zk4/zoo.cfg
/usr/bin/java
ZooKeeper JMX enabled by default
Using config: zk4/zoo.cfg
Client port found: 2184. Client address: localhost.
Mode: observer
[root@zookeeper1 zookeeper-cluster]# ls
11 连接集群
代码语言:javascript复制zkCli.sh -server 127.0.0.1:2181
#可以通过 查看/zookeeper/config 节点数据来查看集群配置
[zk: 127.0.0.1:2181(CONNECTED) 1] get /zookeeper/config
server.1=127.0.0.1:2001:3001:participant
server.2=127.0.0.1:2002:3002:participant
server.3=127.0.0.1:2003:3003:participant
server.4=127.0.0.1:2004:3004:observer
version=0