1 Zookeeper简介

  • zookeeper的官网。
  • zookeeper由雅虎研究院开发，是Google Chubby的开源实现，后来托管到Apache，于2010年11月正式成为Apache的顶级项目。
  • 大数据生态系统里的很多组件的命名都是某种动物或者昆虫，比如Hadoop就是Eureka替换方案Zookeeper（不推荐） - 图1，Hive就是Eureka替换方案Zookeeper（不推荐） - 图2。zookeeper即动物园管理者，顾名思义就是管理大数据生态系统各组件的管理员，如下图所示。

2 服务提供者注册到Zookeeper

2.1 导入相关jar包的Maven坐标

  • 修改部分：
  1. <!--   SpringCloud整合zookeeper     -->
  2. <dependency>
  3.     <groupId>org.springframework.cloud</groupId>
  4.     <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  5.     <!--排除zk3.5.3-->
  6.     <exclusions>
  7.         <exclusion>
  8.             <groupId>org.apache.zookeeper</groupId>
  9.             <artifactId>zookeeper</artifactId>
  10.         </exclusion>
  11.     </exclusions>
  12. </dependency>
  13. <dependency>
  14.     <groupId>org.apache.zookeeper</groupId>
  15.     <artifactId>zookeeper</artifactId>
  16.     <version>3.4.10</version>
  17.     <exclusions>
  18.         <exclusion>
  19.             <groupId>org.slf4j</groupId>
  20.             <artifactId>slf4j-log4j12</artifactId>
  21.         </exclusion>
  22.     </exclusions>
  23. </dependency>
  • 完整部分：
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xmlns="http://maven.apache.org/POM/4.0.0"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>spring_cloud_demo</artifactId>
  7.         <groupId>org.sunxiaping</groupId>
  8.         <version>1.0</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>product_service_zookeeper9001</artifactId>
  14.     <dependencies>
  15.         <!--   SpringCloud整合zookeeper     -->
  16.         <dependency>
  17.             <groupId>org.springframework.cloud</groupId>
  18.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  19.             <!--排除zk3.5.3-->
  20.             <exclusions>
  21.                 <exclusion>
  22.                     <groupId>org.apache.zookeeper</groupId>
  23.                     <artifactId>zookeeper</artifactId>
  24.                 </exclusion>
  25.             </exclusions>
  26.         </dependency>
  27.         <dependency>
  28.             <groupId>org.apache.zookeeper</groupId>
  29.             <artifactId>zookeeper</artifactId>
  30.             <version>3.4.10</version>
  31.             <exclusions>
  32.                 <exclusion>
  33.                     <groupId>org.slf4j</groupId>
  34.                     <artifactId>slf4j-log4j12</artifactId>
  35.                 </exclusion>
  36.             </exclusions>
  37.         </dependency>
  38.         <dependency>
  39.             <groupId>org.springframework.boot</groupId>
  40.             <artifactId>spring-boot-starter-web</artifactId>
  41.         </dependency>
  42.         <dependency>
  43.             <groupId>org.springframework.boot</groupId>
  44.             <artifactId>spring-boot-devtools</artifactId>
  45.             <scope>runtime</scope>
  46.             <optional>true</optional>
  47.         </dependency>
  48.         <dependency>
  49.             <groupId>org.springframework.boot</groupId>
  50.             <artifactId>spring-boot-starter-test</artifactId>
  51.             <scope>test</scope>
  52.         </dependency>
  53.         <dependency>
  54.             <groupId>org.springframework.boot</groupId>
  55.             <artifactId>spring-boot-starter-data-jpa</artifactId>
  56.         </dependency>
  57.         <dependency>
  58.             <groupId>mysql</groupId>
  59.             <artifactId>mysql-connector-java</artifactId>
  60.         </dependency>
  61.         <dependency>
  62.             <groupId>org.springframework.boot</groupId>
  63.             <artifactId>spring-boot-starter-actuator</artifactId>
  64.         </dependency>
  65.     </dependencies>
  66. </project>

