2. Eureka
2.1 Eureka 概述
Eureka 是 Netflix 提供的基于 REST 的服务发现组件，用于帮助开发者管理微服务架构中的服务实例。它提供了一个可伸缩的注册中心，可以让每个微服务都能够找到其他微服务的位置和元数据信息，并对其进行负载均衡、自动故障转移等操作。
通过将 Eureka Server 部署在中心服务器上，然后将各个微服务节点（即Eureka Client）注册到该中心服务器上，便可以实现微服务间的快速查找和调用。
使用Eureka能够方便地扩展和部署大规模微服务应用程序，并让你更容易地维护和监控整个系统。
同时，由于Eureka本身是基于REST接口设计的，因此它能够与多种编程语言和框架无缝集成，可以让开发者像使用本地服务一样轻松地编写分布式应用程序。
2.2 搭建 Eureka
2.2.1 pom
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>2.3.9.RELEASE</version> </parent> <artifactId>eureka-service</artifactId> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding> <java.version>1.8</java.version> <!-- SpringCloud版本号 --> <spring-cloud.version>Hoxton.SR10</spring-cloud.version> </properties> <!-- 版本锁定: 并不是jar包导入 --> <dependencyManagement> <dependencies> <!-- todo:2.导入springCloud父工程 --> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-dependencies</artifactId> <version>${spring-cloud.version}</version> <!-- 打包方式为pom: 说明我们导入的是一个父工程 --> <type>pom</type> <scope>import</scope> </dependency> </dependencies> </dependencyManagement> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter</artifactId> </dependency> <dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId> </dependency> </dependencies> <build> <finalName>app</finalName> <plugins> <plugin> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-maven-plugin</artifactId> </plugin> </plugins> </build> </project>
2.2.2 yml
server: port: 10086 spring: application: name: eureka-server eureka: # 给内置的客户端设置服务端地址 client: service-url: defaultZone: http://127.0.0.1:10086/eureka register-with-eureka: false # 不注册自己 fetch-registry: false #不拉取服务本eureka服务中的服务信息
2.2.3 启动类
@SpringBootApplication // 开启Eureka服务端支持 @EnableEurekaServer public class EurekaApplication { public static void main(String[] args) { SpringApplication.run(EurekaApplication.class, args); } }
2.2.4 启动访问
2.3 将服务注册进 Eureka
给user服务和order服务分别引入依赖：
<dependency> <groupId>org.springframework.cloud</groupId> <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId> </dependency>
修改 user 和 order 的 yml 文件
server: port: 8081 spring: datasource: url: jdbc:mysql://192.168.0.108:3306/cloud?useSSL=false username: root password: root driver-class-name: com.mysql.jdbc.Driver application: name: USER-SERVER eureka: client: service-url: defaultZone: http://127.0.0.1:10086/eureka instance: # 在Eureka中显示服务的ip地址 ip-address: 127.0.0.1 # 配置服务器ip地址 prefer-ip-address: true # 更倾向于使用ip,而不是host名 instance-id: ${eureka.instance.ip-address}:${server.port} # 自定义实例的id
server: port: 9091 spring: datasource: url: jdbc:mysql://192.168.0.108:3306/cloud?useSSL=false username: root password: root driver-class-name: com.mysql.jdbc.Driver application: name: ORDER-SERVER eureka: client: service-url: defaultZone: http://127.0.0.1:10086/eureka
重启服务。
服务就已注册进来了。
2.4 通过Eureka调用服务
回看我们之前 order 调用 user 时候的方式是直接通过 RestTemplate 调用的，这样耦合是有些大的，比如我们的 user 服务换了部署地址，就得去动 order 的源代码。实在不妥。
下来我们通过 Eureka 提供的注册发现服务去调用。
改造OrderController
@GetMapping("/get/{id}") public Order get(@PathVariable("id") Long id){ String user_server_name = "USER-SERVER"; String url = "http://" + user_server_name + "/user/get/"; Order order = orderMapper.selectById(id); User user = restTemplate.getForObject(url + order.getUserId(), User.class); order.setUser(user); return order; }
启动访问：
3. Eureka 原理
Eureka 采用了客户端-服务端的设计架构，分为 Eureka Server 和 Eureka Client 两部分。
Eureka Server 是一个基于 RESTful 的服务，用于管理和维护客户端节点的信息。每个 Eureka Client 向 Eureka Server 注册自己提供的服务，并定时通过心跳机制告知 Eureka Server 自己仍然存活。同时，Eureka Server 也会定期对注册在自己那里的每个 Eureka Client 进行监控，以确保它们正常运行。
Eureka Client 则是一个轻量级的 Java 客户端，用于将自己注册到 Eureka Server 并获取所依赖服务的信息。他们使用轮询来访问 Eureka Server 来达到负载均衡的目的。 另外，它还会缓存 Eureka Server 中的服务列表信息，当服务端不能访问时可以快速切换到本地缓存服务列表模式，尽可能降低系统的开销。
具体流程如下
Eureka Client 启动后，会向 Eureka Server 发送一个注册请求，包含了该客户端所提供的服务实例、IP 地址、端口号等元数据。
Eureka Server 接收到注册请求后，会将该客户端所提供的服务实例信息记录到自身的内存中，同时将变更信息广播给其他的 Eureka Server 节点，以实现服务注册中心的高可用和服务同步。
Eureka Client 通过 “心跳” 机制定期向 Eureka Server 发送请求，以更新服务健康状态、刷新缓存等操作。如果在一定时间内 Eureka Server 没有接收到“心跳”消息，则会将该客户端实例从注册列表中摘除。
Eureka Client 还可以通过发送 RESTful API 请求来查询可用的服务节点信息，以实现负载均衡等功能。
Eureka 的核心对象是服务实例，每个服务实例都可以作为提供者向 Eureka Server 注册自己，同时也可以作为消费者从 Eureka Server 中获取所需服务的信息，从而实现服务发现和调用。
4. 注意
Eurek 已经停止维护 2.x 版本！
