[大数据]【SpringCloud】Eureka服务注册与发现、Eureka集群配置、微服务集群发布到Eureka

🔰 学习视频 🔰

尚硅谷SpringCloud框架开发教程(SpringCloudAlibaba微服务分布式架构丨Spring Cloud)

集数：15—27

🔰 学习格言 🔰

不在能知，乃在能行。

🔰 学习笔记 🔰

【Java】学习笔记汇总

一、基础知识

1.1 服务治理

Spring Cloud封装了Netflix 公司开发的Eureka模块来实现服务治理，在传统的rpc远程调用框架中，管理每个服务与服务之间依赖关系比较复杂，管理比较复杂，所以需要使用服务治理，管理服务与服务之间依赖关系，可以实现服务调用、负载均衡、容错等,实现服务发现与注册。

1.2 服务注册与发现

Eureka采用了CS的设计架构，Eureka Server 作为服务注册功能的服务器，它是服务注册中心。而系统中的其他微服务,使用Eureka的客户端连接到Eureka Server并维持心跳连接。这样系统的维护人员就可以通过Eureka Server 来监控系统中各个微服务是否正常运行。
在服务注册与发现中，有一个注册中心。 当服务器启动的时候，会把当前自己服务器的信息比如服务地址通讯地址等以别名方式注册到注册中心上。另-方(消费者|服务提供者)，以该别名的方式去注册中心上获取到实际的服务通讯地址，然后再实现本地RPC调用RPC远程调用框架核心设计思想:在于注册中心,因为使用注册中心管理每个服务与服务之间的一个依赖关系(服务治理概念)。在任何rpc远程框架中，都会有一个注册中心(存放服务地址相关信息(接口地址))

1.3 Eureka两个组件

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

Eureka Server提供服务注册服务,各个微服务节点通过配置启动后，会在EurekaServer中进行注册， 这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观看到。

EurekaClient通过注册中心进行访问是一个Java客户端，用于简化Eureka Server的交互，客户端同时也具备一个内置的、 使用轮询(round-robin)负载算法的负载均衡器。在应用启动后,将会向Eureka Server发送心跳(默认周期为30秒)。如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，EurekaServer将 会从服务注册表中把这个服务节点移除(默认90秒)

二、Eureka服务端

2.1 项目创建

创建maven项目，或者springboot项目。

2.1.1 pom.xml

添加Eureka的server依赖，以及其他相关依赖。

<dependencies>
    <!--eureka-server-->
    <dependency>
        <groupId>org.springframework.cloud</groupId>
        <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
    </dependency>
    <dependency>
        <groupId>com.zqc.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>
        <optional>true</optional>
    </dependency>
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-test</artifactId>
        <scope>test</scope>
    </dependency>
</dependencies>

2.1.2 application.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/

2.1.3 主启动类

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;

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

运行启动访问：http://localhost:7001/

2.2 注册服务

2.2.1 pom.xml

在需要注册的微服务内修改pom.xml，添加Eureka的client依赖。

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

2.2.2 application.yml

eureka:
  client:
    # 表示将自己注册进EurekaServer 默认为true
    register-with-eureka: true
    # 从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
    fetch-registry: true
    service-url:
      # 设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址
      defaultZone: http://localhost:7001/eureka

2.2.3 主启动类

在主启动类上添加注解：

@EnableEurekaClient

2.2.4 运行

运行两个注册的微服务，访问http://localhost:7001/可以看到：

两个微服务为前一章节的支付模块和订单模块。

三、Eureka集群搭建

3.1 概念

解决办法: 搭建Eureka注册中心集群,实现负载均衡+故障容错

3.2 构建步骤

3.2.1 修改映射配置

找到C:\Windows\System32\drivers\etc下的host文件，配置本地dns，添加以下内容：

# SpringCloud2021
127.0.0.1	eureka7001.com
127.0.0.1	eureka7002.com

刷新host文件：ipconfig/flushdns

3.2.2 新建子项目

新建子工程cloud-eureka-server7002，构建步骤参考支付模块和订单模块内的支付模块cloud-eureka-server7001。

修改7001的配置application.yml

server:
  port: 7001

eureka:
  instance:
    hostname: eureka7001.com   # eureka服务端的实例名称
  client:
    register-with-eureka: false   # false表示不向注册中心注册自己
    fetch-registry: false   # false表示自己就是注册中心，职责就是维护服务实例，并不需要去检索服务
    service-url:
      defaultZone: http://eureka7002.com:7002/eureka/

