索取营销诊断书
021-80394720QQ
    您的位置：上海毫米网络优化公司 > 网站优化分享 >
    相关推荐recommended
    Zookeeper详解（从安装—入门—使用）
    作者：mmseoamin日期：2024-01-18

    Zookeeper详解（从安装—入门—简单使用）

      • 🍋1.zookeeper概念
      • 🍋2.zookeeper的安装
        • 🍊2.1环境准备：
        • 🍊2.2下载
        • 🍊2.3上传并安装
        • 🍊2.4配置
        • 🍊2.5启动zookeeper
        • 🍋3.zookeeper内存模型
          • 🍊3.1模型
          • 🍊3.2模型的特点：
          • 🍊3.3节点的分类：
          • 🍋4.zookeeper配置文件详解
          • 🍋5.zookeeper客户端常用命令
          • 🍋6.Java客户端操作
            • 🍊6.1连接zk server服务端
            • 🍊6.2创建节点
            • 🍊6.3查看某个节点信息
            • 🍊6.4修改节点信息
            • 🍊6.5查看当前节点所有子节点
            • 🍊6.6监听

              🍋1.zookeeper概念

              Zookeeper是 Apache Hadoop项目下的一个子项目，是一个树形目录服务。

              Zookeeper翻译过来就是动物园管理员，他是用来管Hadoop(大象)、Hive(蜜蜂)、

              Pig(小猪)的管理员，简称zk

              Zookeeper是一个分布式的、开源的应用程序的协调服务。

              zookeeper提供的主要功能包括:

              • 配置管理

                在多个应用程序(或服务器)中，假如存在一些相同的配置信息，在对该配置信息进行修改时，我们需要一个一个进行修改，这样会大大增加维护的成本，不方便管理。这时如果使用一个专门放配置中心的组件，将相同的配置信息放在配置中心，需要的时候直接拉取，这样可以大大节约维护的成本, 而zookeeper即可实现配置中心的功能。

                Zookeeper详解（从安装—入门—使用）,image-20220307195432635,第1张

                • 分布式锁：

                  在多个用户访问同一台主机上的应用程序数据时，我们可以通过加锁解决并发操作的问题，但是如果有多台主机相同的应用程序要访问同一数据时，这个时候我们在一台主机上加锁是不能解决另一台主机的并发问题的，换句话说自己的锁只对自己有效并不影响别的 ，这个时候就需要分布式锁解决这类问题，我个人理解分布式锁像是从所有主机中抽取出来的一把锁，或者是有一把总锁对所有主机都有效。zookeeper可以实现分布式锁的功能

                  Zookeeper详解（从安装—入门—使用）,image-20220307200342280,第2张

                  • 集群管理：

                    Zookeeper详解（从安装—入门—使用）,image-20220307200440212,第3张

                    zookeeper作为注册中心，管理服务提供方的ip地址端口号url信息，并在服务消费方请求需要时发送给服务消费方

                    🍋2.zookeeper的安装

                    🍊2.1环境准备：

                    zookeeper服务器是用Java创建的，运行在JVM之上。需要安装JDK7以上版本（最好JDK8或以上）

                    🍊2.2下载

                    官网下载地址：

                    Apache ZooKeeper

                    🍊2.3上传并安装

                    下载在本地之后可以把安装包上传到服务器或者虚拟机中，我使用的是服务器并远程shell连接

                    1.使用xshell 远程连接服务器，在opt目录下新建一个zookeeper目录

                    Zookeeper详解（从安装—入门—使用）,在这里插入图片描述,第4张

                    2.使用xftp将刚才下载的安装包上传到zookeeper目录下

                    Zookeeper详解（从安装—入门—使用）,在这里插入图片描述,第5张

                    3.进入zookeeper目录下解压

                    tar -zxvf apache-zookeeper-3.8.0-bin.tar.gz

                    Zookeeper详解（从安装—入门—使用）,image-20220308112851104,第6张

                    4. 安装成功！

                    Zookeeper详解（从安装—入门—使用）,第7张

                    🍊2.4配置

                    进入conf配置目录

                    Zookeeper详解（从安装—入门—使用）,image-20220308113306625,第8张

                    zoo_sample.cfg就是配置文件，但是此文件不能生效，需要名称为zoo.cfg的文件才能生效

                    改名复制一份配置文件

                    Zookeeper详解（从安装—入门—使用）,image-20220308113519657,第9张

                    编辑配置文件zoo.cfg /tmp/zookeeper这个目录是zookeeper用于存储持久化的数据到本地的，但是服务器默认是没有的

                    Zookeeper详解（从安装—入门—使用）,image-20220311175938147,第10张

                    进入opt/zookeeper目录下，新建一个目录zkdata（目录名随意取）用于存放zookeeper的持久化数据

                    Zookeeper详解（从安装—入门—使用）,image-20220308113915311,第11张

                    复制此目录/opt/zookeeper/zkdata，将zoo.cfg配置文件中的dataDir修改为/opt/zookeeper/zkdata

                    Zookeeper详解（从安装—入门—使用）,第12张

                    保存退出！

                    🍊2.5启动zookeeper

                    Zookeeper详解（从安装—入门—使用）,image-20220308114501999,第13张

                    启动成功！

                    🍋3.zookeeper内存模型

                    🍊3.1模型

                    Zookeeper详解（从安装—入门—使用）,image-20220313212813160,第14张

                    🍊3.2模型的特点：

                    • 每个子目录如/node1都被称作一个znode(节点)。这个znode是被它所在的路径唯一标识
                    • znode可以有子节点目录，并且每个znode可以存储数据
                    • znode是有版本的，每个znode中存储的数据可以有多个版本，也就是一个访问路径中可以存储多份

                      数据

                    • znode可以被监控，包括这个目录节点中存储的数据的修改，子节点目录的变化等，一旦变化可以通

                      知设置监控的客户端

                      🍊3.3节点的分类：

                      1.持久节点（默认） 2.持久顺序节点 3.临时节点 4.临时顺序节点

                      1.create 节点path data

                      创建一个节点。并给节点绑定数据(默认是持久性节点)

                      2.create -s 节点path data

                      创建持久性顺序节点

                      3.create -e 节点path data

                      创建临时性节点

                      4.create -e -s 节点path data

                      创建临时顺序节点

                      (注意:临时节点不能含有任何子节点)

                      🍋4.zookeeper配置文件详解

                      Zookeeper详解（从安装—入门—使用）,image-20220312171808138,第15张

                      🍋5.zookeeper客户端常用命令

                      连接ZooKeeper服务端

                      ./zkCli.sh -server ip:port 如果是本机连接可以不写 ip:port

                      断开连接 quit

                      CRUD

                      1.设置（修改）节点值

                      set 节点path value

                      2.查看命令帮助

                      help

                      3.删除单个节点

                      delete 节点path

                      4.显示指定目录下节点

                      ls 目录名

                      5.删除带有子节点的节点

                      deleteall 节点path

                      6.创建节点

                      create 节点path value

                      7.获取节点值

                      get 节点path

                      8.查看路径下节点信息及子节点

                      ls s 节点路径

                      9.查看节点状态

                      stat 节点path

                      节点监听机制watch

                      客户端可以监测znode节点的变化。Zonode节点的变化触发相应的事件，然后清除对该节点的监

                      测。当监测一个znode节点时候,Zookeeper会发送通知给监测节点。在shell终端一个Watch事件是一个一次性

                      的触发器，当被设置了Watch的数据或者目录发生了改变的时候,则服务器将这个改变发送给设置了

                      Watch的客户端以便通知它们。

                      1.ls -w 节点path 监听节点目录的变化

                      Zookeeper详解（从安装—入门—使用）,image-20220313200127758,第16张

                      🌰新建一个会话连接 对/app1的目录进行修改，增加一个子节点

                      Zookeeper详解（从安装—入门—使用）,image-20220313200234898,第17张

                      Zookeeper详解（从安装—入门—使用）,image-20220313200422360,第18张

                      然后监听就失效了，因为是一次性的

                      2.get -w 节点path 监听节点数据的变化

                      Zookeeper详解（从安装—入门—使用）,image-20220313200648786,第19张

                      🌰修改节点信息

                      Zookeeper详解（从安装—入门—使用）,image-20220313200745215,第20张

                      触发监听，并且之后监听就失效了

                      Zookeeper详解（从安装—入门—使用）,image-20220313200810275,第21张

                      🍋6.Java客户端操作

                      导入zookeeper的依赖包和junit的测试包

                      
    junit
    junit
    4.12
    provided


    com.101tec
    zkclient
    0.10

                      🍊6.1连接zk server服务端

                      @Before
