【Spring Cloud】深入理解 Eureka 注册中心的原理、服务的注册与发现

news2024/11/26 13:31:49

文章目录

  • 前言
  • 一、微服务调用出现的问题
    • 1.1 服务消费者如何获取服务提供者的地址信息？
    • 1.2 如果有多个服务提供者，消费者该如何选择？
    • 1.3 消费者如何得知服务提供者的健康状态？
  • 二、什么是 Eureka
    • 2.1 Eureka 的核心概念
    • 2.2 Eureka 的解决微服务调用问题的方案
  • 三、Eureka 的原理
    • 3.1 Eureka 的核心组件
      • 3.1.1 eureka-server
      • 3.1.2 eureka-client
    • 3.2 Eureka 的工作流程
  • 四、搭建 Eureka 服务
  • 五、注册服务
    • 5.1 注册 `user-service` 服务
    • 5.2 注册 `order-service` 服务
    • 5.3 同一个服务启动多个实例
  • 六、服务的发现

前言

在微服务架构中，服务的注册与发现是至关重要的一环。为了实现这一目标，Eureka 注册中心应运而生。在本篇文章中，我们将深入理解 Eureka 注册中心的原理，以及探讨服务的注册与发现机制。

在微服务的协作中，服务之间的远程调用是常见的需求。然而，使用传统的 RestTemplate 远程调用方式存在一些问题，例如耦合度高、维护困难等。为了解决这些问题，我们将探讨如何利用 Eureka 注册中心来优雅地进行服务的注册与发现，从而更好地构建微服务架构。

接下来，我们将逐步深入探讨 Eureka 注册中心的原理、搭建 Eureka 服务、服务的注册与发现等关键内容。希望通过阅读本文，可以帮助我们更全面地理解微服务架构中 Eureka 的作用以及如何灵活运用它来构建高效可靠的分布式系统。

一、微服务调用出现的问题

在微服务架构中，服务之间的远程调用是常见的需求。然而，随着系统的复杂性增加，服务调用也带来了一些问题和挑战。

1.1 服务消费者如何获取服务提供者的地址信息？

在微服务架构中，服务提供者的地址信息通常是动态的，可能随时发生变化，例如服务的扩容、缩容、迁移等情况。因此，服务消费者需要一种机制来获取服务提供者的地址信息，以确保能够正确地发起远程调用。

解决方案：服务注册与发现

  • 服务提供者在启动时将自己的地址信息注册到服务注册中心，包括主机名、端口号等信息。
  • 服务消费者通过查询服务注册中心来获取服务提供者的地址信息，从而可以动态地发起调用。

1.2 如果有多个服务提供者，消费者该如何选择？

在实际应用中，可能会存在多个提供相同服务的服务提供者，这时服务消费者需要选择一个合适的提供者来发起调用。选择的依据可以包括负载均衡、性能指标、健康状态等因素。

解决方案：负载均衡

  • 负载均衡是一种策略，用于在多个服务提供者之间分配请求，以达到均衡负载的目的。
  • 常见的负载均衡策略包括轮询、随机、加权轮询、加权随机等，不同策略适用于不同的场景。

1.3 消费者如何得知服务提供者的健康状态？

在微服务架构中，服务提供者的健康状态对于服务消费者是非常重要的信息。如果一个服务提供者出现了故障或不可用，服务消费者需要避免向其发起请求，以确保系统的稳定性和可靠性。

解决方案：健康检查与容错机制

  • 健康检查是一种监测服务提供者健康状态的机制，通常由服务注册中心来执行。
  • 服务消费者可以根据健康检查的结果来判断服务提供者是否可用，从而决定是否发起调用。
  • 容错机制可以帮助服务消费者处理远程调用时可能出现的故障，例如超时、重试、降级等。

其中，Eureka 就是是一种服务注册与发现的解决方案，它通过服务注册中心来解决了微服务调用中的一些关键问题。

二、什么是 Eureka

Eureka 是 Netflix 提供的一款开源的服务注册与发现框架，用于构建基于微服务架构的分布式系统。它解决了在微服务架构中，服务的动态注册、发现和负载均衡的问题，是构建可伸缩和高可用性微服务的重要工具之一。

