文章目录

  • 入门
    • 概述
    • 特点
    • 数据结构
    • 应用场景
      • 统一命名服务
      • 统一配置管理
      • 统一集群管理
      • 服务器节点动态上下线
      • 软负载均衡等。
  • Zookeeper内部原理
    • 配置参数解读
    • 选举机制(面试重点)
    • 节点类型
    • Stat结构体
    • 监听器原理(面试重点)
    • 写数据流程
  • 操作
    • 客户端命令行操作 (shell)
    • API应用
      • Idea环境搭建
      • 创建一个节点
      • 获取子节点并监听
      • 判断Znode是否存在
    • 监听服务器节点动态上下线案例
      • 需求
      • 需求分析,如图所示
      • 具体实现

入门

概述

Zookeeper是一个开源的分布式的,为分布式应用提供协调服务的Apache项目

特点

在这里插入图片描述1) Zokeeper: -个领导者(Ladr) ,多个跟随者(ollower) 组成的集群。

2)集群中只要有半数以上节点存活,Zoke集群就能正常服务。

3)全局数据-致:每个Sere保存一份相同的数搞本,Cie无论连接到哪个Serer,数据都是一致的。4)更新清求顺序进行,来自同-个Cl的更新青求按其发送顺序依次执行。

5)数据更新原子性,一次数据更新要么成功,要么失败。

6)实时性,在一-定时间范围内,Client能读到最新数据。

数据结构

数据模型结构与Unix文件系统很类似,整体上可以看作是一棵树,每个节点称作一个ZNode,每一个ZNode默认能存储1MB的数据,每个ZNode都可以通过其路径唯一标识

在这里插入图片描述

应用场景

统一命名服务

在分布式环境下,经常需要对应用/服
务进行统一命名,便于识别。
例如: IP不容易记住,而域名容易记住。

在这里插入图片描述

统一配置管理

1)分布式环境下,配置文件同步非常常见。

(1) -般要求一个集群中,所有节点的配置信息是一致的,比如Kafka集群。
(2)对配置文件修改后,希望能够快速同步到各个节点上。

2)配置管理可交由ZooK eeper实现。

(1)可将配置信息写入ZooKeper.上的- -个Znode.
(2)各个客户端服务器监听这个Znode.
(3)一旦Znode中的数据被修改,ZooKeepe将通知各个客户端服务器。

在这里插入图片描述

统一集群管理

  • 分布式环境中,实时掌握每个节点的状态是必要的。
    (1)可根据节点实时状态做出一些调整。

  • ZooKeeper可以实现实时监控节点状态变化
    (1)可将节点信息写入ZooKeeper.上的一个ZNode。
    (2)监听这个ZNode可获取它的实时状态变化。

在这里插入图片描述

服务器节点动态上下线

在这里插入图片描述

软负载均衡等。

在Zookeeper中记录每台服务器的访问数,让访问数最少的服务器去处理最新的客户端请求
在这里插入图片描述

Zookeeper内部原理

配置参数解读

Zookeeper中的配置文件zoo.cfg中参数含义解读如下:
1.tickTime =2000:通信心跳数,Zookeeper服务器与客户端心跳时间,单位毫秒
Zookeeper使用的基本时间,服务器之间或客户端与服务器之间维持心跳的时间间隔,也就是每个tickTime时间就会发送一个心跳,时间单位为毫秒。
它用于心跳机制,并且设置最小的session超时时间为两倍心跳时间。(session的最小超时时间是2*tickTime)
2.initLimit =10:LF初始通信时限
集群中的Follower跟随者服务器与Leader领导者服务器之间初始连接时能容忍的最多心跳数(tickTime的数量),用它来限定集群中的Zookeeper服务器连接到Leader的时限。
3.syncLimit =5:LF同步通信时限
集群中Leader与Follower之间的最大响应时间单位,假如响应超过syncLimit * tickTime,Leader认为Follwer死掉,从服务器列表中删除Follwer。
4.dataDir:数据文件目录+数据持久化路径
主要用于保存Zookeeper中的数据。
5.clientPort =2181:客户端连接端口
监听客户端连接的端口。

选举机制(面试重点)

1)半数机制:集群中半数以上机器存活,集群可用。所以Zookeeper适合安装奇数台服务器。
2)Zookeeper虽然在配置文件中并没有指定Master和Slave。但是,Zookeeper工作时,是有一个节点为Leader,其他则为Follower,Leader是通过内部的选举机制临时产生的。
3)以一个简单的例子来说明整个选举的过程。
假设有五台服务器组成的Zookeeper集群,它们的id从1-5,同时它们都是最新启动的,也就是没有历史数据,在存放数据量这一点上,都是一样的。假设这些服务器依序启动,来看看会发生什么

在这里插入图片描述
(1)服务器1启动,此时只有它一台服务器启动了,它发出去的报文没有任何响应,所以它的选举状态一直是LOOKING状态。
(2)服务器2启动,它与最开始启动的服务器1进行通信,互相交换自己的选举结果,由于两者都没有历史数据,所以id值较大的服务器2胜出,但是由于没有达到超过半数以上的服务器都同意选举它(这个例子中的半数以上是3),所以服务器1、2还是继续保持LOOKING状态。
(3)服务器3启动,根据前面的理论分析,服务器3成为服务器1、2、3中的老大,而与上面不同的是,此时有三台服务器选举了它,所以它成为了这次选举的Leader。
(4)服务器4启动,根据前面的分析,理论上服务器4应该是服务器1、2、3、4中最大的,但是由于前面已经有半数以上的服务器选举了服务器3,所以它只能接收当小弟的命了。
(5)服务器5启动,同4一样当小弟。

节点类型

在这里插入图片描述

Stat结构体

1)czxid-创建节点的事务zxid,每次修改ZooKeeper状态都会收到一个zxid形式的时间戳,也就是ZooKeeper事务ID。事务ID是ZooKeeper中所有修改总的次序。每个修改都有唯一的zxid,如果zxid1小于zxid2,那么zxid1在zxid2之前发生。
2)ctime - znode被创建的毫秒数(从1970年开始)
3)mzxid - znode最后更新的事务zxid
4)mtime - znode最后修改的毫秒数(从1970年开始)
5)pZxid-znode最后更新的子节点zxid
6)cversion - znode子节点变化号,znode子节点修改次数
7)dataversion - znode数据变化号
8)aclVersion - znode访问控制列表的变化号
9)ephemeralOwner- 如果是临时节点,这个是znode拥有者的session id。如果不是临时节点则是0。
10)dataLength- znode的数据长度
11)numChildren - znode子节点数量

监听器原理(面试重点)

在这里插入图片描述

写数据流程

在这里插入图片描述

操作

客户端命令行操作 (shell)

命令基本语法 功能描述
help 显示所有操作命令
ls path [watch] 使用 ls 命令来查看当前znode中所包含的内容
ls2 path [watch] 查看当前节点数据并能看到更新次数等数据
create 普通创建 -s含有序列 -e 临时(重启或者超时消失)
get path [watch] 获得节点的值
set 设置节点的具体值
stat 查看节点状态
delete 删除节点
rmr 递归删除节点

1.启动客户端

[root@hadoop103 zookeeper-3.4.10]$ bin/zkCli.sh

2.显示所有操作命令

[zk: localhost:2181(CONNECTED) 1] help

3.查看当前znode中所包含的内容

[zk: localhost:2181(CONNECTED) 0] ls /
[zookeeper]

4.查看当前节点详细数据

[zk: localhost:2181(CONNECTED) 1] ls2 /
[zookeeper]
cZxid = 0x0
ctime = Thu Jan 01 08:00:00 CST 1970
mZxid = 0x0
mtime = Thu Jan 01 08:00:00 CST 1970
pZxid = 0x0
cversion = -1
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 0
numChildren = 1

5.分别创建2个普通节点

[zk: localhost:2181(CONNECTED) 3] create /sanguo "jinlian"
Created /sanguo
[zk: localhost:2181(CONNECTED) 4] create /sanguo/shuguo "liubei"
Created /sanguo/shuguo

6.获得节点的值

[zk: localhost:2181(CONNECTED) 5] get /sanguo
jinlian
cZxid = 0x100000003
ctime = Wed Aug 29 00:03:23 CST 2018
mZxid = 0x100000003
mtime = Wed Aug 29 00:03:23 CST 2018
pZxid = 0x100000004
cversion = 1
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 7
numChildren = 1
[zk: localhost:2181(CONNECTED) 6]
[zk: localhost:2181(CONNECTED) 6] get /sanguo/shuguo
liubei
cZxid = 0x100000004
ctime = Wed Aug 29 00:04:35 CST 2018
mZxid = 0x100000004
mtime = Wed Aug 29 00:04:35 CST 2018
pZxid = 0x100000004
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 6
numChildren = 0

7.创建短暂节点

[zk: localhost:2181(CONNECTED) 7] create -e /sanguo/wuguo "zhouyu"
Created /sanguo/wuguo
(1)在当前客户端是能查看到的
[zk: localhost:2181(CONNECTED) 3] ls /sanguo 
[wuguo, shuguo]2)退出当前客户端然后再重启客户端
[zk: localhost:2181(CONNECTED) 12] quit
[root@hadoop104 zookeeper-3.4.10]$ bin/zkCli.sh
(3)再次查看根目录下短暂节点已经删除
[zk: localhost:2181(CONNECTED) 0] ls /sanguo
[shuguo]

8.创建带序号的节点

