目录

一、.创建Maven工具

二、将Maven的默认配置文件设置为自己下载的配置文件(非必要)

三、在maven文件中导入zookeeper依赖

四、创建增删改查类MyzkTest

五、实现zookeeper的连接和增删改查

效果展示:

1.连接上zookeeper

2.创建节点名为myzktest内容为junjie

3.修改节点值为test

4.删除节点myzktest


一、.创建Maven工具

1.点击idea->File->New->Project

2.选择Maven,直接选next就行

3.输入想要修改的文件名

二、将Maven的默认配置文件设置为自己下载的配置文件(非必要)

三、在maven文件中导入zookeeper依赖

<dependencies><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.12</version></dependency>
</dependencies>

下载好后在maven中可以看到zookeeper插件

四、创建增删改查类MyzkTest

五、实现zookeeper的连接和增删改查

java抛出异常的几种方案

java抛出异常的几种方案
1,try{
}catch(){
}finally{
}
2,throw,是在方法里的
3,throws是在方法上的

zk的连接地址,此处地址是自己网上服务器的地址,端口号是zookeeper的服务端口

import org.apache.zookeeper.CreateMode;
import org.apache.zookeeper.KeeperException;
import org.apache.zookeeper.ZooDefs;
import org.apache.zookeeper.ZooKeeper;
import org.apache.zookeeper.data.ACL;
import org.apache.zookeeper.data.Stat;import java.io.IOException;
import java.util.List;public class MyzkTest {//zk的连接地址,此处地址是自己网上服务器的地址,端口号是zookeeper的服务端口public static final String zkconnect = "127.0.0.1:2181";//超时时间public static final int timeout = 15000;public static void main(String[] args) throws IOException, KeeperException, InterruptedException {ZooKeeper zooKeeper = connect();create(zooKeeper,"/myzktest","junjie");update(zooKeeper,"/myzktest","test1");query(zooKeeper,"/myzktest");delete(zooKeeper,"/myzktest");}//zk连接方法public static ZooKeeper connect() throws IOException{ZooKeeper zk = new ZooKeeper(zkconnect,timeout,null);System.out.println("zk连接成功");return zk;}//增加public static void create(ZooKeeper zooKeeper,String node,String data) throws KeeperException, InterruptedException {System.out.println("开始创建节点:"+node+"节点数据为:"+data);List<ACL> acl = ZooDefs.Ids.OPEN_ACL_UNSAFE;CreateMode createMode = CreateMode.PERSISTENT;zooKeeper.create(node,data.getBytes(),acl,createMode);System.out.println("zk节点创建成功");}//删除public static void delete(ZooKeeper zooKeeper,String node) throws KeeperException, InterruptedException {//先检查这个节点是否存在Stat stat = zooKeeper.exists(node,false);System.out.println("开始删除节点:"+node+"原来的版本号是"+stat.getVersion());zooKeeper.delete(node,stat.getVersion());System.out.println("删除成功");}/*** 修改* @param zooKeeper* @param node* @param data* @throws KeeperException* @throws InterruptedException*/public static void update(ZooKeeper zooKeeper,String node,String data) throws KeeperException, InterruptedException {//先检查这个节点是否存在Stat stat = zooKeeper.exists(node,false);System.out.println("开始修改节点:"+node+"修改后的值为:"+data);zooKeeper.setData(node,data.getBytes(),stat.getVersion());System.out.println("修改成功");}public static void query(ZooKeeper zooKeeper,String node) throws KeeperException, InterruptedException{String result = new String(zooKeeper.getData(node,false,null));System.out.println("准备查询数据:"+node+"---------节点数据为:"+result);}
}

效果展示:

查看Linux的工具为finalshell

1.连接上zookeeper

2.创建节点名为myzktest内容为junjie

3.修改节点值为test

4.删除节点myzktest

