当前位置: 首页 > news >正文

Java客户端如何进行操作_java培训

Java客户端操作

Maven工程和配置POM

<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.0</modelVersion>

  <groupId>com.atguigu.mall</groupId>

  <artifactId>zk0919</artifactId>

  <version>0.0.1-SNAPSHOT</version>

  <packaging>jar</packaging>

  <name>zk0919</name>

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

  <properties>

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

  </properties>

  <dependencies>

   <!– https://mvnrepository.com/artifact/com.101tec/zkclient –>

   <dependency>

     <groupId>com.101tec</groupId>

     <artifactId>zkclient</artifactId>

     <version>0.10</version>

   </dependency>

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

   <dependency>

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

     <artifactId>zookeeper</artifactId>

     <version>3.4.9</version>

   </dependency>

   <dependency>

     <groupId>log4j</groupId>

     <artifactId>log4j</artifactId>

     <version>1.2.17</version>

   </dependency>

   <dependency>

     <groupId>junit</groupId>

     <artifactId>junit</artifactId>

     <version>4.9</version>

     <scope>test</scope>

   </dependency>

  </dependencies>

</project>

程序代码

package com.atguigu.zk3;

import java.io.IOException;

import org.apache.log4j.Logger;

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.Ids;

import org.apache.zookeeper.ZooKeeper;

import org.apache.zookeeper.data.Stat;

public class HelloZK

{

   /**

   * Logger for this class

   */

   private static final Logger logger = Logger.getLogger(HelloZK.class);

   private static final String CONNECTSTRING = “192.168.67.167:2181”;

   private static final String PATH = “/atguigu”;

   private static final int    SESSION_TIMEOUT = 50*1000;

   public ZooKeeper startZK() throws IOException

   {

       return new ZooKeeper(CONNECTSTRING, SESSION_TIMEOUT, new Watcher() {

          @Override

          public void process(WatchedEvent event)

          {

          }

       });

   }

   public void stopZK(ZooKeeper zk) throws InterruptedException

   {

       if(zk != null)

       {

          zk.close();

       }

   }

   public void createZNode(ZooKeeper zk,String path,String nodeValue) throws KeeperException, InterruptedException

   {

       zk.create(path,nodeValue.getBytes(),Ids.OPEN_ACL_UNSAFE,CreateMode.PERSISTENT);

   }

   public String getZNode(ZooKeeper zk,String path) throws KeeperException, InterruptedException

   {

       byte[] byteArray = zk.getData(path, false, new Stat());

       return new String(byteArray);

   }

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

   {

       HelloZK hello = new HelloZK();

       ZooKeeper zk = hello.startZK();

       Stat stat = zk.exists(PATH, false);

       if(stat == null)

       {

          hello.createZNode(zk, PATH, “zk1014”);

          String result = hello.getZNode(zk, PATH);

          System.out.println(“**********result: “+result);

       }else{

          System.out.println(“***********znode has already ok***********”);

       }

       hello.stopZK(zk);

   }

}

相关文章:

  • SAP ARFCSTATE ARFCSDATA TRFCQOUT
  • 两种形式的import
  • 什么是DCMM认证,企业为什么要做DCMM
  • 《自己动手写CPU》学习记录(1)——第1章
  • java计算机毕业设计农产品供销服务系统源程序+mysql+系统+lw文档+远程调试
  • 第4季6:图像sensor的寄存器操作
  • 汽车电子之功能安全介绍
  • 【viper】go 配置管理神器viper使用详解
  • 170-本地WIFI测试环境配置IP
  • 【面试宝典】Mysql面试题大全
  • Unity 符号表
  • Sentinel--服务容错
  • rust编译器教我做人,为啥还要学习rust语言,因为想使用rust做一些底层服务,更深入的研究技术。
  • Visual Assist v10.9.2471.0 Crack
  • 面试题:SpringBoot调用http服务几种方式
  • yolov7配置与训练记录(二)
  • Spring Cloud(十五):微服务自动化部署 DevOps CI/CD、Maven打包、ELK日志采集
  • [设计] Doris血缘解析流程
  • 【校招VIP】[推电影项目]商业项目的竞品分析和需求分析
  • 语法练习:array123
  • myBaits Target Capture Kits;myBaits 靶向捕获试剂盒,快速捕获富集目标序列
  • 【表格单元格可编辑】vue-elementul简单实现table表格点击单元格可编辑,点击单元格变成输入框修改数据
  • ES7-ES13 新特性
  • 【C++】打开C++的大门
  • 【深度学习】U-Net和FCN具体分析
  • Linux下 git 上传与删除 的基本指令
  • Swift 新 async/await 同步机制小技巧:消除“多余”的 await 关键字
  • Github如何使用详细介绍(保姆级教学)
  • 【ardunio+sx1268】与【esp32+sx1268】实现不同主控单片机lora通讯
  • Linux常用命令——pvscan命令
  • 旅游管理专业学什么 难就业吗
  • 2022海南高考体育专业考试时间 什么时候考试
  • 云南楚雄高考时间2021具体时间:6月7日
  • 高考什么特长可以加分 政策有哪些
  • 2022年贵州高考218分能报什么大学 218分能上哪些院校
  • 2022大专石油化工专业毕业后待遇 工资高吗
  • 中国科学院大学2021年各省录取分数线及专业分数线
  • 学英语用点读笔好不好 有效果吗
  • 2021河南职业技术学院学费多少 各专业收费标准
  • 2022广西外语口试成绩查询时间公布 什么时候查分