1)先创建一个普通的根节点/sanguo/weiguo
[zk: localhost:2181(CONNECTED) 1] create /sanguo/weiguo "caocao"
Created /sanguo/weiguo
(2)创建带序号的节点
[zk: localhost:2181(CONNECTED) 2] create -s /sanguo/weiguo/xiaoqiao "jinlian"
Created /sanguo/weiguo/xiaoqiao0000000000
[zk: localhost:2181(CONNECTED) 3] create -s /sanguo/weiguo/daqiao "jinlian"
Created /sanguo/weiguo/daqiao0000000001
[zk: localhost:2181(CONNECTED) 4] create -s /sanguo/weiguo/diaocan "jinlian"
Created /sanguo/weiguo/diaocan0000000002
如果原来没有序号节点,序号从0开始依次递增。如果原节点下已有2个节点,则再排序时从2开始,以此类推。

9.修改节点数据值

[zk: localhost:2181(CONNECTED) 6] set /sanguo/weiguo "simayi"

10.节点的值变化监听

1)在hadoop104主机上注册监听/sanguo节点数据变化
[zk: localhost:2181(CONNECTED) 26] [zk: localhost:2181(CONNECTED) 8] get /sanguo watch
(2)在hadoop103主机上修改/sanguo节点的数据
[zk: localhost:2181(CONNECTED) 1] set /sanguo "xisi"3)观察hadoop104主机收到数据变化的监听WATCHER::WatchedEvent state:SyncConnected type:NodeDataChanged path:/sanguo

11.节点的子节点变化监听(路径变化)

1)在hadoop104主机上注册监听/sanguo节点的子节点变化
[zk: localhost:2181(CONNECTED) 1] ls /sanguo watch
[aa0000000001, server101]2)在hadoop103主机/sanguo节点上创建子节点
[zk: localhost:2181(CONNECTED) 2] create /sanguo/jin "simayi"
Created /sanguo/jin
(3)观察hadoop104主机收到子节点变化的监听WATCHER::WatchedEvent state:SyncConnected type:NodeChildrenChanged path:/sanguo

12.删除节点

[zk: localhost:2181(CONNECTED) 4] delete /sanguo/jin

13.递归删除节点

[zk: localhost:2181(CONNECTED) 15] rmr /sanguo/shuguo

14.查看节点状态

[zk: localhost:2181(CONNECTED) 17] stat /sanguo
cZxid = 0x100000003
ctime = Wed Aug 29 00:03:23 CST 2018
mZxid = 0x100000011
mtime = Wed Aug 29 00:21:23 CST 2018
pZxid = 0x100000014
cversion = 9
dataVersion = 1
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 4
numChildren = 1

API应用

Idea环境搭建

1.创建一个Maven工程
2.添加pom文件

<dependencies><dependency><groupId>junit</groupId><artifactId>junit</artifactId><version>RELEASE</version></dependency><dependency><groupId>org.apache.logging.log4j</groupId><artifactId>log4j-core</artifactId><version>2.8.2</version></dependency><!-- https://mvnrepository.com/artifact/org.apache.zookeeper/zookeeper --><dependency><groupId>org.apache.zookeeper</groupId><artifactId>zookeeper</artifactId><version>3.4.10</version></dependency>
</dependencies>

3.拷贝log4j.properties文件到项目根目录
需要在项目的src/main/resources目录下,新建一个文件,命名为“log4j.properties”,在文件中填入。

log4j.rootLogger=INFO, stdout  
log4j.appender.stdout=org.apache.log4j.ConsoleAppender  
log4j.appender.stdout.layout=org.apache.log4j.PatternLayout  
log4j.appender.stdout.layout.ConversionPattern=%d %p [%c] - %m%n  
log4j.appender.logfile=org.apache.log4j.FileAppender  
log4j.appender.logfile.File=target/spring.log  
log4j.appender.logfile.layout=org.apache.log4j.PatternLayout  
log4j.appender.logfile.layout.ConversionPattern=%d %p [%c] - %m%n  

4 .尝试连接zk客户端

