Spring Cloud（五）Eureka 服务注册与发现

清疚 2023-03-04 08:27 9阅读 0赞

**Table of Contents**

1.Eureka VS Zookeeper

2.Eureka 组件

3.Eureka 服务搭建

4.服务模块入驻Eureka

5.Eureka 服务集群搭建

6.服务模块入驻Eureka集群

7.服务模块集群入驻Eureka集群

8.Eureka 服务发现 Discovery

9.Eureka 自我保护机制

--------------------

### 1.Eureka VS Zookeeper ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70][]

**1. Eureka保证AP**

Eureka服务器节点之间是对等的，只要有一个节点在，就可以正常提供服务。Eureka客户端的所有操作可能需要一段时间才能在Eureka服务器中反映出来，随后在其他Eureka客户端中反映出来。也就是说，客户端获取到的注册信息可能不是最新的，它并不保证强一致性

**2. Zookeeper保证CP**

Zookeeper集群中有一个Leader，多个Follower。Leader负责写，Follower负责读，ZK客户端连接到任何一个节点都是一样的，写操作完成以后要同步给所有Follower以后才会返回。如果Leader挂了，那么重新选出新的Leader，在此期间服务不可用。

**3. 为什么用Eureka**

分布式系统大都可以归结为两个问题：数据一致性和防止单点故障。而作为注册中心的话，即使在一段时间内不一致，也不会有太大影响，所以在A和C之间选择A是比较适合该场景的。

### 2.Eureka 组件 ###

*  **Eureka Client：**

一个Java客户端，用于简化与 Eureka Server 的交互（通常就是微服务中的客户端和服务端）

*  **Eureka Server：**

提供服务注册和发现的能力（通常就是微服务中的注册中心）服务在Eureka上注册，然后每隔30秒发送心跳来更新它们的租约。如果客户端不能多次续订租约，那么它将在大约90秒内从服务器注册表中剔除。注册信息和更新被复制到集群中的所有eureka节点。来自任何区域的客户端都可以查找注册表信息（每30秒发生一次）来定位它们的服务（可能在任何区域）并进行远程调用。

### 3.Eureka 服务搭建 ###

**1.pom文件**

<dependencies>
            
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.ak.demo</groupId>
                <artifactId>api-commons</artifactId>
                <version>${project.version}</version>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-actuator</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
            </dependency>
            
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
        </dependencies>

**2.application.yml**

server:
      port: 7001
    
    eureka:
      instance:
        hostname: localhost #eureka服务端的实例名称
      client:
        register-with-eureka: false  #false 表示不向注册中心注册自己
        fetch-registry: false #表示自己端就是注册中心，职责就是维护服务实例，并不需要去检索服务
        service-url:
          #设置与eureka server 交互的地址，查询服务和注册服务都需要依赖这个地址
          defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

**3.启动类**

@EnableEurekaServer
    @SpringBootApplication
    public class EurekaServer7001 {
        public static void main(String[] args) {
            SpringApplication.run(EurekaServer7001.class, args);
        }
    }

## ##

### 4.服务模块入驻Eureka ###

**1.pom文件**

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

**2.application.yml**

eureka:
      client:
        register-with-eureka: true #表示向注册中心注册自己 默认为true
        fetch-registry: true #是否从EurekaServer抓取已有的注册信息，默认为true,单节点无所谓,集群必须设置为true才能配合ribbon使用负载均衡
        service-url:
          defaultZone: http://localhost:7001/eureka/ # 入驻地址

**3.启动类**

@EnableEurekaClient
    @SpringBootApplication
    public class Payment8001 {
        public static void main(String[] args) {
            SpringApplication.run(Payment8001.class,args);
        }
    }

访问eureka：[http://localhost:7001/][http_localhost_7001]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 1][]

### 5.Eureka 服务集群搭建 ###

1.依照7001创建7002

2.修改C:\\Windows\\System32\\drivers\\etc下的hosts

127.0.0.1       eureka7001.com
    	127.0.0.1       eureka7002.com

3.7001 application.yml

server:
      port: 7001
    
    eureka:
      instance:
        hostname: eureka7001.com #eureka服务端的实例名称
      client:
        register-with-eureka: false  #false 表示不向注册中心注册自己
        fetch-registry: false #表示自己端就是注册中心，职责就是维护服务实例，并不需要去检索服务
        service-url:
          #设置与eureka server 交互的地址，查询服务和注册服务都需要依赖这个地址
          defaultZone: http://eureka7002.com:7002/eureka/

4.7002 application.yml

server:
      port: 7002
    
    eureka:
      instance:
        hostname: eureka7002.com #eureka服务端的实例名称
      client:
        register-with-eureka: false  #false 表示不向注册中心注册自己
        fetch-registry: false #表示自己端就是注册中心，职责就是维护服务实例，并不需要去检索服务
        service-url:
          #设置与eureka server 交互的地址，查询服务和注册服务都需要依赖这个地址
          defaultZone: http://eureka7001.com:7001/eureka/

5.互相注册，相互守望

[http://eureka7001.com:7001/][http_eureka7001.com_7001]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 2][]

[http://eureka7002.com:7002/][http_eureka7002.com_7002]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 3][]

### 6.服务模块入驻Eureka集群 ###

### 7.服务模块集群入驻Eureka集群 ###

1.依照8001创建8002

2.修改消费模块80调用URL

private final static String PAYMENT_URL = "http://PAYMENT-SERVICE";

3.消费模块开启负载均衡

@Configuration
    public class ApplicationContextConfig {
    
        @Bean
        @LoadBalanced //开启负载均衡
        public RestTemplate getRestTemplate(){
            return new RestTemplate();
        }
    }

4.actuator信息完善：修改服务名称和访问会出现IP信息

前：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 4][]

application.yml 修改

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 5][]

instance:
        instance-id: payment8002
        prefer-ip-address: true

后：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 6][]

