Spring Cloud系列教程(七)：服务注册与发现ZooKeeper(Finchley版本)

ゝ一世哀愁。 2023-07-07 08:03 34阅读 0赞

一、前言

在前面的几篇文章中，分别讲了如何使用时SpringCloud整合Eureka和SpringCloud整合Consul作为注册中心实现服务的注册与发现，Eureka在闭源后，注册中心可替代的有Consul、Zookeeper，这篇文章就来学习一下SpringCloud整合Zookeeper作为微服务的注册中心，实现服务的注册与发现，然后通过服务提供者提供服务和服务消费者消费服务为例，基于Feign+Zookeeper+Ribbon组合实现RPC远程调用、本地负载均衡功能。

二、了解Zookeeper

Zookeeper是一个高性能，分布式的，开源分布式应用协调服务，使用Java语言开发。是一个分布式协调工具，可以实现服务注册与发现、注册中心、消息中间件、分布式配置中心、负载均衡、统一命名服务、集群管理、Leader选举、分布式锁、分布式队列等。

  • Zookeeper默认支持Ribbon负载均衡
    在这里插入图片描述

三、安装Zookeeper前你需要知道的版本问题

最开始搭建这套环境的时候，我所使用的环境是：

  • JDK版本是JDK1.8
  • SpringBoot版本是2.0.3
  • SpringCloud版本是Finchley版本
  • Zookeeper安装包使用的是zookeeper-3.3.6

在环境搭建完了之后，启动服务提供者和消费者，启动失败，然后将Zookeeper版本换成3.4，启动提供者和消费者工程后，启动成功，无论如何服务无法注册到Zookeeper上去，老是注册Zookeeper节点不成功，通过查看引入的spring-cloud-starter-zookeeper-discovery依赖，发现curator是curator4.0的版本：
在这里插入图片描述
然后查看Zookeeper官网说明： curator4.0要求zookeeper3.5
在这里插入图片描述

结论： SpringBoot2.0以上版本需要Zookeeper3.5版本

四、安装使用Zookeeper

Zookeeper是Java语言开发的，所以也需要下载、安装、启动，这里以Windows安装使用为例，注意，从官网下载完Zookeeper后需要编译一下才可以使用，度娘上也有编译好的，下载即可使用，另外我的文章末尾贴源码里也有对应编译好的Zookeeper安装包，是我自己学习时使用的，版本对应关系都OK，大家直接解压启动便可以直接使用，所以无需另外下载，下面贴出3种下载安装包途径；

  • 文章末尾源码有： 可以直接使用文章末尾贴的源码里的安装包
  • CSDN(已编译好)下载： https://download.csdn.net/download/Thinkingcao/12187726
  • 官网下载地址为： https://archive.apache.org/dist/zookeeper/zookeeper-3.5.5/

1.下载解压后如图所示：
在这里插入图片描述
2. 启动zookeeper服务
双击zkServer.cmd即可启动zookeeper服务；
在这里插入图片描述

3. 打开ZooInspector可视化工具
双击zookeeper-dev-ZooInspector.jar即可启动
在这里插入图片描述

五、实现思路

  • 第一步： 创建服务提供者工程springcloud-zookeeper-provider端口为8005
  • 第二步： 创建服务消费者工程springcloud-feign-consumer端口为8001
  • 第三步： 然后配置提供者注册服务到zookeeper节点，
  • 第四步： 服务消费者注册服务到zookeeper节点
  • 第五步： 然后基于Feign+Ribbon+Zookeeper实现RPC远程调用、负载均衡。

注意： 注册到zookeeper上的服务节点都是临时节点，其服务节点伴随着服务的声明周期结束而消失，消失的时候会有稍微一点延迟(也就是程序关闭后zookeeper上的服务节点消失)

贴一下项目完整截图：
在这里插入图片描述

六、搭建服务提供者

