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

﹏ヽ暗。殇╰゛Y 2023-07-07 08:02 27阅读 0赞

一、前言

在微服务领域，服务注册与发现是其中很重要的一个模块，主要用于服务治理问题；在分布式Dubbo中常用的服务发现与注册中心是Zookeeper，Cosul与其类似，在SpringCloud刚占领市场的时候，SpringCloud微服务框架默认使用的注册中心组建是Eureka，总所周知，Eureka已经开始闭源了，那么可以替代Eureka的有：Consul、Zookeeper ，这两种比较常用，同样可以很好的与SpringCloud集成，用于替代Eureka，本篇就主要实现SpringCloud整合Consul实现服务注册与发现。

二、Consul是什么

Consul是一个支持多数据中心分布式高可用的服务发现和配置共享的服务软件，采用 Go 语言开发。Consul内置了服务注册与发现框 架、分布一致性协议实现、健康检查、Key/Value存储、多数据中心方案。由于出现得晚些，Consul具有功能完善、部署简单、使用方便等特点。

1. 使用Consul 的优势

  • 使用 Raft 算法来保证一致性, 比 ZooKeeper 的 Paxos 算法更简单直接。
  • 支持多数据中心，内外网的服务采用不同的端口进行监听。 ZooKeeper 和 etcd 均不提供多数据中心功能的- 支持。
  • 支持健康检查，etcd 不提供此功能。
  • 支持 http 和 dns 协议接口。ZooKeeper 的集成较为复杂，etcd 只支持 http 协议。
  • 官方提供 web 管理界面，etcd 无此功能。
  • Consul 1.2 新增 Service Mesh 解决方案。

2. Consul默认支持Ribbon负载均衡

在这里插入图片描述

三、Consul的安装

1. 下载安装

Consul由Go语言开发，因此也继承了Go语言跨平台，易安装的特点，支持Windwos、Linux、macOS，解压即可运行使用；以Windwos为例，去官网下载： https://www.consul.io/downloads.html , 解压后只有一个.exe文件。
在这里插入图片描述

2. 运行Consul

a. 启动Consul命令：

consul agent -dev -ui -node=cy

-dev开发服务器模式启动，-node结点名为cy，-ui可以用界面访问，默认能访问。
在这里插入图片描述

b. 起始访问地址：
访问地址： http://localhost:8500
在这里插入图片描述

四、实现思路

启动Consul后，创建两个基于Consul的客户端服务工程，一个服务提供者和一个服务消费者，使用Feign进行服务消费，客户端配置连接运行的Consul服务，这里先贴一下项目完整结构图；
在这里插入图片描述

五、搭建服务提供者springcloud-consul-provider

1.引入pom依赖

  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-consul-discovery</artifactId>
  41.         </dependency>
  43.         <!-- 引入Feign接口公共层-->
  44.         <!--<dependency>-->
  45.             <!--<groupId>com.thinkingcao</groupId>-->
  46.             <!--<artifactId>springcloud-feign-interface</artifactId>-->
  47.             <!--<version>0.0.1-SNAPSHOT</version>-->
  48.         <!--</dependency>-->
  50.     </dependencies>
  52.     <!--maven插件-->
  53.     <build>
  54.         <plugins>
  55.             <plugin>
  56.                 <groupId>org.springframework.boot</groupId>
  57.                 <artifactId>spring-boot-maven-plugin</artifactId>
  58.             </plugin>
  59.         </plugins>
  60.     </build>

2. 启动类上加@EnableDiscoveryClient注解

  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 AppMemerProvider { 
  11.     public static void main(String[] args) { 
  12.         SpringApplication.run(AppMemerProvider.class, args);
  13.     }
  14. }

3. @EnableDiscoveryClient 与@EnableEurekaClient区别

  • @EnableDiscoveryClient注解是基于spring-cloud-commons依赖，并且在classpath中实现； 适合于consul、zookeeper注册中心
  • @EnableEurekaClient注解是基于spring-cloud-netflix依赖，只能为eureka作用；

4. 修改application.yml

  1. ##=========服务生产者-会员服务配置========
  2. ##服务在7777端口暴露出来
  3. server:
  4.   port: 8764
  6. ##配置Spring相关
  7. spring:
  8.   ##应用服务名称,切记不能为下划线consul_member_provider，因为Feign不支持
  9.   application:
  10.     name: consul-member-provider
  11.   ##consul注册中心地址
  12.   cloud:
  13.     consul:
  14.       ##Consul所在主机ip
  15.       host: localhost
  16.       ##Consul监听的端口
  17.       port: 8500
  18.       discovery:
  19.         ##配置开启服务注册到Consul上
  20.         register: true
  21.         ##配置注册到Consul的服务实例名称(Consul里Feign是通过此名称调用，而非spring.application.name)
  22.         service-name: member-provider
  23.         ##配置服务健康检查地址，供Consul调用
  24.         healthCheckPath: /health
  25.         ##Consul 健康检查频率
  26.         healthCheckInterval: 15s

