微服务系列-基于Spring Cloud Eureka进行服务的注册与消费 ...

公众号「架构成长指南」，专注于生产实践、云原生、分布式系统、大数据技术分享。

在之前的几个教程中，我们学了：

使用 RestTemplate 的 Spring Boot 微服务通信示例
使用 WebClient 的 Spring Boot 微服务通信示例
使用 Spring Cloud Open Feign 的 Spring Boot 微服务通信示例
在本教程中，我们将学习如何在Spring boot微服务项目中使用Spring Cloud Eureka进行服务注册与消费
服务注册和发现概述

在微服务项目中，我们一般会对一个项目，以业务的维度拆分至多个服务，比如用户服务、账务服务、订单服务、仓储服务等，这些服务在生产环境部署，
至少是2个服务实例，如果业务量大几十个都是有可能的。
试想这样一种场景

订单服务实例部署了4个，仓库服务部署了5个，仓库服务要调用订单服务，如果没有注册中心，他会怎么做，那只有把对应的ip和端口写死在代码中，如果新增了一个订单服务怎么办？或者下线了订单服务怎么办？
另外，在云环境中，服务实例随时都有可能启动和关闭，随之IP也会发生变化，没法把IP写死在代码中。
基于以上问题就有了服务注册中心Eureka

Eureka能实现服务自动的注册和发现，在每次服务调用的时候根据服务名称会获取到目标服务的IP和端口，在进行调用。
如果服务下线或者上线，对应的服务的地址信息也会进行更新，这样就保证了，随时可以调用到有效的服务。
同时为了提高性能，这个服务地址信息会在每个服务本地缓存一份地址信息表，定时更新，这样每次请求服务时，不用每次去Eureka查询来降低服务调用耗时。
在本教程中，我们将学习如何使用SpringCloud  Eureka进行服务注册和发现，并通过OpenFeign进行服务的调用。
我们将做什么

我们部署一个Eureka Server，并将我们的微服务（部门服务和用户服务）作为 Eureka 客户端，注册到Eureka Server，同时使用用户服务调用根据部门服务的Service ID 来调用部门服务相关接口。

创建Eureka Server

1. 在 IntelliJ IDEA 中创建并设置 Spring boot 项目

让我们使用 springinitializr创建一个 Spring boot 项目。
请参阅下面的屏幕截图，在使用 springinitializr创建 Spring Boot 应用程序时输入详细信息 ：

单击生成按钮以 zip 文件形式下载 Spring boot 项目。解压zip文件并在IntelliJ IDEA中导入Spring boot项目。
这是 pom.xml 文件供参考：

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
3.         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 https://maven.apache.org/xsd/maven-4.0.0.xsd">
4.         <modelVersion>4.0.0</modelVersion>
5.         <parent>
6.                 <groupId>org.springframework.boot</groupId>
7.                 <artifactId>spring-boot-starter-parent</artifactId>
8.                 <version>2.7.17</version>
9.                 <relativePath/>
10.         </parent>
11.         <groupId>io.wz</groupId>
12.         <artifactId>eureka-server</artifactId>
13.         <version>0.0.1-SNAPSHOT</version>
14.         <name>eureka-server</name>
15.         <description>eureka-server</description>
16.         <properties>
17.                 <java.version>1.8</java.version>
18.                 <spring-cloud.version>2021.0.8</spring-cloud.version>
19.         </properties>
20.         <dependencies>
21.                 <dependency>
22.                         <groupId>org.springframework.cloud</groupId>
23.                         <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
24.                 </dependency>
26.                 <dependency>
27.                         <groupId>org.springframework.boot</groupId>
28.                         <artifactId>spring-boot-starter-test</artifactId>
29.                         <scope>test</scope>
30.                 </dependency>
31.         </dependencies>
32.         <dependencyManagement>
33.                 <dependencies>
34.                         <dependency>
35.                                 <groupId>org.springframework.cloud</groupId>
36.                                 <artifactId>spring-cloud-dependencies</artifactId>
37.                                 <version>${spring-cloud.version}</version>
38.                                 <type>pom</type>
39.                                 <scope>import</scope>
40.                         </dependency>
41.                 </dependencies>
42.         </dependencyManagement>
44.         <build>
45.                 <plugins>
46.                         <plugin>
47.                                 <groupId>org.springframework.boot</groupId>
48.                                 <artifactId>spring-boot-maven-plugin</artifactId>
49.                                 <configuration>
50.                                         <image>
51.                                                 <builder>paketobuildpacks/builder-jammy-base:latest</builder>
52.                                         </image>
53.                                 </configuration>
54.                         </plugin>
55.                 </plugins>
56.         </build>
58. </project>

复制代码

2.添加@EnableEurekaServer注解

我们需要添加@EnableEurekaServer注解，使我们应用程序成为服务注册中心。

1. package io.wz.eurekaserver;
3. import org.springframework.boot.SpringApplication;
4. import org.springframework.boot.autoconfigure.SpringBootApplication;
5. import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
7. @SpringBootApplication
8. @EnableEurekaServer
9. public class EurekaServerApplication {
11.         public static void main(String[] args) {
12.                 SpringApplication.run(EurekaServerApplication.class, args);
13.         }
15. }

复制代码

3. 禁用Eureka Server作为Eureka Client

默认情况下，每个Eureka Server 也是一个Eureka客户端。由于我们只想让他做好服务注册中心，不想让他做客户端，因此我们将通过在application.properties文件中配置以下属性来禁用此客户端行为。

