Zookeeper,2021年最新Java大厂面试题来袭

2021年09月15日 阅读数:3
这篇文章主要向大家介绍Zookeeper,2021年最新Java大厂面试题来袭,主要内容包括基础应用、实用技巧、原理机制等方面,希望对大家有所帮助。

四、搭建集群java


???????node

一、Zookeeper 概念git

==============面试

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

Zookeeper 翻译过来就是 动物园管理员,他是用来管 Hadoop(大象)、Hive(蜜蜂)、Pig(小 猪)的管理员。简称zkapache

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

Zookeeper 提供的主要功能包括:markdown

  • 配置管理session

  • 分布式锁app

  • 集群管理

Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

?二、Zookeeper命令操做

================

一、Zookeeper 数据模型

  • ZooKeeper 是一个树形目录服务,其数据模型和Unix的文件系统目录树很相似,拥有一个层次化结构。

  • 这里面的每个节点都被称为: ZNode,每一个节点上都会保存本身的数据和节点信息

  • 节点能够拥有子节点,同时也容许少许(1MB)数据存储在该节点之下。

  • 节点能够分为四大类:

PERSISTENT 持久化节点

EPHEMERAL 临时节点 : -e(会话断开,自动删除)

PERSISTENT_SEQUENTIAL 持久化顺序节点 : -s

EPHEMERAL_SEQUENTIAL 临时顺序节点 ?: - es

Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

?二、Zookeeper 服务端经常使用命令

?Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

三、Zookeeper 客户端经常使用命令

Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

?或

?Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

?Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

?Zookeeper,2021年最新Java大厂面试题来袭

?Zookeeper,2021年最新Java大厂面试题来袭

Zookeeper,2021年最新Java大厂面试题来袭

?Zookeeper,2021年最新Java大厂面试题来袭

?Zookeeper,2021年最新Java大厂面试题来袭

?三、JavaAPI操做

============

一、Curator API?经常使用操做

  • Curator 是 Apache ZooKeeper 的Java客户端库。

  • 常见的ZooKeeper Java API :

? 原生 Java API

? ZkClient