2.2 application.yml

  • 修改部分：
  1. spring:
  2. # SpringCloud
  3.   cloud:
  4.     zookeeper:
  5.       connect-string: 192.168.237.100:2181
  • 完整部分：
  1. server:
  2.   port: 9001 # 微服务的端口号
  4. spring:
  5.   application:
  6.     name: service-product # 微服务的名称
  7.   datasource:
  8.     url: jdbc:mysql://192.168.237.100:3306/test?useUnicode=true&characterEncoding=UTF-8&autoReconnect=true&useSSL=false&serverTimezone=GMT%2B8&allowPublicKeyRetrieval=true
  9.     driver-class-name: com.mysql.cj.jdbc.Driver
  10.     username: root
  11.     password: 123456
  12.   jpa:
  13.     generate-ddl: true
  14.     show-sql: true
  15.     open-in-view: true
  16.     database: mysql
  17.   # SpringCloud
  18.   cloud:
  19.     zookeeper:
  20.       connect-string: 192.168.237.100:2181
  22. # 微服务info内容详细信息
  23. info:
  24.   app.name: xxx
  25.   company.name: xxx
  26.   build.artifactId: $project.artifactId$
  27.   build.version: $project.version$

2.3 在启动类上标注@EnableDiscoveryClient注解

  1. package com.sunxiaping.product;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  7. @SpringBootApplication
  8. @EnableDiscoveryClient //该注解用于向使用Consul或者zookeeper作为注册中心时注册服务
  9. public class Product9001Application {
  10.     public static void main(String[] args) {
  11.         SpringApplication.run(Product9001Application.class, args);
  12.     }
  13. }

2.4 ProductController

  1. package com.sunxiaping.product.controller;
  3. import com.sunxiaping.product.domain.Product;
  4. import com.sunxiaping.product.service.ProductService;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.beans.factory.annotation.Value;
  7. import org.springframework.web.bind.annotation.*;
  9. @RestController
  10. @RequestMapping(value = "/product")
  11. public class ProductController {
  13.     @Value("${server.port}")
  14.     private String port;
  16.     @Value("${spring.cloud.client.ip-address}")
  17.     private String ip;
  19.     @Autowired
  20.     private ProductService productService;
  22.     @PostMapping(value = "/save")
  23.     public String save(@RequestBody Product product) {
  24.         productService.save(product);
  25.         return "新增成功";
  26.     }
  28.     @GetMapping(value = "/findById/{id}")
  29.     public Product findById(@PathVariable(value = "id") Long id) {
  30.         Product product = productService.findById(id);
  31.         product.setProductName("访问的地址是：" + ip + ":" + port);
  32.         return product;
  33.     }
  34. }

3 服务消费者注册到Zookeeper

3.1 导入相关jar包的Maven坐标

  • 修改部分：
  1. <!--   SpringCloud整合zookeeper     -->
  2. <dependency>
  3.     <groupId>org.springframework.cloud</groupId>
  4.     <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  5.     <!--排除zk3.5.3-->
  6.     <exclusions>
  7.         <exclusion>
  8.             <groupId>org.apache.zookeeper</groupId>
  9.             <artifactId>zookeeper</artifactId>
  10.         </exclusion>
  11.     </exclusions>
  12. </dependency>
  13. <dependency>
  14.     <groupId>org.apache.zookeeper</groupId>
  15.     <artifactId>zookeeper</artifactId>
  16.     <version>3.4.10</version>
  17.     <exclusions>
  18.         <exclusion>
  19.             <groupId>org.slf4j</groupId>
  20.             <artifactId>slf4j-log4j12</artifactId>
  21.         </exclusion>
  22.     </exclusions>
  23. </dependency>
  • 完整部分：
  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
  3.          xmlns="http://maven.apache.org/POM/4.0.0"
  4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
  5.     <parent>
  6.         <artifactId>spring_cloud_demo</artifactId>
  7.         <groupId>org.sunxiaping</groupId>
  8.         <version>1.0</version>
  9.     </parent>
  10.     <modelVersion>4.0.0</modelVersion>
  12.     <artifactId>order_service_zookeeper8001</artifactId>
  13.     <dependencies>
  14.         <!--   SpringCloud整合zookeeper     -->
  15.         <dependency>
  16.             <groupId>org.springframework.cloud</groupId>
  17.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  18.             <!--排除zk3.5.3-->
  19.             <exclusions>
  20.                 <exclusion>
  21.                     <groupId>org.apache.zookeeper</groupId>
  22.                     <artifactId>zookeeper</artifactId>
  23.                 </exclusion>
  24.             </exclusions>
  25.         </dependency>
  26.         <dependency>
  27.             <groupId>org.apache.zookeeper</groupId>
  28.             <artifactId>zookeeper</artifactId>
  29.             <version>3.4.10</version>
  30.             <exclusions>
  31.                 <exclusion>
  32.                     <groupId>org.slf4j</groupId>
  33.                     <artifactId>slf4j-log4j12</artifactId>
  34.                 </exclusion>
  35.             </exclusions>
  36.         </dependency>
  37.         <dependency>
  38.             <groupId>org.springframework.boot</groupId>
  39.             <artifactId>spring-boot-starter-web</artifactId>
  40.         </dependency>
  41.         <dependency>
  42.             <groupId>org.springframework.boot</groupId>
  43.             <artifactId>spring-boot-devtools</artifactId>
  44.             <scope>runtime</scope>
  45.             <optional>true</optional>
  46.         </dependency>
  47.         <dependency>
  48.             <groupId>org.springframework.boot</groupId>
  49.             <artifactId>spring-boot-starter-test</artifactId>
  50.             <scope>test</scope>
  51.         </dependency>
  52.         <dependency>
  53.             <groupId>org.springframework.boot</groupId>
  54.             <artifactId>spring-boot-starter-actuator</artifactId>
  55.         </dependency>
  56.     </dependencies>
  58. </project>