### 8.Eureka 服务发现 Discovery ###

1.通过 DiscoveryClient  获取信息

@Resource
        private DiscoveryClient discoveryClient;
    
        @GetMapping("/discovery")
        public Object discovery(){
            List<String> services = discoveryClient.getServices();
            log.info("*******"+services);
            List<ServiceInstance> instances = discoveryClient.getInstances("PAYMENT-SERVICE");
            for (ServiceInstance instance : instances){
                log.info("******{},{},{},{}"
                        ,instance.getHost(),instance.getPort(),
                        instance.getInstanceId(),instance.getServiceId());
            }
            return discoveryClient;
        }

2.启动类增加 @EnableDiscoveryClient

@EnableDiscoveryClient
    @EnableEurekaClient
    @SpringBootApplication
    public class Payment8001 {
        public static void main(String[] args) {
            SpringApplication.run(Payment8001.class,args);
        }
    }

## ##

### 9.Eureka 自我保护机制 ###

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 7][]

**为什么会产生自我保护机制？**

为防止EurekaClient可以正常运行，但是与EurekaServer网络不同的情况下，EurekaServer不会立刻将EurekaClient服务剔除。

**什么是自我保护机制？**

默认情况下，当Eureka server在一定时间内没有收到实例的心跳，便会把该实例从注册表中删除（默认是90秒），但是，如果短时间内丢失大量的实例心跳，便会触发eureka server的自我保护机制。

比如在开发测试时，需要频繁地重启微服务实例，但是我们很少会把eureka server一起重启（因为在开发过程中不会修改eureka注册中心），当一分钟内收到的心跳数大量减少时，会触发该保护机制。可以在eureka管理界面看到Renews threshold和Renews(last min)，当后者（最后一分钟收到的心跳数）小于前者（心跳阈值）的时候，触发保护机制，会出现红色的警告：

EMERGENCY!EUREKA MAY BE INCORRECTLY CLAIMING INSTANCES ARE UP WHEN THEY'RE NOT.RENEWALS ARE LESSER THAN THRESHOLD AND HENCE THE INSTANCES ARE NOT BEGING EXPIRED JUST TO BE SAFE.

自我保护模式是一种应对网络异常的安全保护措施它的架构哲学是宁可同时保留所有微服务，也不忙保姆注销如何健康的微服务，使用自我保护模式，可以让Eureka集群更加健壮，稳定。

**禁止自我保护机制**

修改 eureka服务 application.xml

server:
        enable-self-preservation: false # 关闭自我保护机制 保证不可用服务及时清除
        eviction-interval-timer-in-ms: 2000 #间隔时间 2s

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 8][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 9][]

修改服务提供者 application.xml

# eureka客户端向服务端发送心跳的时间间隔 单位秒 默认30
        lease-renewal-interval-in-seconds: 1
        # eureka服务端在收到最后一次心跳后等待时间上限，单位秒 默认90，超时将剔除服务
        lease-expiration-duration-in-seconds: 2

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 10][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70]: /images/20230208/08b987d1939b4c46ac610b13b6cdd523.png
[http_localhost_7001]: http://localhost:7001/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 1]: /images/20230208/86e67b45554446888c04bd7fa32ad321.png
[http_eureka7001.com_7001]: http://eureka7001.com:7001/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 2]: /images/20230208/490abac68fb44dcd812aa58d4ae615ac.png
[http_eureka7002.com_7002]: http://eureka7002.com:7002/
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 3]: /images/20230208/b973875c142b40efa904367f590d7f97.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 4]: /images/20230208/4dc867038e8345788b96abb4e1d813fe.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 5]: /images/20230208/adc6079b5e5f48769ff972f9c20a7d48.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 6]: /images/20230208/99e79815f3f942108a98b7cb1e5b3ca9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 7]: /images/20230208/b07f81bbe27c46c4b11009f8c1b660fe.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 8]: /images/20230208/67a75f77fe524409add045a1421110fb.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 9]: /images/20230208/40df8e0bce3d40ab8b2086ac60139db2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjAzMjE5OQ_size_16_color_FFFFFF_t_70 10]: /images/20230208/22c53e82ddcd4b9e9d0a2a64a8823ee5.png