Spring Boot2.0之整合Zookeeper集群

迷南。 2022-01-28 11:11 379阅读 0赞

# [Spring Boot2.0之 整合Zookeeper集群][Spring Boot2.0_ _Zookeeper] #

普通的连接：

pom：

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
      <groupId>com.toov5.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>0.0.1-SNAPSHOT</version>
    	<dependencies>
    		<dependency>
    			<groupId>com.101tec</groupId>
    			<artifactId>zkclient</artifactId>
    			<version>0.10</version>
    			<exclusions>
    				<exclusion>
    					<artifactId>slf4j-api</artifactId>
    					<groupId>org.slf4j</groupId>
    				</exclusion>
    				<exclusion>
    					<artifactId>log4j</artifactId>
    					<groupId>log4j</groupId>
    				</exclusion>
    				<exclusion>
    					<artifactId>slf4j-log4j12</artifactId>
    					<groupId>org.slf4j</groupId>
    				</exclusion>
    			</exclusions>
    		</dependency>
    	</dependencies>
    </project>

代码：

package com.toov5.controller;
    
    import org.I0Itec.zkclient.ZkClient;
    
    public class zkTest {
    
          public static void main(String[] args) {
            String connection = "192.168.91.1:2181,192.168.91.3:2181,192.168.91.4:2181";
            ZkClient zkClient = new ZkClient(connection);
            zkClient.createPersistent("/toov5_01");
            zkClient.close();
        }
        
        
    }

运行查看结果：

![1179709-20181104231815077-950514229.png][]

SpringBoot整合：

配置文件抽取到 yml中

connection:192.168.91.1:2181,192.168.91.3:2181,192.168.91.4:2181

整合：

package com.toov5.service;
    
    import org.I0Itec.zkclient.ZkClient;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.stereotype.Service;
    
    @Service
    public class zkService {
       @Value("{connection}")
       private String connection;
        private ZkClient zkClient = new ZkClient(connection);
       
       public String creteNode(String path){   
           try {
               zkClient.createPersistent(path); //没返回结果 所以用try catch 方式解决哦
               return "ok";
        } catch (Exception e) {
               return "fail";
        }  
       }
         
        
    }

pom.xml

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
      <groupId>com.toov5.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      <parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.0.0.RELEASE</version>
    	</parent>
    	<dependencies>
    		<dependency>
    			<groupId>com.101tec</groupId>
    			<artifactId>zkclient</artifactId>
    			<version>0.10</version>
    			<exclusions>
    				<exclusion>
    					<artifactId>slf4j-api</artifactId>
    					<groupId>org.slf4j</groupId>
    				</exclusion>
    				<exclusion>
    					<artifactId>log4j</artifactId>
    					<groupId>log4j</groupId>
    				</exclusion>
    				<exclusion>
    					<artifactId>slf4j-log4j12</artifactId>
    					<groupId>org.slf4j</groupId>
    				</exclusion>
    			</exclusions>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    	</dependencies>
    </project>

[Spring Boot2.0_ _Zookeeper]: https://www.cnblogs.com/toov5/p/9906640.html
[1179709-20181104231815077-950514229.png]: /images/20220128/d751e6f55c79410fa7b08282ecb7e63b.png