栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 软件开发 > 后端开发 > Java

Spring Cloud-超详细讲解Eureka服务注册中心

Java 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

Spring Cloud-超详细讲解Eureka服务注册中心




哈喽!大家好,我是【一心同学】,一位上进心十足的Java邻域博主!

【一心同学】写作风格:喜欢用【通俗易懂】的文笔去讲解每一个知识点,而不喜欢用高大上的官方陈述。

如果有对【后端技术】感兴趣的小可爱,欢迎关注【一心同学】

【一心同学】正在参加【博客之星】

希望各位大佬能够投【五星】⭐ ⭐ ⭐ ⭐ ⭐给予【一心同学】,每一份投票都是【一心同学】的动力。

【一心同学】投票专区入口:https://bbs.csdn.net/topics/603956556 

❤️❤️❤️感谢各位大可爱小可爱!❤️❤️❤️ 


目录

前言

一、什么是服务注册?

二、什么是服务发现?

三、Eureka组件

3.1 Eureka Server

3.2 Eureka Client

四、搭建单机版Eureka Server

4.1 建立一个Maven父工程编写

4.1.1 建立子工程

4.2 配置服务注册中心springcloud-eureka-7001

4.3  配置springcloud-provider-blog-8001

4.3.1 配置

4.3.2 关于Status

4.3.3 Eureka自我保护机制

4.3.4 获取注册进来的微服务信息

4.4 配置springcloud-consumer-blog-80

五、搭建集群Eureka Server

结语


前言

服务治理是微服务架构中最为核心和基础的模块,它主要用来实现各个微服务实例的自动化注册和发现。

而Spring Cloud Eureka主要负责的就是完成微服务架构中的服务治理功能。

一、什么是服务注册?

(1)在服务治理框架中,通常都会构建一个注册中心,每个服务单元向注册中心登记自己提供的服务,包括服务的主机与端口号、服务版本号、通讯协议等一些附加信息。

(2)注册中心按照服务名分类组织服务清单,同时还需要以心跳检测的方式去监测清单中的服务是否可用,若不可用需要从服务清单中剔除,以达到排除故障服务的效果。

二、什么是服务发现?

(1)在服务治理框架下,服务间的调用不再通过指定具体的实例地址来实现,而是通过服务名发起请求调用实现。

(2)服务调用方通过服务名从服务注册中心的服务清单中获取服务实例的列表清单,通过指定的负载均衡策略取出一个服务实例位置来进行服务调用。

三、Eureka组件

Eureka包含两个组件:

  • Eureka Server
  • Eureka Client。

3.1 Eureka Server

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

(2)Eureka Server本身也是一个服务,默认情况下会自动注册到Eureka注册中心。

(3)Eureka Server通过Register、Get、Renew等接口提供服务的注册、发现和心跳检测等服务。

3.2 Eureka Client

(1)介绍

Eureka Client是一个java客户端,用于简化与Eureka Server的交互,客户端同时也具备一个内置的、使用轮询(round-robin)负载算法的负载均衡器。

(2)作用

在应用启动后,Eureka Client将会向Eureka Server发送心跳,默认周期为30秒,如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳,Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)。

(3)角色

Eureka Client分为两个角色,分别是:Service Provider和Service Consumer


Service Provider:
服务生产方,将自身服务注册到Eureka中,从而使服务消费方能够找到


Service Consumer:
服务消费方,从Eureka中获取注册服务列表,从而找到消费服务


综上所述,Eureka主要就是分为三大角色:

Eureka Server:既是一个注册中心,同时也是一个服务,提供服务的注册与发现。

Service Provider:服务生产方,将自身服务注册到Eureka中,从而使服务消费方能够找到。

Service Consumer:服务消费方,从Eureka中获取注册服务列表,从而找到消费服务。


一张图,直接理清三大角色的关系:

四、搭建单机版Eureka Server

4.1 建立一个Maven父工程编写


 

 
 org.springframework.cloud
 spring-cloud-alibaba-dependencies
 0.2.0.RELEASE
 pom
 import
 

 
 
 org.springframework.cloud
 spring-cloud-dependencies
 Hoxton.SR12
 pom
 import
 

 
 
 org.springframework.boot
 spring-boot-dependencies
 2.3.12.RELEASE
 pom
 import
 

 

 

4.1.1 建立子工程

注:同样是以Maven形式

springcloud-eureka-7001:服务注册中心

springcloud-provider-blog-8001:服务生产方

springcloud-consumer-blog-80:服务消费方

4.2 配置服务注册中心springcloud-eureka-7001


(1)建立目录如下