JUnit4使用Java5中的注解(annotation),以下是JUnit4常用的几个annotation:
@Before:初始化方法 对于每一个测试方法都要执行一次(注意与BeforeClass区别,后者是对于所有方法执行一次)
@After:释放资源 对于每一个测试方法都要执行一次(注意与AfterClass区别,后者是对于所有方法执行一次)
@Test:测试方法,在这里可以测试期望异常和超时时间
@Test(expected=ArithmeticException.class)检查被测方法是否抛出ArithmeticException异常
@Ignore:忽略的测试方法
@BeforeClass:针对所有测试,只执行一次,且必须为static void
@AfterClass:针对所有测试,只执行一次,且必须为static void
一个JUnit4的单元测试用例执行顺序为:
@BeforeClass -> @Before -> @Test -> @After -> @AfterClass;
每一个测试方法的调用顺序为:
@Before -> @Test -> @After;
public class ZookeeperTest {private String connectString = "huan01:2181,huan02:2181,huan03:2181";private int sessionTimeout = 2000;private ZooKeeper zkClit;@Testpublic void init() throws IOException {//TODO 传三个参数,第一个设置zk集群,第二个毫秒时间,第三个监听器zkClit =  new ZooKeeper( connectString,  sessionTimeout, new Watcher() {public void process(WatchedEvent event) {}} );}
}

5 .结果如下

D:\java\java\jdk1.8.0_92\bin\java.exe -ea -Didea.test.cyclic.buffer.size=1048576 "-javaagent:F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar=11013:F:\Big DATA\IntelliJ IDEA 2020.1\bin" -Dfile.encoding=UTF-8 -classpath "F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit5-rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit-rt.jar;D:\java\java\jdk1.8.0_92\jre\lib\charsets.jar;D:\java\java\jdk1.8.0_92\jre\lib\deploy.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\access-bridge-64.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\cldrdata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\dnsns.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jaccess.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jfxrt.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\localedata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\nashorn.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunec.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunjce_provider.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunmscapi.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunpkcs11.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\zipfs.jar;D:\java\java\jdk1.8.0_92\jre\lib\javaws.jar;D:\java\java\jdk1.8.0_92\jre\lib\jce.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfr.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfxswt.jar;D:\java\java\jdk1.8.0_92\jre\lib\jsse.jar;D:\java\java\jdk1.8.0_92\jre\lib\management-agent.jar;D:\java\java\jdk1.8.0_92\jre\lib\plugin.jar;D:\java\java\jdk1.8.0_92\jre\lib\resources.jar;D:\java\java\jdk1.8.0_92\jre\lib\rt.jar;E:\Project\Hadoop\Zookeeper\target\classes;E:\maven\repository\junit\junit\4.13\junit-4.13.jar;E:\maven\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar;E:\maven\repository\org\apache\logging\log4j\log4j-core\2.8.2\log4j-core-2.8.2.jar;E:\maven\repository\org\apache\logging\log4j\log4j-api\2.8.2\log4j-api-2.8.2.jar;E:\maven\repository\org\apache\zookeeper\zookeeper\3.4.5\zookeeper-3.4.5.jar;E:\maven\repository\org\slf4j\slf4j-api\1.6.1\slf4j-api-1.6.1.jar;E:\maven\repository\org\slf4j\slf4j-log4j12\1.6.1\slf4j-log4j12-1.6.1.jar;E:\maven\repository\log4j\log4j\1.2.15\log4j-1.2.15.jar;E:\maven\repository\javax\mail\mail\1.4\mail-1.4.jar;E:\maven\repository\javax\activation\activation\1.1\activation-1.1.jar;E:\maven\repository\javax\jms\jms\1.1\jms-1.1.jar;E:\maven\repository\com\sun\jdmk\jmxtools\1.2.1\jmxtools-1.2.1.jar;E:\maven\repository\com\sun\jmx\jmxri\1.2.1\jmxri-1.2.1.jar;E:\maven\repository\jline\jline\0.9.94\jline-0.9.94.jar;E:\maven\repository\org\jboss\netty\netty\3.2.2.Final\netty-3.2.2.Final.jar" com.intellij.rt.junit.JUnitStarter -ideVersion5 com.huan.ZookeeperTest,init
2020-08-11 18:15:05,460 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT2020-08-11 18:15:05,462 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:host.name=DESKTOP-B32P6612020-08-11 18:15:05,462 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.version=1.8.0_922020-08-11 18:15:05,462 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.vendor=Oracle Corporation2020-08-11 18:15:05,462 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.home=D:\java\java\jdk1.8.0_92\jre2020-08-11 18:15:05,462 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.class.path=F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit5-rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit-rt.jar;D:\java\java\jdk1.8.0_92\jre\lib\charsets.jar;D:\java\java\jdk1.8.0_92\jre\lib\deploy.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\access-bridge-64.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\cldrdata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\dnsns.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jaccess.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jfxrt.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\localedata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\nashorn.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunec.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunjce_provider.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunmscapi.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunpkcs11.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\zipfs.jar;D:\java\java\jdk1.8.0_92\jre\lib\javaws.jar;D:\java\java\jdk1.8.0_92\jre\lib\jce.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfr.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfxswt.jar;D:\java\java\jdk1.8.0_92\jre\lib\jsse.jar;D:\java\java\jdk1.8.0_92\jre\lib\management-agent.jar;D:\java\java\jdk1.8.0_92\jre\lib\plugin.jar;D:\java\java\jdk1.8.0_92\jre\lib\resources.jar;D:\java\java\jdk1.8.0_92\jre\lib\rt.jar;E:\Project\Hadoop\Zookeeper\target\classes;E:\maven\repository\junit\junit\4.13\junit-4.13.jar;E:\maven\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar;E:\maven\repository\org\apache\logging\log4j\log4j-core\2.8.2\log4j-core-2.8.2.jar;E:\maven\repository\org\apache\logging\log4j\log4j-api\2.8.2\log4j-api-2.8.2.jar;E:\maven\repository\org\apache\zookeeper\zookeeper\3.4.5\zookeeper-3.4.5.jar;E:\maven\repository\org\slf4j\slf4j-api\1.6.1\slf4j-api-1.6.1.jar;E:\maven\repository\org\slf4j\slf4j-log4j12\1.6.1\slf4j-log4j12-1.6.1.jar;E:\maven\repository\log4j\log4j\1.2.15\log4j-1.2.15.jar;E:\maven\repository\javax\mail\mail\1.4\mail-1.4.jar;E:\maven\repository\javax\activation\activation\1.1\activation-1.1.jar;E:\maven\repository\javax\jms\jms\1.1\jms-1.1.jar;E:\maven\repository\com\sun\jdmk\jmxtools\1.2.1\jmxtools-1.2.1.jar;E:\maven\repository\com\sun\jmx\jmxri\1.2.1\jmxri-1.2.1.jar;E:\maven\repository\jline\jline\0.9.94\jline-0.9.94.jar;E:\maven\repository\org\jboss\netty\netty\3.2.2.Final\netty-3.2.2.Final.jar;F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar2020-08-11 18:15:05,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.library.path=D:\java\java\jdk1.8.0_92\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;C:\Program Files (x86)\Common Files\NetSarang;C:\Program Files (x86)\Common Files\Oracle\Java\javapath;C:\ProgramData\Oracle\Java\javapath;C:\Windows\system32;C:\Windows;C:\Windows\system32\wbem;D:\mysql\bin;D:\java\java\jdk1.8.0_92\bin;D:\java\java\jdk1.8.0_92\jre\bin;D:\maven\apache-maven-3.6.1\bin;%CATALINA_HOME%\lib;%CATALINA_HOME%\bin;D:\scala\bin;D:\hadoop\hadoop-2.7.2\bin\winutils.exe;F:\Sublime Text 3;D:\hadoop\hadoop-2.6.5\bin;D:\Tomcat\apache-tomcat-7.0.53\bin;C:\Program Files (x86)\NVIDIA Corporation\PhysX\Common;D:\Gradle\gradle-4.7\bin;C:\Users\栾昊\AppData\Local\Microsoft\WindowsApps;D:\java\java\jdk1.8.0_92\bin;%CATALINA_HOME%\bin\;;D:\idea\IntelliJ IDEA 2019.1.3\bin;;.2020-08-11 18:15:05,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.io.tmpdir=C:\Users\栾昊\AppData\Local\Temp\2020-08-11 18:15:05,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.compiler=<NA>2020-08-11 18:15:05,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.name=Windows 102020-08-11 18:15:05,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.arch=amd642020-08-11 18:15:05,465 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.version=10.02020-08-11 18:15:05,465 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.name=hao2020-08-11 18:15:05,465 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.home=C:\Users\栾昊2020-08-11 18:15:05,465 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.dir=E:\Project\Hadoop\Zookeeper2020-08-11 18:15:05,470 INFO [org.apache.zookeeper.ZooKeeper] - Initiating client connection, connectString=huan01:2181,huan02:2181,huan03:2181 sessionTimeout=2000 watcher=com.huan.ZookeeperTest$1@5a42bbf4Process finished with exit code 0

创建一个节点

代码如下

public class ZookeeperTest {private String connectString = "huan01:2181,huan02:2181,huan03:2181";private int sessionTimeout = 2000;private ZooKeeper zkClit;@Beforepublic void init() throws IOException {//TODO 传三个参数,第一个设置zk集群,第二个毫秒时间,第三个监听器zkClit =  new ZooKeeper( connectString,  sessionTimeout, new Watcher() {public void process(WatchedEvent event) {}} );}@Testpublic void createNode() throws KeeperException, InterruptedException {String path = zkClit.create( "/dahuanhuan", "huanhuan".getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT );System.out.println(path);}
}

结果如下

2020-08-11 20:19:46,933 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT2020-08-11 20:19:46,935 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:host.name=DESKTOP-B32P6612020-08-11 20:19:46,935 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.version=1.8.0_922020-08-11 20:19:46,935 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.vendor=Oracle Corporation2020-08-11 20:19:46,935 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.home=D:\java\java\jdk1.8.0_92\jre2020-08-11 20:19:46,935 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.class.path=F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit5-rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit-rt.jar;D:\java\java\jdk1.8.0_92\jre\lib\charsets.jar;D:\java\java\jdk1.8.0_92\jre\lib\deploy.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\access-bridge-64.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\cldrdata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\dnsns.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jaccess.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jfxrt.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\localedata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\nashorn.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunec.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunjce_provider.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunmscapi.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunpkcs11.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\zipfs.jar;D:\java\java\jdk1.8.0_92\jre\lib\javaws.jar;D:\java\java\jdk1.8.0_92\jre\lib\jce.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfr.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfxswt.jar;D:\java\java\jdk1.8.0_92\jre\lib\jsse.jar;D:\java\java\jdk1.8.0_92\jre\lib\management-agent.jar;D:\java\java\jdk1.8.0_92\jre\lib\plugin.jar;D:\java\java\jdk1.8.0_92\jre\lib\resources.jar;D:\java\java\jdk1.8.0_92\jre\lib\rt.jar;E:\Project\Hadoop\Zookeeper\target\classes;E:\maven\repository\junit\junit\4.13\junit-4.13.jar;E:\maven\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar;E:\maven\repository\org\apache\logging\log4j\log4j-core\2.8.2\log4j-core-2.8.2.jar;E:\maven\repository\org\apache\logging\log4j\log4j-api\2.8.2\log4j-api-2.8.2.jar;E:\maven\repository\org\apache\zookeeper\zookeeper\3.4.5\zookeeper-3.4.5.jar;E:\maven\repository\org\slf4j\slf4j-api\1.6.1\slf4j-api-1.6.1.jar;E:\maven\repository\org\slf4j\slf4j-log4j12\1.6.1\slf4j-log4j12-1.6.1.jar;E:\maven\repository\log4j\log4j\1.2.15\log4j-1.2.15.jar;E:\maven\repository\javax\mail\mail\1.4\mail-1.4.jar;E:\maven\repository\javax\activation\activation\1.1\activation-1.1.jar;E:\maven\repository\javax\jms\jms\1.1\jms-1.1.jar;E:\maven\repository\com\sun\jdmk\jmxtools\1.2.1\jmxtools-1.2.1.jar;E:\maven\repository\com\sun\jmx\jmxri\1.2.1\jmxri-1.2.1.jar;E:\maven\repository\jline\jline\0.9.94\jline-0.9.94.jar;E:\maven\repository\org\jboss\netty\netty\3.2.2.Final\netty-3.2.2.Final.jar;F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar2020-08-11 20:19:46,936 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.library.path=D:\java\java\jdk1.8.0_92\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;C:\Program Files (x86)\Common Files\NetSarang;C:\Program Files (x86)\Common Files\Oracle\Java\javapath;C:\ProgramData\Oracle\Java\javapath;C:\Windows\system32;C:\Windows;C:\Windows\system32\wbem;D:\mysql\bin;D:\java\java\jdk1.8.0_92\bin;D:\java\java\jdk1.8.0_92\jre\bin;D:\maven\apache-maven-3.6.1\bin;%CATALINA_HOME%\lib;%CATALINA_HOME%\bin;D:\scala\bin;D:\hadoop\hadoop-2.7.2\bin\winutils.exe;F:\Sublime Text 3;D:\hadoop\hadoop-2.6.5\bin;D:\Tomcat\apache-tomcat-7.0.53\bin;C:\Program Files (x86)\NVIDIA Corporation\PhysX\Common;D:\Gradle\gradle-4.7\bin;C:\Users\栾昊\AppData\Local\Microsoft\WindowsApps;D:\java\java\jdk1.8.0_92\bin;%CATALINA_HOME%\bin\;;D:\idea\IntelliJ IDEA 2019.1.3\bin;;.2020-08-11 20:19:46,936 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.io.tmpdir=C:\Users\栾昊\AppData\Local\Temp\2020-08-11 20:19:46,936 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.compiler=<NA>2020-08-11 20:19:46,936 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.name=Windows 102020-08-11 20:19:46,936 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.arch=amd642020-08-11 20:19:46,936 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.version=10.02020-08-11 20:19:46,936 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.name=hao2020-08-11 20:19:46,936 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.home=C:\Users\栾昊2020-08-11 20:19:46,937 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.dir=E:\Project\Hadoop\Zookeeper2020-08-11 20:19:46,940 INFO [org.apache.zookeeper.ZooKeeper] - Initiating client connection, connectString=huan01:2181,huan02:2181,huan03:2181 sessionTimeout=2000 watcher=com.huan.ZookeeperTest$1@270421f52020-08-11 20:19:47,216 INFO [org.apache.zookeeper.ClientCnxn] - Opening socket connection to server huan01/192.168.168.234:2181. Will not attempt to authenticate using SASL (unknown error)2020-08-11 20:19:47,222 INFO [org.apache.zookeeper.ClientCnxn] - Socket connection established to huan01/192.168.168.234:2181, initiating session2020-08-11 20:19:47,271 INFO [org.apache.zookeeper.ClientCnxn] - Session establishment complete on server huan01/192.168.168.234:2181, sessionid = 0x173d87741390000, negotiated timeout = 4000/dahuanhuan

进入客户端查看

WatchedEvent state:SyncConnected type:None path:null
[zk: localhost:2181(CONNECTED) 0] ls /
[cluster, brokers, tonghuan, zookeeper, dahuanhuan, admin, isr_change_notification, controller_epoch, servers, kafka-manager, consumers, latest_producer_id_block, config, hbase]
[zk: localhost:2181(CONNECTED) 1] get /dahuanhuan
huanhuan
cZxid = 0x3b00000002
ctime = Mon Aug 10 22:55:57 CST 2020
mZxid = 0x3b00000002
mtime = Mon Aug 10 22:55:57 CST 2020
pZxid = 0x3b00000002
cversion = 0
dataVersion = 0
aclVersion = 0
ephemeralOwner = 0x0
dataLength = 8
numChildren = 0

获取子节点并监听

代码展示

public class ZookeeperTest {private String connectString = "huan01:2181,huan02:2181,huan03:2181";private int sessionTimeout = 2000;private ZooKeeper zkClit;//TODO 创建客户端@Beforepublic void init() throws IOException {//TODO 传三个参数,第一个设置zk集群,第二个毫秒时间,第三个监听器zkClit =  new ZooKeeper( connectString,  sessionTimeout, new Watcher() {public void process(WatchedEvent event) {System.out.println("---start---");List<String> children ;try {children = zkClit.getChildren( "/", true );for (String child : children) {System.out.println(child);}System.out.println("---end---");} catch (KeeperException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}} );}//TODO 获取子节点并监听@Testpublic void getChildren() throws KeeperException, InterruptedException {List<String> children = zkClit.getChildren( "/", true );for (String child : children) {System.out.println(child);}//TODO 最大延迟Thread.sleep( Long.MAX_VALUE );}
}

客户端展示

[zk: localhost:2181(CONNECTED) 3] rmr /tonghuan

运行结果

2020-08-11 20:48:14,017 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT2020-08-11 20:48:14,019 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:host.name=DESKTOP-B32P6612020-08-11 20:48:14,019 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.version=1.8.0_922020-08-11 20:48:14,019 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.vendor=Oracle Corporation2020-08-11 20:48:14,019 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.home=D:\java\java\jdk1.8.0_92\jre2020-08-11 20:48:14,019 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.class.path=F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit5-rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit-rt.jar;D:\java\java\jdk1.8.0_92\jre\lib\charsets.jar;D:\java\java\jdk1.8.0_92\jre\lib\deploy.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\access-bridge-64.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\cldrdata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\dnsns.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jaccess.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jfxrt.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\localedata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\nashorn.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunec.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunjce_provider.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunmscapi.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunpkcs11.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\zipfs.jar;D:\java\java\jdk1.8.0_92\jre\lib\javaws.jar;D:\java\java\jdk1.8.0_92\jre\lib\jce.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfr.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfxswt.jar;D:\java\java\jdk1.8.0_92\jre\lib\jsse.jar;D:\java\java\jdk1.8.0_92\jre\lib\management-agent.jar;D:\java\java\jdk1.8.0_92\jre\lib\plugin.jar;D:\java\java\jdk1.8.0_92\jre\lib\resources.jar;D:\java\java\jdk1.8.0_92\jre\lib\rt.jar;E:\Project\Hadoop\Zookeeper\target\classes;E:\maven\repository\junit\junit\4.13\junit-4.13.jar;E:\maven\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar;E:\maven\repository\org\apache\logging\log4j\log4j-core\2.8.2\log4j-core-2.8.2.jar;E:\maven\repository\org\apache\logging\log4j\log4j-api\2.8.2\log4j-api-2.8.2.jar;E:\maven\repository\org\apache\zookeeper\zookeeper\3.4.5\zookeeper-3.4.5.jar;E:\maven\repository\org\slf4j\slf4j-api\1.6.1\slf4j-api-1.6.1.jar;E:\maven\repository\org\slf4j\slf4j-log4j12\1.6.1\slf4j-log4j12-1.6.1.jar;E:\maven\repository\log4j\log4j\1.2.15\log4j-1.2.15.jar;E:\maven\repository\javax\mail\mail\1.4\mail-1.4.jar;E:\maven\repository\javax\activation\activation\1.1\activation-1.1.jar;E:\maven\repository\javax\jms\jms\1.1\jms-1.1.jar;E:\maven\repository\com\sun\jdmk\jmxtools\1.2.1\jmxtools-1.2.1.jar;E:\maven\repository\com\sun\jmx\jmxri\1.2.1\jmxri-1.2.1.jar;E:\maven\repository\jline\jline\0.9.94\jline-0.9.94.jar;E:\maven\repository\org\jboss\netty\netty\3.2.2.Final\netty-3.2.2.Final.jar;F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar2020-08-11 20:48:14,020 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.library.path=D:\java\java\jdk1.8.0_92\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;C:\Program Files (x86)\Common Files\NetSarang;C:\Program Files (x86)\Common Files\Oracle\Java\javapath;C:\ProgramData\Oracle\Java\javapath;C:\Windows\system32;C:\Windows;C:\Windows\system32\wbem;D:\mysql\bin;D:\java\java\jdk1.8.0_92\bin;D:\java\java\jdk1.8.0_92\jre\bin;D:\maven\apache-maven-3.6.1\bin;%CATALINA_HOME%\lib;%CATALINA_HOME%\bin;D:\scala\bin;D:\hadoop\hadoop-2.7.2\bin\winutils.exe;F:\Sublime Text 3;D:\hadoop\hadoop-2.6.5\bin;D:\Tomcat\apache-tomcat-7.0.53\bin;C:\Program Files (x86)\NVIDIA Corporation\PhysX\Common;D:\Gradle\gradle-4.7\bin;C:\Users\栾昊\AppData\Local\Microsoft\WindowsApps;D:\java\java\jdk1.8.0_92\bin;%CATALINA_HOME%\bin\;;D:\idea\IntelliJ IDEA 2019.1.3\bin;;.2020-08-11 20:48:14,020 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.io.tmpdir=C:\Users\栾昊\AppData\Local\Temp\2020-08-11 20:48:14,020 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.compiler=<NA>2020-08-11 20:48:14,020 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.name=Windows 102020-08-11 20:48:14,020 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.arch=amd642020-08-11 20:48:14,020 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.version=10.02020-08-11 20:48:14,020 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.name=hao2020-08-11 20:48:14,020 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.home=C:\Users\栾昊2020-08-11 20:48:14,021 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.dir=E:\Project\Hadoop\Zookeeper2020-08-11 20:48:14,025 INFO [org.apache.zookeeper.ZooKeeper] - Initiating client connection, connectString=huan01:2181,huan02:2181,huan03:2181 sessionTimeout=2000 watcher=com.huan.ZookeeperTest$1@270421f52020-08-11 20:48:14,292 INFO [org.apache.zookeeper.ClientCnxn] - Opening socket connection to server huan01/192.168.168.234:2181. Will not attempt to authenticate using SASL (unknown error)2020-08-11 20:48:14,299 INFO [org.apache.zookeeper.ClientCnxn] - Socket connection established to huan01/192.168.168.234:2181, initiating session2020-08-11 20:48:14,325 INFO [org.apache.zookeeper.ClientCnxn] - Session establishment complete on server huan01/192.168.168.234:2181, sessionid = 0x173d87741390002, negotiated timeout = 4000---start---
cluster
brokers
tonghuan
zookeeper
dahuanhuan
admin
isr_change_notification
controller_epoch
servers
kafka-manager
consumers
latest_producer_id_block
config
hbase
cluster
brokers
tonghuan
zookeeper
dahuanhuan
admin
isr_change_notification
controller_epoch
servers
kafka-manager
consumers
latest_producer_id_block
config
hbase
---end---
---start---
cluster
brokers
zookeeper
dahuanhuan
admin
isr_change_notification
controller_epoch
servers
kafka-manager
consumers
latest_producer_id_block
config
hbase
---end---

判断Znode是否存在

代码展示

public class ZookeeperTest {private String connectString = "huan01:2181,huan02:2181,huan03:2181";private int sessionTimeout = 2000;private ZooKeeper zkClit;//TODO 创建客户端@Beforepublic void init() throws IOException {//TODO 传三个参数,第一个设置zk集群,第二个毫秒时间,第三个监听器zkClit =  new ZooKeeper( connectString,  sessionTimeout, new Watcher() {public void process(WatchedEvent event) {}} );}//TODO 判断Znode是否存在@Testpublic void exist() throws KeeperException, InterruptedException {Stat stat = zkClit.exists( "/huanma", false );//判断stat是否为空,为空时为 no exists 不为空时为 existsSystem.out.println(stat == null? "no exists" : "exists");}
}

结果如下

2020-08-11 21:02:10,458 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:zookeeper.version=3.4.5-1392090, built on 09/30/2012 17:52 GMT2020-08-11 21:02:10,460 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:host.name=DESKTOP-B32P6612020-08-11 21:02:10,460 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.version=1.8.0_922020-08-11 21:02:10,460 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.vendor=Oracle Corporation2020-08-11 21:02:10,461 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.home=D:\java\java\jdk1.8.0_92\jre2020-08-11 21:02:10,461 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.class.path=F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit5-rt.jar;F:\Big DATA\IntelliJ IDEA 2020.1\plugins\junit\lib\junit-rt.jar;D:\java\java\jdk1.8.0_92\jre\lib\charsets.jar;D:\java\java\jdk1.8.0_92\jre\lib\deploy.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\access-bridge-64.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\cldrdata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\dnsns.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jaccess.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\jfxrt.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\localedata.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\nashorn.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunec.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunjce_provider.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunmscapi.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\sunpkcs11.jar;D:\java\java\jdk1.8.0_92\jre\lib\ext\zipfs.jar;D:\java\java\jdk1.8.0_92\jre\lib\javaws.jar;D:\java\java\jdk1.8.0_92\jre\lib\jce.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfr.jar;D:\java\java\jdk1.8.0_92\jre\lib\jfxswt.jar;D:\java\java\jdk1.8.0_92\jre\lib\jsse.jar;D:\java\java\jdk1.8.0_92\jre\lib\management-agent.jar;D:\java\java\jdk1.8.0_92\jre\lib\plugin.jar;D:\java\java\jdk1.8.0_92\jre\lib\resources.jar;D:\java\java\jdk1.8.0_92\jre\lib\rt.jar;E:\Project\Hadoop\Zookeeper\target\classes;E:\maven\repository\junit\junit\4.13\junit-4.13.jar;E:\maven\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar;E:\maven\repository\org\apache\logging\log4j\log4j-core\2.8.2\log4j-core-2.8.2.jar;E:\maven\repository\org\apache\logging\log4j\log4j-api\2.8.2\log4j-api-2.8.2.jar;E:\maven\repository\org\apache\zookeeper\zookeeper\3.4.5\zookeeper-3.4.5.jar;E:\maven\repository\org\slf4j\slf4j-api\1.6.1\slf4j-api-1.6.1.jar;E:\maven\repository\org\slf4j\slf4j-log4j12\1.6.1\slf4j-log4j12-1.6.1.jar;E:\maven\repository\log4j\log4j\1.2.15\log4j-1.2.15.jar;E:\maven\repository\javax\mail\mail\1.4\mail-1.4.jar;E:\maven\repository\javax\activation\activation\1.1\activation-1.1.jar;E:\maven\repository\javax\jms\jms\1.1\jms-1.1.jar;E:\maven\repository\com\sun\jdmk\jmxtools\1.2.1\jmxtools-1.2.1.jar;E:\maven\repository\com\sun\jmx\jmxri\1.2.1\jmxri-1.2.1.jar;E:\maven\repository\jline\jline\0.9.94\jline-0.9.94.jar;E:\maven\repository\org\jboss\netty\netty\3.2.2.Final\netty-3.2.2.Final.jar;F:\Big DATA\IntelliJ IDEA 2020.1\lib\idea_rt.jar2020-08-11 21:02:10,461 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.library.path=D:\java\java\jdk1.8.0_92\bin;C:\Windows\Sun\Java\bin;C:\Windows\system32;C:\Windows;C:\Program Files (x86)\Common Files\NetSarang;C:\Program Files (x86)\Common Files\Oracle\Java\javapath;C:\ProgramData\Oracle\Java\javapath;C:\Windows\system32;C:\Windows;C:\Windows\system32\wbem;D:\mysql\bin;D:\java\java\jdk1.8.0_92\bin;D:\java\java\jdk1.8.0_92\jre\bin;D:\maven\apache-maven-3.6.1\bin;%CATALINA_HOME%\lib;%CATALINA_HOME%\bin;D:\scala\bin;D:\hadoop\hadoop-2.7.2\bin\winutils.exe;F:\Sublime Text 3;D:\hadoop\hadoop-2.6.5\bin;D:\Tomcat\apache-tomcat-7.0.53\bin;C:\Program Files (x86)\NVIDIA Corporation\PhysX\Common;D:\Gradle\gradle-4.7\bin;C:\Users\栾昊\AppData\Local\Microsoft\WindowsApps;D:\java\java\jdk1.8.0_92\bin;%CATALINA_HOME%\bin\;;D:\idea\IntelliJ IDEA 2019.1.3\bin;;.2020-08-11 21:02:10,462 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.io.tmpdir=C:\Users\栾昊\AppData\Local\Temp\2020-08-11 21:02:10,462 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:java.compiler=<NA>2020-08-11 21:02:10,462 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.name=Windows 102020-08-11 21:02:10,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.arch=amd642020-08-11 21:02:10,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:os.version=10.02020-08-11 21:02:10,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.name=hao2020-08-11 21:02:10,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.home=C:\Users\栾昊2020-08-11 21:02:10,463 INFO [org.apache.zookeeper.ZooKeeper] - Client environment:user.dir=E:\Project\Hadoop\Zookeeper2020-08-11 21:02:10,469 INFO [org.apache.zookeeper.ZooKeeper] - Initiating client connection, connectString=huan01:2181,huan02:2181,huan03:2181 sessionTimeout=2000 watcher=com.huan.ZookeeperTest$1@270421f52020-08-11 21:02:10,974 INFO [org.apache.zookeeper.ClientCnxn] - Opening socket connection to server huan02/192.168.168.235:2181. Will not attempt to authenticate using SASL (unknown error)2020-08-11 21:02:10,980 INFO [org.apache.zookeeper.ClientCnxn] - Socket connection established to huan02/192.168.168.235:2181, initiating session2020-08-11 21:02:11,008 INFO [org.apache.zookeeper.ClientCnxn] - Session establishment complete on server huan02/192.168.168.235:2181, sessionid = 0x273d87767360001, negotiated timeout = 4000
no exists

监听服务器节点动态上下线案例

需求

某分布式系统中,主节点可以有多台,可以动态上下线,任意一台客户端都能实时感知到主节点服务器的上下线。

需求分析,如图所示

在这里插入图片描述

具体实现

(1)服务器端向Zookeeper注册代码

public class DistributeServer {public static void main(String[] args) throws Exception {DistributeServer server = new DistributeServer();//TODO 1 注册节点server.getConnect();//TODO 2 连接注册服务器信息(在第一台注册)server.registServer( args[0] );//TODO 3 启动业务功能server.business();}//TODO 3 启动业务功能private void business() throws InterruptedException {Thread.sleep( Long.MAX_VALUE );}//2 连接注册服务器信息(在第一台注册)private void registServer(String hostname) throws KeeperException, InterruptedException {String path = zkClient.create( "/servers/server", hostname.getBytes(), ZooDefs.Ids.OPEN_ACL_UNSAFE, CreateMode.EPHEMERAL_SEQUENTIAL );System.out.println( path + "on line" );}//TODO 1 注册节点private String connectString = "huan01:2181,huan02:2181,huan03:2181";private int sessionTimeout = 20000;ZooKeeper zkClient;private void getConnect() throws IOException {zkClient = new ZooKeeper( connectString, sessionTimeout, new Watcher() {public void process(WatchedEvent event) {}} );}
}

(2)客户端代码

public class DistributeClient {public static void main(String[] args) throws Exception {DistributeClient client = new DistributeClient();//TODO 1 获取集群连接client.getConnect();//TODO 2 注册监听client.getChildren();//TODO 3 业务处理逻辑client.business();}//TODO 3 业务处理逻辑private void business() throws InterruptedException {Thread.sleep( Long.MAX_VALUE );}//TODO 2 注册监听private void getChildren() throws KeeperException, InterruptedException {List<String> children = zkClient.getChildren( "/servers", true );//TODO 存储服务器节点名称ArrayList<String> hosts = new ArrayList<String>();for (String child : children) {byte[] data = zkClient.getData( "/servers/" + child, false, null );hosts.add( new String(data) );}//TODO 将所有在线主机名称打印到控制台System.out.println(hosts);}//TODO 1 获取集群连接private String connectString = "huan01:2181,huan02:2181,huan03:2181";private int sessionTimeout = 2000;private ZooKeeper zkClient;private void getConnect() throws IOException {zkClient  = new ZooKeeper( connectString, sessionTimeout, new Watcher() {@Overridepublic void process(WatchedEvent event) {try {getChildren();} catch (KeeperException e) {e.printStackTrace();} catch (InterruptedException e) {e.printStackTrace();}}} );}
}
查看全文
如若内容造成侵权/违法违规/事实不符,请联系编程学习网邮箱:809451989@qq.com进行投诉反馈,一经查实,立即删除!

相关文章

