Spring Cloud（三）：集群 Eureka 构建

悠悠 2022-10-23 11:10 150阅读 0赞

## 1. Eureka 集群构建 ##

### 1.1 Eureka 集群原理说明 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]

*  解决方案：搭建Eureka注册中心集群，实现负载均衡+故障容错

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 1]

### 1.2 建 Module ###

新建 cloud-eureka-server7002  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 2]

### 1.3 改pom ###

pom.xml

<dependencies>
       <dependency>
           <groupId>org.springframework.cloud</groupId>
           <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
       </dependency>
       <dependency>
           <groupId>com.lele.springcloud</groupId>
           <artifactId>cloud-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.projectlombok</groupId>
           <artifactId>lombok</artifactId>
       </dependency>
       <dependency>
           <groupId>org.springframework.boot</groupId>
           <artifactId>spring-boot-starter-test</artifactId>
           <scope>test</scope>
       </dependency>
       <dependency>
           <groupId>junit</groupId>
           <artifactId>junit</artifactId>
       </dependency>
    </dependencies>

### 1.4 yml ###

*  7001

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

*  7002

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

### 1.5 主启动 ###

package com.lele.springcloud;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
    
    /**
     * @author: lele
     * @date: 2021/3/5 21:13
     * @description:
     */
    @SpringBootApplication
    @EnableEurekaServer
    public class EurekaMain7002 {
        
        public static void main(String[] args) {
        
            SpringApplication.run(EurekaMain7002.class, args);
        }
    }

修改映射配置：  
找到C:\\Windows\\System32\\drivers\\etc路径下的hosts文件  
新增如下配置

127.0.0.1 eureka7001.com  
    127.0.0.1 eureka7002.com

### 1.6 测试 ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 3]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 4]

## 2. 将8001发布到两台Eureka服务中 ##

8001的yml文件修改为：

