1.Eureka基础知识

1.1什么是服务治理？

Spring Cloud 封装了 Netflix 公司开发的 Eureka 模块来实现服务治理

在传统的rpc远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，管理比较复杂，所以需要使用服务治理，管理服务于服务之间依赖关系，可以实现服务调用、负载均衡、容错等，实现服务发现与注册。

1.2什么是服务注册？

Eureka采用了CS的设计架构，Eureka Server 作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务，使用 Eureka的客户端连接到 Eureka Server并维持心跳连接。这样系统的维护人员就可以通过 Eureka Server 来监控系统中各个微服务是否正常运行。

在服务注册与发现中，有一个注册中心。当服务器启动的时候，会把当前自己服务器的信息 比如 服务地址通讯地址等以别名方式注册到注册中心上。另一方（消费者|服务提供者），以该别名的方式去注册中心上获取到实际的服务通讯地址，然后再实现本地RPC调用RPC远程调用框架核心设计思想：在于注册中心，因为使用注册中心管理每个服务与服务之间的一个依赖关系(服务治理概念)。在任何rpc远程框架中，都会有一个注册中心(存放服务地址相关信息(接口地址))

下左图是Eureka系统架构，右图是Dubbo的架构，请对比：

1.3Eureka组件

Eureka包含两个组件：Eureka Server和Eureka Client

• Eureka Server提供服务注册服务
  各个微服务节点通过配置启动后，会在EurekaServer中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观看到
• Eureka Client通过注册中心进行访问
  是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。在应用启动后，将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将会从服务注册表中把这个服务节点移除（默认90秒）

2.单机Eureka构建步骤

2.1IDEA生成eurekaServer服务端注册中心

1. 建Module

   建立cloud-eureka-server7001

   

2. 改POM

   现在新版本（当前使用2020.2）
   <dependency>
       <groupId>org.springframework.cloud</groupId>
       <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
   </dependency>
   

   <?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>
       <parent>
           <groupId>com.atguigu.springcloud</groupId>
           <artifactId>cloud2022</artifactId>
           <version>1.0-SNAPSHOT</version>
       </parent>
   
       <artifactId>cloud-eureka-server7001</artifactId>
   
       <properties>
           <maven.compiler.source>8</maven.compiler.source>
           <maven.compiler.target>8</maven.compiler.target>
           <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
       </properties>
   
       <dependencies>
           <!--eureka-server-->
           <dependency>
               <groupId>org.springframework.cloud</groupId>
               <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
           </dependency>
           <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
           <dependency>
               <groupId>com.atguigu.springcloud</groupId>
               <artifactId>cloud-api-common</artifactId>
               <version>${project.version}</version>
           </dependency>
           <!--boot web actuator-->
           <dependency>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-starter-web</artifactId>
           </dependency>
           <!--图形监控，以后的swagger和Hystrix要用的-->
           <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>
   </project>
   

3. 写YML

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

4. 主启动

   package com.atguigu.springcloud;
   
   import org.springframework.boot.SpringApplication;
   import org.springframework.boot.autoconfigure.SpringBootApplication;
   import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
   
   /**
    * 简要描述
    *
    * @Author: ASuLe
    * @Date: ${DATE} ${TIME}
    * @Version: 1.0
    * @Description: 文件作用详细描述....
    */
   @SpringBootApplication
   //@EnableEurekaServer表明是服务注册中心
   @EnableEurekaServer
   public class EurekaMain7001 {
       public static void main(String[] args) {
           SpringApplication.run(EurekaMain7001.class,args);
       }
   }
   

5. 测试
   
   

2.2EurekaClient端cloud-provider-payment8001，将注册进EurekaServer成为服务提供者provider

1. 改POM

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

   

2. 写YML
   添加

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

   

3. 主启动
   添加

   @EnableEurekaClient
   

   

4. 测试
   先要启动EurekaServer
   访问http://localhost:7001/
   微服务注册名配置说明
   

5. 自我保护机制

2.3EurekaClient端cloud-provider-order80，将注册进EurekaServer成为服务消费者consumer

1. 改POM

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

   

2. 写YML
   添加

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

   

3. 主启动
   添加

   @EnableEurekaClient
   

   

4. 测试
   

2.4bug

Failed to bind properties under ‘eureka.client.service-url’ to java.util.Map<java.lang.String, java.lang.String>

3.集群Eureka构建步骤

3.1Eureka集群原理说明

问题：微服务RPC远程服务调用最核心的是什么
答案: 高可用，试想你的注册中心只有一个，如果出故障那就g了，会导致整个环境不可用
解决办法： 搭建Eureka注册中心集群，实现负载均衡+故障容错

3.2EurekaServer集群环境构建步骤

1. 新建cloud-eureka-server7002