(2)编写pom.xml导入依赖

  
 
 
 
 
 org.springframework.cloud
 spring-cloud-starter-eureka-server
 1.4.6.RELEASE
 
 
 
 org.springframework.boot
 spring-boot-devtools
 
 

(3)编写配置文件application.yml

server:
  port: 7001
# Eureka配置
eureka:
  instance:
    # Eureka服务端的实例名字
    hostname: localhost
  client:
    # 表示是否向 Eureka 注册中心注册自己(这个模块本身是服务器,所以不需要)
    register-with-eureka: false
    # fetch-registry如果为false,则表示自己为注册中心,客户端的化为 ture
    fetch-registry: false
    # Eureka监控页面~
    service-url:
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
      #相当于:http://localhost:7001/eureka/

(4)编写Spring Boot启动器

注意:要在主启动器上方添加 @EnableEurekaServer表示 服务端的启动类,可以接受别人注册进来

package com.yixin.springcloud;
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.netflix.eureka.server.EnableEurekaServer;
@SpringBootApplication
@EnableEurekaServer
public class EurekaServer_7001 {
 public static void main(String[] args) {
 SpringApplication.run(EurekaServer_7001.class,args);
 }
}

(5)启动并访问http://localhost:7001/

页面出现如下,表示成功!

4.3  配置springcloud-provider-blog-8001

4.3.1 配置

(1)建立以下目录

(2)编写pom.xml

 
 
 
 
 org.springframework.cloud
 spring-cloud-starter-eureka
 1.4.6.RELEASE
 
 
 
 org.springframework.boot
 spring-boot-test
 2.4.5
 
 
 org.springframework.boot
 spring-boot-starter-web
 2.4.5
 
 
 
 org.springframework.boot
 spring-boot-devtools
 
 

(3)编写 application.yml

server:
  port: 8001

spring:
  application:
    name: springcloud-provider-blog

# Eureka配置:配置服务注册中心地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka/

(4)编写启动类

注意:要为主启动类添加@EnableEurekaClient注解

 
package com.yixin.springcloud;

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.cloud.client.discovery.EnableDiscoveryClient;
import org.springframework.cloud.netflix.eureka.EnableEurekaClient;

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

(5)启动测试

依次启动:

服务端:springcloud-eureka-7001------>客户端:springcloud-provider-blog-8001

访问监控页:http://localhost:7001/

可以发现,eureka已经成功将我们的客户端注册进去了。

4.3.2 关于Status

可以发现如果我们不对其描述信息进行描述,Eureka会采用默认的描述方式

(1)修改默认描述信息

修改springcloud-provider-blog-8001下的application.yml

# Eureka配置:配置服务注册中心地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka/
  instance:
    instance-id: springcloud-provider-dept-8001 #修改Eureka上的默认描述信息

重新启动springcloud-provider-blog-8001

可以发现,成功修改为我们自定义的描述信息了!

(2)配置服务加载的监控信息

但我们点击这个描述链接时,会跳到一个页面

现在我们希望在这个页面添加一些我们自己的描述信息。

修改springcloud-provider-blog-8001

a、pom.xml中添加依赖


 org.springframework.boot
 spring-boot-starter-actuator

b、修改配置文件application.yml 

配置info:

# Eureka配置:配置服务注册中心地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka/
  instance:
    instance-id: springcloud-provider-dept-8001 #修改Eureka上的默认描述信息


# info配置
info:
  app.name: yixin-springcloud  # 项目的名称
  company.name: yixin   # 公司的名称
 

c、重新启动springcloud-provider-blog-8001,进入描述信息链接 

结果:

(3)客户端宕机

如果在运行过程中,我们的客户端springcloud-provider-blog-8001突然停止运行了,那么等30s后 监控会开启保护机制,即不会立即清理该实例,依旧会对该微服务的信息进行保存!

4.3.3 Eureka自我保护机制

一句话总结就是:好死不如赖活着,某时刻某一个微服务不可用,eureka不会立即清理,依旧会对该微服务的信息进行保存!

(1)保护机制出发原因

默认情况下eurekaclient会定时向eurekaserver端发送心跳(默认是30S),如果eurekaserver在一定时间内没有收到eurekaclient发送的心跳,便会把该实例从注册服务列表中剔除(默认是90S),但是短时间内丢失大量的实例心跳的话,这时候eureka server会开启自我保护机制,所有的注册服务实例都将被保护起来,不被剔除。

(2)保护机制的目的

目的是为了避免网络连接故障,在发生网络故障时,微服务和注册中心之间无法正常通信,但服务本身是健康的,不应该注销该服务。

