SpringCloud实战微服务之——服务发现与服务注册(二)-Eureka的简单使用

灰太狼 2022-05-29 03:47 207阅读 0赞

# 服务发现组件Eureka简介 #

服务发现组件可以使用ZK ，也可以使用Consul，之所以Eureka使用最多有如下的原因导致：

① Eureka来自生产环境。  
② Spring  Cloud对Eureka的支持很好。  
Eureka简介：  
Eureka是Netflix开发的服务发现组件，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的。Spring cloud将它集成在子项目spring-cloud-netflix中，以实现Spring Cloud的服务发现功能。  
Eureka 项目相当活跃，代码更新相当频繁。  
Eureka原理：(具体可以参考GitHub上Eureka的wiki [https://github.com/Netflix/eureka/wiki/Eureka-at-a-glance][https_github.com_Netflix_eureka_wiki_Eureka-at-a-glance])  
Region和Zone的关系：

![20180316111744614][]

Eureka的核心架构图如下：

![20180316112214542][]

上图是来自Eureka官方的架构图，大致描述了Eureka集群的工作过程。图描述的架构原理如下：  
\- Application Service 就相当于本书中的服务提供者（用户微服务），Application Client就相当于本书中的服务消费者（电影微服务）；  
\- Make Remote Call，可以简单理解为调用RESTful的接口；  
\- us-east-1c、us-east-1d等是zone，它们都属于us-east-1这个region；  
由图可知，Eureka包含两个组件：Eureka Server 和 Eureka Client。  
① Eureka Server提供服务注册服务，各个节点启动后，会在Eureka Server中进行注册，这样Eureka Server中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。  
② Eureka Client是一个Java客户端，用于简化与Eureka Server的交互，客户端同时也具备一个内置的、使用轮询（round-robin）负载算法的负载均衡器。  
在应用启动后，将会向Eureka Server发送心跳（默认周期为30秒）。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，Eureka Server将会从服务注册表中把这个服务节点移除（默认90秒）。  
Eureka Server之间将会通过复制的方式完成数据的同步。（详见Eureka高可用章节）  
Eureka还提供了客户端缓存的机制，即使所有的Eureka Server都挂掉，客户端依然可以利用缓存中的信息消费其他服务的API。  
综上，Eureka通过心跳检测、健康检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性。

# 服务发现与服务注册的实现 #

父pom.xml

<?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>
    
    	<groupId>com.liuxun.cloud</groupId>
    	<artifactId>microservice-spring-cloud</artifactId>
    	<version>0.0.1-SNAPSHOT</version>
    	<packaging>pom</packaging>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<modules>
    		<module>microservice-simple-provider-user</module>
    		<module>microservice-simple-consumer-movie</module>
    		<module>microservice-provider-user</module>
    		<module>microservice-consumer-movie</module>
    		<module>microservice-discovery-eureka</module>
    	</modules>
    
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>1.4.5.RELEASE</version>
    	</parent>
    
    	<dependencyManagement>
    		<dependencies>
    			<dependency>
    				<groupId>org.springframework.cloud</groupId>
    				<artifactId>spring-cloud-dependencies</artifactId>
    				<version>Camden.SR7</version>
    				<type>pom</type>
    				<scope>import</scope>
    			</dependency>
    		</dependencies>
    	</dependencyManagement>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>
    </project>

## 编写Eureka Server ##

注意：对于euraka-server而言，在application.properties或yml中需要配置  
eureka.client.register-with-eureka= false  
eureka.client.fetch-registry=false  
作用在于只把当前程序当做eureka-server 而不充当eureka-client的角色  
其次要配置Eureka注册中心的地址:  
eureka.client.service-url.defaultZone=http://localhost:8761/eureka  
然后需要在POM中添加spring-cloud-starter-eureka-server的依赖  
如果需要为注册中心配置登录认证还需要在application.properties中添加以下配置:  
security.basic.enabled=true  
security.user.name=liuxun  
security.user.password=123456  
eureka.client.service-url.defaultZone=http://liuxun:123456@localhost:8761/eureka  
同时还要再添加spring-boot-starter-security依赖  
最后需要为主程序添加注解  
在主程序上添加注解@EnableEurekaServer, 注意不存在@EnableDiscoveryServer  
具体代码如下：  
pom.xml

application.yml

security:
      basic:
        enabled: true
      user:
        name: liuxun
        password: 123456
    server:
      port: 8761
      
    eureka:
      client:
        healthcheck:
          enabled: true # 不是必须的
        register-with-eureka: false #防止将自身当做Eureka客户端
        fetch-registry: false       #防止将自身当做Eureka客户端
        service-url:
          defaultZone: http://liuxun:123456@localhost:8761/eureka #如果对注册中心登录授权，其用户名和密码要和上边一致

EurekaApplication.java

package com.liuxun.cloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    @SpringBootApplication
    @EnableEurekaServer
    public class EurekaApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(EurekaApplication.class, args);
    	}
    }

