Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）

2021-12-04 23:16:17

写在前面的话

　　　　可详细参考，一定得去看

HBase 开发环境搭建（Eclipse\MyEclipse + Maven）

　　我这里，相信，能看此博客的朋友，想必是有一定基础的了。我前期写了大量的基础性博文。可以去补下基础。

　　步骤一：File -> New -> Project -> Maven Project

$Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）$

　　步骤二：自行设置，待会创建的myHBase工程，放在哪个目录下。

$Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）$

　　步骤三:

$Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）$

　　步骤四：自行设置

$Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）$

　　步骤五：修改jdk

$Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）$

　　省略，很简单！

　　步骤六：修改pom.xml配置文件

$Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）$

官网Maven的zookeeper配置文件内容：

地址：

http://www.mvnrepository.com/search?q=zookeeper

$Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）$

　　我这里，集群用的是zookeeper3.4.6

$Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）$

　　总的pom.xml配置文件是

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">

<modelVersion>4.0.</modelVersion>

<groupId>zhouls.bigdata</groupId>

<artifactId>myZookeeper</artifactId>

<version>0.0.-SNAPSHOT</version>

<packaging>jar</packaging>

<name>myZookeeper</name>

<url>http://maven.apache.org</url>

<properties>

<project.build.sourceEncoding>UTF-</project.build.sourceEncoding>

</properties>

<dependencies>

<dependency>

<groupId>junit</groupId>

<artifactId>junit</artifactId>

<version>3.8.</version>

<scope>test</scope>

</dependency>

<!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper -->

<dependency>

<groupId>org.apache.zookeeper</groupId>

<artifactId>zookeeper</artifactId>

<version>3.4.</version>

</dependency>

</dependencies>

</project>

　　当然，这只是初步而已，最简单的，以后可以自行增删。

$Zookeeper项目开发环境搭建（Eclipse\MyEclipse + Maven）$

　　步骤七：这里，给大家，通过一组简单的Zookeeper应用程序实例来向大家展示Zookeeper的某些功能。这一节所实现的主要功能包括：创建组、加入组、列出组成员，以及删除组。

　　类名为ZookeeperTestCase.java

package zhouls.bigdata.myZookeeper;

import java.io.IOException;

import org.apache.zookeeper.WatchedEvent;

import org.apache.zookeeper.Watcher;

import org.apache.zookeeper.ZooKeeper;

public class ZookeeperTestCase {

//        private static String connectString="192.168.80.10:2181"; 

//会话超时时间，设置为系统默认时间一致

        private static final int sessionTimeout=; 

//创建Zookeeper实例

        ZooKeeper zk;

//创建Watcher实例

        Watcher watcher=new Watcher(){

            public void process(WatchedEvent event) {

                System.out.println("监听到的事件："+event.toString());

            }

        }; 

//初始化Zookeeper实例

            public void createZKInstance() throws IOException{

                zk= new ZooKeeper("192.168.80.10:2181",ZookeeperTestCase.sessionTimeout,this.watcher);

            }

//关闭Zookeeper实例

            public void ZKclose() throws InterruptedException{

                zk.close();

            }

}