如果eureka因网络故障而把微服务误删了,那即使网络恢复了,该微服务也不会重新注册到eureka server了,因为只有在微服务启动的时候才会发起注册请求,后面只会发送心跳和服务列表请求,这样的话,该实例虽然是运行着,但永远不会被其它服务所感知。

所以,eureka server在短时间内丢失过多的客户端心跳时,会进入自我保护模式,该模式下,eureka会保护注册表中的信息,不在注销任何微服务,当网络故障恢复后,eureka会自动退出保护模式。自我保护模式可以让集群更加健壮。

(3)设置自我保护机制开关

使用场景:

我们在开发测试阶段,需要频繁地重启发布,如果触发了保护机制,则旧的服务实例没有被删除,这时请求有可能跑到旧的实例中,而该实例已经关闭了,这就导致请求错误,影响开发测试。所以,在开发测试阶段,我们可以把自我保护模式关闭,只需在eureka server配置文件中加上如下配置即

eureka.server.enable-self-preservation=false

4.3.4 获取注册进来的微服务信息

(1)编写BlogController

package com.yixin.springcloud.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.cloud.client.ServiceInstance;
import org.springframework.cloud.client.discovery.DiscoveryClient;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import java.util.List;

@RestController
public class BlogController {

//获取端口号
 @Value("${server.port}")
 private Integer port;

 
 @Autowired
 private DiscoveryClient client;
 @GetMapping("/getPort")
 public Integer getTodayFinishOrderNum(){
 return port;
 }

 //注册进来的微服务,获取一些消息
 @GetMapping("/blog/discovery")
 public Object discovery(){
 //获取微服务列表清单
 List services = client.getServices();
 System.out.println("discovery => services: "+services);

 //得到一个具体的微服务信息
 List instances = client.getInstances("SPRINGCLOUD-PROVIDER-BLOG");
 for (ServiceInstance instance : instances) {
 System.out.println(instance.getHost() + "t" +
 instance.getPort() + "t" +
 instance.getUri()+ "t" +
 instance.getServiceId());
 }
 return this.client;
 }
}

(2)启动类添加@EnableDiscoveryClient 注解

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

(3)重新启动springcloud-provider-blog-8001

访问:http://localhost:8001/blog/discovery

访问成功!

4.4 配置springcloud-consumer-blog-80

(1)创建以下目录

(2)编写pom.xml

 
 

 
 
 org.springframework.cloud
 spring-cloud-starter-eureka
 1.4.6.RELEASE
 

 
 
 org.springframework.boot
 spring-boot-test
 2.4.5
 

 
 org.springframework.boot
 spring-boot-starter-web
 2.4.5
 

 
 
 org.springframework.boot
 spring-boot-devtools
 

 

(3)编写application.yml

server:
  port: 8000

spring:
  application:
    name: springcloud-consumer-blog


# Eureka配置:配置服务注册中心地址
eureka:
  client:
    service-url:
      defaultZone: http://localhost:7001/eureka/
  instance:
    instance-id: springcloud-consumer-blog8000

(4)编写ConfigBean

RestTemplate并没有注入到Spring中,所以才需要我们自己编写配置类注册到Spring中。

package com.yixin.springcloud.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.web.client.RestTemplate;

@Configuration
public class ConfigBean {

 @Bean
 public RestTemplate getRestTemplate(){
 return new RestTemplate();
 }
}

(5)编写BlogConsumerController

package com.yixin.springcloud.controller;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.PathVariable;
import org.springframework.web.bind.annotation.RestController;
import org.springframework.web.client.RestTemplate;

@RestController
public class BlogConsumerController {

 @Autowired
 private RestTemplate restTemplate;

 private static final String REST_URL_PREFIX="http://localhost:8001";

 @GetMapping("/consumer/blog")
 public String get(){
 return "消费端:"+restTemplate.getForObject(REST_URL_PREFIX +"/blog/discovery", String.class);
 }
}

(6)编写主启动类

注意:要在主启动类添加@EnableEurekaClient注解。

package com.yixin.springcloud;

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

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

(7)测试

依次启动以下微服务:

(1)springcloud-eureka-7001

(2)springcloud-provider-blog-8001:服务生产方

(3)springcloud-consumer-blog-80:服务消费方

访问:http://localhost:8000/consumer/blog

测试成功!

五、搭建集群Eureka Server

搭建集群Eureka Server的好处就是:当我们任意一个Eureka注册中心宕机了,由于有其它Eureka注册中心,就不会导致服务中断,其它的Eureka注册中心将会接替已经宕机的Eureka注册中心的工作,不至于一个注册中心奔溃而导致全部服务停止。

