Eureka注册与发现

快来打我* 2021-12-17 01:23 340阅读 0赞

Eureka是Netflix开发的服务发现框架，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的。SpringCloud将它集成在其子项目spring-cloud-netflix中，以实现SpringCloud的服务发现功能。

## 一、原理 ##

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70]  
EureKa采用C-S的设计架构，即包括了Eureka Server（服务端），EureKa client（客户端）。  
1)、**Eureka Server**：提供服务注册服务，各个节点启动后，会在Eureka Server中进行注册，包括主机与端口号、服务版本号、通讯协议等。这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。  
Eureka服务端支持集群模式部署，首尾相连形成一个闭环即可，集群中的的不同服务注册中心通过异步模式互相复制各自的状态，这也意味着在给定的时间点每个实例关于所有服务的状态可能存在不一致的现象;  
3)、**Eureka client**，在应用启动后，会向EuekaServer发送心跳（默认30秒），如果EUR额卡 Server在多个心跳周期内没有接受到某个节点的心跳，EureKa Server将会从服务注册表中将这个服务移出（默认90秒），主要处理服务的注册和发现;  
4)、**服务调用**,服务消费者在获取服务清单后，通过服务名可以获取具体提供服务的实例名和该实例的元数据信息。因为有这些服务实例的详细信息，所以客户端可以根据自己的需要决定具体调用哪个实例，在Ribbon中会默认采用轮询的方式进行调用，从而实现客户端的负载均衡;  
5)、EureKa Server 通过心跳链接， 相互复杂Client的注册信息；  
**环境要求：java 1.8 以上；Eureka 2.0的现有开源工作已经停止,只能用Eureka 1.x版本；**

## 二、SpringCloud Eureka的使用步骤 ##

## 2.1、Eureka Service端(服务端) ##

**1）pom文件**

<properties>
    		<java.version>1.8</java.version>
    		<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
    </properties>
    
    <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>
    	
    	<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
        </dependency>

**2）配置文件**  
application.properties

#服务端端口
    server.port=8761
    #服务端禁用注册
    eureka.client.register-with-eureka=false
    eureka.client.fetch-registry=false

**3）启用 EurekaServer**

@SpringBootApplication
    //通过注解启用
    @EnableEurekaServer
    public class EurekaServerApplication {
    	public static void main(String[] args) {
    		SpringApplication.run(EurekaServerApplication.class, args);
    	}
    }

3） EurekaServer 启动成功  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 1]

## 2.2、Eureka Clinet(服务提供端) ##

**1）pom文件**

<properties>
    		<java.version>1.8</java.version>
    		<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
    	</properties>
    		<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>
    	
    	<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-actuator</artifactId>
    	</dependency>
    	<dependency>
    			<groupId>org.springframework.cloud</groupId>
    			<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
        </dependency>

**2）配置文件**  
application.properties

#服务端口
    server.port=12345

bootstrap.properties

#应用名称
    spring.application.name=waiter-service

**3）启用 EurekaClient**  
@EnableDiscoveryClient 注解启用client

@SpringBootApplication
    @EnableDiscoveryClient
    public class WaiterServiceApplication implements WebMvcConfigurer {
    
    	public static void main(String[] args) {
    		SpringApplication.run(WaiterServiceApplication.class, args);
    	}
    	｝

**注意：在本地启用EurekaServer，本地EurekaClient不需要配置注册地址，默认会注册上EurekaServer**  
**4）验证启动结果**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 2]

## 2.3、Eureka Clinet(服务消费端) ##

**1）pom文件**

<properties>
    		<java.version>1.8</java.version>
    		<spring-cloud.version>Greenwich.SR1</spring-cloud.version>
    </properties>
    <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>
    
    <dependency>
    		<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-actuator</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.cloud</groupId>
    		<artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    </dependency>

**2）配置文件**  
application.properties

#服务端口0表示任意端口
    server.port=0

bootstrap.properties

