java上安装zookeeper并且实现增删改查
目录
一、.创建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并且实现增删改查相关推荐
- java jdbc 连接mysql数据库 实现增删改查
好久没有写博文了,写个简单的东西热热身,分享给大家. jdbc相信大家都不陌生,只要是个搞java的,最初接触j2ee的时候都是要学习这么个东西的,谁叫程序得和数据库打交道呢!而jdbc就是和数据库打 ...
- MySQL基础知识-MySQL概述安装,单表增删改查,函数,约束,多表查询,事物
MySQL基础知识-MySQL概述安装,单表增删改查,函数,约束,多表查询,事物 前言 1.MySQL概述 1.1数据库相关概念 1.2MySQL数据库 1.2.1版本 1.2.2下载 1.2.3安装 ...
- 二进制安装mysql及MySQL增删改查
二进制安装mysql及MySQL增删改查 1. MySQL简介 2. MySQL的特点 3. 数据库在 Web 开发中的重要地位 4. 安装MySQL 4.1 首先需要下载MySQL的包 4.3 解决 ...
- SQLite 数据库安装、创建、增删改查(一)
目录 一.学习资料 二.下载软件 1.SQLite 2.SQLiteStudio 3.Navicat 15 for SQLite 4.System.Data.SQLite.dll 三.创建数据库 1. ...
- java之全文索引搜索lucene之增删改查文档与中文分词搜索
java之全文索引搜索lucene之增删改查文档与中文分词搜索 接上文,接下来介绍一个lucene的各种query,然后介绍一下中文全文索引搜索. 对于各种query,我就直接上代码了,具体的话,我已 ...
- 【MyBatis】安装 + 框架搭建 + 优化 + 增删改查(全程一条龙服务讲解~)
目录 前言 一.准备工作 1.1.下载MyBatis 1.2.数据库设计 二.搭建框架 2.1.创建Maven项目 2.2.jar包.引入依赖 2.3.创建MyBatis核心配置文件 2.4.映射文件 ...
- java对mysql的简单操作——增删改查的总结
增删改查的详细内容可以点击以下链接: java对mysql的简单操作--增加数据 java对mysql的简单操作--删除数据 java对mysql的简单操作--修改数据 java连接mysql5.1教 ...
- MySQL数据库安装以及SQL基本增删改查
目录 1.介绍下数据库 1.1.DB概念和特点 1.2.常见DB软件 1.3.数据库结构 2.MySQL安装与使用 2.1.安装 2.2.卸载 2.3.MySQL服务启动与关闭 2.4.MySQL登录 ...
- java map 输入 查询 修改_Mybatis增删改查mapper文件写法详解
1. 插入 INSERT sql命令(命令里通过#{}获取对象属性) EG: INSERT INTO PRAC_PERSON(p_NAME,P_PASSWORD) VALUES(#{name},#{p ...
最新文章
- 苹果手机如何恢复联系人呢?快速的恢复
- ionice使用说明与参数详析
- 动画代码Android动画学习笔记动画代码
- linux安装java_Linux安装JDK完整步骤
- c语言学指针变量,C语言指针变量学习五
- LSP(分层服务提供者)
- 如何判断当前请求的是健康检查API
- Magento 获取原价格和打折价格 get Special price or Regular Price in magento
- 什么是数据的表分区(文章附上Server 2005分区实施方案)
- jquery--动态篇
- 抖音何以为“抖音”?少不了A/B测试的功劳
- MBR分析(1): 代码获取与初始化
- 计算机一级cad试题,全国计算机等级考试一级试题与答案(25套)(1)2
- linux卸载wine qq,ubuntu安装wineQQ
- Ubuntu系统安装ghostscript seq2logo
- CodeBook 可以自定义字符集的密码本
- DNW5.0 USB 不OK
- 30KP30A高功率瞬态二极管参数
- Linux的常用命令就是记不住,还在百度找?于是推出了这套教程,
- 基于SSM+Layui的逆风医疗管理系统
热门文章
- iden 很实用的快捷键
- vxlan 分布式网关(evpn 带RR场景)
- vue2 最后的倔强(知识点查漏补缺)
- 安装ug时提示java出错_为什么安装ug许可证会失败?快速解决ug安装许可证会失败问题...
- Mac M1 JAVA环境变量配置
- linux 进入recovery模式,小米进入Recovery模式的两种方式
- 鸟哥私房菜 第二部分学安文件目录与磁盘格式笔记
- java获取时间_Java 获取当前时间的小时(24小时制)
- Apache Awstats 安装配置系列 (4)之 Awstats 安装 配置
- 【无标题】llllllll