server:
      port: 8001
    
    spring:
      application:
        name: cloud-payment-service
      datasource:
        #当前数据源操作类型
        type: com.alibaba.druid.pool.DruidDataSource
        #mysql驱动包
        driver-class-name: org.gjt.mm.mysql.Driver
        url: jdbc:mysql://localhost:3306/spring-cloud?useUnicode=true&characterEncoding=utf-8&useSSL=false
        username: root
        password: root
    
    eureka:
      client:
        #表示是否将自己注册进EurekaServer默认为true
        register-with-eureka: true
        #是否从EurekaServer抓取已有的注册信息，默认为true，单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
        fetch-registry: true
        service-url:
          #defaultZone: http://localhost:7001/eureka
          defaultZone: http://eureka7001:7001/eureka,http://eureka7002.com:7002/eureka #集群版
    
    mybatis:
      mapperLocations: classpath:mapper/*.xml
      type-aliases-package: com.lele.springcloud.entities  #所有Entity别名类所在包

## 3. 将80发布到两台Eureka中 ##

80的yml文件修改为：

server:
      port: 80
    
    spring:
      application:
        name: cloud-order-service
    eureka:
      client:
        #表示是否将自己注册进EurekaServer，默认为true
        register-with-eureka: true
        #是否从EurekaServer抓取已有的注册信息，默认为true，单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
        fetch-registry: true
        service-url:
          #defaultZone: http://localhost:7001/eureka
          defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  #集群版

## 4. 测试 ##

*  先启动 7001、7002
 *  再启动8001
 *  最后启动80
 *  浏览器访问：eureka7001.com:7001 eureka7002.com:7002  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 5]  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 6]
 *  浏览器访问：http://localhost/consumer/payment/get/1  
    ![在这里插入图片描述][20210306101431112.png]

## 5. 支付微服务提供者8001集群构建 ##

参考 cloud-provider-payment8001 构建 cloud-provider-payment8002

### 5.1 新建 cloud-provider-payment8002 模块 ###

### 5.2 改pom（复制8001） ###

<?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">
        <parent>
            <artifactId>spring-cloud-demo</artifactId>
            <groupId>com.lele.springcloud</groupId>
            <version>1.0-SNAPSHOT</version>
        </parent>
        <modelVersion>4.0.0</modelVersion>
    
        <artifactId>cloud-provider-payment8002</artifactId>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.cloud</groupId>
                <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
            </dependency>
            
            <dependency>
                <groupId>com.lele.springcloud</groupId>
                <artifactId>cloud-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.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.1.10</version>
            </dependency>
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-jdbc</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-devtools</artifactId>
                <scope>runtime</scope>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.projectlombok</groupId>
                <artifactId>lombok</artifactId>
                <optional>true</optional>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-test</artifactId>
                <scope>test</scope>
            </dependency>
        </dependencies>
    
    </project>

### 5.3 主启动类 ###

*  复制8001的mapper到8002；
 *  复制 8001 Java目录下的所有文件到 8002；
 *  重命名 8002 的启动类名；

8001、8002启动类改为：

package com.lele.springcloud.controller;
    
    import com.lele.springcloud.entities.CommonResult;
    import com.lele.springcloud.entities.Payment;
    import com.lele.springcloud.service.PaymentService;
    import lombok.extern.slf4j.Slf4j;
    import org.springframework.beans.factory.annotation.Value;
    import org.springframework.web.bind.annotation.*;
    
    import javax.annotation.Resource;
    
    /**
     * @author: lele
     * @date: 2021/2/28 22:09
     * @description:
     */
    @RestController
    @Slf4j
    public class PaymentController {
        
    
        @Resource
        private PaymentService paymentService;
    
        @Value("${server.port}")
        private String serverPort;
    
        @PostMapping(value = "/payment/create")
        public CommonResult create(@RequestBody Payment payment) {
        
            int result = paymentService.create(payment);
            log.info("**********插入结果："+result);
    
            if (result > 0) {
        
                return new CommonResult(200, "插入数据库成功，serverPort:"+serverPort, result);
            } else {
        
                return new CommonResult(444, "插入数据失败", null);
            }
        }
    
        @GetMapping(value = "/payment/get/{id}")
        public CommonResult getPaymentById(@PathVariable("id") Long id) {
        
            Payment payment = paymentService.getPaymentById(id);
            log.info("**********插入结果："+payment);
    
            if (payment != null) {
        
                return new CommonResult(200, "查询成功，serverPort:"+serverPort, payment);
            } else {
        
                return new CommonResult(444, "没有对应记录，查询id：" +id, null);
            }
        }
    }

## 6. 负载均衡 ##

*  订单服务访问地址不能写死；
 *  改为：public static final String PAYMENT\_URL = “http://CLOUD-PAYMENT-SERVICE”;  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 7]
 *  使用@LoadBalanced注解赋予RestTemplate负载均衡的能力  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 8]

测试：  
先启动7001、7002  
在启动8001、8002  
启动80

浏览器访问：http://localhost/consumer/payment/get/1  
打印不同结果，负载均衡效果达到，8001/8002端口交替出现；

Ribbon和Eureka整合后Consumer可以直接调用服务而不用再关心地址和端口号，且该服务还有负载功能了。

## 7. actuator微服务信息完善 ##

*  主机名称：服务名称修改

instance-id: payment8002

*  访问信息有ip信息提示

prefer-ip-address: true

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 9]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 10]  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 11]

## 8. 服务发现 Discovery ##

对于注册进eureka里面的微服务，可以通过服务发现来获得该服务的信息。

修改cloud-provider-payment8001的Controller，新增如下内容：

*  PaymentController

@Resource
    private DiscoveryClient discoveryClient;
    
    @GetMapping(value = "/payment/discovery")
    public Object discovery() {
        
        List<String> services = discoveryClient.getServices();
        for (String element : services) {
        
            log.info("******element" + element);
        }
    
        List<ServiceInstance> instances = discoveryClient.getInstances("CLOUD-PAYMENT-SERVICES");
        for (ServiceInstance instance : instances) {
        
            log.info(instance.getServiceId() + "\t" + instance.getHost()+"\t"+instance.getPort()+"\t"+instance.getUri());
        }
    
        return this.discoveryClient;
    }

