1、上传文件目录说明

上传的文件一般放在 /home/下

安装文件一般在 /usr/local/下

2. 安装zookeeper

2.1将zookeeper-3.4.11.tar.gz拷贝到/home/下

2.2解压、重命名、移动

tar -xvzf zookeeper-3.4.11.tar.gz

mv zookeeper-3.4.11.tar.gz zookeeper

mv zookeeper /usr/local

3. 配置环境变量

vim /etc/profile

export ZOOKEEPER_HOME=/usr/local/zookeeper

export PATH=$PATH:$ZOOKEEPER_HOME/bin;

sourse /etc/profile //刷新文件

4. 目录结构

bin:运行命令

conf:配置文件

contri:附加功能

dist-maven:maven编译后的目录

docs:文档

lib:依赖的jar包

recipes:案例demo代码

src:源码

5. 启动zookeeper

5.1修改conf/

cd /usr/local/zookeeper/conf/

cp zoo_sample.cfg zoo.cfg

zoo.cfg参数说明:tickTime(时间单元)、initLimit(节点同步到master节点的连接时间)、syncLimit(master节点与从节点发消息请求和应答时间)、dataDir(必须配置)、dataLogDir(日志目录)、clientPort(连接服务器端口,默认2181)

5.2启动

cd /usr/local/zookeeper/bin

启动服务端:./zkServer.sh start

启动客户端:./zkCli.sh

6. Linux端命令

启动客户端之后:

help:查看zk命令

ls:ls  / (/代表根节点,/下的目录代表子节点)

ls2:ls  /+状态信息(stat /)

get:get  / 获得当前节点的数据

session:客户端与服务端的会话、可设置超时时间、心跳结束session过期、session过期临时节点znode被抛弃

心跳机制:客户端向服务端的ping包请求,或者不删、挂了才删,重新连接后如果心跳机制未超时,临时节点还存在

create /zkfk zkfk-data:创建一个zkfk目录,zkfk-data节点

create -e /zkfk/temp zdfk-data 在temp目录下创建一个zkfk-data临时节点(-e)

create -s /zkfk/seq seq:创建sequence目录,名称自动增长(-s)

set /zkfk new-data 1:修改zkfk节点,zkfk-data -> new-data,版本号加1,1代表最新版本号

delete /zkfk/seq0000000005 1:删除目录,版本号为1的目录

watcher:监督每个节点的操作,znode变化时触发,触发后立即销毁,父子节点增删改能够触发

stat /zkfk/one watch:创建时触发watch(父)

get /zkfk/one watch:get时设置,当修改、删除时触发watch(父)

ls /zkfk watch:创建、删除子节点时触发watch(子)

get /zkfk/one watch:修改时触发watch(子)

acl:权限控制,getAcl(获取节点权限信息),setAcl(设置节点权限信息),addauth(输入认证授权信息)

crdwa:create(创建子节点)、read、delete(删除子节点)、wirte、admin(设置权限)

setAcl /zkfk/one world:anyone:crwa:设置权限,不能删除

addauth digest fk:fk:添加用户fk,密码fk或登录

setAcl /zkfk/one auth:fk:fk:cdrwa:通过认证信息设置权限

setAcl /zkfk/one digest:fk:xJ0PRXcE29ROsbH4WtFbbjYdsP8=:cdrwa:通过认证信息设置权限

setAcl /zkfk/ip ip:192.168.1.103:cdrwa:通过ip设置权限

超级管理员权限:

vim zkServer.sh修改如下

重启服务

四字命令:是有自身的简短命令与服务器进行交互(先:yum install nc )

echo stat | nc localhost 2181:查看当前ip端口stat信息

echo ruok | nc localhost 2181:查看当前ip端口zk是否启动

echo dump | nc localhost 2181:查看当前ip端口未经处理的会话和临时节点

echo conf | nc localhost 2181:查看当前ip端口服务器配置信息

echo confs| nc localhost 2181:查看当前ip端口连接到服务器的客户端信息

echo envi| nc localhost 2181:查看当前ip端口环境变量

mntr:健康信息

wchs:watch信息

4lw.commands.whitelist=*:开启所有四字命令,修改zookeeper/conf/zoo.cfg文件,加载最后一行,重启

wchc:watch节点

wchp:watch路径

7. 集群

7.1选举模式:

master节点down机器,子节点会竞争,有一个子节点成为master节点,若开始的master节点恢复,则成为子节点

7.2伪分布式集群搭建

  1. 在 zookeeper/conf/zoo.cfg中添加:

server.1=192.168.107.128:2888:3888

