三万字！DubboZookeeper学习笔记！秒杀面试官！——双非上岸阿里巴巴系列
Posted 来老铁干了这碗代码
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了三万字！DubboZookeeper学习笔记！秒杀面试官！——双非上岸阿里巴巴系列相关的知识，希望对你有一定的参考价值。
东北某不知名双非本科，四面成功上岸阿里巴巴，在这里把自己整理的笔记分享出来，欢迎大家阅读。
恰个饭——>《阿里巴巴 Java 开发手册》，业界普遍遵循的开发规范
本博客内容持续维护，如有改进之处，还望各位大佬指出，感激不尽！
文章目录
Dubbo部分
第一章 分布式系统相关概念
1.1 大型互联网项目架构目标
互联网项目特点：用户多、流量大、并发高、海量数据、易受攻击、功能繁琐、变更快
大型互联网项目架构性能指标：响应时间、并发数、吞吐量
大型互联网项目架构目标：高性能、高可用（网站一直可以正常访问）、可伸缩（通过硬件增加/减少，提高/减低处理能力）、高可扩展（耦合低、方便通过新增/移除方式，增加/减少功能模块）、安全性、敏捷性
1.2 集群和分布式
集群：一个业务模块，部署在多台服务器上。
分布式：一个大的业务系统，拆分成小的业务模块，分别部署在不同的机器上。
1.3 架构演进
个人理解：微服务架构是对SOA架构的进一步拆分和细化
Dubbo是SOA时代的产物，SpringCloud是微服务时代的产物
第二章 Dubbo概述
2.1 Dubbo概念
- Dubbo是阿里巴巴公司开源的一个高性能、轻量级的Java RPC框架
- 致力于提供高性能和透明化的RPC远程服务调用方案，以及SOA服务治理方案。
- 官网：http://dubbo.apache.org
2.2 Dubbo架构
2.2.1 Dubbo架构及调用顺序
节点角色说明
| 节点 | 角色说明 |
|---|---|
Provider | 暴露服务的服务提供方 |
Consumer | 调用远程服务的服务消费方 |
Registry | 服务注册与发现的注册中心 |
Monitor | 统计服务的调用次数和调用时间的监控中心 |
Container | 服务运行容器 |
调用关系说明参考文档
- 服务容器负责启动，加载，运行服务提供者。
- 服务提供者在启动时，向注册中心注册自己提供的服务。
- 服务消费者在启动时，向注册中心订阅自己所需的服务。
- 注册中心返回服务提供者地址列表给消费者，如果有变更，注册中心将基于长连接推送变更数据给消费者。
- 服务消费者，从提供者地址列表中，基于软负载均衡算法，选一台提供者进行调用，如果调用失败，再选另一台调用。
- 服务消费者和提供者，在内存中累计调用次数和调用时间，定时每分钟发送一次统计数据到监控中心。
Dubbo 架构具有以下几个特点，分别是连通性、健壮性、伸缩性、以及向未来架构的升级性
个人理解：Registry就相当于ESB，Consumer和Provider通过其连接
2.2.2 Dubbo特点
连通性
- 注册中心负责服务地址的注册与查找，相当于目录服务，服务提供者和消费者只在启动时与注册中心交互，注册中心不转发请求，压力较小
- 监控中心负责统计各服务调用次数，调用时间等，统计先在内存汇总后每分钟一次发送到监控中心服务器，并以报表展示
- 服务提供者向注册中心注册其提供的服务，并汇报调用时间到监控中心，此时间不包含网络开销
- 服务消费者向注册中心获取服务提供者地址列表，并根据负载算法直接调用提供者，同时汇报调用时间到监控中心，此时间包含网络开销
- 注册中心，服务提供者，服务消费者三者之间均为长连接，监控中心除外
- 注册中心通过长连接感知服务提供者的存在，服务提供者宕机，注册中心将立即推送事件通知消费者
- 注册中心和监控中心全部宕机，不影响已运行的提供者和消费者，消费者在本地缓存了提供者列表
- 注册中心和监控中心都是可选的，服务消费者可以直连服务提供者
健壮性
- 监控中心宕掉不影响使用，只是丢失部分采样数据
- 数据库宕掉后，注册中心仍能通过缓存提供服务列表查询，但不能注册新服务
- 注册中心对等集群，任意一台宕掉后，将自动切换到另一台
- 注册中心全部宕掉后，服务提供者和服务消费者仍能通过本地缓存通讯
- 服务提供者无状态，任意一台宕掉后，不影响使用
- 服务提供者全部宕掉后，服务消费者应用将无法使用，并无限次重连等待服务提供者恢复
伸缩性
- 注册中心为对等集群，可动态增加机器部署实例，所有客户端将自动发现新的注册中心
- 服务提供者无状态，可动态增加机器部署实例，注册中心将推送新的服务提供者信息给消费者
升级性
当服务集群规模进一步扩大，带动IT治理结构进一步升级，需要实现动态部署，进行流动计算，现有分布式服务架构不会带来阻力。下图是未来可能的一种架构：
节点角色说明
| 节点 | 角色说明 |
|---|---|
Deployer | 自动部署服务的本地代理 |
Repository | 仓库用于存储服务应用发布包 |
Scheduler | 调度中心基于访问压力自动增减服务提供者 |
Admin | 统一管理控制台 |
Registry | 服务注册与发现的注册中心 |
Monitor | 统计服务的调用次数和调用时间的监控中心 |
第三章 Dubbo快速入门
3.1 Zookeeper
3.1.1 Zookeeper概述
注册中心：https://dubbo.apache.org/zh/docs/v2.7/user/references/registry/
Zookeeper是Apache Hadoop的子项目，是一个树形的目录服务，适合作为Dubbo服务的注册中心，工业强度较高，可用于生产环境，并推荐使用。
更详细概述，见我的HSF笔记
3.1.2 Zookeeper安装与配置
下载安装
1、环境准备：Java1.7+
2、上传：将下载的ZooKeeper放到/opt/ZooKeeper目录下
#上传zookeeper alt+p
put f:/setup/apache-zookeeper-3.5.6-bin.tar.gz
#打开 opt目录
cd /opt
#创建zooKeeper目录
mkdir zooKeeper
#将zookeeper安装包移动到 /opt/zooKeeper
mv apache-zookeeper-3.5.6-bin.tar.gz /opt/zookeeper/
3、解压：将tar包解压到/opt/zookeeper目录下
tar -zxvf apache-ZooKeeper-3.5.6-bin.tar.gz
配置启动
1、配置zoo.cfg
进入conf目录拷贝一个zoo_sample.cfg并完成配置（zoo_sample本质上不起配置作用，只是一个模板，需要自行创建zoo.cfg并修改配置内容。）
#进入到conf目录
cd /opt/zooKeeper/apache-zooKeeper-3.5.6-bin/conf/
#拷贝（将zoo_sample.cfg拷贝一份，名字是zoo.cfg）
cp zoo_sample.cfg zoo.cfg
修改zoo.cfg
#打开目录
cd /opt/zooKeeper/
#创建zooKeeper存储目录
mkdir zkdata
#修改zoo.cfg
vim /opt/zooKeeper/apache-zooKeeper-3.5.6-bin/conf/zoo.cfg
修改存储目录：dataDir = /opt/zookeeper/zkdata
2、启动zookeeper
cd /opt/zooKeeper/apache-zooKeeper-3.5.6-bin/bin/
#启动（.sh文件一般为脚本执行文件，zkServer是注册中心的意思）
./zkServer.sh start
看到上图表示zookeeper已经成功启动。
3、查看zookeeper状态
./zkServer.sh status
zookeeper启动成功。standalone代表zk没有搭建集群，现在是单节点
zookeeper没有启动成功
3.2 Dubbo快速入门
3.2.1 Spring和SpringMVC整合
代码：1. spring和springmvc整合后代码
实施步骤：
1、创建服务提供者Provider模块
2、创建服务消费者Consumer模块
3、在服务提供者模块编写UserServiceImpl提供服务
4、在服务消费者中的UserController远程调用（提供者是Service，消费者是Controller）
5、UserServiceImpl提供的服务
6、分别启动两服务，测试。
Dubbo作为一个RPC框架，其最核心的功能就是要实现跨网络的远程调用。本小节就是要创建两个应用，一个作为服务的提供方，一个作为服务的消费方。通过Dubbo来实现服务消费方远程调用服务提供方的方法。
0、创建项目、准备环境
首先创建空项目
接下来配置Maven地址
接下来创建Maven的Module
新建服务方：
新建消费方：
接下来就是编写逻辑代码了。
核心原理：consumer中的pom.xml中添加了servicer的pom依赖，本质上并没有用到dubbo
3.2.2 服务提供者
代码见：2. dubbo快速入门
dubbo的作用：
服务提供者编写过程：
1、将Servicer的服务注册到Zookeeper中（注册中心）
2、在mvc的xml中编写dubbo的配置，包括配置项 目的名称（唯一标识），配置注册中心（zookeeper）的地址，配置dubbo包扫描的路径
3、配置web.xml
3.2.3 服务消费者
服务消费者编写过程：
1、在Controller中远程注入userService，即获取其url（抛弃Autowired注解，使用Reference注解）
2、在mvc的xml中编写dubbo的配置，包括配置项目的名称（唯一标识），配置注册中心的地址(本机ip+端口)，配置dubbo包扫描的路径
3、配置web.xml
服务方和消费方都遵循上述配置，不同的是消费方配置的是Controller，并且不用放到注册中心
**注意：当消费者调用提供者的Service方法时，消费者中也要定义相对应的Service类的接口，因此为了去冗余设计，新定义一个interface的module，来做代码提取。**至于如何调用，直接在Servicer和Consumer的pom.xml中定义即可。
以上，完成了最最最最简单的Dubbo的功能实现。
第四章 Dubbo高级特性
4.1 Dubbo-admin管理平台
简介：
- dubbo-admin管理平台，是图形化的服务管理页面
- 从注册中心获取到所有提供者/消费者进行配置管理
- 路由规则、动态配置、服务降级、访问控制、权重调整、负载均衡等管理功能
- dubbo-admin是一个前后端分离的项目。前端使用vue，后端使用springboot
- 安装dubbo-admin其实就是部署该项目
4.1.1 dubbo-admin安装
1、环境准备
dubbo-admin 是一个前后端分离的项目。前端使用vue，后端使用springboot，安装 dubbo-admin 其实就是部署该项目。我们将dubbo-admin安装到开发环境上。要保证开发环境有jdk，maven，nodejs
安装node**(如果当前机器已经安装请忽略)**
因为前端工程是用vue开发的，所以需要安装node.js，node.js中自带了npm，后面我们会通过npm启动
把node.js理解成更牛逼的tomcat就行
下载地址
https://nodejs.org/en/
2、下载 Dubbo-Admin
进入github，搜索dubbo-admin
https://github.com/apache/dubbo-admin
下载：
3、把下载的zip包解压到指定文件夹(解压到那个文件夹随意)
4、修改配置文件
解压后我们进入…\\dubbo-admin-develop\\dubbo-admin-server\\src\\main\\resources目录，找到 application.properties 配置文件 进行配置修改
修改zookeeper地址
# centers in dubbo2.7
admin.registry.address=zookeeper://192.168.149.135:2181
admin.config-center=zookeeper://192.168.149.135:2181
admin.metadata-report.address=zookeeper://192.168.149.135:2181
admin.registry.address注册中心（服务信息的中介（非持久化））
admin.config-center 配置中心（存储 Dubbo 服务的各种治理规则（持久化））
admin.metadata-report.address元数据中心（元数据是指 Dubbo服务对应的方法列表以及参数结构等信息）
5、打包项目
在 dubbo-admin-develop 目录执行打包命令
mvn clean package
6、启动后端
切换到目录
dubbo-Admin-develop\\dubbo-admin-distribution\\target>
执行下面的命令启动 dubbo-admin，dubbo-admin后台由SpringBoot构建。
java -jar .\\dubbo-admin-0.1.jar
7、前台后端
dubbo-admin-ui 目录下执行命令
npm run dev
8、访问
浏览器输入。用户名密码都是root
http://localhost:8081/
4.1.2 dubbo-admin简单使用
注意:Dubbo Admin【服务Mock】【服务统计】将在后续版本发布…
在上面的步骤中，我们已经进入了Dubbo-Admin的主界面，在【快速入门】章节中，我们定义了服务生产者、和服务消费者，下面我们从Dubbo-Admin管理界面找到这个两个服务
1、点击服务查询
2、查询结果
A:输入的查询条件com.itheima.service.UserService
B:搜索类型，主要分为【按服务名】【按IP地址】【按应用】三种类型查询
C:搜索结果
3.1.4 dubo-admin查看详情
我们查看com.itheima.service.UserService （服务提供者）的具体详细信息，包含【元数据信息】
1）点击详情
从【详情】界面查看，主要分为3个区域
A区域：主要包含服务端 基础信息比如服务名称、应用名称等
B区域：主要包含了生产者、消费者一些基本信息
C区域：是元数据信息，注意看上面的图,元数据信息是空的
我们需要打开我们的生产者配置文件加入下面配置
<!-- 元数据配置 -->
<dubbo:metadata-report address="zookeeper://192.168.149.135:2181" />
重新启动生产者，再次打开Dubbo-Admin
这样我们的元数据信息就出来了
4.2 Dubbo常用高级配置
4.2.1 序列化
注意！！！将来所有的pojo类都需要实现Serializable接口！
代码实现见：3. dubbo高级特性-序列化
两台机器之间传输数据，通过序列化和反序列化传输Java对象
- dubbo 内部已经将序列化和反序列化的过程内部封装了
- 我们只需要在定义pojo类时实现Serializable接口即可
- 一般会定义一 个公共的pojo模块,让生产者和消费者都依赖该模块。
User对象未实现Serializable接口
错误信息：
解决办法：
User implements Serializable
下图为项目的基础架构图：
- interface的pom中写入pojo的依赖。service和web的pom中写入interface的依赖。
- User继承了序列化接口
4.2.2 地址缓存
注册中心挂了，服务是否可以正常访问？
- 可以，因为dubbo服务消费者在第一-次调用时，会将服务提供方地址缓存到本地，以后在调用则不会访问注册中心。
- 当服务提供者地址发生变化时，注册中心会通知服务消费者。
运行后，发现还是可以继续访问的。
4.2.3 超时
参考代码：4. 超时与重试
- 服务消费者在调用服务提供者的时候发生了阻塞、等待的情形,这个时候,服务消费者会直等待下去。
- 在某个峰值时刻，大量的请求都在同时请求服务消费者,会造成线程的大量堆积，势必会造成雪崩。
- dubbo利用超时机制来解决这个问题，设置-个超时时间, 在这个时间段内，无法完成服务访问,则自动断开连接。
- 使用timeout属性配置超时时间，默认值1000，单位毫秒
//timeout 超时时间 单位毫秒 retries 重试次数
@Service(timeout = 3000,retries=0)
代码实现：用sleep模拟服务器查询很慢：
4.2.4 重试
- 设置了超时时间，在这个时间段内，无法完成服务访问,则自动断开连接。
- 如果出现网络抖动,则这一-次请求就会失败。
- Dubbo提供重试机制来避免类似问题的发生。
- 通过retries属性来设置重试次数。默认为2次
//timeout 超时时间 单位毫秒 retries 重试次数
@Service(timeout = 3000,retries=2)
4.2.5 多版本
参考代码：5. 多版本
**灰度发布:**当出现新功能时,会让一部分用户先使用新功能，用户反馈没问题时，再将所有用户迁移到新功能。
dubbo中使用version属性来设置和调用同一个接口的不同版本
生产者配置（通过@Service注解）
@Service(version="v2.0")
public class UserServiceImp12 implements UserService {...}
消费者配置（通过@Reference注解）
@Reference(version = "v2.0")//远程注入
private UserService userService;
代码示例：
4.2.6 负载均衡
解释：当存在多个服务提供者时，消费者应该怎样消费，才能使多个服务提供者的负载均衡。
负载均衡策略(4种) :
-
**Random:**按权重随机，默认值。按权重设置随机概率。
-
RoundRobin: 按权重轮询。
-
LeastActive: 最少活跃调用数,相同活跃数的随机。
-
**ConsistentHash: **一致性Hash,相同参数的请求总是发到同一提供者。
服务提供者配置
@Service(weight = 100)
public class UserServiceImp12 implements UserService {...}
application.xml 配置parameter key
消费者配置
//@Reference(loadbalance = "roundrobin")
//@Reference(loadbalance = "leastactive")
//@Reference(loadbalance = "consistenthash")
@Reference(loadbalance = "random")//默认 按权重随机
private UserService userService;
代码参考：
4.2.7 集群容错
解释：如果某一个服务器出错了，则选择执行什么策略。是换其他服务器重试，还是直接返回失败等等。
集群容错模式:
**Failover Cluster:**失败重试。默认值。当出现失败，重试其它服务器，默认重试2次，使用retries配置。一般用于读操作
**Failfast Cluster 😗*快速失败,发起-次调用，失败立即报错。通常用于写操作。
**Failsafe Cluster:**失败安全，出现异常时，直接忽略。返回一个空结果。
**Failback Cluster:**失败自动恢复,后台记录失败请求,定时重发。
**Forking Cluster 😗*并行调用多个服务器，只要一个成功即返回。
Broadcast Cluster: 广播调用所有提供者,逐个调用，任意一台报错则报错。
消费者配置
@Reference(cluster = "failover")//远程注入
private UserService userService;
代码示例：
4.2.8 服务降级
服务降级：当服务器压力剧增的情况下，根据实际业务情况及流量，对一些服务和页面有策略的不处理或换种简单的方式处理，从而释放服务器资源以保证核心交易正常运作或高效运作
服务降级方式:
mock= force:return null：表示消费方对该服务的方法调用都直接返回null值,不发起远程调用。用来屏蔽不重要服务不可用时对调用方的影响。
mock=fail:return null：表示消费方对该服务的方法调用在失败后，再返回null值,不抛异常。用来容忍不重要服务不稳定时对调用方的影响
消费方配置
//远程注入
@Reference(mock ="force :return null")//不再调用userService的服务
private UserService userService;
Zookeeper部分
第一章 初识Zookeeper
1.1 Zookeeper概念
-
Zookeeper 是 Apache Hadoop 项目下的一个子项目，是一个树形目录服务。
-
Zookeeper 翻译过来就是 动物园管理员，他是用来管 Hadoop（大象）、Hive(蜜蜂)、Pig(小 猪)的管理员。简称zk
-
Zookeeper 是一个分布式的、开源的分布式应用程序的协调服务。
-
Zookeeper提供的功能主要包括
- 配置管理（增删改查）
- 分布式锁（常规锁无效，因为是不同机器(常规锁由JDK提供)，不同集群，因此要采用分布式锁）
- 集群管理
第二章 Zookeeper安装与配置
见3.1
第三章 Zookeeper命令操作
3.1 Zookeeper命令操作数据类型
-
ZooKeeper 是一个树形目录服务,其数据模型和Unix的文件系统目录树很类似，拥有一个层次化结构。
-
这里面的每一个节点都被称为： ZNode，每个节点上都会保存自己的数据和节点信息。
-
节点可以拥有子节点，同时也允许少量（1MB）数据存储在该节点之下。
-
节点可以分为四大类：
- PERSISTENT 持久化节点
- EPHEMERAL 临时节点 ：-e （服务端关闭后就消失了）
- PERSISTENT_SEQUENTIAL 持久化顺序节点 ：-s （即节点后跟序号）
- EPHEMERAL_SEQUENTIAL 临时顺序节点 ：-es
3.2 Zookeeper命令操作服务端命令
进入到Zookeeper/bin中，可执行如下操作
-
启动 ZooKeeper 服务: ./zkServer.sh start
-
查看 ZooKeeper 服务状态: ./zkServer.sh status
-
停止 ZooKeeper 服务: ./zkServer.sh stop
-
重启 ZooKeeper 服务: ./zkServer.sh restart
3.3 Zookeeper客户端常用命令
概述：连接上Server（服务端）后，操作节点。
- 连接ZooKeeper服务端
./zkCli.sh –server ip:port
- 断开连接
quit
- 查看命令帮助
help
- 显示指定目录下节点（如果目录是/，则为根节点）
ls 目录
- 创建节点（节点里面存放value）
create /节点path value
例子： create /app1
- 获取节点值
get /节点path
- 设置节点值
set /节点path value
- 删除单个节点
delete /节点path
- 删除带有子节点的节点
deleteall /节点path
3.4 客户端命令-创建临时有序节点
- 创建临时节点
create -e /节点path value
- 创建顺序节点
create -s /节点path value
- 查询节点详细信息
ls –s /节点path
-
czxid：节点被创建的事务ID
-
ctime: 创建时间
-
mzxid: 最后一次被更新的事务ID
-
mtime: 修改时间
-
pzxid：子节点列表最后一次被更新的事务ID
-
cversion：子节点的版本号
-
dataversion：数据版本号
-
aclversion：权限版本号
-
ephemeralOwner：用于临时节点，代表临时节点的事务ID，如果为持久节点则为0
-
dataLength：节点存储的数据的长度
-
numChildren：当前节点的子节点个数
以上的命令也侧面体现出了Zookeeper的作用，即持久化or非持久化存储数据、配置管理、分布式锁、集群管理（节点储存信息，树形结构、方便查找）
第四章 ZooKeeper JavaAPI 操作
4.1 Curator介绍
其核心就是对节点的操作，对节点的操作贯穿配置管理、分布式锁、集群搭建三大模块
-
Curator 是 Apache ZooKeeper 的Java客户端库。
-
常见的ZooKeeper Java API ：
- 原生Java API
- ZkClient
- Curator
-
Curator 项目的目标是简化 ZooKeeper 客户端的使用。
-
Curator 最初是 Netfix 研发的,后来捐献了 Apache 基金会,目前是 Apache 的顶级项目。
-
官网：http://curator.apache.org/
4.2 基本操作（配置管理）
操作-建立连接
[外链图片转存失败,源站可能有防盗链机制,建议将图片保存下来直接上传(img-kF4w6Jb7-1626871686069)(/Users/zhanglong/Library/Application Support/typora-user-images/image-20210720110747301.png)]
具体代码见资料
1、搭建项目
创建项目curator-zk
引入pom和日志文件
资料文件夹下pom.xml和log4j.properties
2、创建测试类，使用curator连接zookeeper
@Before
public void testConnect() {
//重试策略
RetryPolicy retryPolicy = new ExponentialBackoffRetry(3000, 10);
//2.第二种方式
//CuratorFrameworkFactory.builder();
client = CuratorFrameworkFactory.builder()
.connectString("192.168.200.130:2181")
.sessionTimeoutMs(60 * 1000)
.connectionTimeoutMs(15 * 1000)
.retryPolicy(retryPolicy)
.namespace("itheima")
.build();
//开启连接
client.start();
}
操作-创建节点
/**
* 创建节点：create 持久 临时 顺序 数据
* 1. 基本创建 ：create().forPath("")
* 2. 创建节点 带有数据:create().forPath("",data)
* 3. 设置节点的类型：create().withMode().forPath("",data)
* 4. 创建多级节点 /app1/p1 ：create().creatingParentsIfNeeded().forPath("",data)
*/
@Test
public void testCreate() throws Exception {
//2. 创建节点 带有数据
//如果创建节点，没有指定数据，则默认将当前客户端的ip作为数据存储
String path = client.create().forPath("/app2", "hehe".getBytes());
System.out.println(path);
}
@Test
public void testCreate2() throws Exception {
//1. 基本创建
//如果创建节点，没有指定数据，则默认将当前客户端的ip作为数据存储
String path = client.create().forPath("/app1");
System.out.println(path);
}
@Test
public void testCreate3() throws Exception {
//3. 设置节点的类型
//默认类型：持久化
String path = client.create().withMode(CreateMode.EPHEMERAL).forPath("/app3");
System.out.println(path);
}
@Test
public void testCreate4() throws Exception {
//4. 创建多级节点 /app1/p1
//creatingParentsIfNeeded():如果父节点不存在，则创建父节点
String path = client.create().creatingParentsIfNeeded().forPath("/app4/p1");
System.out.println(path);
}
操作-查询节点
/**
* 查询节点：
* 1. 查询数据：get: getData().forPath()
* 2. 查询子节点： ls: getChildren().forPath()
* 3. 查询节点状态信息：ls -s:getData().storingStatIn(状态对象).forPath()
*/
@Test
public void testGet1() throws Exception {
//1. 查询数据：get
byte[] data = client.getData().forPath("/app1");
System.out.println(new String(data));
}
@Test
public void testGet2() throws Exception {
// 2. 查询子节点： ls
List<String> path = client.getChildren().forPath("/");
System.out.println(path);
}
@Test
public void testGet3() throws Exception {
Stat status = new Stat();
System.out.println(status);
//3. 查询节点状态信息：ls -s
client.getData().storingStatIn(status).forPath("/app1");
System.out.println(status);
}
操作-修改节点
/**
* 修改数据
* 1. 基本修改数据：setData().forPath()
* 2. 根据版本修改: setData().withVersion().forPath()
* * version 是通过查询出来的。目的就是为了让其他客户端或者线程不干扰我。
*
* @throws Exception
*/
@Test
public void testSet() throws Exception {
client.setData().forPath("/app1", "itcast".getBytes());
}
@Test
public void testSetForVersion() throws Exception {
Stat status = new Stat();
//3. 查询节点状态信息：ls -s
client.getData().storingStatIn(status).forPath("/app1");
int version = status.getVersion三万字，Spark学习笔记