Zookeeper 简单总结（1）

我就是我 2023-01-19 11:57 4阅读 0赞

# 一、Zookeeper单机模式安装 #

--------------------

> 1.  Zookeeper是基于java写的，所以安装需要配置JAVA环境，校验环境：java -version
> 2.  下载并解压Zookeeper
> 
>     cd /usr/local
>     wget http://archive.apache.org/dist/zookeeper/zookeeper-3.4.12/zookeeper-3.4.12.tar.gz
>     tar -zxvf zookeeper-3.4.12.tar.gz
>     cd zookeeper-3.4.12
> 
>     3. 重命名配置文件zoo\_sample.cfg
> 
>     cp conf/zoo_sample.cfg conf/zoo.cfg
> 
>     4. 启动zookeeper
> 
>     bin/zkServer.sh start
> 
>     5. 检测是否成功启动
> 
>     bin/zkCli.sh
> 
>    6. zookeeper 命令行操作
> 
>     ls / #查看当前Zookeeper包含的内容
>     create /Myznode mydata #创建一个新的znode
>     get /Myznode #/获取节点值
>     set /Myznode mydata2 #修改节点值
>     delete /Myznode #删除节点

# 二、zookeeper是什么 #

> 简单来说就是文件系统+监听通知机制

# 三、 使用java api 操作 zookeeper #

>  *  pom.xml 引入zookeeper包
> 
>     <dependency>
>     			<groupId>org.apache.zookeeper</groupId>
>     			<artifactId>zookeeper</artifactId>
>     			<version>3.4.12</version>
>     		</dependency>
> 
>  *  zk分布式配置中心demo
> 
>     package com.shierdu.zkstudy.demo;
>     
>     import org.apache.zookeeper.WatchedEvent;
>     import org.apache.zookeeper.Watcher;
>     import org.apache.zookeeper.ZooKeeper;
>     import org.apache.zookeeper.data.Stat;
>     
>     import java.util.concurrent.CountDownLatch;
>     
>     /**
>      * @author ：swordker 哒哒先生
>      * @date ：Created in 2021/5/10 22:29
>      * @updateTime：
>      * @modified By：
>      * 分布式配置中心demo
>      */
>     public class ZookeeperProSync implements Watcher {
>     	private static CountDownLatch connectedSemaphore = new CountDownLatch(1);
>     	private static ZooKeeper zk = null;
>     	private static Stat stat = new Stat();
>     
>     	public static void main(String[] args) throws Exception {
>     		//存储路径
>     		String path = "/myznode";
>     		//连接zookeeper并且注册一个默认的观察者
>     		zk = new ZooKeeper("192.168.0.106:2181", 5000, new ZookeeperProSync());
>     		//等待zk连接成功通知
>     		connectedSemaphore.await();
>     		//获取path目录节点的配置数据，并注册默认的监听器
>     		System.out.println(new String(zk.getData(path,true,stat)));
>     		Thread.sleep(Integer.MAX_VALUE);
>     	}
>     
>     	@Override
>     	public void process(WatchedEvent event) {
>     		if(Event.KeeperState.SyncConnected == event.getState()){ //zk连接成功通知事件
>     			if(Event.EventType.None == event.getType() && null == event.getPath()){
>     				connectedSemaphore.countDown();
>     			}else if(event.getType() == Event.EventType.NodeDataChanged){ //zk目录节点数据变化通知事件
>     				try{
>     					System.out.println("配置已修改，新增为："+ new String(zk.getData(event.getPath(), true, stat)));
>     				}catch (Exception e){}
>     			}
>     		}
>     	}
>     }
> 
>

# 四、zookeeper集群模式安装 #

> 第一、二步跟单机一样
> 
> 3. 重命名配置文件zoo\_sample.cfg
> 
>     cp conf/zoo_sample.cfg conf/zoo-1.cfg
> 
> 4. 修改配置文件zoo-1.cfg，原配置文件里有的，修改成下面的值，没有则加上
> 
>     # vim conf/zoo-1.cfg
>     dataDir=/tmp/zookeeper-1
>     clientPort=2181
>     server.1=127.0.0.1:2888:3888
>     server.2=127.0.0.1:2889:3889
>     server.3=127.0.0.1:2890:3890
> 
> 5. 再从zoo-1.cfg复制两个配置文件zoo-2.cfg和zoo-3.cfg，只需要修改dataDir和clientPort不同即可
> 
>     # cp conf/zoo-1.cfg conf/zoo-2.cfg
>     # cp conf/zoo-1.cfg conf/zoo-3.cfg
>     # vim conf/zoo-2.cfg
>     dataDir=/tmp/zookeeper-2
>     clientPort=2182
>     # vim conf/zoo-3.cfg
>     dataDir=/tmp/zookeeper-3
>     clientPort=2183
> 
> 6. 标识Server ID
> 
> 创建三个文件夹/tmp/zookeeper-1，/tmp/zookeeper-2，/tmp/zookeeper-3，在每个目录中创建文件myid文件，写入当前实例的server id，即1、2、3
> 
>     # cd /tmp/zookeeper-1
>     # vim myid
>     1
>     # cd /tmp/zookeeper-2
>     # vim myid
>     2
>     # cd /tmp/zookeeper-3
>     # vim myid
>     3
> 
> 7. 启动三个zookeeper实例
> 
>     # bin/zkServer.sh start conf/zoo-1.cfg
>     # bin/zkServer.sh start conf/zoo-2.cfg
>     # bin/zkServer.sh start conf/zoo-3.cfg
> 
> 8. 检测集群状态，也可以直接用命令 “zkCli.sh -server IP:PORT” 连接zookeeper服务端检测
> 
> 9. 可以参考 [https://www.cnblogs.com/ysocean/p/9860529.html][https_www.cnblogs.com_ysocean_p_9860529.html]

[https_www.cnblogs.com_ysocean_p_9860529.html]: https://www.cnblogs.com/ysocean/p/9860529.html