【Spring Cloud 系列 二】微服务注册与发现

一 服务发现简介

---

当我们在尝试使用微服务架构时，我们会将一个大的单应用拆解成多个独立自治的小服务，如果在没有服务发现的机制下，我们想要在服务之间进行通信，我们只能使用 hard code 的方式，将需要通信的服务的网络信息写在服务中。这样会导致一系列的问题：

• 使用场景有限：如果服务提供者的网络地址发生了变化，将会影响服务消费者。
• 无法动态收缩：在生产环境中，每个服务一般都会部署多个实例，从而实现容灾和负载均衡，硬编码则无法适应这种需求。

那么要解决这些问题，服务的消费者就需要有一个强大的服务发现机制，服务消费者使用这个机制获取服务提供者的网络信息。即使服务提供者的信息发生变化，服务消费者也无须修改配置文件。服务发现组件便提供了这种能力，在微服务架构中，服务发现组件是一个非常重要的组件。

服务发现架构图

1. 在各个服务在启动时，将自己的网络地址等信息注册到服务发现组件中，服务发现组件会存储这些信息。
2. 服务消费者可从服务发现组件中查询提供者到网络地址，并使用该地址调用服务提供者的接口。
3. 各个服务与服务发现组件使用一定机制（例如心跳机制）通信。服务发现组件如果长时间无法与某微服务实例通信，就会注销该实例。
4. 微服务网络地址发生变更时，会重新注册到微服务发现组件。

二 Eureka 简介

---

Eureka 是Netflix 开源到服务发现组件，本身是一个基于 REST 到服务，它包含 Server 和 Client 两部分。 Spring Cloud 将它集成在子项目 Spring Cloud Netflix 中来实现微服务到注册与发现。

三 Eureka 原理

---

Eureka 架构图

其中：

• Application Service 相当于服务提供者
• Application Client 相当于服务消费者
• Make Remote Call 相当于调用 RESTful API 的行为

Eureka 包含两个组件：Eureka Server 和 Eureka Client

• Eureka Server 提供服务发现的能力，各个微服务启动时，会向 Eureka Server 注册自己的信息，Eureka Server 会存储这些信息
• Eureka Client 是一个 Java 客户端，用于简化与 Eureka Server 的交互
• 微服务启动后会周期性（默认30秒）的向 Eureka Server 发送心跳以续约自己的“租期“
• 如果 Eureka Server 在一定时间内没有接收到某个服务实例到心跳，那么会注销该实例
• 默认情况下，Eureka Server 同时也是 Eureka Client，多个 Eureka Server 实例之间是通过复制的方式来实现服务注册表中数据的同步
• Eureka Client 会缓存注册表中的信息。无须微服务每次请求都查询 Eureka Server

四 编写 Eureka Server

---

1. 添加 eureka 依赖

<dependencies>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>
  </dependencies>

2. 在启动类上添加 @EnableEurekaServer 注解，声明这是一个 Eureka Server
3. 在配置文件application.yml中添加

server:
  port: 8761                    # 指定该Eureka实例的端口
eureka:
  client:
    registerWithEureka: false # 表示是否将自己注册到 Eureka Server ，默认为 true，由于当前应用就是 Eureka Server，所以设置为 false
    fetchRegistry: false # 表示是否从 Eureka Server 中获取注册信息，默认为 true，因为这是一个单节点到 Eureka Server，不需要同步其他到节点
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/ #设置与 Eureka Serve 交互到地址，查询和注册服务都需要依赖这个地址。默认是 http://localhost:8761/eureka/；多个地址可用逗号分隔

4. 访问 http://localhost:8761
   http://localhost:8761

五 将微服务注册到 Eureka Server 上

---

1. 在微服务应用中添加依赖

<dependencies>
    <dependency>
      <groupId>org.springframework.cloud</groupId>
      <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>
  </dependencies>

2. 在配置文件中添加

spring:
  application:
    name: microservice-provider-user   # 用于制动注册到 Eureka Server 上到应用名称
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
  instance:
    prefer-ip-address: true    # 将自己到 IP 注册到 Eureka Server 上，默认为 false，则表示注册微服务所在操作系统到 hostname 到 Eureka Server 上。

3. 启动类上添加 @EnableDiscoveryCilent 注解，声明这个是一个 Eureka Client。
4. 启动 服务发现组件APP 和 微服务客户端，访问 http://localhost:8761

http://localhost:8761

六 高可用

---

Eureka Server 可以通过运行多个实例并相互这次的方式实现高可用部署，Eureka Server 会彼此增量的同步信息，从而确保所有节点数据一致。

1. 在 hosts 中配置以下信息

127.0.0.1 peer1 peer2

2. 将 application.yml 配置中添加

spring:
  application:
    name: microservice-discovery-eureka-ha
---
spring:
  profiles: peer1                                 # 指定profile=peer1
server:
  port: 8761
eureka:
  instance:
    hostname: peer1                               # 指定当profile=peer1时，主机名是peer1
  client:
    serviceUrl:
      defaultZone: http://peer2:8762/eureka/      # 将自己注册到peer2这个Eureka上面去

---
spring:
  profiles: peer2
server:
  port: 8762
eureka:
  instance:
    hostname: peer2
  client:
    serviceUrl:
      defaultZone: http://peer1:8761/eureka/

3 将应用注册到 Eureka Server 上
在 application.yml 中添加

eureka:
  client:
    serviceUrl:
      defaultZone: http://peer1:8761/eureka/

示例代码