IT评测·应用市场-qidao123.com

标题: ZooKeeper的安装与操纵 [打印本页]
作者: 丝    时间: 2024-7-14 08:05
标题: ZooKeeper的安装与操纵
一、ZooKeeper简介

ZooKeeper是一个分布式的、开放源码的分布式应用程序协调服务，它是Google的Chubby服务的开源实现，也是Hadoop和HBase等大数据生态系统中的重要组件。ZooKeeper的目的是为分布式应用提供一致性服务，包括设置维护、域名服务、分布式同步和组服务等。它封装了复杂且易出错的关键服务，通过简单的接口和高效、稳定的系统提供给用户。
ZooKeeper的工作原理基于Fast Paxos算法，该算法通过选举产生一个领导者（leader），只有领导者能提交proposer，以此来办理Paxos算法中大概存在的活锁题目。
ZooKeeper提供的服务包括但不限于：

Zookeeper的数据模子雷同于文件系统，是树状结构，每个树节点（目次）对应一个Znode节点。这些目次节点和我们普通的目次一样可以新建、删除、修改。

ZooKeeper的底层功能主要包括管理和监听用户程序提交的数据，以及为用户程序提供数据节点监听服务。它的文件系统接纳目次树结构，不依赖于HDFS，而是有自己的文件系统目次树。ZooKeeper使用Java编写，但支持Java和C两种编程语言的接口。
ZooKeeper的代码版本中提供了分布式独享锁、选举、队列的接口，其中分布锁和队列有Java和C两个版本，选举只有Java版本。它不仅是一个集群的管理者，还监视着集群中各个节点的状态，并根据节点提交的反馈举行下一步合理操纵。
二、ZooKeeper安装与设置

实验环境：
                Centos7操纵系统
                虚拟机1，虚拟机2        
                Zookeeper集群
！！！留意，以下操纵两台虚拟机都要举行！！！

1、下载解压ZooKeeper到/usr/local文件夹下

  1. wget http://mirror.bit.edu.cn/apache/zookeeper/zookeeper-3.4.6/zookeeper-3.4.6.tar.gz
  2. sudo mv /home/qyf/Desktop/zookeeper-3.4.10.tar.gz /usr/local
  3. tar -zxvf /usr/local/zookeeper-3.4.10.tar.gz
复制代码

2、编辑/etc/profile文件

  1. sudo vi /etc/profile
复制代码
写入以下内容：
  1. export ZOOKEEPER_HOME=/usr/local/zookeeper-3.4.10
  2. export PATH=$PATH:$ZOOKEEPER_HOME/bin:$ZOOKEEPER_HOME/conf
复制代码
使设置收效：
  1. source /etc/profile
复制代码
3、进入zookeeper/conf目次，建立新文件zoo.cfg

  1. sudo cd /home/zookeeper-3.4.10/conf
  2. sudo vi zoo.cfg
复制代码
写入以下内容：
  1. dataDir=/usr/local/zookeeper-3.4.10/data # data文件夹要创建的位置
  2. tickTime=2000
  3. initLimit=5
  4. syncLimit=2
  5. clientPort=2181 # 端口号，可以自己设置
  7. server.1=192.168.37.104:2888:3888  // 此处IP地址为你的两台虚拟机的IP地址
  8. server.2=192.168.37.105:2888:3888      
复制代码
4.如果是普通模式下要给Zookeeper文件夹相关的操纵权限，如果是root用户则忽略这一步

  1. sudo chmod -R 777 ./zookeeper-3.4.10
复制代码
5、启动ZooKeeper服务

  1. zkServer.sh start
复制代码
如果输出以下内容，则启动乐成

建立myid，在第一台虚拟机输入1，第二台输入2



三、使用命令行操纵Zookeeper

设置好Zookeeper之后，就可以操纵Zookeeper集群了，现在我们使用命令行终端举行操纵
1、输入以下命令，毗连Zookeeper集群(第二台虚拟机举行同样的操纵，IP地址记得换！)

  1. zkCli.sh -server 192.168.37.104:2181
复制代码
因为_现在我是在第一台虚拟机上操纵的，以是IP地址填写第一台虚拟，机的IP地址，端标语即是前面写设置文件时所规定的
毗连乐成后，会出现"Welcome to ZooKeeper"等信息
出现以上信息表明毗连乐成，可以举行下面的操纵了！
2、命令行

使用ls命令查看当前ZooKeeper所包含的内容
  1. ls /
复制代码
使用create可以创建新节点，例如使用命令create /zk "mydata"可以创建一个名为zk的节点以及在上面存放的数据字符串mydata
  1. create /zk "mydata"
复制代码
会输出以下内容：ˊ
  1. Created /zk
复制代码
使用get命令可以确认zk是否包含字符串mydata
  1. get /zk
复制代码
输入乐成会显示以下内容
  1. [zk: 192.168.37.104:2181(CONNECTED) 15] get /zk         
  2. mydata
  3. cZxid = 0x200000001
  4. ctime = Tue Apr 02 03:50:46 PDT 2024
  5. mZxid = 0x30000001f
  6. mtime = Tue Apr 02 06:28:53 PDT 2024
  7. pZxid = 0x200000002
  8. cversion = 1
  9. dataVersion = 2
  10. aclVersion = 0
  11. ephemeralOwner = 0x0
  12. dataLength = 6
  13. numChildren = 1
复制代码
使用set命令，可以修改mydata字符串为其他内容
  1. set /zk "hahahaha"
