Spring Cloud Eureka基础应用及原理

目录
  • Eureka简介
  • 搭建Eureka服务注册中心
  • 搭建Eureka服务提供者
  • 搭建Eureka服务调用者
  • Eureka服务注册和发现

Eureka简介

Eureka这个词来源于古希腊语,意为“我找到了!我发现了!”。据传,阿基米德在洗澡时发现浮力原理,高兴得来不及穿上衣服,跑到街上大喊:“Eureka! ”。
在Netflix中,Eureka是一个RESTful风格的服务注册与发现的基础服务组件。Eureka由两部分组成,一个是Eureka Server,提供服务注册和发现功能,即我们上面所说的服务器端;另一个是Eureka Client,它简化了客户端与服务端之间的交互。Eureka Client会定时将自己的信息注册到Eureka Server中,并从Server中发现其他服务。Eureka Client中内置一个负载均衡器,用来进行基本的负载均衡。
下面我们将通过搭建一个简单的Eureka例子来了解Eureka的运作原理。

搭建Eureka服务注册中心

可以搭建包含Eureka Server依赖的Spring Boot项目。主要依赖如下:

在启动类中添加注解@EnableEurekaServer,代码如下所示:

@SpringBootApplication
//会为项目自动配置必须的配置类,标识该服务为注册中心
@EnableEurekaServer
public class DemoApplication {

    public static void main(String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }
}

在application.yml配置文件中添加以下配置,配置注册中心的端口和标识自己为Eureka Server:

server:
  port: 8761
#eureka配置--4部分
#1.dashboard web控制台
#2.server服务端配置--配置过期时间等
#3.client客户端配置--配置注册发现地址
#4.instance项目实例
eureka:
  #配置服务可视化默认开启
  dashboard:
    enabled: true
    path: /
  instance:
    hostname: localhost
  #这个是euraka暴漏给提供者和消费者服务发现注册用的
  client:
    service-url:
      #defaultZone: http://localhost:8761/eureka不能写死
      defaultZone: http://${eureka.instance.hostname}:${server.port}/eureka
    #是否注册到eureka上注册中心是不用把自己上床到自己的provider
    register-with-eureka: false
    #是否需要到eureka上拉去服务路径--consumer需要
    fetch-registry: false

lnstanceld是Eureka服务的唯一标记,主要用于区分同一服务集群的不同实例。一般来讲,一个Eureka服务实例默认注册的Instanceld是它的主机名(即一个主机只有一个服务)。但是这样会引发一个问题,一台主机不能启动多个属于同一服务的服务实例。为了解决这种情况,spring-cloud-netflix-eureka提供了一个合理的实现,如上面代码中的Instanceld设置样式。通过设置random.value可以使得每一个服务实例的lnstanceld独一无二,从而可以唯一标记它自身。

Eureka Server既可以独立部署,也可以集群部署。在集群部署的信况下,EurekaServeri间会进行注册表信息同步的换作,这时被同步注册表信息的Eureka Server将会被其他同步注册表信息的Eureka Server称为peer。

请注意,上述配置中的service-url指向的注册中心为实例本身。通常来讲,一个Eureka Server也是一个Eureka Client,它会尝试注册自己,所以需要至少一个注册中心的URL来定位对等点peer。如果不提供这样一个注册端点,注册中心也能工作,但是会在日志中打印无法向peer注册自己的信息。在独立(Standalone) Eureka Server的模式下,Eureka Server一般会关闭作为客户端注册自己的行为。

Eureka Server与Eureka Client之间的联系主要通过心跳的方式实现。心跳(Heartbeat)即Eureka Client定时向Eureka Server汇报本服务实例当前的状态,维护本服务实例在注册表中租约的有效性。

Eureka Server需要随时维持最新的服务实例信息,所以在注册表中的每个服务实例都需要定期发送心跳到Server中以使自己的注册保持最新的状态.(数据一般直接保存在内存中)。为了避免Eureka Client在每次服务间调用都向注册中心请求依赖服务实例的信息,Eureka Client将定时从Eureka Server中拉取注册表中的信息,并将这些信息缓存到本地,用于服务发现。

启动Eureka Server后,应用会有一个主页面用来展示当前注册表中的服务实例信息并同时暴露一些基于HTTP协议的端点在/eureka路径下,这些端点将由EurekaClient用于注册自身、获取注册表信息以及发送心跳等。

搭建Eureka服务提供者

可以搭建包含Eurake Client依赖的Spring Boot项目。主要依赖有:

<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-client -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    <version>3.1.2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.6.7</version>
</dependency>

启动类如下:

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

在Spring Cloud的Finchley版本中,只要引入spring-cloud-starter-netflix-eureka-client的依赖,应用就会自动注册到Eureka Server,但是需要在配置文件中添加Eureka Server的地址。在application.yml添加以下配置:

# Eureka配置
eureka:
  instance:
     hostname: client
     instance-id: ${spring.application.name} :$ lvcap.application.instance_id:$ lspring.application.instance_id:$trandom value}}}
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
server :
  port : 8760