3.2 application.yml

  • 修改部分：
  1. spring: 
  2.  # SpringCloud
  3.   cloud:
  4.     zookeeper:
  5.       connect-string: 192.168.237.100:2181
  • 完整部分：
  1. server:
  2.   port: 8001 # 微服务的端口号
  4. spring:
  5.   application:
  6.     name: service-order # 微服务的名称
  7.   # SpringCloud
  8.   cloud:
  9.     zookeeper:
  10.       connect-string: 192.168.237.100:2181
  13. # 微服务info内容详细信息
  14. info:
  15.   app.name: xxx
  16.   company.name: xxx
  17.   build.artifactId: $project.artifactId$
  18.   build.version: $project.version$
  20. # 开启日志debug
  21. logging:
  22.   level:
  23.     root: info

3.3 在Spring容器中注入RestTemplate

  • SpringConfig.java
  1. package com.sunxiaping.order.config;
  3. import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  4. import org.springframework.context.annotation.Bean;
  5. import org.springframework.context.annotation.Configuration;
  6. import org.springframework.web.client.RestTemplate;
  8. @Configuration
  9. public class SpringConfig {
  11.     @Bean
  12.     @LoadBalanced
  13.     public RestTemplate restTemplate() {
  14.         return new RestTemplate();
  15.     }
  16. }

3.4 在启动类上标注@EnableDiscoveryClient注解

  1. package com.sunxiaping.order;
  3. import org.springframework.boot.SpringApplication;
  4. import org.springframework.boot.autoconfigure.SpringBootApplication;
  5. import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
  8. @SpringBootApplication
  9. @EnableDiscoveryClient
  10. public class Order8001Application {
  11.     public static void main(String[] args) {
  12.         SpringApplication.run(Order8001Application.class, args);
  13.     }
  14. }

3.5 OrderController

  1. package com.sunxiaping.order.controller;
  4. import com.sunxiaping.order.domain.Product;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.web.bind.annotation.GetMapping;
  7. import org.springframework.web.bind.annotation.PathVariable;
  8. import org.springframework.web.bind.annotation.RequestMapping;
  9. import org.springframework.web.bind.annotation.RestController;
  10. import org.springframework.web.client.RestTemplate;
  12. @RestController
  13. @RequestMapping(value = "/order")
  14. public class OrderController {
  15.     @Autowired
  16.     private RestTemplate restTemplate;
  19.     /**
  20.      * 使用OrderCommand调用远程远程服务
  21.      *
  22.      * @param id
  23.      * @return
  24.      */
  25.     @GetMapping(value = "/buy/{id}")
  26.     public Product buy(@PathVariable(value = "id") Long id) {
  27.         return restTemplate.getForObject("http://service-product/product/findById/" + id, Product.class);
  28.     }
  29. }