(1)新建springcloud-eureka-7002、springcloud-eureka-7003 模块

(2)编写pom.xml

springcloud-eureka-7002和springcloud-eureka-7003的pom.xml的配置和7001一样


 
 
 
 org.springframework.cloud
 spring-cloud-starter-eureka-server
 1.4.6.RELEASE
 
 
 
 org.springframework.boot
 spring-boot-devtools
 

(3)编写自定义本机名

为了更加接近真实开发,配置一些自定义本机名字,例如:我们之前localhost==127.0.0.1

a、找到本机hosts文件并打开

b、在hosts文件最后加上,要访问的本机名称,默认是localhost

(3)编写配置类

a、springcloud-eureka-7001

在集群中使springcloud-eureka-7001关联springcloud-eureka-7002、springcloud-eureka-7003,其它两个配置类也一样

application.yml:

server:
  port: 7001
# Eureka配置
eureka:
  instance:
    # Eureka服务端的实例名字
    hostname: eureka7001.com
  client:
    # 表示是否向 Eureka 注册中心注册自己(这个模块本身是服务器,所以不需要)
    register-with-eureka: false
    # fetch-registry如果为false,则表示自己为注册中心,客户端的化为 ture
    fetch-registry: false
    # Eureka监控页面~
    service-url:
      defaultZone: http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
      # 集群(关联):7001关联7002、7003
      # 单机: defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/
 

b、springcloud-eureka-7002

application.yml:

server:
  port: 7002
# Eureka配置
eureka:
  instance:
    # Eureka服务端的实例名字
    hostname: eureka7002.com
  client:
    # 表示是否向 Eureka 注册中心注册自己(这个模块本身是服务器,所以不需要)
    register-with-eureka: false
    # fetch-registry如果为false,则表示自己为注册中心,客户端的化为 ture
    fetch-registry: false
    # Eureka监控页面~
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7003.com:7003/eureka/
      # 集群(关联):7002关联7001、7003
      # 单机: defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

c、springcloud-eureka-7003

application.yml:

server:
  port: 7003
# Eureka配置
eureka:
  instance:
    # Eureka服务端的实例名字
    hostname: eureka7003.com
  client:
    # 表示是否向 Eureka 注册中心注册自己(这个模块本身是服务器,所以不需要)
    register-with-eureka: false
    # fetch-registry如果为false,则表示自己为注册中心,客户端的化为 ture
    fetch-registry: false
    # Eureka监控页面~
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/
      # 集群(关联):7003关联7001、7002
      # 单机: defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka/

(4)编写主启动类与springcloud-eureka-7001类似

(5)修改springcloud-provider-blog-8001的配置文件

修改其defaultZone,让其关联三个Server

application.yml:

# Eureka配置:配置服务注册中心地址
eureka:
  client:
    service-url:
      defaultZone: http://eureka7001.com:7001/eureka/,http://eureka7002.com:7002/eureka/,http://eureka7003.com:7003/eureka/
  instance:
    instance-id: springcloud-provider-dept-8001 #修改Eureka上的默认描述信息

(6)测试

依次启动:

a、springcloud-eureka-7001

b、springcloud-eureka-7001

c、springcloud-eureka-7001

d、springcloud-provider-blog-8001:服务生产方

(我感觉我的电脑要起飞了!(T_T))

(7)访问:http://localhost:7001/

同理,访问http://localhost:7002/和http://localhost:7003/也会出现其它两个的绑定信息。

(8)集群测试

访问:http://localhost:8001/blog/discovery

可以看到正常出现结果!

继续测试

a、停止运行springcloud-eureka-7001

发现仍然可以正常运行,因为还有springcloud-eureka-7002和springcloud-eureka-7003

b、停止运行springcloud-eureka-7002

发现仍然可以正常运行,因为还有springcloud-eureka-7003

c、停止运行springcloud-eureka-7003

继续访问,发现控制台出现异常了,因为我们把三个Eureka注册中心全部停掉了,已经没有可以进行接替的了。

至此,集群搭建成功!!!


结语

花费一整天的时间,终于整理好啦!看了许多文章,途中也一直在测试各种功能,也更加理解了“自动化注册和发现”这个概念,现在大家重新回头去看上面我对Eureka服务注册中心的概念描述,是不是就悟了!

如果这篇文章有帮助到你,希望可以给【一心同学】点个赞,创作不易,相比官方的陈述,我更喜欢用通俗易懂的文笔去讲解每一个知识点,如果有对【后端技术】感兴趣的小可爱,也欢迎关注❤️❤️❤️ 【一心同学】❤️❤️❤️,我将会给你带来巨大的收获与惊喜!

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/697718.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号