启动Eureka Server 访问注册中心如下：  
![20180316172546040][]

## 编写Eureka Client进行服务注册 ##

①首先需要添加spring-cloud-starter-eureka依赖，如下所示：

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

②然后在配置文件中配置注册中心地址  
eureka.client.service-url.defaultZone=http://liuxun:123456@localhost:8761/eureka  
③最后为主程序添加注解@EnableEurekaClient即可 ( @EnableEurekaClient 只适用于Eureka 相当于对@EnableDiscoveryClient的增强,  @EnableDiscoveryClient适用于所有)  
启动Eureka Server后再启动Eureka Client, 打开注册中心地址，效果如下：  
![20180319093231553][]

# Actuator实现监管 #

为Eureka Client添加actuator依赖  用来监管运行环境的相关信息  
<dependency>  
<groupId>org.springframework.boot</groupId>  
<artifactId>spring-boot-starter-actuator</artifactId>  
</dependency>  
启动后后台日志会出现很多访问相关环境信息的url

![20180320160508831][]  
访问测试：  
![20180320160644720][]

# 获取Eureka Client的相关信息 #

首先向控制器注入  
org.springframework.cloud.client.discovery.DiscoveryClient  
com.netflix.discovery.EurekaClient

代码示例如下：

@Autowired
    private UserRepository userRepository;
    @Autowired
    private EurekaClient eurekaClient;    
    
    @GetMapping("/eureka-instance")
    public String serviceUrl() {
    	InstanceInfo instance = this.eurekaClient.getNextServerFromEureka("MICROSERVICE-PROVIDER-USER", false);
    	return instance.getHomePageUrl();
    }
    @GetMapping("/instance-info")
    public ServiceInstance showInfo() {
    	ServiceInstance localServiceInstance = this.discoveryClient.getLocalServiceInstance();
    	return localServiceInstance;
    }

注意：调用的服务名称其实是 服务提供者的注册的主机名 应该和注册中心显示的一致，应该全部大写  
分别启动Eureka Server和User  
访问测试如下：![20180320161008316][]

![20180320161037581][]  
具体代码已上传至GitHub 地址:  [https://github.com/liuxun1993728/microservice-spring-cloud1][https_github.com_liuxun1993728_microservice-spring-cloud1]

[https_github.com_Netflix_eureka_wiki_Eureka-at-a-glance]: https://github.com/Netflix/eureka/wiki/Eureka-at-a-glance
[20180316111744614]: /images/20220529/5001b9caf1484c2292fca8a6632c5e31.png
[20180316112214542]: /images/20220529/9374d825538e4c8994a22a1b424aa37e.png
[20180316172546040]: /images/20220529/410c357f9acd4db3b8dc25956e889f23.png
[20180319093231553]: /images/20220529/5dfb7f2c1b21471298eccd64142f4d76.png
[20180320160508831]: /images/20220529/1b71d01be5ad4fe9967cafe8cb11276c.png
[20180320160644720]: /images/20220529/57d0efb9add142a4acdfb7adb66e451d.png
[20180320161008316]: /images/20220529/8a10322a56db48608a5c83bd2af2f0d2.png
[20180320161037581]: /images/20220529/781a739ad13c45dab9b9bb55b3c04eb1.png
[https_github.com_liuxun1993728_microservice-spring-cloud1]: https://github.com/liuxun1993728/microservice-spring-cloud1