  1. 联通大数据的数据质量如何

    “ 联通大数据以全量数据为基础,结合海量、实时数据处理能力,提供持续、稳定、高效的大数据运营服务。联通大数据积累了丰富的数据能力、平台能力、产品交付能力和行业解决方案能力,累计服务17个行业。联通大数据在精准营销、数达营销和数言舆情标准产品的基础上形成了针对各…...

    2024/5/5 20:10:52
  2. 字符编码集和不同编码的区别

    文章目录历史不同编码区别转自:编码历史与区别 历史 一直对字符的各种编码方式懵懵懂懂,什么ANSI UNICODE UTF-8 GB2312 GBK DBCS UCS……是不是看的很晕,假如您细细的阅读本文你一定可以清晰的理解他们。Let’s go! 很久很久以前,有一群人,他们决定用8个可以开合的晶体管…...

    2024/4/29 14:17:23
  3. 远程控制软件vnc,推荐三款你绝对会喜欢的远程控制软件vnc

    远程控制软件vnc不是很多,而且基本上都是英文的。所以可能会比较的难找一点。专业的就更少了。远程控制软件vnc需要的是简单方便快捷明了。所以接下来小编给大家推荐三款你绝对会喜欢的远程控制软件vnc。 第一款:IIS7服务器管理工具 这个工具里面的VNC功能可以说是使用感非常…...