2.1 Eureka 的核心概念

  • 服务注册

在微服务架构中，服务提供者在启动时将自己的信息注册到 Eureka 注册中心，包括服务名称、网络地址等。这样，Eureka 注册中心就知道了系统中有哪些服务是可用的。

  • 服务发现

服务消费者可以通过查询 Eureka 注册中心获取可用服务的信息，从而决定向哪些服务发起调用。Eureka 注册中心维护了一个服务实例列表，包括每个服务的网络地址。

  • 心跳与健康检查

Eureka 注册中心会定期向服务提供者发送心跳请求，以检测服务是否仍然可用。如果一个服务在一定时间内未发送心跳，Eureka 将其标记为不可用。这就实现了对服务健康状态的监控。

  • 负载均衡

Eureka 客户端集成了 Ribbon 负载均衡器，可以在多个服务提供者之间实现负载均衡。通过使用 Ribbon，服务消费者可以选择一个合适的服务提供者来发起调用。

Eureka 的优势

  1. 简化了服务调用： Eureka 提供了简洁的 API，使得服务的注册、发现和调用变得非常容易。

  2. 高可用性： Eureka 支持服务注册中心的集群部署，通过相互注册来保证注册中心的高可用性。

  3. 负载均衡： 集成了 Ribbon 负载均衡器，可实现对多个服务提供者的请求分配，提高系统的性能和稳定性。

  4. 动态扩展： Eureka 支持服务的动态注册和注销，适应服务实例的动态变化。

  5. 健康检查： 通过心跳和健康检查，Eureka 能够及时发现不可用的服务实例，确保服务的高可用性。

总体而言，Eureka 是一个功能强大的服务注册与发现框架，为构建微服务架构提供了可靠的基础设施支持。

2.2 Eureka 的解决微服务调用问题的方案

  1. 服务消费者如何获取服务提供者的地址信息？

    • Eureka 注册中心： 服务提供者在启动时将自己的地址信息注册到 Eureka 注册中心。服务消费者可以通过查询 Eureka 注册中心获取服务提供者的地址信息。

  2. 如果有多个服务提供者，消费者该如何选择？

    • 负载均衡： Eureka 支持负载均衡，服务消费者可以使用负载均衡策略来选择一个合适的服务提供者。Eureka 客户端集成了 Ribbon 负载均衡器，可方便地实现负载均衡。

  3. 消费者如何得知服务提供者的健康状态？

    • 健康检查： Eureka 注册中心会定期对服务提供者进行健康检查，如果一个服务提供者出现故障，Eureka 将其标记为不可用。服务消费者在查询服务列表时可以过滤掉不可用的服务提供者，确保只选择健康的服务。

综上所述，Eureka 提供了服务注册与发现的机制，同时集成了负载均衡和健康检查等功能，有效地解决了微服务调用中的关键问题。通过使用 Eureka，微服务架构中的服务调用变得更加灵活、可靠、具有高可用性。

三、Eureka 的原理

Eureka 是一个由 Netflix 提供的服务注册与发现框架，通过 eureka-server 和 eureka-client 两部分协同工作，实现了微服务架构中服务的动态注册、发现、负载均衡和健康检查等功能。下面我们将深入了解 Eureka 的工作原理。

3.1 Eureka 的核心组件

3.1.1 eureka-server

  • 服务注册中心： eureka-server 充当服务的注册中心，负责接收服务提供者注册信息并维护注册表。

  • 服务注册表： 服务提供者在启动时向 eureka-server 注册自己的信息，包括服务名称、网络地址等，形成服务注册表。

  • 健康检查： eureka-server 定期向服务提供者发送心跳，通过健康检查来维护服务的健康状态。

3.1.2 eureka-client

  • 服务提供者： 微服务中的各个服务模块通过 eureka-client 向 eureka-server 注册自己的服务。

  • 服务消费者： 微服务中的服务消费者通过 eureka-client 从 eureka-server 获取可用服务的信息，实现服务的发现。

  • 负载均衡： eureka-client 集成了 Ribbon 负载均衡器，可以在多个服务提供者之间实现负载均衡，提高系统的性能和可靠性。