复制代码
在使用get命令查看，神奇的发现刚才的字符串“mydata”被覆盖成“hahahaha"”了
  1. [zk: 192.168.37.104:2181(CONNECTED) 18] get /zk           
  2. hahahaha
  3. cZxid = 0x200000001
  4. ctime = Tue Apr 02 03:50:46 PDT 2024
  5. mZxid = 0x300000021
  6. mtime = Tue Apr 02 06:30:32 PDT 2024
  7. pZxid = 0x200000002
  8. cversion = 1
  9. dataVersion = 4
  10. aclVersion = 0
  11. ephemeralOwner = 0x0
  12. dataLength = 8
  13. numChildren = 1
复制代码
如果要删除节点则要使用delete命令：
  1. delete /zk
复制代码
删除刚刚创建的节点zk
四、使用API操纵Zookeeper

举行下面的操纵前请确保你的虚拟机已经安装了eclipse，并且相关设置已设置好，如果还没有举行设置，请按照我下面的步骤举行操纵
下载eclipse
在 CentOS 中安装 Eclipse，必要下载安装程序，我们选择 Eclipse IDE for Java Developers 版：

下载完成后解压使用
  1. sudo tar -zxf ~/下载/eclipse-java-mars-1-linux-gtk*.tar.gz -C /usr/lib
复制代码
建立maven文件，并且编辑pom.xml文件，输入以下内容
  1. <dependencies>
  2.         <dependency>
  3.             <groupId>org.apache.zookeeper</groupId>
  4.             <artifactId>zookeeper</artifactId>
  5.             <version>3.4.10</version>
  6.         </dependency>
  7.         <dependency>
  8.             <groupId>com.github.sgroschupf</groupId>
  9.             <artifactId>zkclient</artifactId>
  10.             <version>0.1</version>
  11.         </dependency>
  12.         <dependency>
  13.             <groupId>junit</groupId>
  14.             <artifactId>junit</artifactId>
  15.             <version>4.12</version>
  16.         </dependency>
  17.   </dependencies>
复制代码

在/src/main/resources下建立log4文件，写入以下内容：
  1. log4j.rootLogger=INFO, stdout
  3. log4j.appender.stdout=org.apache.log4j.ConsoleAppender
  5. log4j.appender.stdout.layout=org.apache.log4j.PatternLayout
  7. log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n
  9. log4j.appender.logfile=org.apache.log4j.FileAppender
  11. log4j.appender.logfile.File=target/spring.log
  13. log4j.appender.logfile.layout=org.apache.log4j.PatternLayout
  15. log4j.appender.lo  
  17. gfile.layout.ConversionPattern=%d %p [%c] - %m%n
复制代码
至此预备工作已完成
1、创建节点

建立新的java文件，写入以下内容
  1. public static void main(String[] args) throws Exception{
  2.                 String connectStr="192.168.37.104:2181,192.168.37.105:2181";
  3.                 ZooKeeper zk = new ZooKeeper(connectStr,3000,null);
  4.                 String path = zk.create("/zk001","zk001_data".getBytes(),Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
  5.                 System.out.println(path);
  6.         }
复制代码
上述代码中，create（）方法必要传入四个参数：第一个参数为节点名称，本例中为zk001；第二个参数为节点数据，必要转成字节数组；第三个参数为权限控制，本例中使用 ZooKeeper 自带的完全开放权限 Ids.OPEN_ACL_UNSAFE；第四个参数为所创建节点的类型，本例中为PERSISTENT，即长期类型的节点。
 
2、添加数据

  1. public static void main(String[] args) throws Exception{
  2.                 String connectStr="192.168.37.104:2181,192.168.37.105:2181";
  3.                 ZooKeeper zk = new ZooKeeper(connectStr,3000,null);
  4.                         Stat stat = zk.setData("/zk001","zk002_data2".getBytes() , -1);
  5.                         System.out.println(stat.getVersion());
  6.         }
复制代码
其中，第一个参数为节点路径，本例中为/zk001；第二个参数为必要添加的数据，并转成字节数组，本例中为“zk002 data2”；第三个参数为版本号，-1代表所有版本。也就
是说，上述代码向节点/zk001的所有版本添加了数据“zk002 data2”。
 
3、获取数据

  1. public static void main(String[] args) throws Exception{
  2.                 String connectStr="192.168.37.104:2181,192.168.37.105:2181";
  3.                 ZooKeeper zk = new ZooKeeper(connectStr,3000,null);
  4.                 Stat stat = new Stat();
  5.                 // 返回指定路径上的几点数据和节点状态，节点的状态会放入stat对象中
  6.                         byte[]bytes = zk.getData("/zk001", new Watcher() {
  7.                                 @Override
  8.                                 public void process(WatchedEvent event) {
  9.                                         System.out.println(event.getType());
  10.                                 }
  11.                         },stat);
  12.                         System.out.println(new String(bytes));
  13.                         // 改变节点数据，出发watcher
  14.                         zk.setData("/zk001", "zk001_data_testwatch".getBytes(), -1);
  15.                         // 验证是否触发了watcher
  16.                         while(true) {
  17.                                 Thread.sleep(3000);
  18.                         }
  19.         }
复制代码
这里在getData（）方法中指定了一个Wacther，对节点的变化举行监听，在数据改变的时候出发Watcher指定的回调方法
4、删除节点

  1. public static void main(String[] args) throws Exception{
  2.                 String connectStr="192.168.37.104:2181,192.168.37.105:2181";
  3.                 ZooKeeper zk = new ZooKeeper(connectStr,3000,null);
  4.                 // DELETE NODE
  5.                 zk.delete("/zk001", -1);
  6.         }
复制代码
上述代码中，delete（）方法传入了两个参数：第一个参数为必要删除的节点路径，本例中为/zk001；第二个参数为节点的版本，如果是-1，则代表删除所有版本。也就是说，上述代码删除了节点/zk001的所有版本内容。



免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/) Powered by Discuz! X3.4