    2024/5/5 18:41:37
  4. linux下载安装redis,redis maven配置,Redis数据类型

    linux下载安装redis link解压文件命令:tar-zxvf压缩包名 基本的环境安装 yum install gcc-c++#查看 gcc -v #命令 make命令 make #确认安装命令 make install默认后台不是启动redis的,修改config文件,找到daemonize 改为yes Redis maven配置: <!-- springboot整合 redi…...

    2024/4/29 14:17:14
  5. 深信服翔鹰计划技术面试

    深信服技术面(综合部分):针对网络基础、协议基础、安全、虚拟化、存储、系统基础来提问。 面试官一问:给你路由器、防火墙和交换机,让你完成如下功能,两个部门,两个部门之间不相互影响能够上外网,你如何挑选设备,你为什么要这么挑选,主要配置有哪些?期间的路由怎么走…...

    2024/5/5 3:35:45
  6. python:math模块的应用

    jmu-python-求三角形面积及周长 输入的三角形的三条边a、b、c,计算并输出面积和周长。假设输入三角形三边是合法整形数据。 三角形面积计算公式: 其中s=(a+b+c)/2。 import math #导入math库 math.sqrt(x) #调用sqrt函数实现开平方运算,x表示要求值的数据输入格式: 每行输…...

    2024/5/4 19:57:54
  7. ARM裸机的知识点总结---------9、pwm定时器