5. 提供会员接口ApiConsulMemberController

  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 ApiConsulMemberController { 
  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. }

6. Consul健康检查接口HealthCheckController

  1. package com.thinkingcao.api.controller;
  3. import org.springframework.web.bind.annotation.RequestMapping;
  4. import org.springframework.web.bind.annotation.RestController;
  6. /** * @desc: 提供给Consul健康检查的controller * @auth: cao_wencao * @date: 2020/2/23 0:08 */
  7. @RestController
  8. public class HealthCheckController { 
  10.     //RequestMapping中的url地址需和配置文件中保持一致
  11.     @RequestMapping("/health")
  12.     public String healthCheck() { 
  13.         return "ok";
  14.     }
  15. }

7. 启动会员服务

启动springcloud-consul-provider项目，会发现项目实例 member-provider 注册到了 consul 中

在这里插入图片描述

六、搭建服务消费者springcloud-feign-consumer

1.引入pom依赖

  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>
  8.     <groupId>com.thinkingcao</groupId>
  9.     <artifactId>springcloud-feign-consumer</artifactId>
  10.     <version>0.0.1-SNAPSHOT</version>
  11.     <name>springcloud-feign-consumer</name>
  12.     <description>SpringCloud整合Feign客户端组件消费服务</description>
  14.     <properties>
  15.         <java.version>1.8</java.version>
  16.         <spring-cloud.version>Finchley.RELEASE</spring-cloud.version>
  17.     </properties>
  19.     <!--声明管理SpringCloud版本依赖信息-->
  20.     <dependencyManagement>
  21.         <dependencies>
  22.             <dependency>
  23.                 <groupId>org.springframework.cloud</groupId>
  24.                 <artifactId>spring-cloud-dependencies</artifactId>
  25.                 <version>${ spring-cloud.version}</version>
  26.                 <type>pom</type>
  27.                 <scope>import</scope>
  28.             </dependency>
  29.         </dependencies>
  30.     </dependencyManagement>
  32.     <dependencies>
  33.         <!-- SpringBootWeb组件 -->
  34.         <dependency>
  35.             <groupId>org.springframework.boot</groupId>
  36.             <artifactId>spring-boot-starter-web</artifactId>
  37.         </dependency>
  39.         <!-- springcloud整合Feign客户端组件   -->
  40.         <dependency>
  41.             <groupId>org.springframework.cloud</groupId>
  42.             <artifactId>spring-cloud-starter-openfeign</artifactId>
  43.         </dependency>
  45.         <!-- 引入Feign接口公共层-->
  46.         <!--<dependency>-->
  47.             <!--<groupId>com.thinkingcao</groupId>-->
  48.             <!--<artifactId>springcloud-feign-interface</artifactId>-->
  49.             <!--<version>0.0.1-SNAPSHOT</version>-->
  50.         <!--</dependency>-->
  52.         <!--springcloud整合consul组件-->
  53.         <dependency>
  54.             <groupId>org.springframework.cloud</groupId>
  55.             <artifactId>spring-cloud-starter-consul-discovery</artifactId>
  56.         </dependency>
  58.         <!-- 健康检查 -->
  59.         <dependency>
  60.             <groupId>org.springframework.boot</groupId>
  61.             <artifactId>spring-boot-starter-actuator</artifactId>
  62.         </dependency>
  64.         <!--lombok代码简化工具-->
  65.         <dependency>
  66.             <groupId>org.projectlombok</groupId>
  67.             <artifactId>lombok</artifactId>
  68.         </dependency>
  69.     </dependencies>
  71.     <build>
  72.         <plugins>
  73.             <plugin>
  74.                 <groupId>org.springframework.boot</groupId>
  75.                 <artifactId>spring-boot-maven-plugin</artifactId>
  76.             </plugin>
  77.         </plugins>
  78.     </build>

2. 启动类添加注解

  • 在启动类添加@EnableFeignClients和@EnableDiscoveryClient注解，表示启用Feign客户端调用和Consul服务注册与发现功能

    package com.thinkingcao.api;

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

    @SpringBootApplication
    @EnableFeignClients
    @EnableDiscoveryClient
    public class AppOrderConsumer { 

    1. public static void main(String[] args) { 
    2.     SpringApplication.run(AppOrderConsumer.class, args);
    3. }

    }