2. 改POM

   <?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>
       <parent>
           <groupId>com.atguigu.springcloud</groupId>
           <artifactId>cloud2022</artifactId>
           <version>1.0-SNAPSHOT</version>
       </parent>
   
       <artifactId>cloud-eureka-server7002</artifactId>
   
       <properties>
           <maven.compiler.source>8</maven.compiler.source>
           <maven.compiler.target>8</maven.compiler.target>
           <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
       </properties>
   
       <dependencies>
           <!--eureka-server-->
           <dependency>
               <groupId>org.springframework.cloud</groupId>
               <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
           </dependency>
           <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
           <dependency>
               <groupId>com.atguigu.springcloud</groupId>
               <artifactId>cloud-api-common</artifactId>
               <version>${project.version}</version>
           </dependency>
           <!--boot web actuator-->
           <dependency>
               <groupId>org.springframework.boot</groupId>
               <artifactId>spring-boot-starter-web</artifactId>
           </dependency>
           <!--图形监控，以后的swagger和Hystrix要用的-->
           <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>
   </project>
   

3. 修改映射配置
   单机情况
   

   单机叫localhost，地址是自己的地址，但目前是集群，如果都叫localhost，就会重名，需要修改C:\Windows\System32\drivers\etc下的host文件
   并且相互守望相互注册，就应该把7001注册到7002，把7002注册到7001

   

4. 写YML（以前单机）
   修改7001

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

   编写7002

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

5. 主启动

   package com.atguigu.springcloud;
   
   import org.springframework.boot.SpringApplication;
   import org.springframework.boot.autoconfigure.SpringBootApplication;
   import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
   
   /**
    * 简要描述
    *
    * @Author: ASuLe
    * @Date: ${DATE} ${TIME}
    * @Version: 1.0
    * @Description: 文件作用详细描述....
    */
   @SpringBootApplication
   //@EnableEurekaServer表明是服务注册中心
   @EnableEurekaServer
   public class EurekaMain7002 {
       public static void main(String[] args) {
           SpringApplication.run(EurekaMain7002.class,args);
       }
   }
   

   启动注册中心集群
   eureka7001
   eureka7002
   

3.3将支付服务8001微服务发布到上面2台Eureka集群配置中

修改YML

defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  

3.4将订单服务80微服务发布到上面2台Eureka集群配置中

修改YML

defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  

3.5第一次测试

先启动7001，再启动7002，再启动8001，再启动80

3.6支付服务提供8001集群环境构建

1. 新建cloud-provider-payment8002

2. 改POM

   <?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>
       <parent>
           <groupId>com.atguigu.springcloud</groupId>
           <artifactId>cloud2022</artifactId>
           <version>1.0-SNAPSHOT</version>
       </parent>
   
       <artifactId>cloud-provider-payment8002</artifactId>
   
       <properties>
           <maven.compiler.source>8</maven.compiler.source>
           <maven.compiler.target>8</maven.compiler.target>
           <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
       </properties>
   
       <dependencies>
           <!--eureka client-->
           <dependency>
               <groupId>org.springframework.cloud</groupId>
               <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
           </dependency>
           <!-- 引入自己定义的api通用包，可以使用Payment支付Entity -->
           <dependency>
               <groupId>com.atguigu.springcloud</groupId>
               <artifactId>cloud-api-common</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>
           <!--mysql-connector-java-->
           <dependency>
               <groupId>mysql</groupId>
               <artifactId>mysql-connector-java</artifactId>
           </dependency>
           <!--jdbc-->
           <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>
   

3. 写YML

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

4. 主启动

   package com.atguigu.springcloud;
   
   import org.springframework.boot.SpringApplication;
   import org.springframework.boot.autoconfigure.SpringBootApplication;
   import org.springframework.cloud.netflix.eureka.EnableEurekaClient;
   
   /**
    * 简要描述
    *
    * @Author: ASuLe
    * @Date: 2023/1/11 16:31
    * @Version: 1.0
    * @Description: 文件作用详细描述....
    */
   @SpringBootApplication
   @EnableEurekaClient
   public class PaymentMain8002 {
       public static void main(String[] args) {
           SpringApplication.run(PaymentMain8002.class,args);
       }
   }
   
   

5. 业务类
   直接复制8001
   

   当前8001和8002对外暴露都是同一个名字cloud-payment-service
   如何作出区分？看下一步

   

6. 修改8001/8002的Controller
   在8001和8002的controller中添加代码

   默认的负载均衡方式就是轮询

   @Value("${server.port}")
   private String serverPort;
   

   

3.7负载均衡

• 订单服务不能写死

• 对业务类的处理就是负载均衡的实现

