Zookeeper(四)实战
分布式安装部署
集群思路:先搞定一台服务器,再克隆出两台,形成集群!
配置服务器编号
在/opt/zookeeper/zkData创建myid文件
vim myid
- 在文件中添加与server对应的编号:1
- 其余两台服务器分别对应2和3
配置zoo.cfg文件
打开zoo.cfg文件,增加如下配置
#######################cluster##########################
server.1=106.75.245.83:2888:3888
server.2=106.75.245.84:2888:3888
server.3=106.75.245.85:2888:3888
- 配置参数解读 server.A=B:C:D
- A:一个数字,表示第几号服务器
集群模式下配置的/opt/zookeeper/zkData/myid文件里面的数据就是A的值 - B:服务器的ip地址
- C:与集群中Leader服务器交换信息的端口
- D:选举时专用端口,万一集群中的Leader服务器挂了,需要一个端口来重新进行选举,选出一个新的Leader,而这个端口就是用来执行选举时服务器相互通信的端口。
- A:一个数字,表示第几号服务器
配置其余两台服务器
- 在虚拟机数据目录vms下,创建zk02
- 将本台服务器数据目录下的.vmx文件和所有的.vmdk文件分别拷贝zk02下
- 虚拟机->文件->打开 (选择zk02下的.vmx文件)
- 开启此虚拟机,弹出对话框,选择“我已复制该虚拟机”
- 进入系统后,修改linux中的ip,修改/opt/zookeeper/zkData/myid中的数值为2
第三台服务器zk03,重复上面的步骤
集群操作
每台服务器的防火墙必须关闭
systemctl stop firewalld.service
启动第1台
./zkServer.sh start
查看状态
./zkServer.sh status
ZooKeeper JMX enabled by default
Using config: /opt/zookeeper/bin/../conf/zoo.cfg
Client port found: 2181. Client address: localhost.
Error contacting service. It is probably not running.
注意:因为没有超过半数以上的服务器,所以集群失败 (防火墙没有关闭也会导致失败)
当启动第2台服务器时
- 查看第1台的状态:Mode: follower
- 查看第2台的状态:Mode: leader
客户端命令行操作
启动客户端
./zkCli.sh
显示所有操作命令
help
查看当前znode中所包含的内容
ls /
查看当前节点详细数据
zookeeper老版本使用 ls2 / ,现在已经被新命令替代
ls -s /
-
cZxid:创建节点的事务
- 每次修改ZooKeeper状态都会收到一个zxid形式的时间戳,也就是ZooKeeper事务ID。
- 事务ID是ZooKeeper中所有修改总的次序。
- 每个修改都有唯一的zxid,如果zxid1小于zxid2,那么zxid1在zxid2之前发生。
-
ctime:被创建的毫秒数(从1970年开始)
-
mZxid:最后更新的事务zxid
-
mtime:最后修改的毫秒数(从1970年开始)
-
pZxid:最后更新的子节点zxid
-
cversion:创建版本号,子节点修改次数
-
dataVersion:数据变化版本号
-
aclVersion:权限版本号
-
ephemeralOwner:如果是临时节点,这个是znode拥有者的session id。如果不是临时节点则是0。
-
dataLength:数据长度
-
numChildren:子节点数
分别创建2个普通节点
-
在根目录下,创建中国和美国两个节点
create /china create /usa
-
在根目录下,创建俄罗斯节点,并保存“普京”数据到节点上
create /ru "pujing"
-
多级创建节点
-
在日本下,创建东京 “热”
-
japan必须提前创建好,否则报错 “节点不存在”
create /japan create /japan/Tokyo "hot"
-
-
获得节点的值
get /japan/Tokyo
-
创建短暂节点:创建成功之后,quit退出客户端,重新连接,短暂的节点消失
create -e /uk ls / quit ls /
-
创建带序号的节点
-
在俄罗斯ru下,创建3个city
create -s /ru/city # 执行三次 ls /ru [city0000000000, city0000000001, city0000000002]
如果原来没有序号节点,序号从0开始递增。
如果原节点下已有2个节点,则再排序时从2开始,以此类推
-
-
修改节点数据值
set /japan/Tokyo "too hot"
-
监听 节点的值变化 或 子节点变化(路径变化)
-
在server3主机上注册监听/usa节点的数据变化
addWatch /usa
-
在Server1主机上修改/usa的数据
set /usa "telangpu"
-
Server3会立刻响应
WatchedEvent state:SyncConnected type:NodeDataChanged path:/usa
-
如果在Server1的/usa下面创建子节点NewYork
create /usa/NewYork
-
Server3会立刻响应
WatchedEvent state:SyncConnected type:NodeCreatedpath:/usa/NewYork
-
-
删除节点
delete /usa/NewYork
-
递归删除节点 (非空节点,节点下有子节点)
deleteall /ru
不仅删除/ru,而且/ru下的所有子节点也随之删除
API应用
<dependencies>
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-core</artifactId>
<version>2.8.2</version>
</dependency>
<dependency>
<groupId>org.apache.zookeeper</groupId>
<artifactId>zookeeper</artifactId>
<version>3.6.0</version>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.12</version>
</dependency>
</dependencies>
log4j.rootLogger=INFO, stdout
log4j.appender.stdout=org.apache.log4j.ConsoleAppender
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n
log4j.appender.logfile=org.apache.log4j.FileAppender
log4j.appender.logfile.File=target/zk.log
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] - %m%n
创建ZooKeeper客户端
/**
* zookeeperAPI
*/
public class TestZK {
//zookeeper集群的IP和端口
private String connectString = "106.75.245.83:2181,06.75.245.83:2182,06.75.245.83:2183";
//session超时时间,毫秒单位,此处为60秒
//时间不宜设置太小,因为zookeeper和加载集群环境会因为性能等原因而延迟略高
//如果时间太少,还没有创建好客户端,就开始创建节点,会报错
private int sesionTimeout = 60 * 1000;
//zookeeper客户端对象
private ZooKeeper zooKeeperClient;
/**
* 创建客户端
*/
@Test
public void init() throws IOException {
/**
* new Watcher():监听器
*/
zooKeeperClient = new ZooKeeper(connectString, sesionTimeout, new Watcher() {
public void process(WatchedEvent watchedEvent) {
System.out.println("得到监听反馈,在进行业务处理代码。");
}
});
}
}
创建节点
- 一个ACL对象就是一个Id和permission对
- 表示哪个/哪些范围的Id(Who)在通过了怎样的鉴权(How)之后,就允许进行那些操作(What):Who How What;
- permission(What)就是一个int表示的位码,每一位代表一个对应操作的允许状态。
- 类似linux的文件权限,不同的是共有5种操作:CREATE、READ、WRITE、DELETE、ADMIN(对应更改ACL的权限)
- OPEN_ACL_UNSAFE:创建开放节点,允许任意操作 (用的最少,其余的权限用的很少)
- READ_ACL_UNSAFE:创建只读节点
- CREATOR_ALL_ACL:创建者才有全部权限
/**
* zookeeperAPI
*/
public class TestZK {
//zookeeper集群的IP和端口
private String connectString = "106.75.245.83:2181,106.75.245.83:2181,106.75.245.83:2181";
//session超时时间,毫秒单位,此处为60秒
//时间不宜设置太小,因为zookeeper和加载集群环境会因为性能等原因而延迟略高
//如果时间太少,还没有创建好客户端,就开始创建节点,会报错
private int sesionTimeout = 60 * 1000;
//zookeeper客户端对象
private ZooKeeper zooKeeperClient;
/**
* 创建客户端
*/
@Before
public void init() throws IOException {
/**
* new Watcher():监听器
*/
zooKeeperClient = new ZooKeeper(connectString, sesionTimeout, new Watcher() {
public void process(WatchedEvent watchedEvent) {
System.out.println("得到监听反馈,在进行业务处理代码。");
System.out.println(watchedEvent.getType());
}
});
}
/**
* 创建节点
*/
@Test
public void creaeNode() throws KeeperException, InterruptedException {
/**
* 参数1:要创建的节点的路径
* 参数2:节点数据
* 参数3:节点权限
* 参数4:节点类型
*/
String string = zooKeeperClient.create("/szx", "xiaoxing".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
System.out.println(string);
}
/**
* 获取节点上的值
*/
@Test
public void getNodeData() throws KeeperException, InterruptedException {
byte[] data = zooKeeperClient.getData("/szx", false, new Stat());
String string = new String(data);
System.out.println(string);
}
/**
* 修改节点的值
*/
@Test
public void updateData() throws KeeperException, InterruptedException {
Stat stat = zooKeeperClient.setData("/szx", "xiaoxing111".getBytes(), 0);
System.out.println(stat);
}
/**
* 删除节点
*/
@Test
public void delete() throws KeeperException, InterruptedException {
zooKeeperClient.delete("/szx",1);
}
/**
* 获取子节点
*/
@Test
public void getChildren() throws KeeperException, InterruptedException {
List<String> children = zooKeeperClient.getChildren("/china", false);
children.forEach(item -> System.out.println(item));
}
/**
* 监听根节点下面的变化
* 程序在运行的过程中,我们在linux下创建一个节点
* IDEA的控制台就会做出响应:NodeChildrenChanged--/
*/
@Test
public void watchNode() throws KeeperException, InterruptedException, IOException {
List<String> children = zooKeeperClient.getChildren("/", true);
children.forEach(item -> System.out.println(item));
//让线程无限等待
System.in.read();
}
/**
* 判断节点是否存在
*/
@Test
public void exists() throws KeeperException, InterruptedException {
Stat szx = zooKeeperClient.exists("/szx", false);
if (szx == null){
System.out.println("节点不存在");
} else {
System.out.println("节点存在");
}
}
}