【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>
  1. 在启动类上添加 @EnableEurekaServer 注解,声明这是一个 Eureka Server
  2. 在配置文件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/;多个地址可用逗号分隔
  1. 访问 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>
  1. 在配置文件中添加
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 上。
  1. 启动类上添加 @EnableDiscoveryCilent 注解,声明这个是一个 Eureka Client。
  2. 启动 服务发现组件APP 和 微服务客户端,访问 http://localhost:8761
http://localhost:8761

六 高可用


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

  1. 在 hosts 中配置以下信息
127.0.0.1 peer1 peer2
  1. 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/

示例代码

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
【社区内容提示】社区部分内容疑似由AI辅助生成,浏览时请结合常识与多方信息审慎甄别。
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

相关阅读更多精彩内容

友情链接更多精彩内容