• 使用@LoadBalanced注解赋予RestTemplate负载均衡的能力
  ApplicationContextConfig添加@LoadBalanced注解

  package com.atguigu.springcloud.config;
  
  import org.springframework.cloud.client.loadbalancer.LoadBalanced;
  import org.springframework.context.annotation.Bean;
  import org.springframework.context.annotation.Configuration;
  import org.springframework.web.client.RestTemplate;
  
  /**
   * 简要描述
   *
   * @Author: ASuLe
   * @Date: 2023/1/11 20:34
   * @Version: 1.0
   * @Description: 文件作用详细描述....
   */
  @Configuration
  public class ApplicationContextConfig {
  
      //@Bean相当于applicationContext.xml <bean id="" class=""/>
      @Bean
      //使用了@LoadBalanced注解赋予了RestTemplate负载均衡的能力
      @LoadBalanced
      public RestTemplate getRestTemplate(){
          return new RestTemplate();
      }
  
  }
  
  

  

• ApplicationContextBean

3.8第二次测试

payment自己访问

如果使用80去访问

第一次访问

问题： 多次刷新之后还是8001端口，虽然程序跑通了，但是业务逻辑还是不合适，只提供了一台端口为8001的机器
答案： 80中端口是写死的

在80中将写死的地址修改为微服务名称，即CLOUD-PAYMENT-SERVICE

修改80的控制层

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

重新启动80，刷新之后，页面500

问题： 对外暴露只有CLOUD-PAYMENT-SERVICE这一个微服务名称，80通过eureka找到这个名称，可是这个微服务下面可能有2、3、甚至多个服务端端口，而此时让80去使用微服务名称访问，80不知道是哪个一个服务端提供的服务。
解决： 此时需要开启RestTemplate的负载均衡功能，即3.7负载均衡功能的第三点

再次测试
第一次刷新

第二次刷新

4.actuator微服务信息完善

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

当前问题： 服务含有主机名称，想要只暴露服务名，不暴露主机名

在8001和8002YML中新增

instance:
  instance-id: payment8001

修改完成之后重启，刷新页面

actuator健康检查查看状态

4.2访问信息有IP信息提示

当前问题： 鼠标停留，无IP信息显示

在8001和8002YML中新增

prefer-ip-address: true     #访问路径可以显示IP地址

修改完成之后重启，刷新页面
成功显示IP

5.服务发现Discovery

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

5.2修改cloud-provider-payment8001的Controller

增加代码

@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-SERVICE");
    for (ServiceInstance instance : instances) {
        log.info(instance.getServiceId() + "\t" + instance.getHost() + "\t" + instance.getPort() + "\t" + instance.getUri());
    }
    return this.discoveryClient;
}

5.3cloud-provider-payment8001的主启动类

添加注解

@EnableDiscoveryClient

5.4自测

6.eureka自我保护

6.1故障现象

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

6.2导致原因

问题：为什么会产生Eureka自我保护机制？

**答案：**为了防止EurekaClient可以正常运行，但是 与 EurekaServer网络不通情况下，EurekaServer不会立刻将EurekaClient服务剔除

问题：什么是自我保护模式？

答案： 默认情况下，如果EurekaServer在一定时间内没有接收到某个微服务实例的心跳，EurekaServer将会注销该实例（默认90秒）。但是当网络分区故障发生(延时、卡顿、拥挤)时，微服务与EurekaServer之间无法正常通信，以上行为可能变得非常危险了——因为微服务本身其实是健康的，此时本不应该注销这个微服务。Eureka通过“自我保护模式”来解决这个问题——当EurekaServer节点在短时间内丢失过多客户端时（可能发生了网络分区故障），那么这个节点就会进入自我保护模式。

在自我保护模式中，Eureka Server会保护服务注册表中的信息，不再注销任何服务实例。

它的设计哲学就是宁可保留错误的服务注册信息，也不盲目注销任何可能健康的服务实例。一句话讲解：好死不如赖活着。

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

一句话： 某时刻某一个微服务不可用了，Eureka不会立刻清理，依旧会对该微服务的信息进行保存

属于CAP里面的AP分支

6.3怎么禁止自我保护（单机版示例）

注册中心eurekaServer端7001

1. 出厂默认，自我保护机制是开启的

   eureka.server.enable-self-preservation=true
   

2. 禁用自我保护模式
   增加YML配置

server:
  #关闭自我保护机制，保证不可用服务被及时踢除
  enable-self-preservation: false
  eviction-interval-timer-in-ms: 2000

3. 关闭效果
   

生产者客户端eurekaClient端8001

默认配置

eureka.instance.lease-renewal-interval-in-seconds=30 #单位为秒(默认是30秒)
eureka.instance.lease-expiration-duration-in-seconds=90 #单位为秒(默认是90秒)

设置

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

成功注册到7001

假设8001宕机（手动关闭8001）

默认情况下： 注册中心还会有信息

现在，马上被删除了

7.Eureka停更说明

Eureka的GitHub

SpringCloud整合Zookeeper代替Eureka