3.2 Eureka 的工作流程

Eureka 的工作流程可用下图表示：

Eureka 的工作流程

  1. 服务注册阶段：

    • 服务提供者启动时，通过 eureka-client 向 eureka-server 注册自己的服务信息。

    • 注册包括服务名称、网络地址等，服务提供者成为服务注册表的一部分。

  2. 服务发现阶段：

    • 服务消费者通过 eureka-client 向 eureka-server 发送服务发现请求。

    • eureka-server 返回可用服务的信息，包括服务名称和对应的网络地址。

    • 服务消费者根据负载均衡策略选择一个服务提供者。

  3. 健康检查与维护：

    • eureka-server 定期向服务提供者发送心跳，检查服务的健康状态。

    • 如果一个服务提供者长时间未发送心跳，eureka-server 将其标记为不可用。

    • 不可用的服务将在服务注册表中被移除，保持服务注册表的准确性。

通过上述流程，Eureka 实现了服务的动态注册与发现，保障了微服务架构的高可用性和弹性扩展能力。Eureka 的原理设计使得微服务之间的调用更加灵活和可靠。

四、搭建 Eureka 服务

在 Spring Cloud Demo 代码中搭建 Eureka 服务的步骤如下：

  1. 创建项目，引入spring-cloud-starter-netflix-eureka-server的依赖
<!-- eureka 服务端-->
<dependency>
    <groupId>org.springframework.cloud</groupId>
    <artifactId>spring-cloud-starter-netflix-eureka-server</artifactId>
</dependency>
  1. 编写启动类，添加@EnableEurekaServer注解
@EnableEurekaServer // 开启 EurekaServer 自动装配
@SpringBootApplication
public class EurekaApplication {
    public static void main(String[] args) {
        SpringApplication.run(EurekaApplication.class, args);
    }
}
  1. 添加application.yml文件，编写下面的配置
server:
  port: 10086
spring:
  application:
    name: eurekaservice # 服务的名称
eureka:
  client:
    service-url: # eureka 的地址信息
      defaultZone: http://127.0.0.1:10086/eureka/ # eureka 也是一个微服务，因此启动的时候也会将自己注册进 eureka 中（为集群起作用）

完成上述所有的步骤之后就可以运行EurekaApplication 启动类了，然后就可以访问地址：http://localhost:10086/。

如果此时出现的页面如下，就说明搭建 Eureka 服务成功了：

其中Instances currently registered with Eureka 下显示的就是当前在 Eureka 中注册的服务。

五、注册服务

5.1 注册 user-service 服务

将 user-service 服务注册到 EurekaServer 中的步骤如下：

  1. 在 user-service 项目的pom.xml中引入spring-cloud-starter-netflix-eureka-client依赖
 <!-- eureka 客户端-->
 <dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
 </dependency>
  1. 在application.yml文件，编写下面的配置
spring:
  application:
    name: userservice
eureka:
  client:
    service-url: 
      defaultZone: http://127.0.0.1:10086/eureka/

此时我们发现这个配置和上面搭建 EurekaServer 时的配置基本相同，其原因就是 Eureka 在启动的时候也会将自己注册到 EurekaServer 中，而这个配置的作用就是将指定的服务（通过application name 区分）注册到defaultZone 对应地址的 EurekaServer 中。

5.2 注册 order-service 服务

  1. 在 order-service 项目的pom.xml中引入spring-cloud-starter-netflix-eureka-client依赖
 <!-- eureka 客户端-->
 <dependency>
     <groupId>org.springframework.cloud</groupId>
     <artifactId>spring-cloud-starter-netflix-eureka-client</artifactId>
 </dependency>
  1. 在application.yml文件，编写下面的配置
spring:
  application:
    name: orderservice
eureka:
  client:
    service-url: 
      defaultZone: http://127.0.0.1:10086/eureka/

此时，启动user-service 和 order-service 服务，再次访问http://localhost:10086/就可以发现成功将服务注册到 EurekaServer 中了：

5.3 同一个服务启动多个实例