public void before() {
    //参数1  --> zk server 服务ip地址:端口号
    //参数2 -->  会话超时时间
    //参数3  --> 连接超时时间
    //参数4  --> 序列化方式
     zkClient = new ZkClient("ip:端口号", 60000 * 30, 60000, new SerializableSerializer());
 }
    private ZkClient zkClient;
   
@Test
    public void  test01(){
        System.out.println(zkClient);
    }
 @After
 public void after() {
     zkClient.close();
 }

                      Zookeeper详解（从安装—入门—使用）,image-20220312211704671,第22张

                      打印出结果，成功连接！

                      🍊6.2创建节点

                       @Test
public void test() {
     //创建持久节点
     zkClient.create("/app2", "xue", CreateMode.PERSISTENT);
   //创建持久顺序节点
     zkClient.create("/app3","yue", CreateMode.PERSISTENT_SEQUENTIAL);
     //创建临时节点
     zkClient.create("/app4","qing", CreateMode.EPHEMERAL);
     //创建临时顺序节点
     zkClient.create("/app5","haha",CreateMode.EPHEMERAL_SEQUENTIAL);
 }

                      🍊6.3查看某个节点信息

                      @Test
public void test2(){
    //查看某个节点数据，需要保证创建和获取的数据序列化方式相同，如果是在linux上创建的节点那么在Java上获取就会出现序列化不匹配的异常
    Object o = zkClient.readData("/app2");
    System.out.println(o);
    //查看节点状态
   Stat stat = new Stat();
      
         System.out.println(o);
    //查看节点创建时间
        System.out.println(stat.getCtime());
    //查看版本
        System.out.println(stat.getCversion());
    //查看id
        System.out.println(stat.getCzxid());
}

                      Zookeeper详解（从安装—入门—使用）,image-20220313160600580,第23张

                      🍊6.4修改节点信息

                      zkClient.writeData("/app2","xueyueqing");

                      🍊6.5查看当前节点所有子节点

                      @Test
