转自： http://my.oschina.net/u/2377453/blog/464739

1、解压zookeeper

2、在$ZOOKEEPER_HOME/conf下创建zoo.cfg文件（参考配置文件：zoo_sample.cfg），内容为：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
# CS通信心跳时间，Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔，也就是每个 tickTime 时间就会发送一个心跳。tickTime以毫秒为单位
tickTime=2000
 
# LF初始化通信时限，集群中的follower服务器(F)与leader服务器(L)之间初始连接时能容忍的最多心跳数（tickTime的数量）
initLimit=10
 
# LF同步通信时限，集群中的follower服务器与leader服务器之间请求和应答之间能容忍的最多心跳数（tickTime的数量）。
syncLimit=5
 
#数据文件目录，Zookeeper保存数据的目录，默认情况下，Zookeeper将写数据的日志文件也保存在这个目录里。
dataDir=/root/app/zookeeper/data
 
#客户端连接端口，客户端连接 Zookeeper 服务器的端口，Zookeeper 会监听这个端口，接受客户端的访问请求。
clientPort=2181
 
#服务器名称与地址：集群信息（服务器编号，服务器地址，LF通信端口，选举端口）
#这个配置项的书写格式比较特殊，规则如下：
#server.N=YYY:A:B 
server.1=hadoop.master:2888:3888
server.2=hadoop.slave:2888:3888
#端口
#2181：用于客户端的连接
#2888：follower与leader通信
#3888：leader选举端口

3、根据zoo.cfg在dataDir配置的路径下创建myid文件，且输入server.N的N内容（例如：当前机器是server.1，那么在    myid中输入1）

4、复制配置完毕的zookeepr到其他节点

1
scp -r $ZOOKEEPER_HOME root@hostname:/home

5、复制完毕之后记得修改myid

6、在各个节点上分别启动脚本：

1
$ZOOKEEPER_HOME/bin/zkServer.sh start

7、检查命令

1
2
3
4
7.1、#zkServer.sh status
//如果出现Error contacting service. It is probably not running.错误，是因为节点只启动了一个，无法启动集群模式
7.2、#echo ruok | nc localhost 2181
//如果命令成功会返回imok（I'm ok）

8、zk客户端

1
2
3
4
5
6
7
8
9
10
$ZOOKEEPER_HOME/bin/zkCli.sh -server hostname:2181
//启动一个zk客户端
//最终要记住一个help命令即可掌握其他命令的用法
（操作之前需要了解类似文件系统的znode，
    简单描述：zk中所有节点都是znode节点,znode节点不仅可以作为目录还可以存储数据.）
CREATE 创建znode
SET 设置znode的数据
GET 查询znode
RMR 删除znode
...等等自行查询

9、Java客户端

相关代码：

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.WatchedEvent;
import org.apache.zookeeper.Watcher;
import org.apache.zookeeper.ZooDefs.Ids;
import org.apache.zookeeper.ZooKeeper;
public class ZKClient {
    // 连接地址
    private final static String CONN = "192.168.1.200:2181";
    // client与zk超时时间(unit:ms)
    private final static int SESSION_TIMEOUT = 5000;
 
    public static void main(String[] args) throws Exception {
 
        //1、持久节点：创建的节点成功时,节点便会持久化在zk上
        //2、临时节点：创建节点过程中一旦发生有意或无意的客户端超时或者关闭,节点都被删除
        ZooKeeper zk = new ZooKeeper(CONN, SESSION_TIMEOUT, new Watcher() {
            @Override
            public void process(WatchedEvent event) {
                //接收zk各个时间通知
                System.out.println("------------------------");
                System.out.println("Path:"+event.getPath());
                System.out.println("type:"+event.getType());
                System.out.println("state"+event.getState());
                System.out.println("wrapper:"+event.getWrapper());
                System.out.println("------------------------");
            }
        });
        String path = "/hello";
        byte[] data = "testhello!".getBytes();
        zk.create(path,data, Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
        zk.close();
    }
}

最新文章

  1. 使用QRCode生成二维码
  2. 一个简单xml数据转换为数组的方法
  3. 重新想象 Windows 8 Store Apps (48) - 多线程之其他辅助类: SpinWait, SpinLock, Volatile, SynchronizationContext, CoreDispatcher, ThreadLocal, ThreadStaticAttribute
  4. 【Unity Shaders】学习笔记——SurfaceShader（十）镜面反射
  5. Javascript实现 图片的无缝滚动
  6. 一个用ASP生成html的新方法
  7. Asp.net的IP地址屏蔽功能设计
  8. linux C之access函数 (20
  9. Android学习笔记（一）开发环境搭建
  10. Markdown 11 种基础语法
  11. 刚开始学python——数据结构——“自定义队列结构“
  12. 【SAP HANA】新建账户和数据库（2）
  13. 一文入门HTML5
  14. metasploit下Windows下多种提权方式
  15. 小学生噩梦——四则运算题库(python 全功能实现)
  16. 加了synchronized后还是不安全的问题
  17. C# List 作为参数传递的值变化
  18. 【转载】重置密码解决MySQL for Linux错误 ERROR 1045 (28000): Access denied for user 'root'@'localhost' (using password: YES)
  19. [Jmeter] 用xsltproc生成html格式的报告
  20. .net core 在linux系统运行

热门文章

  1. CSS里width: auto\9 是什么意思
  2. Unity3D之随心所欲的获取对象
  3. Maven打包程序
  4. 新手用git
  5. Strus2第一次课：dom4j操作xml
  6. 使用时间戳和sequence生成主键的function
  7. HTML5扩展之微数据与丰富网页摘要
  8. ssh 登录
  9. [原创] Easy SysLite V1.2 （2016.5.29更新，新增加WIN10支持，一个程序适配所有系统减肥）
  10. Servlet实现简单CRUD