可参照该博客：ZK可视化Web工具(zkui)安装与搭建(zookeeper)

SpringCloud与Zookeeper完美结合,搭建简易的服务注册中心，依赖的三脚架jar包如下            

<dependency>
  <groupId>org.springframework.cloud</groupId>
  <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  <version>2.1.2.RELEASE</version>
</dependency>
<dependency>
  <groupId>org.apache.zookeeper</groupId>
  <artifactId>zookeeper</artifactId>
  <version>3.4.10</version>
  <exclusions>
    <exclusion>
      <groupId>org.slf4j</groupId>
      <artifactId>slf4j-log4j12</artifactId>
    </exclusion>
    <exclusion>
      <groupId>log4j</groupId>
      <artifactId>log4j</artifactId>
    </exclusion>
  </exclusions>
</dependency>

三脚架整合SpringCloud以Zookeeper作为服务注册中心。

服务提供者的pom.xml配置如下:

======================================pom.xml=========================

<?xml version="1.0" encoding="UTF-8"?>

<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>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.2.RELEASE</version>
    <relativePath/>
  </parent>

  <groupId>com.dubbo.zookeeper.register</groupId>
  <artifactId>SSO-SpringCloud-Zookeeper</artifactId>
  <version>1.0-SNAPSHOT</version>

  <name>SSO-SpringCloud-Zookeeper</name>

  <!-- 设定主仓库，按设定顺序进行查找。 -->
  <repositories>
    <repository>
      <id>repos</id>
      <name>Repository</name>
      <url>http://maven.aliyun.com/nexus/content/groups/public</url>
    </repository>
    <repository>
      <id>central</id>
      <name>Maven Repository Switchboard</name>
      <layout>default</layout>
      <url>http://repo1.maven.org/maven2</url>
      <snapshots>
        <enabled>false</enabled>
      </snapshots>
    </repository>
  </repositories>
  <!-- 设定插件仓库 -->
  <pluginRepositories>
    <pluginRepository>
      <id>repos</id>
      <name>Repository</name>
      <url>http://maven.aliyun.com/nexus/content/groups/public</url>
    </pluginRepository>
  </pluginRepositories>

  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
  </properties>

  <dependencies>
  <dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
  </dependency>
    <!--springcloud使用zk做服务注册发现用的-->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
      <version>2.1.2.RELEASE</version>
    </dependency>
    <!--连接zk服务的客户端包；然后在程序启动入口出增加注解 @EnableDiscoveryClient-->
    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.10</version>
      <exclusions>
        <exclusion>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
        <exclusion>
          <groupId>log4j</groupId>
          <artifactId>log4j</artifactId>
        </exclusion>
      </exclusions>
    </dependency>
  </dependencies>

  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>

</project>

相关的*.properties配置文件如下：

===============================application.properties=============

spring.profiles.active=dev

===============================application-dev.properties===========

##  配置引用名称,会在/zk-server下生成该名称的节点
spring.application.name=spring-cloud-zookeeper-provider
##  配置服务端口
server.port=8888
## 关闭安全控制
management.security.enabled=false
## connect-string：连接zk服务的连接串
spring.cloud.zookeeper.connect-string=centoshadoop1:2181,centoshadoop2:2181,centoshadoop3:2181
# register: 是否启动服务注册
spring.cloud.zookeeper.discovery.enabled=true
spring.cloud.zookeeper.discovery.register=true

instance-id: zk唯一id的标识,会在/zk-server/spring-cloud-zookeeper-provider/下面生成该节点
spring.cloud.zookeeper.discovery.instance-id=zk-00001
root: zk根节点名称，默认/services 
spring.cloud.zookeeper.discovery.root=/zk-server-provider

服务业务逻辑:

package com.dubbo.zookeeper.register.controller;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;

import java.util.ArrayList;
import java.util.List;
import java.util.Random;

@RestController
public class ZKUserController {
    @Value("${server.port}")
    private int port;
    @Value("${spring.application.name}")
    private String applicationName;

    @GetMapping("/list")
    public List<Zkuser> findZkUser(){
        List<Zkuser> resultList =  new ArrayList<>();
        resultList.add(new Zkuser("zk-server-"+applicationName+"-"+new Random().nextInt(10000) ,new Random().nextInt(120),port));
        resultList.add(new Zkuser("zk-server-"+applicationName+"-"+new Random().nextInt(10000) ,new Random().nextInt(120),port));
        resultList.add(new Zkuser("zk-server-"+applicationName+"-"+new Random().nextInt(10000) ,new Random().nextInt(120),port));
        resultList.add(new Zkuser("zk-server-"+applicationName+"-"+new Random().nextInt(10000) ,new Random().nextInt(120),port));
        return resultList;
    }
}

