zoukankan      html  css  js  c++  java
  • 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();
        }
        
        
    }

    运行查看结果:

    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>
    

      

  • 相关阅读:
    Supervisord管理进程实践
    centos7优化启动项,关闭一些不必要开启的服务
    centos彻底删除文件夹、文件命令(centos 新建、删除、移动、复制等命令)讲解
    CentOS 7 vi编辑命令
    C# 23种设计模式汇总
    设计模式——速记口诀
    CentOS 7.x设置自定义开机启动,添加自定义系统服务
    T-SQL 之 事务
    T-SQL 之 触发器
    T-SQL 之 表变量和临时表
  • 原文地址:https://www.cnblogs.com/toov5/p/9906640.html
Copyright © 2011-2022 走看看