springboot 连接zookeeper ，添加节点

阳光穿透心脏的1/2处 2021-12-14 21:59 381阅读 0赞

pom.xml  依赖

<dependency>
    	       <groupId>org.apache.zookeeper</groupId>
    			<artifactId>zookeeper</artifactId>
    			<version>3.4.14</version>
    		</dependency>

代码： countdownlatch  防止 还没连接就操作节点。 注释了信号量等待就会报错， 因为zk创建连接是一个子线程， 创建节点是在主线程。

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Rhbmdfamlhbl9kb25n_size_16_color_FFFFFF_t_70][]

private static final String address = "192.168.xxx.xxx:2181";
    		private static final int session_timeout = 5000;
    		private static final CountDownLatch cout = new CountDownLatch(1);
    	
    		public static void main(String[] args) throws IOException, KeeperException, InterruptedException {
    				ZooKeeper zk = new ZooKeeper(address, session_timeout, new Watcher() {
    					// 事件通知
    					@Override
    					public void process(WatchedEvent event) 
    					{
    						// 事件状态
    						KeeperState state = event.getState();
    						// 连接状态
    						if (KeeperState.SyncConnected == state) 
    						{
    							EventType type = event.getType();
    							// 事件类型
    							if (EventType.None == type)
    							{
    								cout.countDown();
    								System.out.println("--------zk开始连接.");
    							}
    						}
    					}
    				});
    				
    				cout.await();
    				//创建节点
    				String create = zk.create("/tangjiandong_tang", "dong".getBytes(), Ids.OPEN_ACL_UNSAFE, CreateMode.PERSISTENT);
    				System.out.println("-------创建节点： " + create);
    				zk.close();
    		}

可视化工具查看zk节点：节点已经创建成功。

下载地址; [https://issues.apache.org/jira/secure/attachment/12436620/][https_issues.apache.org_jira_secure_attachment_12436620]*ZooInspector*.zip；

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Rhbmdfamlhbl9kb25n_size_16_color_FFFFFF_t_70 1][]

启动可视化工具及 开始连接zookeeper

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Rhbmdfamlhbl9kb25n_size_16_color_FFFFFF_t_70 2][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Rhbmdfamlhbl9kb25n_size_16_color_FFFFFF_t_70]: /images/20211214/58c714f69b9a4a17bfc02b740111bd4d.png
[https_issues.apache.org_jira_secure_attachment_12436620]: https://issues.apache.org/jira/secure/attachment/12436620/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Rhbmdfamlhbl9kb25n_size_16_color_FFFFFF_t_70 1]: /images/20211214/1d291cfcf4a744e29dd9c54d6c309b34.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3Rhbmdfamlhbl9kb25n_size_16_color_FFFFFF_t_70 2]: /images/20211214/674fb1315d3141d5bd6b92b7028b9e6b.png