引用的辅助实体类:
 

package com.dubbo.zookeeper.register.controller;

import java.io.Serializable;

public class Zkuser implements Serializable {
    private String name;
    private int age;
    private int port;

    public Zkuser(String name, int age, int port) {
        this.name = name;
        this.age = age;
        this.port = port;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }

    public int getPort() {
        return port;
    }

    public void setPort(int port) {
        this.port = port;
    }

    @Override
    public String toString() {
        return "Zkuser{" +
                "name='" + name + '\'' +
                ", age=" + age +
                ",server port=" + port +
                '}';
    }
}

服务提供者启动类：

package com.dubbo.zookeeper.register;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
/**
 *
 *zookeeper配置注册中心
 */
@SpringBootApplication
public class SpringCloudZookeeperApplication {
    public static void main( String[] args ) {
        SpringApplication.run(SpringCloudZookeeperApplication.class,args);
    }
}

启动服务提供者:
访问:http://localhost:8888/list  ,返回业务数据:

[
  {"name":"zk-server-spring-cloud-zookeeper-server-5701","age":32,"port":8888},
  {"name":"zk-server-spring-cloud-zookeeper-server-5338","age":96,"port":8888},
  {"name":"zk-server-spring-cloud-zookeeper-server-5520","age":65,"port":8888},
  {"name":"zk-server-spring-cloud-zookeeper-server-7225","age":65,"port":8888}
]

=================服务消费者相关配置========================================

pom.xml配置

<?xml version="1.0" encoding="UTF-8"?>

<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>
  <parent>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-parent</artifactId>
    <version>2.1.2.RELEASE</version>
    <relativePath/>
  </parent>
  <groupId>com.zookeeper.dubbo.register.consumer</groupId>
  <artifactId>SSO-SpringCloud-Zookeeper-Consumer</artifactId>
  <version>1.0-SNAPSHOT</version>

  <name>SSO-SpringCloud-Zookeeper-Consumer</name>
  <!-- 设定主仓库，按设定顺序进行查找。 -->
  <repositories>
    <repository>
      <id>repos</id>
      <name>Repository</name>
      <url>http://maven.aliyun.com/nexus/content/groups/public</url>
    </repository>
    <repository>
      <id>central</id>
      <name>Maven Repository Switchboard</name>
      <layout>default</layout>
      <url>http://repo1.maven.org/maven2</url>
      <snapshots>
        <enabled>false</enabled>
      </snapshots>
    </repository>
  </repositories>
  <!-- 设定插件仓库 -->
  <pluginRepositories>
    <pluginRepository>
      <id>repos</id>
      <name>Repository</name>
      <url>http://maven.aliyun.com/nexus/content/groups/public</url>
    </pluginRepository>
  </pluginRepositories>
  <properties>
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    <maven.compiler.source>1.8</maven.compiler.source>
    <maven.compiler.target>1.8</maven.compiler.target>
    <spring-cloud.version>Finchley.SR2</spring-cloud.version>
  </properties>

  <dependencies>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-feign</artifactId>
      <version>1.4.6.RELEASE</version>
    </dependency>
    <dependency>
      <groupId>org.springframework.boot</groupId>
      <artifactId>spring-boot-starter-web</artifactId>
    </dependency>
    <!--springcloud使用zk做服务注册发现用的-->
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
      <version>2.1.2.RELEASE</version>
    </dependency>
    <!--连接zk服务的客户端包；然后在程序启动入口出增加注解 @EnableDiscoveryClient-->
    <dependency>
      <groupId>org.apache.zookeeper</groupId>
      <artifactId>zookeeper</artifactId>
      <version>3.4.10</version>
      <exclusions>
        <exclusion>
          <groupId>org.slf4j</groupId>
          <artifactId>slf4j-log4j12</artifactId>
        </exclusion>
        <exclusion>
          <groupId>log4j</groupId>
          <artifactId>log4j</artifactId>
        </exclusion>
      </exclusions>
    </dependency>
  </dependencies>

  <dependencyManagement>
    <dependencies>
      <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-dependencies</artifactId>
        <version>${spring-cloud.version}</version>
        <type>pom</type>
        <scope>import</scope>
      </dependency>
    </dependencies>
  </dependencyManagement>

  <build>
    <plugins>
      <plugin>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-maven-plugin</artifactId>
      </plugin>
    </plugins>
  </build>
</project>

application-dev.properties 配置如下：

