博客分类：
，解压缩至/usr/zookeeper.
复制conf/zoo_sample.cfg重命名为conf/zoo.cfg，执行命令 & sudo cp conf/zoo_sample.cfg conf/zoo.cfg
修改zoo.cfg文件，编辑为如下：
tickTime=2000
dataDir=/home/sulin/zookeeper
#数据存放目录
dataLogDir=/usr/zookeeper/logs
#日志存放目录，手动存在。如果没有貌似启动不成功
clientPort=2181
#客户端连接端口
# 此时已经可以通过“bin/zkServer.sh start”命令启动zookeeper，然后通过shell访问了zookeeper了
----------后面的配置是为了上面配置的单机版能让其他主机也能访问此zookeeper（其实也是伪分布式）
server.1=218.196.207.186: #2888是zookeeper服务之间的通信端口，3888是zookeeper与其他应用程序之间通信端口。
手动创建数据存放目录（/home/sulin/zookeeper），然后在目录中创建一个叫做"myid"的文件，文件内容为“1”。此处的1与上面的1对应。
分布式配置
和上面的伪分布式配置是一样的，如果是三台的话，zoo.cfg配置为：
tickTime=2000
dataDir=/home/sulin/zookeeper
dataLogDir=/usr/zookeeper/logs
clientPort=2181
server.1=218.196.207.186:
server.2=218.196.207.185:
server.3=218.196.207.184:
然后可以使用rsync指令将第一台机器上的zookeeper文件夹发送至其他两台
& sudo rsync -a /usr/zookeeper UbuntuB:/usr
& sudo rsync -a /usr/zookeeper UbuntuC:/usr
之后在其余两台机器上面手动创建dataDir文件夹，并且新建myid文件，写入自己的序号1/2/3。
然后分别在三台机器上面启动zookeeper服务：& bin/zooService.sh start
注意：一定要谨记将logs文件夹重建，因为里面的version-2里面会保存原有记录，此记录有可能与新集群有冲突。
注意：还有dataDir也要重建，原有的节点快照都会导致新集群出现问题。下面就是dataDir忘记重建出现的读取快照失败错误
下面是一个比较简单的测试程序，此程序改编自ZooKeeper官方文档中的例子：
package net.sulin.hbase.
import java.io.IOE
import java.util.ArrayL
import java.util.L
import org.apache.hadoop.hbase.util.B
import org.apache.zookeeper.AsyncCallback.StatC
import org.apache.zookeeper.CreateM
import org.apache.zookeeper.KeeperE
import org.apache.zookeeper.KeeperException.C
import org.apache.zookeeper.WatchedE
import org.apache.zookeeper.W
import org.apache.zookeeper.ZooD
import org.apache.zookeeper.ZooK
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Id;
import org.apache.zookeeper.data.S
* @author sulin
上午08:59:50
@SuppressWarnings("deprecation")
public class ZooKeeperTest01 implements Watcher, Runnable, StatCallback{
private static String znode = "/test";
public ZooK
public ZooKeeperTest01(String hostPort, String znode, String filename) {
zk = new ZooKeeper(hostPort, 5000, this);
} catch (IOException e) {
e.printStackTrace();
if(zk.exists(znode, false) == null){
// 创建节点，权限随便设置了。
Id id = new Id("ip", "218.196.207.187");
ACL acl = new ACL(ZooDefs.Perms.ALL, id);
List&ACL& acls = new ArrayList&ACL&();
acls.add(acl);
zk.create(znode, Bytes.toBytes("这是第一次放入的数据"), acls, CreateMode.PERSISTENT);
stat = new Stat();
System.out.println("第一次读到的数据： " + Bytes.toString(zk.getData(znode,true,stat)));
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
public static void main(String[] args) {
ZooKeeperTest01 temp = new ZooKeeperTest01("218.196.207.185:.207.184:.207.186:2181", znode, "");
new Thread(temp).start();
// 其他线程已启动
temp.zk.setData(znode, Bytes.toBytes("第二次放入的数据"), temp.stat.getVersion());
} catch (KeeperException e) {
e.printStackTrace();
} catch (InterruptedException e) {
e.printStackTrace();
synchronized (temp) {
temp.wait();
} catch (InterruptedException e) {
e.printStackTrace();
public void run() {
synchronized(this){
} catch (InterruptedException e) {
public void close(){
synchronized(this){
this.notifyAll();
* 监视事件被触发时执行此方法。
public void process(WatchedEvent event) {
String path = event.getPath();
if(event.getType() == Event.EventType.None){
// 节点没有发生改变，无节点创建、无接点删除、节点数据未改变、子节点未改变
// 那么说明可能是会话状态发生了改变
switch(event.getState()){
case SyncConnected:
// 此客户端处于连接状态，不需要做任何事
case Expired:
// 会话失效，结束
this.close();
// 状态改变了，检查是否znode节点值改变。如果改变则取出
if(path != null && path.equals(znode)){
zk.exists(znode, true, this, null);
* 状态回调方法，此方法被执行的触发条件是
* 在异步请求exists方法时，如果节点状态已经改变则执行此方法。
public void processResult(int rc, String path, Object ctx, Stat stat) {
boolean exists =
* 现在ZooKeeper已经将异常代码换为枚举类型而不是静态int常量
* 可以用KeeperException.Code.get(rc)获取rc的枚举类型。
switch(rc){
case Code.Ok:
// 一切完好
case Code.NoNode:
// 节点不存在
case Code.SessionExpired:
case Code.NoAuth:
this.close();
// 其他错误，重新尝试。。。
zk.exists(znode, false, this, null);
byte[] buf =
if(exists){
buf = zk.getData(znode, false, null);
} catch (KeeperException e) {
// 前面已经处理了此异常，此处不必处理
} catch (InterruptedException e) {
// 线程中断？事件线程中断？
// 读到了数据，简单打印看看了事
System.out.println("第二次异步读到的数据：" + Bytes.toString(buf));
执行的就是创建一个/test节点，之后放入一个数据，读出打印出来，同时设置监视器。
当第二次放入数据时，监视器会被触发，之后异步读取新数据并打印出来：
第一次读到的数据： 这是第一次放入的数据
第二次异步读到的数据：第二次放入的数据
浏览 11670
写道s 写道 写道楼主你好，你这个好像是在Linux下面安装的，是吗？ 我对这个也不怎么懂，我想在window下面怎么安装呢？还是说不能装呢？请楼主多多指教，先谢过啦！应该可以在Windows上安装吧，不过我没有试过。但是bin目录里面有Windows的脚本文件（*.cmd），你把上面的执行*.sh替换成*.cmd试试看行不。非常感谢楼主的回答。好像是可以的，呵呵，只是我也不知道到底服务有没有启动好！我只是查看了一下端口netstat -ano发现2181的端口已经开启了，是不是说明我的服务已经启动了啊？呵呵可以用 bin/zcCli.cmd -server ip:port去连接看看。成功了会有"Welcome to Zookeeper!",还可以进一步操作写错了，是zkCli.cmd
s 写道 写道楼主你好，你这个好像是在Linux下面安装的，是吗？ 我对这个也不怎么懂，我想在window下面怎么安装呢？还是说不能装呢？请楼主多多指教，先谢过啦！应该可以在Windows上安装吧，不过我没有试过。但是bin目录里面有Windows的脚本文件（*.cmd），你把上面的执行*.sh替换成*.cmd试试看行不。非常感谢楼主的回答。好像是可以的，呵呵，只是我也不知道到底服务有没有启动好！我只是查看了一下端口netstat -ano发现2181的端口已经开启了，是不是说明我的服务已经启动了啊？呵呵可以用 bin/zcCli.cmd -server ip:port去连接看看。成功了会有"Welcome to Zookeeper!",还可以进一步操作
写道楼主你好，你这个好像是在Linux下面安装的，是吗？ 我对这个也不怎么懂，我想在window下面怎么安装呢？还是说不能装呢？请楼主多多指教，先谢过啦！应该可以在Windows上安装吧，不过我没有试过。但是bin目录里面有Windows的脚本文件（*.cmd），你把上面的执行*.sh替换成*.cmd试试看行不。非常感谢楼主的回答。好像是可以的，呵呵，只是我也不知道到底服务有没有启动好！我只是查看了一下端口netstat -ano发现2181的端口已经开启了，是不是说明我的服务已经启动了啊？呵呵
楼主你好，你这个好像是在Linux下面安装的，是吗？ 我对这个也不怎么懂，我想在window下面怎么安装呢？还是说不能装呢？请楼主多多指教，先谢过啦！应该可以在Windows上安装吧，不过我没有试过。但是bin目录里面有Windows的脚本文件（*.cmd），你把上面的执行*.sh替换成*.cmd试试看行不。
浏览: 69091 次
来自: 北京
lliiqiang 写道既然是算法一定是有限功能，不可能完成无 ...
其实不存在什么知识产权的事情，因为都是人可以做的.只是说甚至对 ...
既然是算法一定是有限功能，不可能完成无限局限，你都挑出它不能做 ...
jar包是哪些啊
s 写道小马在天 写道楼主能否把加密的流程写 ...
(window.slotbydup=window.slotbydup || []).push({
id: '4773203',
container: s,
size: '200,200',
display: 'inlay-fix'