大数据入门第二天——基础部分之zookeeper（下）

一、集群自启动脚本

　　1.关闭zk

[root@localhost bin]# jps
3104 Jps
2805 QuorumPeerMain
[root@localhost bin]# kill -9 2805

　　//kill或者stop都是可以的

　　2.远程执行命令

[root@localhost bin]# ssh 192.168.137.138 /opt/zookeeper/zookeeper-3.4.5/bin/zkServer.sh start
root@192.168.137.138's password: 
JMX enabled by default
Using config: /opt/zookeeper/zookeeper-3.4.5/bin/../conf/zoo.cfg
Starting zookeeper ... /opt/zookeeper/zookeeper-3.4.5/bin/zkServer.sh: 第 103 行:[: /tmp/zookeeper: 期待二元表达式
STARTED

　　出现以上中文的地方只需要修改一下zoo.cfg，把多余的配置注释即可！

　　当然，这样还是无法启动！因为ssh过去是以一个bash的方式过去的（不会执行/etc/profile，而正常登录是会执行的，也可以打开相应的脚本进行查看），也就是PATH不在了，导致JAVA_HOME等找不到了！

　　EXPORT所定义的变量对自己所在的shell以及子shell生效

　　这里就需要用到之前说到的source命令了：https://www.cnblogs.com/pkufork/p/linux_source.html

ssh 192.168.137.138 "source /etc/profile&&/opt/zookeeper/zookeeper-3.4.5/bin/zkServer.sh start"

　　//如果不使用引号，将会以空格作为命令的分割！

　　3.配置免密登录

　　在其中一台机器上（这里是192.168.137.128）

ssh-keygen

　　//之后enter即可

ssh-copy-id 192.168.137.128
ssh-copy-id 192.168.137.138
ssh-copy-id 192.168.137.148

　　4.一键启动脚本

cd /root
mkdir bin
cd bin
vim startZK.sh

#!/bin/bash
SERVERS="192.168.137.128 192.168.137.138 192.168.137.148"
echo "start zk..."
for SERVER in $SERVERS
do
    ssh $SERVER "source /etc/profile&&/opt/zookeeper/zookeeper-3.4.5/bin/zkServer.sh start"
done

chmod +x startZK.sh

　　这样，通过startZK.sh就能一键启动了！（/root/bin默认在PATH中了！）

二、zk的Java客户端

　　相关API入门可以参考：https://www.cnblogs.com/ggjucheng/p/3370359.html

　　第三方的客户端：zkclient参考：https://www.cnblogs.com/f1194361820/p/5575206.html

　　1.引入maven依赖

        <dependency>
            <groupId>org.apache.zookeeper</groupId>
            <artifactId>zookeeper</artifactId>
            <version>3.4.6</version>
        </dependency>

　　2.测试程序是否能通

public class SimpleZK {
    // 设置连接字符串（可以用逗号隔开多个），失败时会自动尝试多个
    private static final String coonectString = "192.168.137.128:2181,192.168.137.138:2181,192.168.137.148:2181";
    // 超时时间
    private static final int sessionTimeout = 2000;
    public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
        ZooKeeper zkClient = new ZooKeeper(coonectString, sessionTimeout, new Watcher() {
            public void process(WatchedEvent watchedEvent) {
                // 收到通知事件后的回调函数
                System.out.println(watchedEvent.getType()+"---"+watchedEvent.getPath());
            }
        });
        // zk的增删改查（这里使用最底层的原生操作,zkclient的待补充）
        String node = zkClient.create("/app2", "hellozk".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

    }

}

　　完美：

　　　　大数据入门第二天——基础部分之zookeeper（下）

　　3.增删改查实例

package com.zk;

import org.apache.zookeeper.*;
import org.apache.zookeeper.data.Stat;
import org.junit.Before;
import org.junit.Test;


import java.io.IOException;
import java.util.List;

/**
 * 测试zk的Java客户端
 *
 * @author zcc ON 2018/1/17
 **/
public class SimpleZK {
    // 设置连接字符串（可以用逗号隔开多个），失败时会自动尝试多个
    private static final String coonectString = "192.168.137.128:2181,192.168.137.138:2181,192.168.137.148:2181";
    // 超时时间
    private static final int sessionTimeout = 2000;
    // 初始变量
    ZooKeeper zkClient = null;

    /**
     * 初始化方法
     * @throws IOException
     */
    @Before
    public void init() throws IOException {
        zkClient = new ZooKeeper(coonectString, sessionTimeout, new Watcher() {
            public void process(WatchedEvent watchedEvent) {
                // 收到通知事件后的回调函数
                System.out.println(watchedEvent.getType()+"---"+watchedEvent.getPath());
                // 开启循环监听（监听调用此方法，此方法又开启监听）
                try {
                    zkClient.getChildren("/", true);
                } catch (KeeperException e) {
                    e.printStackTrace();
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
    }

    /**
     * 创建
     */
    public void testCreate() throws IOException, KeeperException, InterruptedException {
        String node = zkClient.create("/app2", "hellozk".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    }

    /**
     * 判断是否存在节点
     * @throws KeeperException
     * @throws InterruptedException
     */
    public void testExists() throws KeeperException, InterruptedException {
        // stat就是zk中那一堆数据（null则不存在）
        Stat stat = zkClient.exists("/", false);
    }
    /**
     * 取得子节点
     */
    @Test
    public void testGetChildren() throws KeeperException, InterruptedException {
        List<String> children = zkClient.getChildren("/", true);
        for (String child : children) {
            System.out.println(child);
        }
    }

    /**
     * 获取数据
     */
    @Test
    public void testGetData() throws KeeperException, InterruptedException {
        // 分别是路径，是否监听以及状态版本（null就OK了，取最新）
        byte[] data = zkClient.getData("/app2", false, null);
        System.out.println(new String(data));
    }

    /**
     * 删除数据
     */
    @Test
    public void testDeleteZnode() throws KeeperException, InterruptedException {
        // -1作为版本号参数表示删除所有版本（上层的API是不用传这些参数的）
        zkClient.delete("/app2",-1);
    }

    /**
     * 修改数据
     */
    public void testSetData() throws KeeperException, InterruptedException {
        zkClient.setData("/app2", "hellozkCli".getBytes(), -1);
    }
}

View Code