##  配置引用名称,会在/zk-server下生成该名称的节点
spring.application.name=spring-cloud-zookeeper-consumer
##  配置服务端口
server.port=7777
## 关闭安全控制
management.security.enabled=false
## connect-string：连接zk服务的连接串
spring.cloud.zookeeper.connect-string=centoshadoop1:2181,centoshadoop2:2181,centoshadoop3:2181
# register: 是否启动服务注册
spring.cloud.zookeeper.discovery.enabled=true
spring.cloud.zookeeper.discovery.register=true
# instance-id: zk唯一id的标识,会在/zk-server/spring-cloud-zookeeper-prover/下面生成该节点
spring.cloud.zookeeper.discovery.instance-id=zk-00001
# # root: zk根节点名称，默认/services,必須與服務提供者的相同 ,否則報錯com.netflix.client.ClientException: Load 
# # balancer does not have available server for client: spring-cloud-zookeeper-provider
spring.cloud.zookeeper.discovery.root=/zk-server-provider

消费者代理接口
package com.zookeeper.dubbo.register.consumer.service;
import com.zookeeper.dubbo.register.consumer.domain.Zkuser;
import org.springframework.cloud.openfeign.FeignClient;
import org.springframework.stereotype.Service;
import org.springframework.web.bind.annotation.GetMapping;
import java.util.List;
@Service
@FeignClient("spring-cloud-zookeeper-provider") // 该值为服务提供者的应用名称
public interface ZkUserService {
    @GetMapping("/list")
    List<Zkuser> getList();
}

图为服务提供者，在zookeeper注册中心注册的服务提供者名称 spring-cloud-zookeeper-provider

controler类

package com.zookeeper.dubbo.register.consumer.controller;

import com.zookeeper.dubbo.register.consumer.domain.Zkuser;
import com.zookeeper.dubbo.register.consumer.service.ZkUserService;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;
@RestController
public class ZkUserController {
    @Autowired
    private ZkUserService zkUserService;

    @GetMapping("/consumerList")
    public List<Zkuser> getList() {
        return zkUserService.getList();
    }
}

启动类：

package com.zookeeper.dubbo.register.consumer;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.openfeign.EnableFeignClients;

/**
 * zookeeper註冊中心消費者
 *
 */
@SpringBootApplication
@EnableDiscoveryClient  // 開啟服務方向機制
@EnableFeignClients
public class ZkConsumerApplication {
    public static void main( String[] args ) {
        SpringApplication.run(ZkConsumerApplication.class,args);
    }
}

Zkuser类同提供者

访问路径：http://localhost:7777/consumerList

[
  {"name":"zk-server-spring-cloud-zookeeper-provider-5421","age":85,"port":8888},
  {"name":"zk-server-spring-cloud-zookeeper-provider-8779","age":13,"port":8888},
  {"name":"zk-server-spring-cloud-zookeeper-provider-6341","age":63,"port":8888},
  {"name":"zk-server-spring-cloud-zookeeper-provider-903","age":16,"port":8888}
]

可以在Zookeeper WebUI中看到已经注册的服务  zk-server-provider

完美SpringCloud以Zookeeper为注册中心整合成功！！

尽请关注下一篇:SpringCloud与Consul(Consul为注册中心)....

SpringCloud与Consul整合

 

Logo
向您推荐>>Eolink开发者社区

权威｜前沿｜技术｜干货｜国内首个API全生命周期开发者社区

更多推荐

沃云统一开发平台介绍

沃云集成平台研发平台介绍1.平台优势2.平台原理3.研发平台使用方法4.遇到的问题5.现阶段实现的功能6.后续需要补充的功能和优化内容研发平台介绍1.平台优势解决孤岛式应用，实现能力共享；现有系统框架过于复杂，跨系统业务处理成本居高不下，协同服务共享，降低运维成本；提高项目应用资源监控能力，改善资源利用率；业务微服务化，快速发布、快速部署，快速响应业务需求变化；沃云平台不仅提供了自动化的、可快速部

avatar 云原生

(20200916 Solved)docker-compose up创建容器自动退出

问题描述如题，创建容器后自动退出了。并且docker start container无效解决方案原因是缺失了控制终端的配置，需要在docker-compose.yml中增加tty:true ，有时候这样也不行，需要再增加一个command:/bin/bash，命令不一定是这个，需要是一个不会退出的命令，然后用-d后台启动容器。Referencesdocker-compose启动容器后自动退出...

avatar 云原生

基于docker的test-containers环境百宝箱

笔者语录： 我开了个公众号【Java你我他】，欢迎大家关注。  在很多时候，程序猿们更关注代码本身，而不愿意把时间花费在环境搭建上，这也是Docker变得越来越受欢迎的原因之一。test-containe是Docker生态圈中的一颗新星，其 主要针对测试领域、背靠Docker实现环境百宝箱功能。  test-containers： 你要的环境，我都有~  假设我们现在需要一个redis-clust

avatar 云原生