java连接zookeeper：

使用java连接zookeeper

1.在虚拟机中启动zookeeper

到虚拟机中找到所安装的zookeeper路径中的bin目录下使用sh命令启动zkServer.sh（注意：zkServer.sh为zookeeper服务，zkCli.sh为zookeeper服务器）。

sh zkServer.sh start

查看服务启动状态：

sh zkServer.sh status

启动完成，leader为主zookeeper

2.在eclipse中创建项目并导入其jar包

导入其所需的jar包。

3.在java项目下新建一个ZookeeperAPI类

package com.zookeeper.run;

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


import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.Watcher.Event.KeeperState;
import org.apache.zookeeper.ZooKeeper;
import org.junit.Test;

public class ZookeeperAPI {
	ZooKeeper zooKeeper;
	@Test
	public void zookeeperConn() throws IOException, InterruptedException {

		CountDownLatch cdl = new CountDownLatch(1);
		//第一个参数为虚拟机的ip地址及zookeeper的端口
		//第二个参数是允许等待连接多久超时，5000即为5秒
		//第三个参数new Watcher()用于监听是否连接成功
		zooKeeper = new ZooKeeper("192.168.75.100:2181", 5000, new Watcher() {

			@Override
			public void process(WatchedEvent event) {
				if(event.getState() == KeeperState.SyncConnected) {
					System.out.println("连接成功");
				}
				cdl.countDown();
			}
			
		});
		cdl.await();
	}
	
}

至此连接成功！