3. 编辑application.yml

  1. ##=========服务消费者-订单服务配置========
  2. #服务端口号
  3. server:
  4.   port: 8787
  6. ##配置Spring相关
  7. spring:
  8.   ##服务名称
  9.   application:
  10.     name: consul-order_consumer
  11.   ##consul注册中心地址
  12.   cloud:
  13.     consul:
  14.       ##Consul所在主机ip
  15.       host: localhost
  16.       ##Consul监听的端口
  17.       port: 8500
  18.       discovery:
  19.         ##配置注册到Consul的服务实例名称(Consul里Feign是通过此名称调用，而非spring.application.name)
  20.         service-name: order-consumer
  21.         ##配置服务健康检查地址，供Consul调用
  22.         healthCheckPath: /health
  23.         ##Consul 健康检查频率
  24.         healthCheckInterval: 15s

4. 定义 Feign 接口IFeignClientService

  • 定义Feign接口时，其中@FeignClient的value 是 provide 注册在 consul中的服务名。RequestMapping 对应 provider的具体映射。

    package com.thinkingcao.api.Feign;

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

    /* @desc: Feign声明式客户端调用工具 @author: cao_wencao @date: 2020-02-22 12:23 */
    @FeignClient(value = “member-provider”)
    public interface IFeignClientService { 

    1. //通过userId查询会员信息数据
    2. @RequestMapping("/getMember")
    3. public String getOrderToMemberInfo(@RequestParam("userName") String userName);

    }

5. 定义Controller调用Feign接口

  1. package com.thinkingcao.api.controller;
  3. import com.thinkingcao.api.Feign.IFeignClientService;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.cloud.client.discovery.DiscoveryClient;
  6. import org.springframework.cloud.client.loadbalancer.LoadBalancerClient;
  7. import org.springframework.web.bind.annotation.RequestMapping;
  8. import org.springframework.web.bind.annotation.RequestMethod;
  9. import org.springframework.web.bind.annotation.RequestParam;
  10. import org.springframework.web.bind.annotation.RestController;
  12. /** * @desc: 服务消费者(订单服务) * @author: cao_wencao * @date: 2020-02-22 12:30 */
  13. @RestController
  14. public class ApiFeignOrderController { 
  16.     @Autowired
  17.     private LoadBalancerClient loadBalancerClient;
  19.     @Autowired
  20.     private DiscoveryClient discoveryClient;
  22.     // @Autowired
  23.     // private OrderService orderService;
  25.     @Autowired(required = false)
  26.     private IFeignClientService feignClientService;
  28.     //基于Feign实现订单调用会员 ，并且实现本地负载均衡
  29.     @RequestMapping(value ="/getMemberInfo",method = RequestMethod.GET)
  30.     public String getMemberInfo(@RequestParam("userName") String userName) { 
  31.         String memberInfo = feignClientService.getOrderToMemberInfo(userName);
  32.         return memberInfo;
  33.     }
  35.      /** * 获取服务实例 */
  36.     @RequestMapping(value = "/discover",method = RequestMethod.GET)
  37.     public String discover(){ 
  38.         String instance = loadBalancerClient.choose("member-provider").getUri().toString();
  39.         return instance;
  40.     }
  42.     /** * 获取所有服务 */
  43.     @RequestMapping("/services")
  44.     public Object services() { 
  45.         return discoveryClient.getInstances("member-provider");
  46.     }
  47. }

6. Consul健康检查接口HealthCheckController

  1. package com.thinkingcao.api.controller;
  3. import org.springframework.web.bind.annotation.RequestMapping;
  4. import org.springframework.web.bind.annotation.RestController;
  6. /** * @desc: 提供给Consul健康检查的controller * @auth: cao_wencao * @date: 2020/2/23 0:08 */
  7. @RestController
  8. public class HealthCheckController { 
  10.     //RequestMapping中的url地址需和配置文件中保持一致
  11.     @RequestMapping("/health")
  12.     public String healthCheck() { 
  13.         return "ok";
  14.     }
  15. }

7. 启动订单服务

启动springcloud-feign-consumer项目，会发现项目实例 order-consumer注册到了 consul 中，这时候有两个服务都注册其中

在这里插入图片描述

七、测试

实现订单调用会员服务接口，为了测试Feign+Ribbon+Cosul实现负载均衡效果，需要启动两个会员提供者服务实例；启动会员服务两个实例后，稍等片刻。
在这里插入图片描述

  • 访问接口： http://127.0.0.1:8787/getMemberInfo?userName=“Thinkingcao”

这是浏览器交替显示结果：

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

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

  • 访问接口： http://127.0.0.1:8787/services ，获取服务列表信息在这里插入图片描述

八、项目源码

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

七、SpringCloud系列教程

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

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

发表评论

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

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

相关阅读