另外，在IDEA中，我们可以同时启动一个服务的多个实例，只需要保证不同实例的端口号不要发生冲突即可。

例如，此时我还想增加两个user-service 服务的实例，步骤如下：

  1. 右键点击 UserApplication ，然后选择 Copy Configuration 进行复制

  2. 然后进行如下设置

    -Dserver.port=8082表明为这个配置重新设置端口号为 8082，可以按照相同的方式，再复制一个配置。

启动这两个实例，然后再次访问http://localhost:10086/：


此时就可以发现user-service 新增的两个实例的服务也成功注册到了 EurekaServer 中。

六、服务的发现

把服务注册到 EurekaServer 之后，要做的就是实现服务的拉取了，EurekaServer 中服务的拉取是基于服务名称来获取服务的列表，然后再对服务列表做负载均衡选择出一个服务。

此时我们想要 order-service 能够拉取到 EurekaServer 中注册的 user-service 服务，需要进行以下操作：

  1. 修改 order-service 的代码，修改访问的 url 路径，用服务名代替 IP和端口
public Order queryOrderById(Long orderId) {
    // 1. 查询订单
    Order order = orderMapper.findById(orderId);

    // 2. 查询用户
    // 2.1 构建查询用户的 url
    String url = "http://userservice/user/" + order.getUserId();

    // 2.2 使用 RestTemplate 远程调用查询用户
    User user = restTemplate.getForObject(url, User.class);

    // 3. 封装 user 信息
    order.setUser(user);

    // 4.返回
    return order;
}

此处就使用 userservice 服务名来代替 user-service 服务的 IP 和端口号了。

  1. 对 order-service 服务的启动类OrderApplication中的 RestTemplate 添加@LoadBalanced负载均衡注解
@SpringBootApplication
public class OrderApplication {
    public static void main(String[] args) {
        SpringApplication.run(OrderApplication.class, args);
    }

    /**
     * 创建 RestTemplate 并注册到 Spring 容器
     */
    @LoadBalanced // 负载均衡
    @Bean
    public RestTemplate restTemplate(){
        return new RestTemplate();
    }
}

至此，重新启动 order-service 服务，便能成功从 EurekaServer 中访问到 user-service 提供的服务了。

此时清空三个 user-service服务实例的日志记录，然后在浏览器中连续查询三次订单信息：



由此可得知，三个实例各种承担了一次服务的请求，说明此时负载均衡所采用的策略是轮询的方式。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/1053276.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

Python-Flask：编写自动化连接demo脚本：v1.0.0

Python-Flask：编写自动化连接demo脚本：v1.0.0

主函数&#xff1a; # _*_ Coding : UTF-8 _*_ # Time : 13:14 # Author : YYZ # File : Flask # Project : Python_Project_爬虫 import jsonfrom flask import Flask,request,jsonify import sshapi Flask(__name__)# methods: 指定请求方式 接口解析参数host host_info[…
阅读更多...
【已解决】 Expected linebreaks to be ‘LF‘ but found ‘CRLF‘.

【已解决】 Expected linebreaks to be ‘LF‘ but found ‘CRLF‘.

问题描述 团队都是用mac&#xff0c;只有我自己是windows&#xff0c;启动项目一直报错 Expected linebreaks to be ‘LF‘ but found ‘CRLF‘. 但我不能因为自己的问题去改团队配置&#xff0c;也尝试过该vscode配置默认是LF还是报错 思路 看文章vscode如何替换所有文件的…
阅读更多...
深度学习笔记_1、定义神经网络

深度学习笔记_1、定义神经网络

1、使用了PyTorch的nn.Module类来定义神经网络模型;使用nn.Linear来创建全连接层。(CPU) import torch.nn as nn import torch.nn.functional as F from torchsummary import summary# 定义神经网络模型 class Net(nn.Module):def __init__(self):super(Net, self).__init__()…
阅读更多...
yolov8 opencv模型部署（python版）

yolov8 opencv模型部署（python版）