1. 引入依赖

  1. <!--SpringBoot依赖版本-->
  2.     <parent>
  3.         <groupId>org.springframework.boot</groupId>
  4.         <artifactId>spring-boot-starter-parent</artifactId>
  5.         <version>2.0.3.RELEASE</version>
  6.         <relativePath/>
  7.     </parent>
  9.     <!--项目编码、jdk版本、SpringCloud版本定义-->
  10.     <properties>
  11.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  12.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  13.         <java.version>1.8</java.version>
  14.         <spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
  15.     </properties>
  17.     <!--声明管理SpringCloud版本依赖信息-->
  18.     <dependencyManagement>
  19.         <dependencies>
  20.             <dependency>
  21.                 <groupId>org.springframework.cloud</groupId>
  22.                 <artifactId>spring-cloud-dependencies</artifactId>
  23.                 <version>${ spring-cloud.version}</version>
  24.                 <type>pom</type>
  25.                 <scope>import</scope>
  26.             </dependency>
  27.         </dependencies>
  28.     </dependencyManagement>
  30.     <dependencies>
  31.         <!-- SpringBootWeb组件 -->
  32.         <dependency>
  33.             <groupId>org.springframework.boot</groupId>
  34.             <artifactId>spring-boot-starter-web</artifactId>
  35.         </dependency>
  37.         <!--springcloud整合consul组件-->
  38.         <dependency>
  39.             <groupId>org.springframework.cloud</groupId>
  40.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  41.         </dependency>
  43.     </dependencies>
  45.     <!--maven插件-->
  46.     <build>
  47.         <plugins>
  48.             <plugin>
  49.                 <groupId>org.springframework.boot</groupId>
  50.                 <artifactId>spring-boot-maven-plugin</artifactId>
  51.             </plugin>
  52.         </plugins>
  53.     </build>

2. 启动类加@EnableDiscoveryClient注解

启动类上加@EnableDiscoveryClient注解表示启用发现注册中心，向Zooeeper注册服务节点

  1. package com.thinkingcao.api;
  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
  9. public class AppZookeeperProvider { 
  11.     public static void main(String[] args) { 
  12.         SpringApplication.run(AppZookeeperProvider.class, args);
  13.     }
  15. }

3. 编辑application.yml

  1. ##=========服务生产者-会员服务配置========
  2. server:
  3.   port: 8005
  4. ###服务别名----服务注册到注册中心名称
  5. spring:
  6.   ##应用服务名称,
  7.   application:
  8.     name: zk-member-provider
  9.   cloud:
  10.     zookeeper:
  11.       ##连接zookeeper的地址
  12.       connect-string: 127.0.0.1:2181
  13.       discovery:
  14.         #开启服务注册
  15.         register: true
  16.         enabled: true

4. 创建服务提供者接口

  1. package com.thinkingcao.api.controller;
  3. import org.springframework.beans.factory.annotation.Value;
  4. import org.springframework.web.bind.annotation.RequestMapping;
  5. import org.springframework.web.bind.annotation.RequestMethod;
  6. import org.springframework.web.bind.annotation.RequestParam;
  7. import org.springframework.web.bind.annotation.RestController;
  9. /** * @desc: 服务生产者(会员服务) * @author: cao_wencao * @date: 2020-02-22 23:44 */
  10. @RestController
  11. public class ApiZklMemberController { 
  13.     @Value("${server.port}")
  14.     private String serverPort;
  16.     @RequestMapping(value="/getMember", method = RequestMethod.GET)
  17.     private String getMember(@RequestParam("userName") String userName){ 
  18.         return "我是会员服务，订单服务调用会员服务成功啦, 姓名为： " + userName + ", 端口为： " + serverPort;
  19.     }
  20. }

七、搭建服务消费者

1. 引入依赖

  1. <!--SpringBoot依赖版本-->
  2.     <parent>
  3.         <groupId>org.springframework.boot</groupId>
  4.         <artifactId>spring-boot-starter-parent</artifactId>
  5.         <version>2.0.3.RELEASE</version>
  6.         <relativePath/>
  7.     </parent>
  9.     <!--项目编码、jdk版本、SpringCloud版本定义-->
  10.     <properties>
  11.         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
  12.         <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
  13.         <java.version>1.8</java.version>
  14.         <spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
  15.     </properties>
  17.     <!--声明管理SpringCloud版本依赖信息-->
  18.     <dependencyManagement>
  19.         <dependencies>
  20.             <dependency>
  21.                 <groupId>org.springframework.cloud</groupId>
  22.                 <artifactId>spring-cloud-dependencies</artifactId>
  23.                 <version>${ spring-cloud.version}</version>
  24.                 <type>pom</type>
  25.                 <scope>import</scope>
  26.             </dependency>
  27.         </dependencies>
  28.     </dependencyManagement>
  30.     <dependencies>
  31.         <!-- SpringBootWeb组件 -->
  32.         <dependency>
  33.             <groupId>org.springframework.boot</groupId>
  34.             <artifactId>spring-boot-starter-web</artifactId>
  35.         </dependency>
  37.         <!--springcloud整合consul组件-->
  38.         <dependency>
  39.             <groupId>org.springframework.cloud</groupId>
  40.             <artifactId>spring-cloud-starter-zookeeper-discovery</artifactId>
  41.         </dependency>
  43.         <!-- SpringCloud整合Feign组件-->
  44.         <dependency>
  45.             <groupId>org.springframework.cloud</groupId>
  46.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  47.         </dependency>
  49.     </dependencies>
  51.     <!--maven插件-->
  52.     <build>
  53.         <plugins>
  54.             <plugin>
  55.                 <groupId>org.springframework.boot</groupId>
  56.                 <artifactId>spring-boot-maven-plugin</artifactId>
  57.             </plugin>
  58.         </plugins>
  59.     </build>