1. spring.application.name=Eureka Server
2. server.port=8761
3. eureka.client.register-with-eureka=false
4. eureka.client.fetch-registry=false

复制代码

4.启动Eureka服务器

Eureka Server 提供了 UI，我们可以在其中看到有关注册服务的所有详细信息。
现在运行EurekaServerApplication并访问 http://localhost:8761，会显示以下界面

将Department-Service注册至Eureka Server

请参阅本教程创建 部门服务 和 用户服务 微服务： 使用 Spring Cloud Open Feign 的 Spring Boot 微服务通信示例
让我们将这个部门服务 作为 Eureka 客户端并向 Eureka 服务器注册。
将 Eureka client pom添加到部门服务中：

1. <dependency>
2.     <groupId>org.springframework.cloud</groupId>
3.     <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
4. </dependency>

复制代码

另外，添加 Spring Cloud 依赖项：

1.         <dependencyManagement>
2.                 <dependencies>
3.                         <dependency>
4.                                 <groupId>org.springframework.cloud</groupId>
5.                                 <artifactId>spring-cloud-dependencies</artifactId>
6.                                 <version>${spring-cloud.version}</version>
7.                                 <type>pom</type>
8.                                 <scope>import</scope>
9.                         </dependency>
10.                 </dependencies>
11.         </dependencyManagement>

复制代码

添加版本属性：

1.         <properties>
2.                 <java.version>1.8</java.version>
3.                 <spring-cloud.version>2021.0.4</spring-cloud.version>
4.         </properties>

复制代码

在application.properties中配置eureka.client.service-url.defaultZone 属性  即可自动注册到 Eureka Server。

1. spring.application.name=DEPARTMENT-SERVICE
2. eureka.instance.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

复制代码

运行部门服务Eureka客户端

完成此配置后，启动Department-service并访问 http://localhost:8761。
看到部门服务已使用 SERVICE ID 注册为 DEPARTMENT-SERVICE,注意到状态为 UP(1)，这意味着服务已启动并正在运行，并且部门服务的一个实例正在运行。

将User-Service微服务注册为Eureka客户端

添加以下依赖

1. <dependency>
2.     <groupId>org.springframework.cloud</groupId>
3.     <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
4. </dependency>

复制代码

在application.properties中配置eureka.client.service-url.defaultZone 属性  即可自动注册到 Eureka Server。

1. spring.application.name=USER-SERVICE
2. eureka.instance.client.serviceUrl.defaultZone=http://localhost:8761/eureka/

复制代码

当服务注册到 Eureka Server 时，它会在一定的时间间隔内不断发送心跳。如果 Eureka 服务器没有收到来自任何服务实例的心跳，它将假定该服务实例已关闭并将其从池中取出
修改user-service的ApiClient

在上一节中中，我们使用APIClient完成了进行服务调用，但是是写了部门服务的url

1. @FeignClient(value = "DEPARTMENT-SERVICE", url = "http://localhost:8080")

复制代码

这次我们修改如下,去除url属性

1. @FeignClient(value = "DEPARTMENT-SERVICE")

复制代码

完整api如下

1. package io.wz.userservice.service;
3. import io.wz.userservice.dto.DepartmentDto;
4. import org.springframework.cloud.openfeign.FeignClient;
5. import org.springframework.web.bind.annotation.GetMapping;
6. import org.springframework.web.bind.annotation.PathVariable;
8. @FeignClient(value = "DEPARTMENT-SERVICE")
9. public interface APIClient {
10.     @GetMapping(value = "/api/departments/{id}")
11.     DepartmentDto getDepartmentById(@PathVariable("id") String departmentId);
12. }

复制代码

运行用户服务Eureka客户端

以上配置后，启动 user-service 并访问http://localhost:8761。看到user-service已使用 SERVICE ID 注册为USER-SERVICE。
您还可以注意到状态为 UP(1)，这意味着服务已启动并正在运行，并且用户服务的一个实例正在运行。

测试

增加测试日志

在部门服务的DepartmentServiceImpl的getDepartmentById方法增加调试日志,如果调用到此接口，会打印getDepartment By Id

1.     @Override
2.     public Department getDepartmentById(Long departmentId) {
3.         log.info("getDepartment By Id:{} ",departmentId);
4.         return departmentRepository.findById(departmentId).get();
5.     }

复制代码

启动2个Department-Service

1. 启动一个8082的部门服务
在idea中复制DepartmentServiceApplication配置，同时在启动参数指定应用端口 -Dserver.port=8082

2. 启动默认的部门服务，端口为8080

以上2个部门服务启动完成，会在eureka看到2个部门服务

点击获取用户 REST API进行测试

多点击几次，会看到2个部门服务控制台都会打印，getDepartment By Id:1，这里使用的是Spring Cloud LoadBalancer提供的轮训算法


结论

在本教程中，我们学习了如何在 Spring boot 微服务项目中使用Eureka来进行服务的注册与发现，同时基于Feign进行服务的调用，但是这里还有遗留问题，如

• 启动服务以后需要多久才会被消费方查询到地址?
  
• 如果要做服务更新，如何让消费无感知，感受不到服务再重启?
  
• 如何让调用方知道调用的是提供方多个实例中具体哪一个服务实例？
  

以上问题后续文章解答，请关注此公众号。
源码下载：
github
gitee

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！