yolov8 opencv模型部署&#xff08;python版&#xff09; 使用opencv推理yolov8模型&#xff0c;以yolov8n为例子&#xff0c;一共几十行代码&#xff0c;没有废话&#xff0c;给出了注释&#xff0c;从今天起&#xff0c;少写一行代码&#xff0c;少掉一根头发。测试数据有需…
阅读更多...
蓝桥等考Python组别九级001

蓝桥等考Python组别九级001

第一部分&#xff1a;选择题 1、Python L9 &#xff08;15分&#xff09; 运行下面程序&#xff0c;可以输出几行“*”&#xff1f;&#xff08; &#xff09; for i in range(0, 7): for j in range(0, 4): print(*, end ) print() 6374 正确答案&#xff1a;C 2、P…
阅读更多...
自动驾驶：未来的道路上的挑战与机遇

自动驾驶：未来的道路上的挑战与机遇

自动驾驶&#xff1a;未来的道路上的挑战与机遇 文章目录 引言安全与道路事故的减少交通拥堵的缓解城市规划的变革技术和法律挑战结语 2023星火培训【专项营】Apollo开发者社区布道师倾力打造&#xff0c;包含PnC、新感知等的全新专项课程上线了。理论与实践相结合&#xff0c;…
阅读更多...
Qt扩展-QCustomPlot绘图基础概述

Qt扩展-QCustomPlot绘图基础概述

QCustomPlot绘图基础概述 一、概述二、改变外观1. Graph 类型2. Axis 坐标轴3. 网格 三、案例1. 简单布局两个图2. 绘图与多个轴和更先进的样式3. 绘制日期和时间数据 四、其他Graph&#xff1a;曲线&#xff0c;条形图&#xff0c;统计框图&#xff0c;… 一、概述 本教程使用…
阅读更多...
Selenium 浏览器坐标转桌面坐标

Selenium 浏览器坐标转桌面坐标

背景&#xff1a; 做图表自动化项目需要做拖拽操作&#xff0c;但是selenium提供的拖拽API无效&#xff0c;因此借用pyautogui实现拖拽&#xff0c;但是pyautogui的拖拽是基于Windows桌面坐标实现的&#xff0c;另外浏览器中的坐标与windows桌面坐标并不是一比一对应的关系&am…
阅读更多...
【计算机网络】因特网中的电子邮件

【计算机网络】因特网中的电子邮件

文章目录 简单邮件传送协议SMTP邮件访问协议POP3IMAPHTTP 参考资料 电子邮件为异步通信媒介 因特网电子邮件系统 电子邮件系统的三个构件&#xff1a;用户代理、邮件服务器、邮件发送和读取协议 用户代理 User Agent 即UA 电子邮件客户端软件&#xff0c;用户与电子邮件系统的接…
阅读更多...
【从入门到起飞】JavaSE—网络编程三要素，软件架构，UDP协议

【从入门到起飞】JavaSE—网络编程三要素，软件架构，UDP协议

文章目录 &#x1f384;什么是网络编程&#x1f33a;常见的软件架构⭐BS架构的优缺点⭐CS架构的优缺点 &#x1f354;网络编程三要素&#x1f6f8;InetAddress类的使用⭐确定主机名称的IP地址✨查看主机名 ⭐获取此IP地址的主机名⭐返回文本显示中的IP地址字符串⭐IP&#x1f3…
阅读更多...
Llama2-Chinese项目：3.1-全量参数微调

Llama2-Chinese项目：3.1-全量参数微调

提供LoRA微调和全量参数微调代码&#xff0c;训练数据为data/train_sft.csv&#xff0c;验证数据为data/dev_sft.csv&#xff0c;数据格式如下所示&#xff1a; "<s>Human: "问题"\n</s><s>Assistant: "答案举个例子&#xff0c;如下所…
阅读更多...
机器学习西瓜书+南瓜书吃瓜教程学习笔记第六章支持向量机

机器学习西瓜书+南瓜书吃瓜教程学习笔记第六章支持向量机

视频来源&#xff1a;b站直播 周志华老师机器学习西瓜树南瓜书 以下是我的学习笔记&#xff1a; 支持向量机&#xff08;support vector machines&#xff0c;SVM&#xff09;是一种二分类模型&#xff0c;它的目的是寻找一个超平面来对样本进行分割&#xff0c;分割的原则是间…
阅读更多...
Java进阶必会JVM-深入浅出Java虚拟机

