文档章节

windows下Zookeeper的安装和使用

writeademo
 writeademo
发布于 2017/03/02 17:28
字数 649
阅读 316
收藏 1

Zookeeper的安装和使用

1、  下载zookeeper安装文件,解压缩,放入固定目录中

下载地址:http://hadoop.apache.org/zookeeper/

下载文件:zookeeper-3.4.6.tar.gz,解压缩后,放入目录

D:\zookeeper-3.4.9\

2、  修改zookeeper配置文件zoo-example.cfg改为zoo.cfg,zookeeper默认寻找zoo.cfg配置文件

Zoo.cfg在zookeeper安装文件的conf文件夹下

修改内容为:

[java] view plain copy

  1. # The number of milliseconds of each tick  
  2. tickTime=2000  
  3. # The number of ticks that the initial   
  4. # synchronization phase can take  
  5. initLimit=10  
  6. # The number of ticks that can pass between   
  7. # sending a request and getting an acknowledgement  
  8. syncLimit=5  
  9. # the directory where the snapshot is stored.  
  10. # do not use /tmp for storage, /tmp here is just   
  11. # example sakes.  
  12. #dataDir=/tmp/zookeeper  
  13. dataDir=D:\\ll\\program\\zookeeper-3.4.6\\data  
  14. dataLogDir=D:\\ll\\program\\zookeeper-3.4.6\\log  
  15. # the port at which the clients will connect  
  16. clientPort=2181  
  17. # the maximum number of client connections.  
  18. # increase this if you need to handle more clients  
  19. #maxClientCnxns=60  
  20. #  
  21. # Be sure to read the maintenance section of the   
  22. # administrator guide before turning on autopurge.  
  23. #  
  24. # http://zookeeper.apache.org/doc/current/zookeeperAdmin.html#sc_maintenance  
  25. #  
  26. # The number of snapshots to retain in dataDir  
  27. #autopurge.snapRetainCount=3  
  28. # Purge task interval in hours  
  29. # Set to "0" to disable auto purge feature  
  30. #autopurge.purgeInterval=1  

说明:

tickTime这个时间是作为Zookeeper 服务器之间或客户端与服务器之间维持心跳的时间间隔,也就是每个 tickTime 时间就会发送一个心跳。

dataDir顾名思义就是Zookeeper 保存数据的目录,默认情况下,Zookeeper 将写数据的日志文件也保存在这个目录里。

dataLogDir顾名思义就是Zookeeper 保存日志文件的目录

clientPort这个端口就是客户端连接Zookeeper 服务器的端口,Zookeeper 会监听这个端口,接受客户端的访问请求。

3、  启动zookeeper

Window下命令:进入bin目录 ->zkServer.cmd

Linux下命令:进入bin目录 -> zkServer.sh

示例:在windows的命令行下执行

D:\zookeeper-3.4.9\bin>zkServer.cmd

4、检查zookeeper是否已经在服务,通过netstat – ano 命令查看是否有你配置的 clientPort 端口号在监听服务

netstat –ano|findstr 2181



4、  Zookeeper启动成功后,编写Java代码

需要两个jar包:zookeeper-3.4.6.jarslf4j-api-1.6.1.jar,在zookeeper-3.4.6.tar.gz中都可找到

package zookeeperLearn.zookeeper1;

 

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;

import org.apache.zookeeper.ZooDefs.Ids;

import org.apache.zookeeper.ZooKeeper;

import org.apache.zookeeper.proto.WatcherEvent;

 

public class ZooKeeper1 {

  private final static int SESSION_TIMEOUT = 30000;

  ZooKeeper zk;

  Watcher wa = new Watcher() {

 

    public void process(WatchedEvent event) {

     System.out.println(event.toString());

 

    }

  };

 

  public static void main(String[] args) throws IOException, InterruptedException, KeeperException {

    ZooKeeper1 z = new ZooKeeper1();

    z.createZlInstance();

    z.zkOpitions();

    z.zKClose();

  }

 