#服务名称
    spring.application.name=customer-service

**3）启用 EurekaClient**  
restTemplate Bean上添加启用负载均衡注解 @LoadBalanced  
**在SpringCloud中默认启用Ribbon作为负载均衡中间件**

@SpringBootApplication
    @Slf4j
    @EnableDiscoveryClient
    public class CustomerServiceApplication {
    
    	public static void main(String[] args) {
    		SpringApplication.run(CustomerServiceApplication.class, args);
    	}
    
    	@Bean
    	public HttpComponentsClientHttpRequestFactory requestFactory() {
    		PoolingHttpClientConnectionManager connectionManager =
    				new PoolingHttpClientConnectionManager(30, TimeUnit.SECONDS);
    		connectionManager.setMaxTotal(200);
    		connectionManager.setDefaultMaxPerRoute(20);
    
    		CloseableHttpClient httpClient = HttpClients.custom()
    				.setConnectionManager(connectionManager)
    				.evictIdleConnections(30, TimeUnit.SECONDS)
    				.disableAutomaticRetries()
    				// 有 Keep-Alive 认里面的值，没有的话永久有效
    				//.setKeepAliveStrategy(DefaultConnectionKeepAliveStrategy.INSTANCE)
    				// 换成自定义的
    				.setKeepAliveStrategy(new CustomConnectionKeepAliveStrategy())
    				.build();
    
    		HttpComponentsClientHttpRequestFactory requestFactory =
    				new HttpComponentsClientHttpRequestFactory(httpClient);
    
    		return requestFactory;
    	}
    
    	@LoadBalanced  //此注解注解表示启用负载均衡
    	@Bean
    	public RestTemplate restTemplate(RestTemplateBuilder builder) {
    		return builder
    				.setConnectTimeout(Duration.ofMillis(100))
    				.setReadTimeout(Duration.ofMillis(500))
    				.requestFactory(this::requestFactory)
    				.build();
    	}
    }

调用已注册到Eureka服务，用服务名称，非域名+端口

private void readMenu() {
            ParameterizedTypeReference<List<Coffee>> ptr =
                    new ParameterizedTypeReference<List<Coffee>>() {};
            ResponseEntity<List<Coffee>> list = restTemplate
                    .exchange("http://waiter-service/coffee/", HttpMethod.GET, null, ptr);
            list.getBody().forEach(c -> log.info("Coffee: {}", c));
        }
       //waiter-service 表示服务提供方服务名称

**4）验证启动结果**  
消费端节点已经注册到Eureka  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 3]  
customer-service 服务通过域名调用到waiter-service  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 4]  
**注意：如果消费端不添加@LoadBalanced 注解， 则无法通过服务名称，调用到服务提供方；**

## 三、Eureka自我保护机制 ##

*  作用：保护由于网络原因，导致Eureka Server与大量服务之间丢失通信，将服务误删除的问题。
 *  原则：宁可保留无效服务，也不误剔除可用服务。（宁可放过一千，也不错杀一个）
 *  机制：Eureka运行期间会统计心跳失败比例，在15min内超过85%的客户端节点没有正常心跳，将注册信息保护起来，并进入保护模式，不再剔除服务。
 *  可通过 eureka.server.enable-self-preservation=false 关闭自我保护。（生产环境不推荐）。
 *  问题解决： 当Eureka进入保护模式，就无法真实感知服务的下线，可使用Ribbon的切换节点重试机制解决。

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70]: /images/20211214/d8cc492b8ba84fc892495fdc4d21b346.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 1]: /images/20211214/e0ee7be1113b480bb1a1f137083dc835.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 2]: /images/20211214/c61cdeb420334e7799228bf19a4fe055.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 3]: /images/20211214/ebded016f03949d2814d8aab1764be11.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2OTE4MTQ5_size_16_color_FFFFFF_t_70 4]: /images/20211214/b9302afe4c354b6094c6735c040eed45.png