修改7002的配置application.yml

server:
  port: 7002

eureka:
  instance:
    hostname: eureka7002.com   # eureka服务端的实例名称
  client:
    register-with-eureka: false   # false表示不向注册中心注册自己
    fetch-registry: false   # false表示自己就是注册中心，职责就是维护服务实例，并不需要去检索服务
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/

3.3 启动测试

🔶 步骤1：启动cloud-eureka-server7001和cloud-eureka-server7002.

🔶 步骤2：浏览器访问http://localhost:7001/或http://eureka7001.com:7001/，可查看到：

🔶 步骤2：浏览器访问http://localhost:7002/或http://eureka7002.com:7002/，可查看到：

说明配置、启动成功。

四、微服务发布到Eureka集群

修改微服务的application.yml的eureka配置为

eureka:
  client:
    # 表示将自己注册进EurekaServer 默认为true
    register-with-eureka: true
    # 从EurekaServer抓取已有的注册信息，默认为true。单节点无所谓，集群必须设置为true才能配合ribbon使用负载均衡
    fetch-registry: true
    service-url:
      # 设置与Eureka Server交互的地址查询服务和注册服务都需要依赖这个地址
      # defaultZone: http://localhost:7001/eureka
      defaultZone: http://eureka7001.com:7001/eureka,http://eureka7002.com:7002/eureka  # 集群版本

启动时要注意，先启动Eureka集群7001和7002，再启动80、8001微服务。

五、支付服务集群配置

5.1 新建子项目

🔶 步骤1：新建子工程cloud-provider-payment8001，构建步骤参考支付模块和订单模块内的支付模块cloud-provider-payment8002。

🔶 步骤2：修改配置文件application.yml中的端口号

🔶 步骤3：修改controller代码，使其在完成调用时显示当前的端口号。

代码如下：

import com.zqc.springcloud.entities.CommonResult;
import com.zqc.springcloud.entities.Payment;
import com.zqc.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;

@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, "插入数据库失败, serverPort:" + serverPort, 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 + " serverPort:" + serverPort, null);
        }
    }
}

5.3 修改订单项目

🔶 修改订单项目的配置类ApplicationContextConfig，负载均衡

使用@LoadBalanced注解赋予RestTemplate负载均衡能力。

🔶 修改订单项目的OrderController，请求的地址不能写死。

5.4 运行项目

🔶 启动

依次启动：

可查看到微服务cloud-payment-service的数量为2。

🔶 测试

访问：http://localhost:8001/payment/get/1

{"code":200,"message":"查询成功, serverPort:8001","data":{"id":1,"serial":"xxxx"}}

访问：http://localhost:8002/payment/get/1

{"code":200,"message":"查询成功, serverPort:8002","data":{"id":1,"serial":"xxxx"}}

访问：http://localhost/consumer/payment/get/1

{"code":200,"message":"查询成功, serverPort:8001","data":{"id":1,"serial":"xxxx"}}
刷新，交替先显示
{"code":200,"message":"查询成功, serverPort:8002","data":{"id":1,"serial":"xxxx"}}

六、actutor微服务信息完善

修改8001和8002的配置文件application.yml

修改完成后运行8001、8002，可在Eureka查看到实例名，鼠标悬浮时可以看到ip地址。

七、服务发现Discovery

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

在8001中PaymentController中添加代码：

@Resource
private DiscoveryClient discoveryClient;

@GetMapping(value = "/payment/discovery")
public Object discovery() {
    List<String> services = discoveryClient.getServices();
    for (String service : services) {
        log.info("----------service:" + service);
    }
	// 根据应用名获取实例
    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;
}

主启动类上添加注解：@EnableDiscoveryClient

访问：http://localhost:8001/payment/discovery

{"services":["cloud-payment-service","cloud-order-service"],"order":0}

控制台输出（这个ip地址不准确，也不知道为什么）

八、Eureka自我保护

🔶 介绍

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

如果在Eureka Server的首页看到以下这段提示，则说明Eureka进入了保护模式:

🔶 为什么会产生Eureka自我保护机制?

为了保证EurekaClient可以正常运行，但是与EurekaServer网络不通情况下，EurekaServer不会立刻将EurekaClient服务剔除

🔶 什么是自我保护模式?

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

🔶 禁用自我保护

https://www.bilibili.com/video/BV18E411x7eT?p=26