Spring Cloud学习--Spring Cloud Zookeeper 服务注册与发现

布满荆棘的人生 2022-05-26 10:57 294阅读 0赞 
  1.     之前几篇博客我们已经介绍过使用Eureka和Consul作为注册中心的实现及代码示例，这边博客我们学习了解一下Spring Cloud给我们提供的用Zookeeper作为注册中心的实现机制。

Zookeeper

  1.     Zookeeper是一个高性能，分布式的，开源分布式应用协调服务。它提供了简单原始的功能，分布式应用可以基于它实现更高级的服务，比如同步，配置管理，集群管理，名空间。它被设计为易于编程，使用文件系统目录树作为数据模型。

1、Zookeeper安装启动 

  1. 官网下载：http://zookeeper.apache.org/releases.html\#download  
  4. 解压运行：zkServer.cmd

70

服务提供者

  1. 服务提供者将自己的地址信息暴露到Zookeeper中即可，简单来说就是一些IP、端口、实例名等基本信息  
  4. 1、pom.mxl配置  
  7. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  8.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  9.     <parent>
  10.         <groupId>org.springframework.boot</groupId>
  11.         <artifactId>spring-boot-starter-parent</artifactId>
  12.         <version>1.5.10.RELEASE</version>
  13.     </parent>
  15.     <dependencyManagement>
  16.         <dependencies>
  17.             <dependency>
  18.                 <groupId>org.springframework.cloud</groupId>
  19.                 <artifactId>spring-cloud-dependencies</artifactId>
  20.                 <version>Edgware.SR3</version>
  21.                 <type>pom</type>
  22.                 <scope>import</scope>
  23.             </dependency>
  24.         </dependencies>
  25.     </dependencyManagement>
  26.     <modelVersion>4.0.0</modelVersion>
  27.     <groupId>com.tianjunwei</groupId>
  28.     <artifactId>TJWspringCloud-zookeeper</artifactId>
  29.     <version>1.0.0-SNAPSHOT</version>
  30.     <packaging>jar</packaging>
  31.     <name>TJWspringCloud-zookeeper</name>
  32.     <properties>
  33.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  34.     </properties>
  35.     <dependencies>
  36.         <dependency>
  37.             <groupId>org.springframework.cloud</groupId>
  38.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  39.         </dependency>
  40.         <dependency>
  41.             <groupId>org.springframework.boot</groupId>
  42.             <artifactId>spring-boot-starter-web</artifactId>
  43.         </dependency>
  44.         <dependency>  
  45.             <groupId>ch.qos.logback</groupId>  
  46.             <artifactId>logback-core</artifactId>  
  47.         </dependency>  
  48.         <dependency>  
  49.             <groupId>ch.qos.logback</groupId>  
  50.             <artifactId>logback-classic</artifactId>  
  51.         </dependency>  
  52.         <dependency>  
  53.             <groupId>ch.qos.logback</groupId>  
  54.             <artifactId>logback-access</artifactId>  
  55.         </dependency>  
  57.     </dependencies>
  58.     <build>
  59.         <resources>
  60.             <resource>
  61.                 <directory>src/main/java</directory>
  62.                 <includes>
  63.                     <include>**/*.xml</include>
  64.                 </includes>
  65.             </resource>
  66.             <resource>
  67.                 <directory>src/test/java</directory>
  68.                 <includes>
  69.                     <include>**/*.xml</include>
  70.                 </includes>
  71.             </resource>
  72.             <resource>
  73.                 <directory>src/main/resources</directory>
  74.                 <includes>
  75.                     <include>**/*.*</include>
  76.                 </includes>
  77.             </resource>
  78.         </resources>
  79.         <plugins>  
  80.             <plugin>
  81.                 <groupId>org.springframework.boot</groupId>
  82.                 <artifactId>spring-boot-maven-plugin</artifactId>
  83.             </plugin>
  85.             <plugin>  
  86.                 <groupId>org.apache.maven.plugins</groupId>  
  87.                 <artifactId>maven-compiler-plugin</artifactId>  
  88.                 <version>2.0.2</version>  
  89.                 <configuration>  
  90.                     <source>1.8</source>  
  91.                     <target>1.8</target>  
  92.                 </configuration>  
  93.             </plugin>  
  94.         </plugins>  
  95.     </build>
  96. </project>

2、在application.properties中添加服务提供者自身及Zookeeper的相关配置

  1. server.port=8822
  2. spring.application.name=spring-cloud-zookeeper
  3. spring.cloud.zookeeper.connectString=localhost:2181
  4. spring.cloud.zookeeper.discovery.instanceHost=localhost
  5. spring.cloud.zookeeper.discovery.instancePort=${server.port}

3、服务提供者相关代码：

  1. 服务提供者暴露服务名为spring-cloud-zookeeper的服务。  
  4. import org.springframework.boot.SpringApplication;
  5. import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
  6. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  7. import org.springframework.context.annotation.Configuration;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.RestController;
  11. @Configuration
  12. @EnableAutoConfiguration
  13. @EnableDiscoveryClient
  14. @RestController
  15. public class ZookeeperMain {
  17.   @RequestMapping("/hi")
  18.   public String home() {
  19.     return "Hello zookeeper";
  20.   }
  22.   public static void main(String[] args) {
  23.     SpringApplication.run(ZookeeperMain.class, args);
  24.   }
  26. }

服务消费者

  1. 服务消费者同样注册到Zookeeper中，从zk中获取到所需要的服务信息。

1、pom.xml中配置 

  1. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  2.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  3.     <parent>
  4.         <groupId>org.springframework.boot</groupId>
  5.         <artifactId>spring-boot-starter-parent</artifactId>
  6.         <version>1.5.10.RELEASE</version>
  7.     </parent>
  9.     <dependencyManagement>
  10.         <dependencies>
  11.             <dependency>
  12.                 <groupId>org.springframework.cloud</groupId>
  13.                 <artifactId>spring-cloud-dependencies</artifactId>
  14.                 <version>Edgware.SR3</version>
  15.                 <type>pom</type>
  16.                 <scope>import</scope>
  17.             </dependency>
  18.         </dependencies>
  19.     </dependencyManagement>
  20.     <modelVersion>4.0.0</modelVersion>
  21.     <groupId>com.tianjunwei</groupId>
  22.     <artifactId>TJWspringCloud-zookeeper-client</artifactId>
  23.     <version>1.0.0-SNAPSHOT</version>
  24.     <packaging>jar</packaging>
  25.     <name>TJWspringCloud-zookeeper</name>
  26.     <properties>
  27.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  29.     </properties>
  31.     <dependencies>
  32.         <dependency>
  33.             <groupId>org.springframework.cloud</groupId>
  34.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  35.         </dependency>
  36.         <dependency>
  37.             <groupId>org.springframework.boot</groupId>
  38.             <artifactId>spring-boot-starter-web</artifactId>
  39.         </dependency>
  40.         <dependency>  
  41.             <groupId>ch.qos.logback</groupId>  
  42.             <artifactId>logback-core</artifactId>  
  43.         </dependency>  
  44.         <dependency>  
  45.             <groupId>ch.qos.logback</groupId>  
  46.             <artifactId>logback-classic</artifactId>  
  47.         </dependency>  
  48.         <dependency>  
  49.             <groupId>ch.qos.logback</groupId>  
  50.             <artifactId>logback-access</artifactId>  
  51.         </dependency>  
  53.     </dependencies>
  54.     <build>
  55.         <resources>
  56.             <resource>
  57.                 <directory>src/main/java</directory>
  58.                 <includes>
  59.                     <include>**/*.xml</include>
  60.                 </includes>
  61.             </resource>
  62.             <resource>
  63.                 <directory>src/test/java</directory>
  64.                 <includes>
  65.                     <include>**/*.xml</include>
  66.                 </includes>
  67.             </resource>
  68.             <resource>
  69.                 <directory>src/main/resources</directory>
  70.                 <includes>
  71.                     <include>**/*.*</include>
  72.                 </includes>
  73.             </resource>
  74.         </resources>
  75.         <plugins>  
  76.             <plugin>
  77.                 <groupId>org.springframework.boot</groupId>
  78.                 <artifactId>spring-boot-maven-plugin</artifactId>
  79.             </plugin>
  81.             <plugin>  
  82.                 <groupId>org.apache.maven.plugins</groupId>  
  83.                 <artifactId>maven-compiler-plugin</artifactId>  
  84.                 <version>2.0.2</version>  
  85.                 <configuration>  
  86.                     <source>1.8</source>  
  87.                     <target>1.8</target>  
  88.                 </configuration>  
  89.             </plugin>  
  90.         </plugins>  
  91.     </build>
  92. </project>