public  void test4(){
    List children = zkClient.getChildren("/");
    for(String c : children ){
        System.out.println(c);
    }
}

                      🍊6.6监听

                      @Test
public  void test5() throws IOException {
  zkClient.subscribeDataChanges("/app1", new IZkDataListener() {
      //当前节点数据变化时触发
      @Override
      public void handleDataChange(String dataPath, Object o) throws Exception {
          System.out.println("当前节点路径"+dataPath);
          System.out.println("当前节点信息"+o);
      }
      //当前节点删除时触发
      @Override
      public void handleDataDeleted(String dataPath) throws Exception {
          System.out.println("当前节点路径"+dataPath);
      }
  });
     //阻塞当前监听
  System.in.read();
}

                      注意：在shell终端修改，Java是监听不了的，必须使用Java代码修改

                      🌰通过Java代码进行修改

                      Zookeeper详解（从安装—入门—使用）,第24张

                      Zookeeper详解（从安装—入门—使用）,image-20220313204107545,第25张

                      监听成功！并发现Java代码进行监听是永久的，不是一次性的

                         @Test
   public  void test6() throws IOException {
//监听节点目录变化
       zkClient.subscribeChildChanges("/app1", new IZkChildListener() {
           @Override
           public void handleChildChange(String s, List list) throws Exception {
               System.out.println("父节点名称:"+s);
               System.out.println("发生变化后孩子节点名称:");
           for(String child : list){
               System.out.println(child);
           }
           }
       });
       //阻塞当前监听
       System.in.read();
   }

                      在/app1目录下创建节点name

                      Zookeeper详解（从安装—入门—使用）,image-20220313205439297,第26张

                      监听成功！

                      Zookeeper详解（从安装—入门—使用）,image-20220313205603347,第27张

                       

    上一篇：kafka基本使用及结合Java使用

    下一篇：世界杯数据可视化分析

    网站优化运营
    整站seo优化
    网络营销运营
    成功案例
    品牌创意网站
    营销型网站
    小程序
    微信小程序
    微信公众号
    百度熊掌号
    网站优化分享
    关于我们
    公司概况
    公司新闻
    公司文化
    结构体系
    企业资质
    加入我们
    关注我们
    扫描二维码
    获取更多信息
    精彩一手掌握
    Copyright © 2014-2019 seo,上海网站优化_网络制作_网站seo排名_网站建设推广_上海网络公司 版权所有 沪ICP备19022315号