您的位置：首页 > 编程语言 > Java开发

基于Spring Cloud教程微服务架构--服务中心Eureka

2018-11-07 14:59 162 查看

1. 构建服务中心

Spring Cloud Eureka 是 Spring Cloud Netflix 微服务套件中的一部分，它基于 Netflix Eureka 做了二次封装，主要负责完成微服务架构中的服务治理功能。
Spring Cloud 通过为 Eureka 增加了 Spring Boot 风格的自动化配置，我们只需通过简单引入依赖和注解配置就能让 Spring Boot 构建的微服务应用轻松地与 Eureka 服务治理体系进行整合。
– 服务注册：微服务向服务中心注册服务
– 服务发现：调用微服务时通过服务中心进行寻址（负载均衡，轮询机制等）

2. 服务注册与服务发现

Spring Cloud Eureka，使用 Netflix Eureka 来实现服务注册与发现，它既包含了服务端组件，也包含了客户端组件

Eureka 服务端，我们也称为服务注册中心。它同其他服务注册中心一样，支持高可用配置

Eureka 客户端，主要处理服务的注册与发现。客户端服务通过注解和参数配置的方式，嵌入在客户端应用程序的代码中，在应用程序运行时， Eureka 客户端向注册中心注册自身提供的服务并周期性地发送心跳来更新它的服务租约。

3. Eureka服务中心搭建

3.1 新建spring boot 项目

访问spring官网，进入https://spring.io/projects
进入Quick start，网址：https://start.spring.io/，选择Dependencies，加入Eureka Server，然后点击Generate Project，就会生成一个Spring Boot基础项目。

3.2 pom文件引入依赖

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>2.0.2.RELEASE</version>
<relativePath/> <!-- lookup parent from repository -->
</parent>

<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<java.version>1.8</java.version>
<spring-cloud.version>Finchley.RC2</spring-cloud.version>
</properties>

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

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
</dependencies>

<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.cloud</groupId>
<artifactId>spring-cloud-dependencies</artifactId>
<version>${spring-cloud.version}</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>

3.3 EurekaServerApplication.java代码

import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

@SpringBootApplication
@EnableEurekaServer
public class EurekaServerApplication {

public static void main(String[] args) {
new SpringApplicationBuilder(EurekaServerApplication.class).web(true).run(args);
}
}

3.3 Application.yml配置

server:
port: 8761

eureka:
instance:
hostname: localhost
client:
registerWithEureka: false
fetchRegistry: false
serviceUrl:
defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

3.4 Eureka信息面板

服务中心启动后，访问默认地址http://localhost:8761/

4. Eureka的服务治理机制

4.1服务提供者

服务注册：“服务提供者” 在启动的时候会通过发送 REST 请求的方式将自己注册到 Eureka Server 上，同时带上了自身服务的一些元数据信息。Eureka Server 接收到这个 REST 请求之后，将元数据信息存储在一个双层结构 Map 中；
服务同步：通过服务同步，两个服务提供者的服务信息就可以通过这两台服务注册中心中的任意一台获取到；
服务续约：在注册完服务之后，服务提供者会维护一个心跳用来持续告诉 Eureka Server:“ 我还活着”，以防止 Eureka Server 的“ 剔除任务” 将该服务实例从服务列表中排除出去，我们称该操作为服务续约（ Renew）。

关于服务续约有两个重要属性，我们可以关注并根据需要来进行调整：
leureka.instance.lease-renewal-interval-in-seconds = 30
leureka.instance.lease-expiration-duration-in-seconds = 90

4.2 服务消费者

获取服务：当我们启动服务消费者的时候，它会发送一个 REST 请求给服务注册中心，来获取上面注册的服务清单。为了性能考虑， Eureka Server 会维护一份只读的服务清单来返回给客户端，同时该缓存清单会每隔 30 秒更新一次。
服务调用：服务消费者在获取服务清单后，通过服务名可以获得具体提供服务的实例名和该实例的元数据信息。客户端可以根据自己的需要决定具体调用哪个实例，在 Ribbon 中会默认采用轮询的方式进行调用，从而实现客户端的负载均衡。
服务下线：所以在客户端程序中，当服务实例进行正常的关闭操作时，它会触发一个服务下线的 REST 请求给 Eureka Server，告诉服务注册中心：“ 我要下线了”。服务端在接收到请求之后，将该服务状态置为下线（ DOWN），并把该下线事件传播出去。

4.3 服务注册中心

失效剔除：Eureka Server 在启动的时候会创建一个定时任务，默认每隔一段时间（默认为 60 秒）将当前清单中超时（默认为 90 秒）没有续约的服务剔除出去。
自我保护：Eureka Server 在运行期间，会统计心跳失败的比例在 15 分钟之内是否低于 85%，如果出现低于的情况（在单机调试的时候很容易满足，实际在生产环境上通常是由于网络不稳定导致）, Eureka Server 会将当前的实例注册信息保护起来，让这些实例不会过期，尽可能保护这些注册信息。