社区首页 >专栏 >zookeeper的安装和demo操作

zookeeper的安装和demo操作

技术从心

发布于 2019-08-06 02:46:56

79600

代码可运行

文章被收录于专栏：技术从心技术从心

运行总次数：0

代码可运行

什么是zookeeper？

之前写过一遍但由于排版的问题将那边文章重新排版编排了一下，后续再研究下zookeeper的监听图片复制

官方版：

ZooKeeper是一个分布式的，开放源码的分布式应用程序协调服务，是Google的Chubby一个开源的实现，是Hadoop和Hbase的重要组件。它是一个为分布式应用提供一致性服务的软件，提供的功能包括：配置维护、域名服务、分布式同步、组服务等。

ZooKeeper的目标就是封装好复杂易出错的关键服务，将简单易用的接口和性能高效、功能稳定的系统提供给用户。

ZooKeeper包含一个简单的原语集，提供Java和C的接口。

ZooKeeper代码版本中，提供了分布式独享锁、选举、队列的接口，代码在zookeeper-3.4.3\src\recipes。其中分布锁和队列有Java和C两个版本，选举只有Java版本。

作者目前使用到的：

在ZooKeeper上创建节点然后再对应的节点上进行增删的操作的同时使用Curator引入了Cache来实现对Zookeeper服务端事件监听，Cache事件监听可以理解为一个本地缓存视图与远程Zookeeper视图的对比过程。Cache提供了反复注册的功能。Cache分为两类注册类型：节点监听和子节点监听。

每个子目录项如 NameService 都被称作为znode，和文件系统一样，我们能够自由的增加、删除znode，在一个znode下增加、删除子znode，唯一的不同在于znode是可以存储数据的。有四种类型的znode：1、PERSISTENT-持久化目录节点客户端与zookeeper断开连接后，该节点依旧存在。2、PERSISTENTSEQUENTIAL-持久化顺序编号目录节点客户端与zookeeper断开连接后，该节点依旧存在，只是Zookeeper给该节点名称进行顺序编号。3、EPHEMERAL-临时目录节点客户端与zookeeper断开连接后，该节点被删除。4、EPHEMERALSEQUENTIAL-临时顺序编号目录节点。

话不多说首先我们来来看看zookeeper在linux下的安装吧！

在linux下安装zookeeper的之前我们首先要安装jdk，对于jdk的安装我们使用yum命令安装非常的简便

1.列出所有jdk版本：

yum -y list java*

2.选择版本安装

yum -y install java-1.7.0-openjdk*

3.验证是否ok

java

javac

java -version

zookeeper在linux的安装那就更加的简便了到zookeeper官网下载稳定版 https://archive.apache.org/dist/zookeeper 的 tar.gz 的上传至linux下的/usr/local目录下其实放在哪个目录下都随意将包解压命令tar -zxvf 包的名称即可解压到当前目录

进入到zookeeper的bin目录下

输入 sh zkServer.sh start 启动zookeeper

输入sh zkCli.sh 进入zookeeper的命令行查看当前我的zookeeper的节点

admin和zk-huey是小编自己创建的。

接下来我们一起走进代码编写吧

我先贴上代码的截图吧

引入zookeeper所需要的jar包

代码实现

package com.open.zookeeper;

import java.util.concurrent.ExecutorService;

import java.util.concurrent.Executors;

import org.apache.curator.framework.CuratorFramework;

import org.apache.curator.framework.CuratorFrameworkFactory;

import org.apache.curator.framework.recipes.cache.NodeCache;

import org.apache.curator.framework.recipes.cache.NodeCacheListener;

import org.apache.curator.framework.recipes.cache.PathChildrenCache;

import org.apache.curator.framework.recipes.cache.PathChildrenCacheEvent;

import org.apache.curator.framework.recipes.cache.PathChildrenCacheListener;

import org.apache.curator.framework.recipes.cache.PathChildrenCache.StartMode;

import org.apache.curator.retry.ExponentialBackoffRetry;

/**

 * @author lyj

 * @date 2019年1月8日 上午10:00:25

 * Curator事件监听测试

 * 使用Curator监听事件

 */

public class CarutorDemo {

    /**

     * ZooKeeper原生的API支持通过注册Watcher来进行事件监听，但是Watcher通知是一次性的，

     * 因此开发过程中需要反复注册Watcher，比较繁琐。Curator引入了Cache来监听ZooKeeper服务端的事件。

     * Cache对ZooKeeper事件监听进行了封装，能够自动处理反复注册监听，简化了ZooKeeper原生API繁琐的开发过程。

     * @param args

     * @throws Exception

     */



    public static void main(String[] args) throws Exception {

        CuratorFramework client = CuratorFrameworkFactory.builder()

            .connectString("118.25.26.200:2181")

            .sessionTimeoutMs(5000)

            .connectionTimeoutMs(3000)

            .retryPolicy(new ExponentialBackoffRetry(1000, 3))

            .build();

        client.start();



        // 创建节点

        client.create()

            .creatingParentsIfNeeded()

            .forPath("/zk-huey/cnode", "hello".getBytes());



        /**

         * 在注册监听器的时候，如果传入此参数，当事件触发时，逻辑由线程池处理

         */

        ExecutorService pool = Executors.newFixedThreadPool(2);



        /**

         * 监听数据节点的变化情况

         */

        final NodeCache nodeCache = new NodeCache(client, "/zk-huey/cnode", false);

        nodeCache.start(true);

        nodeCache.getListenable().addListener(

            new NodeCacheListener() {

                @Override

                public void nodeChanged() throws Exception {

                    System.out.println("Node data is changed, new data: " + 

                        new String(nodeCache.getCurrentData().getData()));

                }

            }, 

            pool

        );



        /**

         * 监听子节点的变化情况

         */

        final PathChildrenCache childrenCache = new PathChildrenCache(client, "/zk-huey", true);

        childrenCache.start(StartMode.POST_INITIALIZED_EVENT);

        childrenCache.getListenable().addListener(

            new PathChildrenCacheListener() {

                @Override

                public void childEvent(CuratorFramework client, PathChildrenCacheEvent event)

                        throws Exception {

                        switch (event.getType()) {

                        case CHILD_ADDED:

                            System.out.println("CHILD_ADDED: " + event.getData().getPath());

                            break;

                        case CHILD_REMOVED:

                            System.out.println("CHILD_REMOVED: " + event.getData().getPath());

                            break;

                        case CHILD_UPDATED:

                            System.out.println("CHILD_UPDATED: " + event.getData().getPath());

                            break;

                        default:

                            break;

                    }

                }

            },

            pool

        );



        client.setData().forPath("/zk-huey/cnode", "world".getBytes());



        Thread.sleep(10 * 1000);

        pool.shutdown();

        client.close();

    }



}