  public void zKClose() throws InterruptedException {

    zk.close();

  }

 

public void zkOpitions() throws KeeperException, InterruptedException {

    System.out.println("create zk znode");

    zk.create("/zoo1", "myData2".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);

    System.out.println("create zk znode is ok?");

    System.out.println(new String(zk.getData("/zoo1", false, null)));

    System.out.println("modify znode");

    zk.setData("/zoo1", "modifyedint".getBytes(), -1);

    System.out.println("is modified ok?");

    System.out.println(new String(zk.getData("/zoo1", false, null)));

    System.out.println("delete znode..");

    zk.delete("/zoo1", -1);

    System.out.println("delete znode  ok?");

    System.out.println("znode state is :" + zk.exists("/zoo1", false));

  }

 

  public void createZlInstance() throws IOException {

    zk = new ZooKeeper("localhost:2181", ZooKeeper1.SESSION_TIMEOUT, this.wa);

 

  }

 

}

 

 

© 著作权归作者所有

writeademo
粉丝 27
博文 681
码字总数 256388
作品 0
东城
私信 提问
Winows上简单配置使用kafka(.net使用)

一、kafka环境配置 1.jdk安装 安装文件:http://www.oracle.com/technetwork/java/javase/downloads/index.html 下载JDK 安装完成后需要添加以下的环境变量(右键点击“我的电脑” -> "高级系...

未名天
今天
0
0
Apache Kafka学习(三)之Kafka常用命令

1、开启zookeeper(在安装目录下使用命令) Linux:bin/zkServer.sh start windows:binzkServer.cmd 2、启动kafka(安装目录下使用命令) Linux:bin/kafka-server-start.sh start config/se...

zqcju
07/05
82
0
《Zookeeper--Windows单机安装》

《Zookeeper--Windows单机安装》 Zookeeper作为Dubbo服务的注册中心,Zookeeper一个分布式的服务框架,是树型的目录服务的数据存储,能做到集群管理数据 ,这里能很好的作为Dubbo服务的注册中...

爱笑的我们
2018/05/09
0
0
Windows 安装运行 Apache Kafka 教程

下面是分步指南,教你如何在Windows OS上安装运行Apache Zookeeper和Apache Kafka。 简介 本文讲述了如何在Windows OS上配置并启动Apache Kafka,这篇指南将会指导你安装Java和Apache Zookee...

大数据之路
2012/08/26
672
0
kafka在windows上的安装、运行

kafka在windows上的安装、运行 目录(?)[+] 1.简介 Kafka是一种高吞吐量的分布式发布订阅消息系统。详细介绍可查阅官网:kafka官网 2.环境搭建 2.1 安装JDK 下载地址:jre下载 有关jdk的安装不...

yucaifu1989
2018/04/21
0
0

没有更多内容

加载失败,请刷新页面

加载更多

手机视频如何制作GIF动图

很多小伙伴都喜欢用GIF动图在各大社交软件上与好友斗图,那你知道这些好玩有趣的GIF动图是如何制作的吗?下面教你一个将手机视频制作成GIF动图的方法,让你都可以随时随地制作有趣的表情包,...

白米稀饭2019
26分钟前
4
0
Spring Security 实战干货:实现自定义退出登录

1. 前言 上一篇对 Spring Security 所有内置的 Filter 进行了介绍。今天我们来实战如何安全退出应用程序。 2. 我们使用 Spring Security 登录后都做了什么 这个问题我们必须搞清楚!一般登录...

码农小胖哥
今天
10
0
JVM核心知识-类加载机制

JVM中类的生命周期包括7个阶段,加载、准备、验证、解析、初始化、使用、卸载。其中准备、验证、解析被归为连接阶段。 加载 jvm在这个阶段完成的工作 通过类名获取类的二进制字节流 将这个字...

moon888
今天
8
0
.net工作流引擎ccflow流程结束相关功能的介绍

关键字: 工作流程管理系统 工作流引擎 asp.net工作流引擎 java工作流引擎. 表单引擎 工作流功能说明 工作流设计 工作流快速开发平台 业务流程管理 bpm工作流系统 java工作流主流框架 自定义...

孟娟
今天
8
0
APP 值入轻量级钱包以太坊网络钱包

APP 值入轻量级钱包以太坊网络钱包

xiaodong16
今天
5
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部