? Curator

  • Curator 项目的目标是简化 ZooKeeper 客户端的使用。

  • Curator 最初是 Netfix 研发的,后来捐献了 Apache 基金会,目前是 Apache 的顶级项目。

  • 官网:[http://curator.apache.org/]( )

?Zookeeper,2021年最新Java大厂面试题来袭


package com.zk.test;

import org.apache.curator.RetryPolicy;

import org.apache.curator.framework.CuratorFramework;

import org.apache.curator.framework.CuratorFrameworkFactory;

import org.apache.curator.framework.api.BackgroundCallback;

import org.apache.curator.framework.api.CuratorEvent;

import org.apache.curator.retry.ExponentialBackoffRetry;

import org.apache.zookeeper.CreateMode;

import org.apache.zookeeper.data.Stat;

import org.junit.After;

import org.junit.Before;

import org.junit.Test;

import java.util.List;

public class CuratorTest {

    CuratorFramework client;

    //创建链接

    @Before

    public void testConnect(){

        //第一种方式

        /*

        * zk地址和端口

        * 会话超时时间 默认 60*1000

        * 链接超时时间 默认 15*1000

        * 重试策略

        * */

        RetryPolicy rp = new ExponentialBackoffRetry(3000,10);

//        CuratorFramework client = CuratorFrameworkFactory.newClient("192.168.126.129:2181", rp);

//        //开启链接

//        client.start();

        //第二种方式

        client = CuratorFrameworkFactory.builder()

                .connectString("192.168.126.129:2181")

                .sessionTimeoutMs(60 * 1000)

                .connectionTimeoutMs(15 * 1000)//namespace会让app1做为根目录

                .retryPolicy(rp).namespace("app1").build();

        //开启链接

        client.start();

    }

    /*=================建立结点=======================*/

    @Test

    public void testCreate() throws Exception {

        //若是没有指定数据,客户端ip会做为数据

        String s = client.create().forPath("/app2","abc".getBytes());

        System.out.println(s);

    }

    @Test

    public void testCreate2() throws Exception {

        //指定类型 默认:持久化

        String s = client.create().withMode(CreateMode.EPHEMERAL).forPath("/app3","abc".getBytes());

        System.out.println(s);

        //延迟会话执行结束

        int i=0;

        while(i<20){

            Thread.sleep(1000);

            i++;

            System.out.println(i);

        }

    }

    @Test

    public void testCreate3() throws Exception {

        //建立多级结点

        //creatingParentsIfNeeded():若是父节点不存在,则建立父节点

        String s = client.create().creatingParentsIfNeeded().forPath("/app4/p1");

        System.out.println(s);

    }

/*=================查询结点=======================*/

    //查询数据

    @Test

    public void get() throws Exception {

        byte[] bytes = client.getData().forPath("/app2");

        System.out.println(new String(bytes));

    }

    //查询结点

    @Test

    public void get2() throws Exception {

        List<String> paths = client.getChildren().forPath("/app4");

        System.out.println(paths);

    }

    //状态信息

    @Test

    public void get3() throws Exception {

        Stat stat = new Stat();

        client.getData().storingStatIn(stat).forPath("/app4");

        System.out.println(stat);

    }

    /*=================修改结点=======================*/

    //修改数据

    @Test

    public void set() throws Exception {

        client.setData().forPath("/app2","aaa".getBytes());

    }

    //根据版本修改数据

    @Test

    public void set2() throws Exception {

        Stat stat = new Stat();

        client.getData().storingStatIn(stat).forPath("/app2");

        int version = stat.getVersion();

        System.out.println(version);

        client.setData().withVersion(version).forPath("/app2","bbb".getBytes());

    }

    /*=================删除结点=======================*/

    //删除单个结点

    @Test

    public void delete() throws Exception {

        client.delete().forPath("/app2");

    }

    //删除带子结点的结点

    @Test

    public void delete2() throws Exception {

        client.delete().deletingChildrenIfNeeded().forPath("/app4");

    }

    //必须删除

    @Test

    public void delete3() throws Exception {

        client.delete().guaranteed().forPath("/app4");

    }

    //回调

    @Test

    public void delete4() throws Exception {

        client.delete().inBackground(new BackgroundCallback() {

            @Override

            public void processResult(CuratorFramework curatorFramework, CuratorEvent curatorEvent) throws Exception {

                System.out.println("已删除");

                System.out.println(curatorEvent);

            }

        }).forPath("/app3");

    }

    @After

    public void after(){

        if(client != null){

            client = null;

        }

    }

} 

? 二、Watch事件监听

  • ZooKeeper 容许用户在指定节点上注册一些Watcher,而且在一些特定事件触发的时候,ZooKeeper 服务端会将事件通知到感兴趣的客户端上去,该机制是 ZooKeeper 实现分布式协调服务的重要特性。

  • ZooKeeper 中引入了Watcher机制来实现了发布/订阅功能能,可以让多个订阅者同时监听某一个对象,当一个对象自身状态变化时,会通知全部订阅者。

  • Curator引入了 Cache 来实现对 ZooKeeper 服务端事件的监听。

  • ZooKeeper提供了三种Watcher:

? NodeCache : 只是监听某一个特定的 节点

? PathChildrenCache : 监控一个 ZNode 的子节点 .

? TreeCache : 能够监控整个树上的全部节点, 相似于 PathChildrenCache 和 NodeCache 的组合



@Test

    public void testNodeCache() throws Exception {

        //建立NodeCache对象

        final NodeCache nc = new NodeCache(client,"/app1");

        //注册监听

        nc.getListenable().addListener(new NodeCacheListener() {

            @Override

            public void nodeChanged() throws Exception {

                System.out.println("结点变化了。。。");

                //获取修改结点后的数据

                byte[] data = nc.getCurrentData().getData();

                System.out.println(new String(data));

            }

        });

        //开启监听

        nc.start(true);

        while (true){

        }

    }

    @Test

# 独家面经总结,超级精彩

本人面试腾讯,阿里,百度等企业总结下来的面试经历,都是真实的,分享给你们!

![image](https://s2.51cto.com/images/20210905/1630829079167661.jpg)

![image](https://s2.51cto.com/images/20210905/1630829080815218.jpg)

![image](https://s2.51cto.com/images/20210905/1630829080874701.jpg)

![image](https://s2.51cto.com/images/20210905/1630829080189239.jpg)

# Java面试准备

准确的说这里又分为两部分:

1.  Java刷题
2.  算法刷题

Java刷题:此份文档详细记录了千道面试题与详解;

![image](https://s2.51cto.com/images/20210905/1630829081338580.jpg)

![image](https://s2.51cto.com/images/20210905/1630829081288766.jpg)

**以上全部文档已经打包好,只须要动动手指点击【转发+关注】,而后[点击便可免费获取](https://gitee.com/vip204888/java-p7)!**