spring:
  application:
    rame: eureka-client

为服务提供者添加一个提供服务的接口,代码如下:

@RestContro11er
public class SayHe11oContro11er {
@RequestMapping(value = "/he11o/{name}")
public String sayHe11o(@PathVarivab1e("name") String name){
return "He11o,".concat(name).concat("! ");
}
}

上述接口将会向请求者返回打招呼的响应信息。

搭建Eureka服务调用者

可以搭建包含Eurake Client依赖的Spring Boot项目。主要依赖有:

<!-- https://mvnrepository.com/artifact/org.springframework.cloud/spring-cloud-starter-netflix-eureka-client -->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
    <version>3.1.2</version>
</dependency>
<!-- https://mvnrepository.com/artifact/org.springframework.boot/spring-boot-starter-web -->
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-web</artifactId>
    <version>2.6.7</version>
</dependency>

启动类代码如下:

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

在application.yml添加eureka-client相关配置,代码如下所示:

# Eureka配置
eureka:
  instance:
     hostname: client
     instance-id: ${spring.application.name} :$ lvcap.application.instance_id:$ lspring.application.instance_id:$trandom value}}}
  client:
    service-url:
      defaultZone: http://localhost:8761/eureka/
server :
  port : 8765
spring:
  application:
    rame: eureka-client

添加一个AskController向eureka-client-service请求sayHello的服务。通过使用可以进行负载均衡的RestTemplate向eureka-client-service发起打招呼的请求,并直接返回对应的响应结果。具体代码如下所示:

@RestController
@Configuration
public class DemoController {
//注入本地服务名
@value("${spring.application. name}")
private string name;
@Autowired
RestTemplate restTemplate;
@RequestMapping(value = "/ask")
public string ask(){
//从eureka-client-service服务提供者中请求sayHello服务
string askHelloFromService = restTemplate.getForEntity("http ://EUREKA-CLIENT-SERVICE/hello/{name}", String.class,name).getBody();
return askHelloFromService;
}
//注入一个可以进行负载均衡的RestTemple用于服务间调用@Bean
@LoadBalanced
public RestTemplate restTemplate(){
return new RestTemplate();
}

Eureka服务注册和发现

搭建好上述三个Eureka应用后,依次启动三个应用。
1.Eureka Server主页
访问Eureka Server的主页http://localhost:8761,可以看到下图所示的界面。
从图中可以看到以下信息:
-展示当前注册到Eureka server上的服务实例信息。
-展示Eureka Server运行环境的通用信息。
-展示Eureka Server实例的信息。

2.服务间调用
访问http:l/localhost:8762/ask,eureka-client将调用eureka-client-service的sayHello服务,向eureka-client-service传递服务名,等待eureka-client-service返回请求响应,响应结果如下:

Hello, eureka-client !

RestTemplate将根据服务名eureka-client-service通过预先从eureka-service缓存到本地的注册表中获取到eureka-client-service服务的具体地址,从而发起服务间调用。

3.与服务注册中心交换信息
DiscoveryClient来源于spring-cloud-client-discovery,是Spring Cloud中定义用来服务发现的公共接口,在Spring Cloud的各类服务发现组件中(如Netflix Eureka或Consul)都有相应的实现。它提供从服务注册中心根据serviceld获取到对应服务实例信息的能力。当一个服务实例拥有DiscoveryClient的具体实现时,就可以从服务注册中心中发现其他的服务实例。
在Eureka Client中注入DiscoveryClient,并从Eureka Server获取服务实例的信息。在chapter4-eureka-client添加一个ServicelnstanceRestController的controller ,如下所示:

@RestController
public class ServiceInstanceRestController {
@Autowired
private DiscoveryClient discoveryClient ;
@RequestMapping(" /service-instances/ {applicationName}")
public List<ServiceInstance> serviceInstancesByApplicationName(
@Pathvariable
String applicationName(){
return this.discoveryClient.getInstances(applicationName);
}
}

启动应用后,访问地址http://localhost:8765/service-instancesleureka-client,获取应用名为eureka-client(服务本身)的服务实例元数据,结果如下所示:

Eureka中标准元数据有主机名、IP地址、端口号、状态页url和健康检查url等,这些元数据都会保存在Eureka Server的注册表中,Eureka Client根据服务名读取这些元数据,来发现和调用其他服务实例。元数据可以自定义以适应特定的业务场景,这些内容将在下一篇文章进行讲解。

到此这篇关于Spring Cloud Eureka基础应用的文章就介绍到这了,更多相关Spring Cloud  Eureka应用内容请搜索我们以前的文章或继续浏览下面的相关文章希望大家以后多多支持我们!

(0)

相关推荐

  • Spring Cloud Eureka: 指定Zone方式

    目录 Eureka如何指定Zone Eureka中的region和Zone 概念 分区服务架构图 Eureka中Regin和Zone的相关配置 服务注册相关 服务调用 Eureka如何指定Zone 有坑. 先说结论:如果想给当前服务指定属于哪个zone, 使用 eureka.instance.metadata-map.zone=myzone 属性是无效的,而应该使用: eureka.client.availabilityZones.beijing=myzone # beijing是region