server.2=192.168.107.128:2889:3889

server.3=192.168.107.128:2890:3890

说明:2888端口(集群中同步数据的端口)、3888端口(选举模式下选举端口)

  1. 修改1中的dataDir=/usr/local/zookeeper/dataDir,并在对应目录下创建myid文件
  2. 将zookeeper文件复制两份,命名:zookeeper02、zookeeper03

cp zookeeper zookeeper02 -rf

cp zookeeper zookeeper03 -rf

  1. 修改zookeeper02、zookeeper03中重复2步骤:并将dataDir改为自己目录、改clientPort
  2. 启动三个zookeeper的服务端:./zkServer.sh start
  3. 客户端连接服务端:./zkCli.sh -server localhost:2181 更改节点,在连接其他服务端,可查看到节点已经更改 即:同步。

7.3真分布式集群搭建

1、准备三台服务器,为了区分zookeeper,分别命名为:zookeeper、zookeeper_c01、zookeeper_c02, ip分别为:

CeantOS64(zookeeper):192.168.107.128

CeantOS64_clon01(zookeeper_c01):192.168.107.130

CeantOS64_clon02(zookeeper_c02):192.168.107.131

2、分别在三台服务气的 zookeeper/conf/zoo.cfg中添加:

server.1=192.168.107.128:2888:3888

server.2=192.168.107.130:2888:3888

server.3=192.168.107.131:2888:3888

其中clientPort都设置为2181,dataDir改为各自的目录,分别在各自dataDir对应的目录下创建myid文件夹,值分别为1、2、3

3、启动三台zookeeper服务,并客户端连接,在任意服务器创建、修改删除zNode都会同步到其他机器

4、查看主从节点:./zkServer.sh status

8.Java客户端连接zookeeper服务

8.1会话重连:

/**

*连接服务端

*@param zkServerPath:zk服务端地址端口,例如192.168.1.1:2181

*@param timeout:超时时间,例如5s:5000

*@param ZKConnectSessionWatcher:watcher

**/

Zookeeper zk = new Zookeeper(zkServerPath,timeout,new ZKConnectSessionWatcher());

/**

*会话重连(根据sessionId和sessionPasswod)

*前三个参数同上

*@param sessionId:zk.getSessionId()

*@param sessionPasswd:zk.getSessionpasswd()

**/

Zookeeper zk = new Zookeeper(connectZkPath,timeout,ZKConnectSessionWatcher(),

sessionId,sessionPasswd);

8.2创建节点

/**

*同步方式创建节点

*@param path:节点路径

*@param data:节点数据byte[]

*@param cals:权限, Ids.属性

*@param CreateMode:CreateMode.属性(临时节点、持久节点、顺序节点)

**/

zk.create(path,data,acls,CreateMode.EPHEMERAL);

/**

*异步方式创建节点

*前四个参数与上面一样

*@param new CreateCallBack():回调函数

*@param ctx:创建节点后做的一些操作,如:返回信息({‘create’:’success’}”)、执行sql、消 息队列发送消息等

**/

zk.create(path,data,acls,CreateMode.PERSISTENT,new CreateCallBack(),ctx);

8.3修改节点

/**

*@param path :节点路径,如:/node

*@param data :节点数据byte[],如:”nodeData”.getBytes()

*@param version :版本号(相当于乐观锁,get /  后显示的dataVersion

* @return Stat :执行之后显示的信息,与get / 返回的信息一致

**/

Stat status = zk.setData(path,data,version);

异步与8.2类似

8.4删除节点

/**

*@param path :节点路径

*@param version : 版本号(相当于乐观锁,get /  后显示的dataVersion

**/

zk.delete(path,version);

异步与8.2类似,同步方式无返回值,建议使用异步方式

8.5CountDownLatch

CountDownLatch:计数器、用于多线程(可暂停、继续)

.await():阻塞当前线程

.countDown():减1,当countDown的值为0时,await()才不阻塞

检查集群中各个中间件是否正常:正常,则启动,不正常,启动不了

8.6节点查询

State state = new State();

CountDownLatch countDown = new CountDownLatch (1);

/**

*@param path:节点路径

*@param b:是否注册watch事件

*@ state:状态,get /path 获得的信息

*@return bytes[]:节点值

**/

byte[] bytes = zk.getZookeeper().getData(String path,boolean b,State state);//异步方式参考8.2

countDown.await();//挂起线程不运行,直到countDown值为0,线程才开始运行

/**

*获取事件的监听方法

*EventType.属性:创建、删除、修改、修改子节点

**/

