三、微服务的注册与发现

发表于 | 分类于

Eureka简介

Eureka是Netflix（一家在线影片租赁提供商）开源的服务发现组件，本身是一个基于REST的服务。它包含Server和Client两部分。Spring Cloud将它集成在子项目Spring Cloud Netflix中，从而实现微服务的注册与发现。

Eureka原理

  • Eureka Server提供服务注册服务，各个节点启动后，会在Eureka Server中注册自己的信息（例如IP、端口、微服务名称等），这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。
  • Eureka Client是一个java客户端，用于简化与Eureka Server的交互，客户端同时也就别一个内置的、使用轮询(round-robin)负载算法的负载均衡器。
  • 在应用启动后，将会向Eureka Server发送心跳，默认周期为30秒，如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)。
  • 默认情况下，Eureka Server同时也是Eureka Client。多个Eureka Server实例之间通过复制的方式完成服务注册表中数据的同步。
  • Eureka还提供了客户端缓存机制，微服务无需每次请求都查询Eureka Server，从而降低Eureka Server的压力；其次，即使所有的Eureka Server都宕掉，客户端依然可以利用缓存中的信息消费其他服务的API。
    综上，Eureka通过心跳检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性

编写Eureka Server

创建Spring Boot项目

引入以下依赖

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

编写启动类

在启动类上添加@EnableEurekaServer注解，声明这是一个Eureka Server。

1
2
3
4
5
6
7
@SpringBootApplication
@EnableEurekaServer
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class, args);
    }
}

在配置文件application.yml中添加一下内容

1
2
3
4
5
6
7
8
server:
  port: 8761 # 指定该Eureka实例的端口
eureka:
  client:
    registerWithEureka: false       #表示是否将自己注册到Eureka Server,默认为true
    fetchRegistry: false            #表示是否从Eureka Server获取注册信息，默认为true
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/      #设置与Eureka Server交互的地址，多个地址见可用,分隔

这样一个Eureka Server就编写完成了。

将微服务注册到Eureka Server上

在pom.xml中添加以下依赖

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

在配置文件application.yml中添加以下配置

1
2
3
4
5
6
7
8
9
spring:
  application:
    name: application-name
eureka:
  client:
    serviceUrl:
      defaultZone: http://localhost:8761/eureka/
  instance:
    prefer-ip-address: true   #表示将自己的IP注册到Eureka Server，默认为false,表示注册微服务所在操作系统的hostname到Eureka Server

编写启动类

1
2
3
4
5
6
7
@EnableDiscoveryClient
@SpringBootApplication
public class ProviderUserApplication {
    public static void main(String[] args) {
        SpringApplication.run(ProviderUserApplication.class, args);
    }
}

这样即可将微服务注册到Eureka Server上。
注意：
1.在Spring Cloud Edgware 之前，要想将微服务注册到Eureka Server或其他服务发现组件上，必须在启动类添加@EnableEurekaClient或@EnableDiscoveryClient
2.在Spring Cloud Edgware 以及更高版本中，只需要添加相关依赖，即可自动注册。
3.若不想将服务注册到Eureka Server，只需设置 spring.cloud.service-registry.auto-registration.enabled=false，或 @EnableDiscoveryClient(autoRegister = false) 即可。
4.@EnableEurekaClient和@EnableDiscoveryClient的区别：spring cloud中discovery service有许多种实现（eureka、consul、zookeeper等等），@EnableDiscoveryClient基于spring-cloud-commons, @EnableEurekaClient基于spring-cloud-netflix。
简单的话来说，就是如果选用的注册中心是eureka，那么就推荐@EnableEurekaClient，如果是其他的注册中心，那么推荐使用@EnableDiscoveryClient。

Eureka Server用户认证

在pom.xml文件中添加如下依赖

1
2
3
4
<dependency>
  <groupId>org.springframework.boot</groupId>
  <artifactId>spring-boot-starter-security</artifactId>
</dependency>

在application.yml中添加以下配置

1
2
3
4
5
6
security:
  basic:
    enabled: true # 开启基于HTTP basic的认证
  user:
    name: user # 配置登录的账号是user
    password: password123 # 配置登录的密码是password123

Server添加了基于HTTP basic的认证，如果不设置这段内容，账号默认：user，密码是一个随机值，该值会在启动是打印出来。

将 Eureka Server 中的eureka.client.serviceUrl.defaultZone
修改为http://user:password@EUREKA_HOST:EUREKA_PORT/eureka/ 的形式。

多网卡环境下的IP选择

忽略指定名称的网卡

1
2
3
4
5
6
7
8
9
spring:
  cloud:
    inetutils:
      ignored-interfaces:
        - docker0
        - veth.*
eureka:
  instance:
    prefer-ip-address: true

这样就可以忽略docker0网卡以及以veth开头的网卡

使用正则表达式，指定使用的网络地址

1
2
3
4
5
6
7
8
9
spring:
  cloud:
    inetutils:
      preferred-networks:
        - 192.168
        - 10.0
eureka:
  instance:
    prefer-ip-address: true

只使用站点本地地址

1
2
3
4
5
6
7
spring:
  cloud:
    inetutils:
      use-only-site-local-interfaces: true
eureka:
  instance:
    prefer-ip-address: true

手动指定IP地址

1
2
3
4
eureka:
  instance:
    prefer-ip-address: true
    ip-address: 127.0.0.1

Eureka Server的自我保护模式与健康检查

自我保护模式

当Eureka Server节点在短时间内丢失过多客户端时（可能发生了网络分区故障），那么这个节点就会进入自我保护模式。一旦进入该模式，Eureka Server就会保护服务注册表中的信息，不再删除服务注册表中的数据（即不会注销任何服务）。当网络故障恢复后，该Eureka Server节点会自动退 出自我保护模式。使用自我保护模式，可以让Eureka 集群更加健壮、稳定。

可以使用eureka.server.enable-self-preservation = false 禁用自我保护模式。

健康检查

1
2
3
4
eureka:
  client:
    healthcheck:
      enabled: true