  • SpringCloud搭建netflix-eureka微服务集群的过程详解

    1.打开官网稍微学习一下,了解一下spring cloud是个什么东西,大概有哪些组件等 https://spring.io/projects/spring-cloud https://docs.spring.io/spring-cloud-netflix/docs/current/reference/html/ 2.新建项目 打开网址:https://start.spring.io/ 选择需要引入的组件,然后下载下来即可 3.更改项目结构 为了测试的方便,需将项目结构更改为多模块的项目. 步骤

  • 解决springcloud-eureka注册时的ip问题

    目录 springcloud-eureka注册,ip问题 手动指定instance-id 服务调用时外网ip使用 Eureka注册服务后,ip展示不正确,调用失败 问题描述 在eureka上展示出来的效果如下 不废话,核心配置 另外,如果这一行还不够,再加几行 springcloud-eureka注册,ip问题 在微服务注册到eureka时,在开启ip显示时,有时候会出现localhost的情况 手动指定instance-id 在配置文件中 eureka.instance.prefer-ip-a

  • springcloud client指定注册到eureka的ip与端口号方式

    client指定注册到eureka的ip与端口号 #设置使用IP eureka.instance.prefer-ip-address=true #设置外网IP号 eureka.instance.ip-address=49.10.22.106 #设置外网端口号 eureka.instance.non-secure-port=5565 eureka注册时使用ip而不是hostname问题 eureka的client注册到server时默认是使用hostname而不是ip,这就导致client在多台机

  • springcloud微服务之Eureka配置详解

    Eureka注册中心/服务发现框架 Eureka是Netflix开发的服务发现框架,本身是一个基于REST的服务,主要用于定位运行在AWS域中的中间层服务,以达到负载均衡和中间层服务故障转移的目的.SpringCloud将它集成在其子项目spring-cloud-netflix中,以实现SpringCloud的服务发现功能. Eureka包含两个组件:Eureka Server和Eureka Client. Eureka Server提供服务注册服务,各个节点启动后,会在Eureka Serve

  • SpringCloud如何使用Eureka实现服务之间的传递数据

    相信大家最关心的肯定不是什么一大堆的破理论,然后还似懂非懂的,最关心得莫过于服务之间的参数传递,数据获取. Ok,今天就告诉大家三种微服务之间传输数据的方式,分别是: 1.最基本的利用Ip端口进行请求访问接口实现数据的传输 2.使用Eureka取代Ip(硬编码)的方式实现数据的传输 3.使用Feign更加快捷"分服务"的方式实现微服务之间的数据传输(对Feign一点不了解的暂时不用理解,就是SpringCloud的组成的一部分后期会进行详细讲解,在此处讲解只是为自己mark一下) 前提

  • springboot cloud使用eureka整合分布式事务组件Seata 的方法

    前言 近期一直在忙项目,我也是打工仔.不多说,我们开始玩一玩seata. 正文 什么都不说,我们按照惯例,先上一个图(图里不规范的使用请忽略): 简单一眼就看出来, 比我们平时用的东西,多了 Seata Server 微服务 . 同样这个 Seata Server 微服务 ,也是需要注册到eureka上面去的. 那么我们首先就搞一搞这个 seata server ,那么剩下的就是一些原本的业务服务整合配置了. 该篇用的 seata server 版本,用的是1.4.1 , 可以去git下载下.当

  • springCloud服务注册Eureka实现过程图解

    介绍 Eureka 是Netfix开发的,一个基于Rest服务的,服务注册与发现的组件. 主要包括两个组件:Eureka Server和Eureka Client Eureka Server:注册中心,提供服务注册与发现 Eureka Client:java客户端(通常就是微服务中的客户端和服务端) 上图简要描述了Eureka的基本架构,由3个角色组成: 1.Eureka Server(注册中心,相当于中介) 2.Service Provider(服务提供方,相当于房东) 3.Service C

  • Spring Cloud引入Eureka组件,完善服务治理

    简介 Netflix Eureka 是一款由 Netflix 开源的基于 REST 服务的注册中心,用于提供服务发现功能.Spring Cloud Eureka 是 Spring Cloud Netflix 微服务套件的一部分,基于 Netflix Eureka 进行了二次封装,主要负责完成微服务架构中的服务治理功能. Spring Cloud Eureka 是一个基于 REST 的服务,并提供了基于 Java 的客户端组件,能够非常方便的将服务注册到 Spring Cloud Eureka 中

  • spring cloud eureka 服务启动失败的原因分析及解决方法

    目录 环境: 错误log 环境: <spring-boot-version>2.3.5.RELEASE</spring-boot-version> <spring-cloud-version>Hoxton.SR8</spring-cloud-version> 错误log Unable to start web server; nested exception is org.springframework.boot.web.server.WebServerEx

随机推荐