@override

public void process(WatchEvent event){

try{

if(event.getType == EventType.属性){

...

count.countDown();

}

}catch(...){

...

}

}

8.7子节点查询

查询父节点下的子节点

/**

*同步

*@param path:节点路径

*@param watch:是否开启watcher

*@return childList:子节点列表

**/

List<String> childList = zkServer.getZookeeper().getChildren(String path,boolean watch);

同8.6重写process方法

/**

*异步

*@前两个参数同上

*@param new ChildrenCallBack():类实现了ChildrenCallBack接口或者Children2CallBack(),重*写processResult()

*@return ctx:查询成功返回值

**/

List<String> childList = zkServer.getZookeeper().getChildren(String path,boolean watch,

new ChildrenCallBack(),Object ctx);

 

8.8判断节点是否存在

Stat stat = zk.getZookeeper().exist(String path,boolean watch);//与上面一样

stat==null?xx:xxx;

异步与上面一样

 

8.9自定义用户权限

List<ACL> acls = new ArrayList<ACL>();

Id id1 = new Id(“digest”,DigestAuthenticationProvider.generateDigest(id1:123456));//定义用户

Id id2 = new Id(“digest”,DigestAuthenticationProvider.generateDigest(id2:123456));user:pwd

acls.add(new ACL(Perms.ALL,id1));//用户设置权限

acls.add(new ACL(Perms.READ,id2));

acls.add(new ACL(Perms.DELETE | Perms.CREATE,id2));//用户设置多个权限

zk.createZKNode(String path,byte[] b,acls);//目录添加用户权限

//用户必须addAuthInfo后才能操作节点

zk.getZookeeper().addAuthInfo(“digest”,”id2:123456”.getBytes());//参数:schema,用户名:密码

zk.createZKNode(path/子节点,byte[] b,Ids.属性);//在添加自定义用户权限的节点下添加子节点

8.10 ip权限

List<ACL> aclsIp = new ArrayList<ACL>();

Id idIp = new Id(“ip”,”192.168.1.1”);//定义ip用户

aclsIp.add(new ACL(Perms.ALL,idIp));//ip用户添加权限

zk.createZKNode(String path,byte[] b,aclsIp);

//当前ip必须是定义的权限ip才能操作(即:ip为192.168.1.1的机器才能对节点操作)

zk.getZookeeper().setData(String path,byte[] b,int version);

随机推荐

  1. HTML &lt;span&gt; 标签

    定义和用法: <span>标签被用来组合文档中的行内元素.在行内定义一个区域,也就是一行内可以被<span>划分成好几个区域,从而实现某种特定效果.<span>本身 ...

  2. 345. Reverse Vowels of a String

    Write a function that takes a string as input and reverse only the vowels of a string. Example 1:Giv ...

  3. C++ Name Mangling 为什么不编码返回值参数

    这篇文章主要是推荐下 http://www.cnblogs.com/skynet/archive/2010/09/05/1818636.html 这篇文章从编译器的角度看问题,比较深入. 回到题目,为 ...

  4. IHttpModule实现URL重写

    1.用自定义IHttpModule实现URL重写 一般来说,要显示一些动态数据总是采用带参数的方式,比如制作一个UserInfo.aspx的动态页面用于显示系统的UserInfo这个用户信息表的数据, ...

  5. android-adb通用

  6. 它们的定义app.config中间section节点和在执行中使用

    如果现在我们需要在app.config一个节点的在下面的例子中,定义,我们需要如何进行操作? <configSections> <section name="integra ...

  7. Windows下快速安装Xgboost(无需Git或者VS)

    xgboost的全称是eXtreme Gradient Boosting,现在已经风靡Kaggle.天池.DataCastle.Kesci等国内外数据竞赛平台,是比赛夺冠的必备大杀器!如果把数据竞赛比 ...

  8. 新手数据比赛中数据处理方法小结(python)

    第一次参加,天池大数据竞赛(血糖预测),初赛排名1%.因为自己对python不熟悉,所以记录一下在比赛中用到的一些python方法的使用(比较基础细节,大佬绕道): 1.数据初探 data.info( ...

  9. [Swift]LeetCode567. 字符串的排列 | Permutation in String

    Given two strings s1 and s2, write a function to return true if s2 contains the permutation of s1. I ...

  10. 在 CentOS 上编写 init.d service script [转]

    背景:之前编写了一些脚本,下载了一些开源软件,想把它们做成系统服务,通过 service your_prog_name start 这样的方式来后台运行,并在开机时自动启动.在了解了 daemon 命 ...