2. 修改启动类

启动类上加@EnableDiscoveryClient注解表示启用发现注册中心
启动类上加@EnableFeignClients注解表示启动Feign

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

3. 编辑application.yml

  1. ##=========服务消费者-订单服务配置========
  2. server:
  3.   port: 8001
  4. ###服务别名----服务注册到注册中心名称
  5. spring:
  6.   ##应用服务名称,
  7.   application:
  8.     name: zk-order-cosumer
  9.   cloud:
  10.     zookeeper:
  11.        ##连接zookeeper的地址
  12.       connect-string: 127.0.0.1:2181
  13.       discovery:
  14.         register: true
  15.         enabled: true

4. 创建Feign接口

  • IFeignOrderService

    package com.thinkingcao.api.feign;

    import org.springframework.cloud.openfeign.FeignClient;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RequestParam;

    /* @desc: 服务消费者通过Feign HTTP客户端调用工具调用服务提供者提供的服务 @author: cao_wencao @date: 2020-02-24 12:24 */
    @FeignClient(“zk-member-provider”)
    public interface IFeignOrderService { 

    1. //本地RPC调用会员接口
    2. @RequestMapping(value = "/getMember", method = RequestMethod.GET)
    3. public String getMember(@RequestParam("userName") String userName);

    }

5. Controller调用Feign接口消费服务

  • ApiFeignOrderController

    package com.thinkingcao.api.controller;

    import com.thinkingcao.api.feign.IFeignOrderService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RequestMethod;
    import org.springframework.web.bind.annotation.RequestParam;
    import org.springframework.web.bind.annotation.RestController;

    /* @desc: @author: cao_wencao @date: 2020-02-24 12:27 */
    @RestController
    public class ApiFeignOrderController { 

    1. @Autowired(required = false)
    2. private IFeignOrderService feignOrderService;
    4. @RequestMapping(value ="/getMemberInfo",method = RequestMethod.GET)
    5. public String getMemberInfo(@RequestParam("userName") String userName) { 
    6.     String memberInfo = feignOrderService.getMember(userName);
    7.     return memberInfo;
    8. }

    }

八、测试

  • 启动springcloud-zookeeper-provider服务两次，端口分别为： 8002、8005
  • 启动springcloud-feign-consumer服务一次，端口为： 8001
    在这里插入图片描述
  • 查看ZooInspector工具，3个服务节点注册上去了
    在这里插入图片描述
  • 访问URL： http://127.0.0.1:8001/getMemberInfo?userName=“Thinkingcao”，浏览器交替显示结果：

我是会员服务，订单服务调用会员服务成功啦, 姓名为： “Thinkingcao”, 端口为： 8005
我是会员服务，订单服务调用会员服务成功啦, 姓名为： “Thinkingcao”, 端口为： 8002

在这里插入图片描述
在这里插入图片描述

九、源码

1. 项目源码： https://github.com/Thinkingcao/SpringCloudLearning/tree/master/springcloud-zookeeper

十、SpringCloud系列教程

1.Spring Cloud系列教程(八)： Spring Cloud系列教程(八)：服务保护断路器Hystrix(Finchley版本)

SpringCloud教程汇总： Spring Cloud系列教程(汇总篇)：专栏汇总篇(持续更新中)

发表评论

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

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

相关阅读