Java进阶必会JVM-深入浅出Java虚拟机

系列文章目录 送书第一期 《用户画像&#xff1a;平台构建与业务实践》 送书活动之抽奖工具的打造 《获取博客评论用户抽取幸运中奖者》 送书第二期 《Spring Cloud Alibaba核心技术与实战案例》 送书第三期 《深入浅出Java虚拟机》 文章目录 系列文章目录前言一、推荐书籍二…
阅读更多...
LeetCode 周赛上分之旅 #48 一道简单的树上动态规划问题

LeetCode 周赛上分之旅 #48 一道简单的树上动态规划问题

⭐️ 本文已收录到 AndroidFamily&#xff0c;技术和职场问题&#xff0c;请关注公众号 [彭旭锐] 和 BaguTree Pro 知识星球提问。 学习数据结构与算法的关键在于掌握问题背后的算法思维框架&#xff0c;你的思考越抽象&#xff0c;它能覆盖的问题域就越广&#xff0c;理解难度…
阅读更多...
软件测试/测试开发丨python 多态与super 学习笔记

软件测试/测试开发丨python 多态与super 学习笔记

本文为霍格沃兹测试开发学社学员学习笔记分享 原文链接&#xff1a;https://ceshiren.com/t/topic/26828 python 多态与super 多态的概念 多态&#xff1a;Polymorphism 同名方法呈现多种行为 多态的表现 号 加法&#xff1a;数字 数字拼接&#xff1a;字符串 字符串合…
阅读更多...
2023年10月腾讯云优惠活动汇总：腾讯云最新优惠、代金券整理

2023年10月腾讯云优惠活动汇总：腾讯云最新优惠、代金券整理

腾讯云作为国内领先的云服务提供商&#xff0c;致力于为用户提供优质、稳定的云服务。为了更好地满足用户需求&#xff0c;腾讯云推出了各种优惠活动。本文将给大家分享腾讯云最新优惠活动&#xff0c;帮助用户充分利用腾讯云提供的优惠。 一、腾讯云优惠券领取【点此领取】 腾…
阅读更多...
北京互联网公司、外企、国企大盘点

北京互联网公司、外企、国企大盘点

今天来盘点北京的泛互联网公司。涵盖了综合类、外企类、硬件类、电商类、游戏类、娱乐类、生活类、工具类、人工智能类、金融类、教育类、招聘类、汽车类、外包类、信息化类以及国企央企类等多个领域。 综合类 字节跳动 美团 百度 阿里巴巴 腾讯 网易 外企类 微软 谷歌 亚马逊…
阅读更多...
CSP-J第二轮试题-2021年-4题

CSP-J第二轮试题-2021年-4题

文章目录 参考&#xff1a;总结 [CSP-J 2021] 小熊的果篮题目描述输入格式输出格式样例 #1样例输入 #1样例输出 #1 样例 #2样例输入 #2样例输出 #2 样例 #3样例输入 #3样例输出 #3 提示答案1答案2答案3 现场真题注意事项 参考&#xff1a; https://www.luogu.com.cn/problem/P…
阅读更多...
Leetcode 50.Pow(x,n)

Leetcode 50.Pow(x,n)

实现 pow(x, n) &#xff0c;即计算 x 的整数 n 次幂函数&#xff08;即&#xff0c;xn &#xff09;。 示例 1&#xff1a; 输入&#xff1a;x 2.00000, n 10 输出&#xff1a;1024.00000示例 2&#xff1a; 输入&#xff1a;x 2.10000, n 3 输出&#xff1a;9.26100示例…
阅读更多...
Java大数 -- BigInteger类

Java大数 -- BigInteger类

在java语言中&#xff0c;每一种整数类型都有自己的上限和下限&#xff0c;如果要想对非常大的整数做运算&#xff0c;就需要使用BigInteger类。特别在做算法题传入一个数值型的字符串时。 1.包 import java.math.*; 2.构造方法 public BigInteger(String str){...} BigInte…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023