2、application.properties中添加自身及zk相关的配置

  1. server.port=8833
  2. spring.application.name=spring-cloud-zookeeper-client
  3. spring.cloud.zookeeper.connectString=localhost:2181
  4. spring.cloud.zookeeper.discovery.instanceHost=localhost
  5. spring.cloud.zookeeper.discovery.instancePort=${server.port}

3、服务调用

  1. 在服务消费者通过服务名称来找到对应调用服务提供者的信息。  
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.boot.SpringApplication;
  6. import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
  7. import org.springframework.cloud.client.discovery.DiscoveryClient;
  8. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  9. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  10. import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
  11. import org.springframework.context.annotation.Bean;
  12. import org.springframework.context.annotation.Configuration;
  13. import org.springframework.web.bind.annotation.RequestMapping;
  14. import org.springframework.web.bind.annotation.RequestMethod;
  15. import org.springframework.web.bind.annotation.RestController;
  16. import org.springframework.web.client.RestTemplate;
  18. @Configuration
  19. @EnableAutoConfiguration
  20. @EnableDiscoveryClient
  21. @RestController
  22. public class ZookeeperClientMain {
  24.     @Autowired
  25.     RestTemplate restTemplate;
  27.     @Bean
  28.     @LoadBalanced
  29.     public RestTemplate restTemplate() {
  30.         return new RestTemplate();
  31.     }
  33.     @RequestMapping(value = "/hi", method = RequestMethod.GET)
  34.     public String add() {
  35.         return restTemplate.getForEntity("http://spring-cloud-zookeeper/hi", String.class).getBody();
  36.     }
  38.   public static void main(String[] args) {
  39.     SpringApplication.run(ZookeeperClientMain.class, args);
  40.   }
  42. }

服务调用结果：

70 1

总结：总体来说使用zk作为注册中心与其他注册中心（consul和eureka）类似，对于开发人员来说几乎可以不用在意注册中心到底是哪种类型，因为在服务进行调用的代码都是一致的。

发表评论

表情：
评论列表 （有 0 条评论，294人围观）

还没有评论，来说两句吧...

相关阅读