zookeeper使用：https://blog.csdn.net/haoyuyang/article/details/53469269

基本原理

部署安装

1. 部署假设3个节点，ip分别为A,B,C

2. 在用户zookeeper用户下安装

# 增加用户，并赋予其密码
$ adduser zookeeper
$ passwd zookeeper            # ur password for zookeeper user
# 赋予用户可以 sudo的权限
$ chmod u+w /etc/sudoers
$ vim /etc/sudoers# 找到 `root ALL=(ALL) ALL`这行，并在下面添加 erickzookeeper    ALL=(ALL)    ALL
$ chmod u-w /etc/sudoers
# 切换到 zookeeper用户
$ su - zookeeper

1. 从zookeeper中下载zookeeper，然后将其导入3个节点中中的路径或者：

 $ wget http://archive.apache.org/dist/zookeeper/zookeeper-3.4.10/zookeeper-3.4.10.tar.gz

$ cd /home/erick
# 存放软件目录 & 安装目录 & 日志目录
$ mkdir install && mkdir software && mkdir logs

1. 然后解压到software中：

$ tar -zxvf zookeeper-3.4.10 -C ~/software
$ cd ~/software
$ ln -s zookeeper-3.4.10 zookeeper

1. 配置

cd zookeeper
$ mkdir tmp
$ cp conf/zoo_sample.cfg conf/zoo.cfg
$ mkdir -p /home/zookeeper/data/zookeeper
$ mkdir -p /home/zookeeper/logs/zookeeper
$ vim conf/zoo.cfgtickTime=2000  dataDir=/home/erick/data/zookeeperdataLogDir=/home/erick/logs/zookeeperclientPort=2181  initLimit=10  syncLimit=5  server.1=A:2888:3888  server.2=B:2888:3888  server.3=C:2888:3888

然后在 dataDir目录新建myid文件，将相应的id写入到其中：

echo 1 > myid
echo 2 > myid
echo 3 > myid

1.最后启动

./zkServer.sh start
./zkServer.sh status

操作使用（java）

• 新建maven工程

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

package LIHAO;/*** Created by Administrator on 2017/12/5.*/
import java.io.IOException;import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;public class Test {// 会话超时时间，设置为与系统默认时间一致private static final int SESSION_TIMEOUT = 30 * 1000;// 创建 ZooKeeper 实例private ZooKeeper zk;// 创建 Watcher 实例private Watcher wh = new Watcher() {/*** Watched事件*/public void process(WatchedEvent event) {System.out.println("WatchedEvent >>> " + event.toString());}};// 初始化 ZooKeeper 实例private void createZKInstance() throws IOException {// 连接到ZK服务，多个可以用逗号分割写zk = new ZooKeeper("A:2181,B:2182,C:2183", Test.SESSION_TIMEOUT, this.wh);}private void ZKOperations() throws IOException, InterruptedException, KeeperException {System.out.println("\n1. 创建 ZooKeeper 节点 (znode ： zoo2, 数据： myData2 ，权限： OPEN_ACL_UNSAFE ，节点类型： Persistent");zk.create("/zoo2", "myData2".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);System.out.println("\n2. 查看是否创建成功： ");System.out.println(new String(zk.getData("/zoo2", this.wh, null)));// 添加Watch// 前面一行我们添加了对/zoo2节点的监视，所以这里对/zoo2进行修改的时候，会触发Watch事件。System.out.println("\n3. 修改节点数据 ");zk.setData("/zoo2", "shanhy20160310".getBytes(), -1);// 这里再次进行修改，则不会触发Watch事件，这就是我们验证ZK的一个特性“一次性触发”，也就是说设置一次监视，只会对下次操作起一次作用。System.out.println("\n3-1. 再次修改节点数据 ");zk.setData("/zoo2", "shanhy20160310-ABCD".getBytes(), -1);System.out.println("\n4. 查看是否修改成功： ");System.out.println(new String(zk.getData("/zoo2", false, null)));System.out.println("\n5. 删除节点 ");zk.delete("/zoo2", -1);System.out.println("\n6. 查看节点是否被删除： ");System.out.println(" 节点状态： [" + zk.exists("/zoo2", false) + "]");}private void ZKClose() throws InterruptedException {zk.close();}public static void main(String[] args) throws IOException, InterruptedException, KeeperException {Test dm = new Test();dm.createZKInstance();dm.ZKOperations();dm.ZKClose();}
}

客户端操作

性能测试

jdk安装

Download from jdk-7u80-linux-x64.rpm或者此下载

$ chmod +x install/jdk-7u80-linux-x64.rpm$ sudo rpm -ivh install/jdk-7u80-linux-x64.rpm
$ java -versionjava version "1.7.0_80"Java(TM) SE Runtime Environment (build 1.7.0_80-b15)Java HotSpot(TM) 64-Bit Server VM (build 24.80-b11, mixed mode)
$ which java/usr/bin/java
$ ln -s /usr/java/jdk1.7.0_80 software/jdk1.7.0_80
$ ln -s /home/eagle/software/jdk1.7.0_80 software/java
$ vim ~/.bash_profile# User specific environment and startup programsexport JAVA_HOME=/home/eagle/software/javaexport CLASSPATH=.:$JAVA_HOME/lib/tools.jar$JAVA_HOME/lib/dt.jarexport PATH=$JAVA_HOME/bin:$PATH
$ source ~/.bash_profile