    Author: 想文艺一点的程序员 自动化专业 工科男 再坚持一点,再自律一点 CSDN@想文艺一点的程序员 来自朱有鹏嵌入式的学习笔记定时器一、S5PV210的定时器1、什么是定时器(timer)2、S5PV210中的定时器二、S5PV210的PWM定时器1、PWM定时器介绍(overview)2、Figure(时钟框图…...

    2024/5/5 22:14:55
  8. 打通BurpSuite与Python之间的任督二脉的插件—Burpy

    Burpy是一款能够打通BurpSuite和Python之间任督二脉的插件,从此之后,你可以用你的python任意处理Http包了! 作用 执行指定python脚本,并将处理结果返回给BurpSuite。功能、UI介绍 这里有个注意事项:要用python2。 在Burpy PY file path:里面指定好你自己的python脚本,点击…...

    2024/5/2 8:38:47
  9. 监听器实判断多个信息

    程序可以实现一个监听器实判断多个信息 package window.listener;import java.awt.*; import java.awt.event.ActionEvent; import java.awt.event.ActionListener; import java.awt.event.WindowAdapter; import java.awt.event.WindowEvent;public class Demo02 {public stat…...

    2024/4/29 14:16:54
  10. 非科班学JAVA 第5天—流程控制语句

    在一场比赛中,只有弱势方才需要裁判,才寻求公正。真正的强者和有长远眼光的运动员,会做好自己应该做的事,并且专心做到更好。我们在比赛的时候,面对任何判罚,都不要波动,接受现实,用自己的方式回应对手。 说到流程控制,最先想到的肯定是ifelse,elseif,没错,这是计算机…...

    2024/4/29 14:16:50
  11. 当jdk1.8+springboot遇上时间差12小时

    1、背景:最近工作过程中发现了一个奇怪的现象,使用jdk1.8+springboot开发的jar,当部署到centos7上时,new date生成的时间会比系统时间慢了12小时,写入到mysql数据库也显示比系统时间慢12小时2、问题排查:因为数据源里配置了serverTimezone=GMT%2B8,因此mysql不背锅,而且…...

    2024/4/29 14:16:46
  12. Pandas库基本使用

    Pandas库基本使用Pandas库基本使用Pandas库基本使用 引子 Numpy 在向量化的数值计算中表现优异 但是在处理更灵活、复杂的数据任务: 如为数据添加标签、处理缺失值、分组和透视表等方面 Numpy显得力不从心 而基于Numpy构建的Pandas库,提供了使得数据分析变得更快更简单的高级…...

    2024/4/29 14:16:42
  13. Python笔记-进制转换

    文章目录前言一、函数介绍二、转二进制三、转八进制四、转十进制五、转十六进制 前言此文章不对进制转换的原理进行讲解,仅对进制转换的方法进行介绍 下面的文章使用的都是十进制数20对应的进制 二进制以0b开头,八进制以0o开头,十六进制以0x开头。一、函数介绍在使用对应的函…...

    2024/4/29 14:16:38
  14. git 拉取公司项目--菜鸟

    1.确定已经安装git(官网——https://git-scm.com/——)2.找到你想要保存数据的地方,新建文件夹。(推荐D盘或者其他,尽量不要用C盘)3.在你刚刚新建的文件中,右击会出现——git bash here——,然后点击它。(如果你没有安装成功,那么右击就没有这个啦)4.在出现的界面中输…...

    2024/4/29 14:16:34
  15. MyBatis学习(01)——快速入门

    MyBatis第一个程序思路流程:搭建环境—>导入Mybatis—>编写代码—>测试创建数据库CREATE DATABASE `mybatis`;USE `mybatis`;CREATE TABLE `user`(`id` INT(20) NOT NULL,`name` VARCHAR(20) DEFAULT NULL,`pwd` VARCHAR(20) DEFAULT NULL,PRIMARY KEY(`id`) )ENGINE…...

    2024/4/29 14:16:30
  16. Less 混合函数

    上一节我们学习了带参混合,当混合作为一个函数时是如何传入参数的。本节我们来学习混合函数,混合可以支持嵌套,接受参数和返回值。 混合范围 如果我们在一个混合中定义了变量,那么这个变量只能在这个混合或者引用了这个混合的区域中使用。但是有一个例外,就是如果调用者包…...

    2024/4/29 3:42:26
  17. VS Code常用快捷键

    VS Code常用快捷键 新建文件: Ctrl+N 文件之间切换: Ctrl+Tab 打开一个新的VS Code编辑器: Ctrl+Shift+N 关闭当前窗口: Ctrl+W 关闭当前的VS Code编辑器: Ctrl+Shift+W 切出一个新的编辑器窗口(最多3个): Ctrl+\ 切换左中右3个编辑器窗口的快捷键: Ctrl+1 Ct…...

    2024/4/29 14:16:23
  18. ubuntu-20.04.1安装Anaconda(图解)

    ubuntu-20.04.1安装Anaconda(图解)一、下载Anaconda的Linux版本官网地址:https://www.anaconda.com/products/individual如果下载失败可以使用清华的镜像,进行下载https://mirrors.tuna.tsinghua.edu.cn/anaconda/archive/?C=M&O=A二、对下载的安装包进行解压安装打开…...

    2024/4/29 14:16:18
  19. 台湾联阳IT6564方案|IT6564电路设计|替代IT6564设计DP转HDMI/VGA扩展坞方案

    台湾联阳IT6564是一种单芯片DP显示端口转HDMI和VGA转换器。IT6564结合DisplayPort接收机、HDMI发射机和三重DAC,通过转换功能支持DisplayPort输入和HDMI/VGA输出。内置DisplayPort接收器完全兼容DisplayPort 1.2a和HDCP 1.3/2.2规范。采用4通道HBR2(高比特率2)配置,DP接收器…...

    2024/4/29 14:16:14
  20. 【8月打卡~Leetcode每日一题】133. 克隆图(难度:中等)

    133. 克隆图对于一张图而言,它的深拷贝即构建一张与原图结构,值均一样的图,但是其中的节点不再是原来图节点的引用。因此,为了深拷贝出整张图,我们需要知道整张图的结构以及对应节点的值。 ①使用一个哈希表存储所有已被访问和克隆的节点。哈希表中的 key 是原始图中的节点…...

    2024/4/29 14:16:10

最新文章

  1. 基于JSP的人才公寓管理系统

    目录 背景 技术简介 系统简介 界面预览 背景 随着互联网的广泛推广和应用&#xff0c;人才公寓管理系统在网络技术的推动下迅速进步。该系统的设计初衷是满足住户的实际需求&#xff0c;通过深入了解住户的期望&#xff0c;开发出高度定制化的人才公寓管理系统。利用互联网…...

    2024/5/6 3:01:13
  2. 梯度消失和梯度爆炸的一些处理方法

    在这里是记录一下梯度消失或梯度爆炸的一些处理技巧。全当学习总结了如有错误还请留言&#xff0c;在此感激不尽。 权重和梯度的更新公式如下&#xff1a; w w − η ⋅ ∇ w w w - \eta \cdot \nabla w ww−η⋅∇w 个人通俗的理解梯度消失就是网络模型在反向求导的时候出…...

    2024/3/20 10:50:27
  3. CSS3 高级- 复杂选择器、内容生成、变形(transform)、过渡(transition)、动画(animation)

    文章目录 一、复杂选择器兄弟选择器:选择平级元素的唯一办法属性选择器:1、通用:基本用不着,太泛了2、自定义:4种伪类选择器:1、目标伪类:2、结构伪类:3、元素状态伪类:4、伪元素选择器:应用于文字,使网页看起来想杂志5、否定伪类:选择器:not([本选择器的条件]) /*…...

    2024/5/5 8:52:14
  4. 实景三维在数字乡村建设中的重要作用

    随着科技的飞速发展&#xff0c;数字乡村建设已成为推动乡村振兴、实现农村现代化的重要途径。实景三维技术作为数字乡村建设的重要支撑&#xff0c;正逐渐在各个领域发挥着不可或缺的作用。本文将从实景三维技术在数字乡村中的应用场景、优势及未来展望等方面进行探讨&#xf…...

    2024/5/5 8:32:06
  5. 416. 分割等和子集问题(动态规划)

    题目 题解 class Solution:def canPartition(self, nums: List[int]) -> bool:# badcaseif not nums:return True# 不能被2整除if sum(nums) % 2 ! 0:return False# 状态定义&#xff1a;dp[i][j]表示当背包容量为j&#xff0c;用前i个物品是否正好可以将背包填满&#xff…...

    2024/5/5 18:19:03
  6. 【Java】ExcelWriter自适应宽度工具类(支持中文)

    工具类 import org.apache.poi.ss.usermodel.Cell; import org.apache.poi.ss.usermodel.CellType; import org.apache.poi.ss.usermodel.Row; import org.apache.poi.ss.usermodel.Sheet;/*** Excel工具类** author xiaoming* date 2023/11/17 10:40*/ public class ExcelUti…...

    2024/5/5 12:22:20
  7. Spring cloud负载均衡@LoadBalanced LoadBalancerClient

    LoadBalance vs Ribbon 由于Spring cloud2020之后移除了Ribbon&#xff0c;直接使用Spring Cloud LoadBalancer作为客户端负载均衡组件&#xff0c;我们讨论Spring负载均衡以Spring Cloud2020之后版本为主&#xff0c;学习Spring Cloud LoadBalance&#xff0c;暂不讨论Ribbon…...

    2024/5/5 19:59:54
  8. TSINGSEE青犀AI智能分析+视频监控工业园区周界安全防范方案

    一、背景需求分析 在工业产业园、化工园或生产制造园区中&#xff0c;周界防范意义重大&#xff0c;对园区的安全起到重要的作用。常规的安防方式是采用人员巡查&#xff0c;人力投入成本大而且效率低。周界一旦被破坏或入侵&#xff0c;会影响园区人员和资产安全&#xff0c;…...

    2024/5/4 23:54:44
  9. VB.net WebBrowser网页元素抓取分析方法

    在用WebBrowser编程实现网页操作自动化时&#xff0c;常要分析网页Html&#xff0c;例如网页在加载数据时&#xff0c;常会显示“系统处理中&#xff0c;请稍候..”&#xff0c;我们需要在数据加载完成后才能继续下一步操作&#xff0c;如何抓取这个信息的网页html元素变化&…...

    2024/5/5 15:25:47
  10. 【Objective-C】Objective-C汇总

    方法定义 参考&#xff1a;https://www.yiibai.com/objective_c/objective_c_functions.html Objective-C编程语言中方法定义的一般形式如下 - (return_type) method_name:( argumentType1 )argumentName1 joiningArgument2:( argumentType2 )argumentName2 ... joiningArgu…...

    2024/5/4 23:54:49
  11. 【洛谷算法题】P5713-洛谷团队系统【入门2分支结构】

    &#x1f468;‍&#x1f4bb;博客主页&#xff1a;花无缺 欢迎 点赞&#x1f44d; 收藏⭐ 留言&#x1f4dd; 加关注✅! 本文由 花无缺 原创 收录于专栏 【洛谷算法题】 文章目录 【洛谷算法题】P5713-洛谷团队系统【入门2分支结构】&#x1f30f;题目描述&#x1f30f;输入格…...

    2024/5/4 23:54:44
  12. 【ES6.0】- 扩展运算符(...)

    【ES6.0】- 扩展运算符... 文章目录 【ES6.0】- 扩展运算符...一、概述二、拷贝数组对象三、合并操作四、参数传递五、数组去重六、字符串转字符数组七、NodeList转数组八、解构变量九、打印日志十、总结 一、概述 **扩展运算符(...)**允许一个表达式在期望多个参数&#xff0…...

    2024/5/6 1:08:53
  13. 摩根看好的前智能硬件头部品牌双11交易数据极度异常!——是模式创新还是饮鸩止渴?

    文 | 螳螂观察 作者 | 李燃 双11狂欢已落下帷幕&#xff0c;各大品牌纷纷晒出优异的成绩单&#xff0c;摩根士丹利投资的智能硬件头部品牌凯迪仕也不例外。然而有爆料称&#xff0c;在自媒体平台发布霸榜各大榜单喜讯的凯迪仕智能锁&#xff0c;多个平台数据都表现出极度异常…...

    2024/5/5 18:50:00
  14. Go语言常用命令详解(二)

    文章目录 前言常用命令go bug示例参数说明 go doc示例参数说明 go env示例 go fix示例 go fmt示例 go generate示例 总结写在最后 前言 接着上一篇继续介绍Go语言的常用命令 常用命令 以下是一些常用的Go命令&#xff0c;这些命令可以帮助您在Go开发中进行编译、测试、运行和…...

    2024/5/6 0:27:44
  15. 用欧拉路径判断图同构推出reverse合法性:1116T4

    http://cplusoj.com/d/senior/p/SS231116D 假设我们要把 a a a 变成 b b b&#xff0c;我们在 a i a_i ai​ 和 a i 1 a_{i1} ai1​ 之间连边&#xff0c; b b b 同理&#xff0c;则 a a a 能变成 b b b 的充要条件是两图 A , B A,B A,B 同构。 必要性显然&#xff0…...

    2024/5/5 2:25:33
  16. 【NGINX--1】基础知识

    1、在 Debian/Ubuntu 上安装 NGINX 在 Debian 或 Ubuntu 机器上安装 NGINX 开源版。 更新已配置源的软件包信息&#xff0c;并安装一些有助于配置官方 NGINX 软件包仓库的软件包&#xff1a; apt-get update apt install -y curl gnupg2 ca-certificates lsb-release debian-…...

    2024/5/4 21:24:42
  17. Hive默认分割符、存储格式与数据压缩

    目录 1、Hive默认分割符2、Hive存储格式3、Hive数据压缩 1、Hive默认分割符 Hive创建表时指定的行受限&#xff08;ROW FORMAT&#xff09;配置标准HQL为&#xff1a; ... ROW FORMAT DELIMITED FIELDS TERMINATED BY \u0001 COLLECTION ITEMS TERMINATED BY , MAP KEYS TERMI…...

    2024/5/5 13:14:22
  18. 【论文阅读】MAG:一种用于航天器遥测数据中有效异常检测的新方法

    文章目录 摘要1 引言2 问题描述3 拟议框架4 所提出方法的细节A.数据预处理B.变量相关分析C.MAG模型D.异常分数 5 实验A.数据集和性能指标B.实验设置与平台C.结果和比较 6 结论 摘要 异常检测是保证航天器稳定性的关键。在航天器运行过程中&#xff0c;传感器和控制器产生大量周…...

    2024/5/4 13:16:06
  19. --max-old-space-size=8192报错

    vue项目运行时&#xff0c;如果经常运行慢&#xff0c;崩溃停止服务&#xff0c;报如下错误 FATAL ERROR: CALL_AND_RETRY_LAST Allocation failed - JavaScript heap out of memory 因为在 Node 中&#xff0c;通过JavaScript使用内存时只能使用部分内存&#xff08;64位系统&…...

    2024/5/5 17:03:52
  20. 基于深度学习的恶意软件检测

    恶意软件是指恶意软件犯罪者用来感染个人计算机或整个组织的网络的软件。 它利用目标系统漏洞&#xff0c;例如可以被劫持的合法软件&#xff08;例如浏览器或 Web 应用程序插件&#xff09;中的错误。 恶意软件渗透可能会造成灾难性的后果&#xff0c;包括数据被盗、勒索或网…...

    2024/5/5 21:10:50
  21. JS原型对象prototype

    让我简单的为大家介绍一下原型对象prototype吧&#xff01; 使用原型实现方法共享 1.构造函数通过原型分配的函数是所有对象所 共享的。 2.JavaScript 规定&#xff0c;每一个构造函数都有一个 prototype 属性&#xff0c;指向另一个对象&#xff0c;所以我们也称为原型对象…...

    2024/5/5 3:37:58
  22. C++中只能有一个实例的单例类

    C中只能有一个实例的单例类 前面讨论的 President 类很不错&#xff0c;但存在一个缺陷&#xff1a;无法禁止通过实例化多个对象来创建多名总统&#xff1a; President One, Two, Three; 由于复制构造函数是私有的&#xff0c;其中每个对象都是不可复制的&#xff0c;但您的目…...

    2024/5/4 23:54:30
  23. python django 小程序图书借阅源码

    开发工具&#xff1a; PyCharm&#xff0c;mysql5.7&#xff0c;微信开发者工具 技术说明&#xff1a; python django html 小程序 功能介绍&#xff1a; 用户端&#xff1a; 登录注册&#xff08;含授权登录&#xff09; 首页显示搜索图书&#xff0c;轮播图&#xff0…...

    2024/5/5 17:03:21
  24. 电子学会C/C++编程等级考试2022年03月(一级)真题解析

    C/C++等级考试(1~8级)全部真题・点这里 第1题:双精度浮点数的输入输出 输入一个双精度浮点数,保留8位小数,输出这个浮点数。 时间限制:1000 内存限制:65536输入 只有一行,一个双精度浮点数。输出 一行,保留8位小数的浮点数。样例输入 3.1415926535798932样例输出 3.1…...

    2024/5/5 15:25:31
  25. 配置失败还原请勿关闭计算机,电脑开机屏幕上面显示,配置失败还原更改 请勿关闭计算机 开不了机 这个问题怎么办...

    解析如下&#xff1a;1、长按电脑电源键直至关机&#xff0c;然后再按一次电源健重启电脑&#xff0c;按F8健进入安全模式2、安全模式下进入Windows系统桌面后&#xff0c;按住“winR”打开运行窗口&#xff0c;输入“services.msc”打开服务设置3、在服务界面&#xff0c;选中…...

    2022/11/19 21:17:18
  26. 错误使用 reshape要执行 RESHAPE,请勿更改元素数目。

    %读入6幅图像&#xff08;每一幅图像的大小是564*564&#xff09; f1 imread(WashingtonDC_Band1_564.tif); subplot(3,2,1),imshow(f1); f2 imread(WashingtonDC_Band2_564.tif); subplot(3,2,2),imshow(f2); f3 imread(WashingtonDC_Band3_564.tif); subplot(3,2,3),imsho…...

    2022/11/19 21:17:16
  27. 配置 已完成 请勿关闭计算机,win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机...

    win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机”问题的解决方法在win7系统关机时如果有升级系统的或者其他需要会直接进入一个 等待界面&#xff0c;在等待界面中我们需要等待操作结束才能关机&#xff0c;虽然这比较麻烦&#xff0c;但是对系统进行配置和升级…...

    2022/11/19 21:17:15
  28. 台式电脑显示配置100%请勿关闭计算机,“准备配置windows 请勿关闭计算机”的解决方法...

    有不少用户在重装Win7系统或更新系统后会遇到“准备配置windows&#xff0c;请勿关闭计算机”的提示&#xff0c;要过很久才能进入系统&#xff0c;有的用户甚至几个小时也无法进入&#xff0c;下面就教大家这个问题的解决方法。第一种方法&#xff1a;我们首先在左下角的“开始…...

    2022/11/19 21:17:14
  29. win7 正在配置 请勿关闭计算机,怎么办Win7开机显示正在配置Windows Update请勿关机...

    置信有很多用户都跟小编一样遇到过这样的问题&#xff0c;电脑时发现开机屏幕显现“正在配置Windows Update&#xff0c;请勿关机”(如下图所示)&#xff0c;而且还需求等大约5分钟才干进入系统。这是怎样回事呢&#xff1f;一切都是正常操作的&#xff0c;为什么开时机呈现“正…...

    2022/11/19 21:17:13
  30. 准备配置windows 请勿关闭计算机 蓝屏,Win7开机总是出现提示“配置Windows请勿关机”...

    Win7系统开机启动时总是出现“配置Windows请勿关机”的提示&#xff0c;没过几秒后电脑自动重启&#xff0c;每次开机都这样无法进入系统&#xff0c;此时碰到这种现象的用户就可以使用以下5种方法解决问题。方法一&#xff1a;开机按下F8&#xff0c;在出现的Windows高级启动选…...

    2022/11/19 21:17:12
  31. 准备windows请勿关闭计算机要多久,windows10系统提示正在准备windows请勿关闭计算机怎么办...

    有不少windows10系统用户反映说碰到这样一个情况&#xff0c;就是电脑提示正在准备windows请勿关闭计算机&#xff0c;碰到这样的问题该怎么解决呢&#xff0c;现在小编就给大家分享一下windows10系统提示正在准备windows请勿关闭计算机的具体第一种方法&#xff1a;1、2、依次…...

    2022/11/19 21:17:11
  32. 配置 已完成 请勿关闭计算机,win7系统关机提示“配置Windows Update已完成30%请勿关闭计算机”的解决方法...

    今天和大家分享一下win7系统重装了Win7旗舰版系统后&#xff0c;每次关机的时候桌面上都会显示一个“配置Windows Update的界面&#xff0c;提示请勿关闭计算机”&#xff0c;每次停留好几分钟才能正常关机&#xff0c;导致什么情况引起的呢&#xff1f;出现配置Windows Update…...

    2022/11/19 21:17:10
  33. 电脑桌面一直是清理请关闭计算机,windows7一直卡在清理 请勿关闭计算机-win7清理请勿关机,win7配置更新35%不动...

    只能是等着&#xff0c;别无他法。说是卡着如果你看硬盘灯应该在读写。如果从 Win 10 无法正常回滚&#xff0c;只能是考虑备份数据后重装系统了。解决来方案一&#xff1a;管理员运行cmd&#xff1a;net stop WuAuServcd %windir%ren SoftwareDistribution SDoldnet start WuA…...

    2022/11/19 21:17:09
  34. 计算机配置更新不起,电脑提示“配置Windows Update请勿关闭计算机”怎么办?

    原标题&#xff1a;电脑提示“配置Windows Update请勿关闭计算机”怎么办&#xff1f;win7系统中在开机与关闭的时候总是显示“配置windows update请勿关闭计算机”相信有不少朋友都曾遇到过一次两次还能忍但经常遇到就叫人感到心烦了遇到这种问题怎么办呢&#xff1f;一般的方…...

    2022/11/19 21:17:08
  35. 计算机正在配置无法关机,关机提示 windows7 正在配置windows 请勿关闭计算机 ,然后等了一晚上也没有关掉。现在电脑无法正常关机...

    关机提示 windows7 正在配置windows 请勿关闭计算机 &#xff0c;然后等了一晚上也没有关掉。现在电脑无法正常关机以下文字资料是由(历史新知网www.lishixinzhi.com)小编为大家搜集整理后发布的内容&#xff0c;让我们赶快一起来看一下吧&#xff01;关机提示 windows7 正在配…...

    2022/11/19 21:17:05
  36. 钉钉提示请勿通过开发者调试模式_钉钉请勿通过开发者调试模式是真的吗好不好用...

    钉钉请勿通过开发者调试模式是真的吗好不好用 更新时间:2020-04-20 22:24:19 浏览次数:729次 区域: 南阳 > 卧龙 列举网提醒您:为保障您的权益,请不要提前支付任何费用! 虚拟位置外设器!!轨迹模拟&虚拟位置外设神器 专业用于:钉钉,外勤365,红圈通,企业微信和…...

    2022/11/19 21:17:05
  37. 配置失败还原请勿关闭计算机怎么办,win7系统出现“配置windows update失败 还原更改 请勿关闭计算机”,长时间没反应,无法进入系统的解决方案...

    前几天班里有位学生电脑(windows 7系统)出问题了&#xff0c;具体表现是开机时一直停留在“配置windows update失败 还原更改 请勿关闭计算机”这个界面&#xff0c;长时间没反应&#xff0c;无法进入系统。这个问题原来帮其他同学也解决过&#xff0c;网上搜了不少资料&#x…...

    2022/11/19 21:17:04
  38. 一个电脑无法关闭计算机你应该怎么办,电脑显示“清理请勿关闭计算机”怎么办?...

    本文为你提供了3个有效解决电脑显示“清理请勿关闭计算机”问题的方法&#xff0c;并在最后教给你1种保护系统安全的好方法&#xff0c;一起来看看&#xff01;电脑出现“清理请勿关闭计算机”在Windows 7(SP1)和Windows Server 2008 R2 SP1中&#xff0c;添加了1个新功能在“磁…...

    2022/11/19 21:17:03
  39. 请勿关闭计算机还原更改要多久,电脑显示:配置windows更新失败,正在还原更改,请勿关闭计算机怎么办...

    许多用户在长期不使用电脑的时候&#xff0c;开启电脑发现电脑显示&#xff1a;配置windows更新失败&#xff0c;正在还原更改&#xff0c;请勿关闭计算机。。.这要怎么办呢&#xff1f;下面小编就带着大家一起看看吧&#xff01;如果能够正常进入系统&#xff0c;建议您暂时移…...

    2022/11/19 21:17:02
  40. 还原更改请勿关闭计算机 要多久,配置windows update失败 还原更改 请勿关闭计算机,电脑开机后一直显示以...

    配置windows update失败 还原更改 请勿关闭计算机&#xff0c;电脑开机后一直显示以以下文字资料是由(历史新知网www.lishixinzhi.com)小编为大家搜集整理后发布的内容&#xff0c;让我们赶快一起来看一下吧&#xff01;配置windows update失败 还原更改 请勿关闭计算机&#x…...

    2022/11/19 21:17:01
  41. 电脑配置中请勿关闭计算机怎么办,准备配置windows请勿关闭计算机一直显示怎么办【图解】...

    不知道大家有没有遇到过这样的一个问题&#xff0c;就是我们的win7系统在关机的时候&#xff0c;总是喜欢显示“准备配置windows&#xff0c;请勿关机”这样的一个页面&#xff0c;没有什么大碍&#xff0c;但是如果一直等着的话就要两个小时甚至更久都关不了机&#xff0c;非常…...

    2022/11/19 21:17:00
  42. 正在准备配置请勿关闭计算机,正在准备配置windows请勿关闭计算机时间长了解决教程...

    当电脑出现正在准备配置windows请勿关闭计算机时&#xff0c;一般是您正对windows进行升级&#xff0c;但是这个要是长时间没有反应&#xff0c;我们不能再傻等下去了。可能是电脑出了别的问题了&#xff0c;来看看教程的说法。正在准备配置windows请勿关闭计算机时间长了方法一…...

    2022/11/19 21:16:59
  43. 配置失败还原请勿关闭计算机,配置Windows Update失败,还原更改请勿关闭计算机...

    我们使用电脑的过程中有时会遇到这种情况&#xff0c;当我们打开电脑之后&#xff0c;发现一直停留在一个界面&#xff1a;“配置Windows Update失败&#xff0c;还原更改请勿关闭计算机”&#xff0c;等了许久还是无法进入系统。如果我们遇到此类问题应该如何解决呢&#xff0…...

    2022/11/19 21:16:58
  44. 如何在iPhone上关闭“请勿打扰”

    Apple’s “Do Not Disturb While Driving” is a potentially lifesaving iPhone feature, but it doesn’t always turn on automatically at the appropriate time. For example, you might be a passenger in a moving car, but your iPhone may think you’re the one dri…...

    2022/11/19 21:16:57