[Zookeeper学习笔记之二]Zookeeper部署脚本

Zookeeper伪分布式安装脚本(此脚本在一台机器上创建Zookeeper三个进程，即创建具有三个节点的Zookeeper集群。这个脚本和zookeeper的tar包放在同一个目录下，脚本中指定的名字是zookeeper的3.4.6版本，需要根据实际情况修改)：

 

#!/bin/bash  
  
#!!!Change the name!!!  
#The zookeeper file should be figured out in the same directory with this script  
ZOOKEEPER_FILE=zookeeper-3.4.6  
  
tar -xzvf ${ZOOKEEPER_FILE}.tar.gz  
  
cd ${ZOOKEEPER_FILE}  
  
mkdir cluster  
  
cd cluster  
  
mkdir -p z1/data  
  
mkdir -p z2/data  
  
mkdir -p z3/data  
  
echo 1 > z1/data/myid  
  
echo 2 > z2/data/myid  
  
echo 3 > z3/data/myid  
  
  
  
echo "initLimit=10\nsyncLimit=5\ndataDir=../cluster/z1/data\nclientPort=2181\nserver.1=127.0.0.1:2222:2223\nserver.2=127.0.0.1:3333:3334\nserver.3=127.0.0.1:4444:4445" > z1/z1.cfg  
  
echo  "initLimit=10\nsyncLimit=5\ndataDir=../cluster/z2/data\nclientPort=2182\nserver.1=127.0.0.1:2222:2223\nserver.2=127.0.0.1:3333:3334\nserver.3=127.0.0.1:4444:4445" > z2/z2.cfg  
  
echo "initLimit=10\nsyncLimit=5\ndataDir=../cluster/z3/data\nclientPort=2183\nserver.1=127.0.0.1:2222:2223\nserver.2=127.0.0.1:3333:3334\nserver.3=127.0.0.1:4444:4445" > z3/z3.cfg  
  
  
echo "The 3 nodes zookeeper has been configured successfully"  
  
cd ../bin  
  
  
echo "Start to start node1\n"  
  
./zkServer.sh start ../cluster/z1/z1.cfg  
  
  
echo "!!!!!!!!!!!!!!!!!Node1 is started!!!!!!!"   
  
echo "Start to start node2\n"  
  
./zkServer.sh start ../cluster/z2/z2.cfg  
  
echo "!!!!!!!!!!!!!!!!!Node2 is started!!!!!!!"   
  
  
echo "Start to start node3\n"  
  
./zkServer.sh start ../cluster/z3/z3.cfg  
  
  
echo "!!!!!!!!!!!!!!!!!Node3 is started!!!!!!!"   
  

 

   

执行完脚本后，三个node已经启动，停止三个node的命令： 
bin/zkServer.sh stop ../cluster/z1/z1.cfg 
bin/zkServer.sh stop ../cluster/z2/z2.cfg 
bin/zkServer.sh stop ../cluster/z3/z3.cfg

客户端验证程序：

 

import org.apache.zookeeper.*;

import java.io.IOException;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ThreadLocalRandom;

public class ZKApplication implements Watcher {
    private static final int SESSION_TIMEOUT = 3000;
    private volatile static boolean shutdown;
    private ZooKeeper zk;
    private CountDownLatch connectedSignal = new CountDownLatch(1);

    public void connect(String hosts) throws IOException, InterruptedException {
        zk = new ZooKeeper(hosts, SESSION_TIMEOUT, this);
        connectedSignal.await();
    }

    @Override
    public void process(WatchedEvent event) { // Watcher interface
        if (event.getState() == Event.KeeperState.SyncConnected) {
            connectedSignal.countDown();
        }
    }

    public void create(String groupName) throws KeeperException,
            InterruptedException {
        String path = "/" + groupName;
        String createdPath = zk.create(path, null/*data*/, ZooDefs.Ids.OPEN_ACL_UNSAFE,
                CreateMode.EPHEMERAL); //The znode will be deleted upon the session is closed.
        System.out.println("Created " + createdPath);
    }

    public void close() throws InterruptedException {
        zk.close();
    }

    public static void main(String[] args) throws Exception {
        final ZKApplication createGroup = new ZKApplication();
        String groupName = "zoo" + ThreadLocalRandom.current().nextInt();
        createGroup.connect(Host.HOST);
        createGroup.create(groupName);
        createGroup.close();
    }
}

 单机部署Zookeeper集群的脚本还有很大的改进空间，应该根据需要很方便的创建n个节点，其中n可以由用户指定