*  主启动类：

@EnableDiscoveryClient

先要启动EurekaServer，7001/7002服务  
再启动8001主启动类，需要稍等一会

http://localhost:8001/payment/discovery  
![在这里插入图片描述][20210307204035463.png]

## 9. Eureka 自我保护 ##

保护模式主要用于一组客户和 Eureka Server 之间存在网络分区场景下的保护。一旦进入保护模式，Eureka Server将会尝试保护其服务注册表中的信息，不再删除服务注册表中的数据，也就是不会注销任何微服务。

如果在 Eureka Server 的首页看到以下这段提示，则说明 Eureka 进入了保护模式。  
![在这里插入图片描述][20210307204930699.png]

**为什么会产生Eureka 自我保护机制？**  
为了防止 EurekaClient 可以正常运行，但是与 EurekaServer 网络不同的情况下，EurekaServer 不会立刻将EurekaClient服务剔除。

**什么是自我保护模式？**  
默认情况下，如果 EurekaServer 在一定时间内没有接收到某个微服务实例的心跳， EurekaServer 将会注销该实例（默认90秒）。但是当网络分区故障发生（延时、卡顿、拥挤）时，微服务与 EurekaServer 之间无法正常通信，以上行为可能变得非常危险了——因为微服务本身其实是健康的，此时不应该注销这个微服务。Eureka 通过 ”自我保护模式“ 来解决这个问题——当 EurekaServer 节点在短时间内丢失过多客户端时（可能发生了网络分区故障），那么这个节点就会进入自我保护模式。  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 12]  
在自我保护模式中，EurekaServer会保护服务注册表中的信息，不再注销任何服务实例。其设计哲学就是宁可保留错误的服务注册信息，也不盲目注销任何可能健康的服务实例。

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

某时刻某一个微服务不可用了，Eureka不会立刻清理，依旧会对该微服务的信息进行保存，属于CAP里面的AP分支。

**怎么禁止自我保护（一般生产环境中不会禁止自我保护）**  
出厂默认，自我保护机制是开启的

eureka.server.enable-self-preservation = true

使用eureka.server.enable-self-preservation = false可以禁用自我保护模式。  
7001 改为单机版并添加以下配置：

server:
        #关闭自我保护机制
        enable-self-preservation: false
        eviction-interval-timer-in-ms: 2000

8001 改为单机版并添加以下配置：

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

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 13]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70]: /images/20221023/e64a9f2b3f224aceb8289c641f1f5917.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 1]: /images/20221023/98734726d6884d7aabd13c0903d4cfff.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 2]: /images/20221023/0336f6d73ba2499c8e45559acd37eb8b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 3]: /images/20221023/8ad4b659b6b546459f53a3caa020e1a9.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 4]: /images/20221023/000528c2719845eab61763a8fed954c3.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 5]: /images/20221023/724ae369a26445dbb1b9563d15ab5b50.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 6]: /images/20221023/d4de8265fe5648db955531e232543dd3.png
[20210306101431112.png]: /images/20221023/96760ce03c3f4fe18f627000d759488a.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 7]: /images/20221023/df9cc40ce30b4cc599d5dd27630f47a0.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 8]: /images/20221023/47c838c8e8404cdc8e7e2c56203dcd30.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 9]: /images/20221023/95e0b6f8b76747c5a41b98bc603c9a7b.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 10]: /images/20221023/e2127de93888459bafefd186182c7dea.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 11]: /images/20221023/c97041f769b742649edf172f6231c663.png
[20210307204035463.png]: /images/20221023/3b0444acc0fc4f5ea1399f63f29f3982.png
[20210307204930699.png]: /images/20221023/d3de01b882db440b954f04bf59a96970.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 12]: /images/20221023/10b02c0b2ba845949d13e1235d691903.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hvdXdhbmxl_size_16_color_FFFFFF_t_70 13]: /images/20221023/7a6b2550df0a42beac7674278c97c987.png