java上安装zookeeper并且实现增删改查相关推荐

  1. java jdbc 连接mysql数据库 实现增删改查

    好久没有写博文了,写个简单的东西热热身,分享给大家. jdbc相信大家都不陌生,只要是个搞java的,最初接触j2ee的时候都是要学习这么个东西的,谁叫程序得和数据库打交道呢!而jdbc就是和数据库打 ...

  2. MySQL基础知识-MySQL概述安装,单表增删改查,函数,约束,多表查询,事物

    MySQL基础知识-MySQL概述安装,单表增删改查,函数,约束,多表查询,事物 前言 1.MySQL概述 1.1数据库相关概念 1.2MySQL数据库 1.2.1版本 1.2.2下载 1.2.3安装 ...

  3. 二进制安装mysql及MySQL增删改查

    二进制安装mysql及MySQL增删改查 1. MySQL简介 2. MySQL的特点 3. 数据库在 Web 开发中的重要地位 4. 安装MySQL 4.1 首先需要下载MySQL的包 4.3 解决 ...

  4. SQLite 数据库安装、创建、增删改查(一)

    目录 一.学习资料 二.下载软件 1.SQLite 2.SQLiteStudio 3.Navicat 15 for SQLite 4.System.Data.SQLite.dll 三.创建数据库 1. ...

  5. java之全文索引搜索lucene之增删改查文档与中文分词搜索

    java之全文索引搜索lucene之增删改查文档与中文分词搜索 接上文,接下来介绍一个lucene的各种query,然后介绍一下中文全文索引搜索. 对于各种query,我就直接上代码了,具体的话,我已 ...

  6. 【MyBatis】安装 + 框架搭建 + 优化 + 增删改查(全程一条龙服务讲解~)

    目录 前言 一.准备工作 1.1.下载MyBatis 1.2.数据库设计 二.搭建框架 2.1.创建Maven项目 2.2.jar包.引入依赖 2.3.创建MyBatis核心配置文件 2.4.映射文件 ...

  7. java对mysql的简单操作——增删改查的总结

    增删改查的详细内容可以点击以下链接: java对mysql的简单操作--增加数据 java对mysql的简单操作--删除数据 java对mysql的简单操作--修改数据 java连接mysql5.1教 ...

  8. MySQL数据库安装以及SQL基本增删改查

    目录 1.介绍下数据库 1.1.DB概念和特点 1.2.常见DB软件 1.3.数据库结构 2.MySQL安装与使用 2.1.安装 2.2.卸载 2.3.MySQL服务启动与关闭 2.4.MySQL登录 ...

  9. java map 输入 查询 修改_Mybatis增删改查mapper文件写法详解

    1. 插入 INSERT sql命令(命令里通过#{}获取对象属性) EG: INSERT INTO PRAC_PERSON(p_NAME,P_PASSWORD) VALUES(#{name},#{p ...

最新文章

  1. 苹果手机如何恢复联系人呢?快速的恢复
  2. ionice使用说明与参数详析
  3. 动画代码Android动画学习笔记动画代码
  4. linux安装java_Linux安装JDK完整步骤
  5. c语言学指针变量,C语言指针变量学习五
  6. LSP(分层服务提供者)
  7. 如何判断当前请求的是健康检查API
  8. Magento 获取原价格和打折价格 get Special price or Regular Price in magento
  9. 什么是数据的表分区(文章附上Server 2005分区实施方案)
  10. jquery--动态篇
  11. 抖音何以为“抖音”?少不了A/B测试的功劳
  12. MBR分析(1): 代码获取与初始化
  13. 计算机一级cad试题,全国计算机等级考试一级试题与答案(25套)(1)2
  14. linux卸载wine qq,ubuntu安装wineQQ
  15. Ubuntu系统安装ghostscript seq2logo
  16. CodeBook 可以自定义字符集的密码本
  17. DNW5.0 USB 不OK
  18. 30KP30A高功率瞬态二极管参数
  19. Linux的常用命令就是记不住,还在百度找?于是推出了这套教程,
  20. 基于SSM+Layui的逆风医疗管理系统

热门文章

  1. iden 很实用的快捷键
  2. vxlan 分布式网关(evpn 带RR场景)
  3. vue2 最后的倔强(知识点查漏补缺)
  4. 安装ug时提示java出错_为什么安装ug许可证会失败?快速解决ug安装许可证会失败问题...
  5. Mac M1 JAVA环境变量配置
  6. linux 进入recovery模式,小米进入Recovery模式的两种方式
  7. 鸟哥私房菜 第二部分学安文件目录与磁盘格式笔记
  8. java获取时间_Java 获取当前时间的小时(24小时制)
  9. Apache Awstats 安装配置系列 (4)之 Awstats 安装 配置
  10. 【无标题】llllllll