服务注册与服务发现

服务注册与服务发现

Eureka的架构

Eureka客户端：使用了@EnableEurekaClient注解的应用服务，如订单服务等，甚至Eureka本身也是一个客户端
Eureka服务端：使用了@EnableEurekaServer注解的应用服务，该服务提供了注册表以及对服务节点的操作
服务提供者：服务启动后，可以向注册中心发起register请求，将服务信息注册进去
服务消费者：服务启动后，可以从注册中心拉取服务信息，并根据所得的服务信息调用服务
他们之间的关系为：
Eureka-server你可以当作他是一个单独的服务，而跟它对接的都是Eureka-client，而Eureka-client中则包含了服务消费者和服务提供者等角色。例如订单服务中包含一个消费者A，商品服务中包含一个提供者B，现在消费者A想查询该订单对应的商品信息，那就是查询提供者B的服务，那么首先A和B都必须先把自己作为一个eureka客户端，然后B将自己的服务信息发送到eureka的服务端中，A再从eureka服务端中拉取B的服务信息（地址），然后发起请求。

服务端

所需依赖

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

启动服务时需要添加两个注解

@EnableEurekaServer
@SpringBootApplication

客户端

所需依赖

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

启动服务需要配置

@EnableEurekaClient
@SpringBootApplication

关系

1、服务提供者、服务消费者、服务发现组件三者之间的关系大致如下:
1）各个微服务在启动时时，将自己的网络地址等信息注册到服务发现组件上(eureka,zookeeper,Consul,spring cloud alibaba的nacos),服务发现组件会存储这些信息。
2）服务消费者会从服务发现组件查询服务提供者的网络地址，然后将服务地址列表缓存到本地，然后根据服务名负载均衡调用服务提供者的接口。
3）各个微服务与服务发现组件使用一定的机制来维持心跳，服务发现组件若发现有服务没有提供心跳，那么服务发现组件会将该服务剔除。
4）微服务网络地址发生变更(例如实例增减或者IP端口发生变化等)，会重新注册到服务发现组件上，使用这种方式，可以避免因网络变化导致服务之间的通讯停止，服务消费者也无须人工的修改网络地址。

Eureka简介

Eureka是Netflix开发的服务发现框架，本身是一个基于REST的服务，主要用于定位运行在AWS域中的中间层服务，以达到负载均衡和中间层服务故障转移的目的。SpringCloud将它集成在其子项目spring-cloud-netflix中，以实现SpringCloud的服务发现功能。
1.Eureka包含两个组件：Eureka Server和Eureka Client。
Eureka Server提供服务注册服务，各个节点启动后，会在Eureka Server中进行注册，这样EurekaServer中的服务注册表中将会存储所有可用服务节点的信息，服务节点的信息可以在界面中直观的看到。
Eureka Client是一个java客户端，用于简化与Eureka Server的交互，客户端同时也就是一个内置的、使用轮询负载算法的负载均衡器。
2.在应用启动后，Eureka Client会向Eureka Server发送心跳,默认周期为30秒，如果Eureka Server在多个心跳周期内没有接收到某个节点的心跳，Eureka Server将会从服务注册表中把这个服务节点移除(默认90秒)。
3.Eureka Server之间通过复制的方式完成数据的同步，Eureka还提供了客户端缓存机制，即使所有的Eureka Server都挂掉，客户端依然可以利用缓存中的信息消费其他服务的API。综上，Eureka通过心跳检查、客户端缓存等机制，确保了系统的高可用性、灵活性和可伸缩性。

三、Eureka一些特性及配置过程时需要注意的问题
1.Eureka能够保证AP，即当Eureka中的某个节点挂掉后，剩余的节点继续仍然可以提供服务的发现与注册服务。而Eureka的客户端在向某个Eureka或者发现了当前的Eureka不可用时，会自动切换到其他的节点，也就是说Eureka的节点是平等的，只要有一台Eureka服务器在，就能保证服务的可以继续被使用。
2.Eureka的自我保护机制，我们在注册服务时，如发生断网的情况，Eureka不能接收到当前服务的任何心跳请求，Eureka会在默认的90s后，将该服务进行强制剔除，这样就能保证到网络故障时，虽然失去了部分节点，但不会像zookeeper那样会使整个注册服务瘫痪。当网络稳定时，新的实例会同步到其他节点中。
3.相关配置问题
服务端的配置如下，不注册自身

security:basic:enabled: trueuser:name: userpassword: password123
eureka:client:register-with-eureka: falsefetch-registry: falseservice-url:defaultZone: http://user:password123@localhost:8761/eureka

引入依赖

<!-- eureka-server-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka-server</artifactId><version>1.2.3.RELEASE</version>
</dependency><!--eureka-client-->
<dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-starter-eureka</artifactId><version>1.2.3.RELEASE</version>
</dependency>

Eureka客户端应用服务注册流程

1、应用集成eureka客户端依赖，配置eureka相关信息；
2、当应用启动完成后，应用会自动向eureka-server服务发请求，将自身的示例信息注册到eureka-server；
3、会启动心跳进程和服务状态检测时间；心跳每隔30s一次；应用服务状态发生变更，也会想eureka-server服务进行服务重新注册；
4、当应用服务进行关闭时，会调用shutdown方法，进行服务下线的操作；当服务因断电/网络问题/意外停机，无法正确的下线服务时，这时心跳就会起到相对应的作用，如果eureka-server服务发现应用超过三次（90s）没有心跳，那么就会将服务进行保护/下线；

源码分析

源码分析：
应用在服务启动时自动注册的实现：配置类：EurekaClientAutoConfiguration里面向IOC容器内注册了EurekaAutoServiceRegistration.class对象

@Bean
@ConditionalOnBean(AutoServiceRegistrationProperties.class)
@ConditionalOnProperty(value = "spring.cloud.service-registry.auto-registration.enabled", matchIfMissing = true)
public EurekaAutoServiceRegistration eurekaAutoServiceRegistration(ApplicationContext context, EurekaServiceRegistry registry,EurekaRegistration registration) {return new EurekaAutoServiceRegistration(context, registry, registration);
}

EurekaAutoServiceRegistration.class实现了SmartLifecycle.class
SmartLifecycle.class这个类是在应用启动后，自动调用start()

@Override
public void start() {// 端口配置if (this.port.get() != 0) {if (this.registration.getNonSecurePort() == 0) {this.registration.setNonSecurePort(this.port.get());}if (this.registration.getSecurePort() == 0 && this.registration.isSecure()) {this.registration.setSecurePort(this.port.get());}}// only initialize if nonSecurePort is greater than 0 and it isn't already running// because of containerPortInitializer belowif (!this.running.get() && this.registration.getNonSecurePort() > 0) {// 进行主动注册this.serviceRegistry.register(this.registration);// 发布注册事件this.context.publishEvent(new InstanceRegisteredEvent<>(this, this.registration.getInstanceConfig()));this.running.set(true);}}

EurekaServiceRegistry#register() 注册代码如下：

@Override
public void register(EurekaRegistration reg) {maybeInitializeClient(reg);if (log.isInfoEnabled()) {log.info("Registering application " + reg.getApplicationInfoManager().getInfo().getAppName()+ " with eureka with status "+ reg.getInstanceConfig().getInitialStatus());}reg.getApplicationInfoManager().setInstanceStatus(reg.getInstanceConfig().getInitialStatus());// 进行注册健康检查reg.getHealthCheckHandler().ifAvailable(healthCheckHandler ->reg.getEurekaClient().registerHealthCheck(healthCheckHandler));
}

进行安全健康检查同时注册信息 DiscoveryClient#registerHealthCheck()

@Overridepublic void registerHealthCheck(HealthCheckHandler healthCheckHandler) {if (instanceInfo == null) {logger.error("Cannot register a healthcheck handler when instance info is null!");}if (healthCheckHandler != null) {this.healthCheckHandlerRef.set(healthCheckHandler);// schedule an onDemand update of the instanceInfo when a new healthcheck handler is registeredif (instanceInfoReplicator != null) {// 进行注册instanceInfoReplicator.onDemandUpdate();}}}

在上述的onDemandUpdate()方法中有个register方法，代码如下
DiscoveryClient#register()

boolean register() throws Throwable {logger.info(PREFIX + "{}: registering service...", appPathIdentifier);EurekaHttpResponse<Void> httpResponse;try {            // 发请求给配置url进行注册 httpResponse = eurekaTransport.registrationClient.register(instanceInfo);} catch (Exception e) {logger.warn(PREFIX + "{} - registration failed {}", appPathIdentifier, e.getMessage(), e);throw e;}if (logger.isInfoEnabled()) {logger.info(PREFIX + "{} - registration status: {}", appPathIdentifier, httpResponse.getStatusCode());}// 返回204码代表注册成功return httpResponse.getStatusCode() == 204;}

AbstractJerseyEurekaHttpClient#register()

@Override
public EurekaHttpResponse<Void> register(InstanceInfo info) {String urlPath = "apps/" + info.getAppName();ClientResponse response = null;try {Builder resourceBuilder = jerseyClient.resource(serviceUrl).path(urlPath).getRequestBuilder();addExtraHeaders(resourceBuilder);response = resourceBuilder.header("Accept-Encoding", "gzip").type(MediaType.APPLICATION_JSON_TYPE).accept(MediaType.APPLICATION_JSON).post(ClientResponse.class, info);return anEurekaHttpResponse(response.getStatus()).headers(headersOf(response)).build();} finally {if (logger.isDebugEnabled()) {logger.debug("Jersey HTTP POST {}/{} with instance {}; statusCode={}", serviceUrl, urlPath, info.getId(), response == null ? "N/A" : response.getStatus());}if (response != null) {response.close();}}
}

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

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

相关文章

使用Git把项目上传到Gitee的详细步骤

使用Git把项目上传到Gitee的详细步骤

1.到Git官网下载并安装 2.到Gitee官网进行注册&#xff0c;然后在Gitee中新建一个远程仓库 3.设置远程仓库的参数 4.返回Gitee查看仓库是否生成成功 5.新建一个文件夹作为你的本地仓库 6.将新建好的文件夹初始化成本地仓库 第一步&#xff1a;右键点击刚创建的本地仓库&#…
阅读更多...
小程序实现一个 倒计时组件

小程序实现一个 倒计时组件

小程序实现一个 倒计时组件 需求背景 要做一个倒计时&#xff0c;可能是天级别&#xff0c;也可能是日级别&#xff0c;时级别&#xff0c;而且每个有效订单都要用&#xff0c;就做成组件了 效果图 需求分析 需要一个未来的时间戳&#xff0c;或者在服务度直接下发一个未来…
阅读更多...
NeuroFlash:AI文章写作与生成工具

NeuroFlash:AI文章写作与生成工具

【产品介绍 ​ 】 名称 NeuroFlash 上线时间 2015 具体描述 Neuroflash是一款基于人工智能的文本和图像生成器&#xff0c;可以帮助用户快速创建高质量的内容。Neuroflash拥有超过100种短文和长文的文本类型&#xff0c;涵盖了各种营销场景和需求。只需要输入简单的指示&#…
阅读更多...
【Excel函数】Trim函数删除前后多余的空格

【Excel函数】Trim函数删除前后多余的空格

Excel 中的 TRIM 函数用于删除文本字符串两端多余的空格&#xff0c;只保留字符串内部的空格。这对于清理和规范化文本数据非常有用。 在使用Excel中使用TRIM可以删除内容前面和后面的空格字符&#xff0c;Trim的语法规则如下&#xff1a; A2trim(Text) text&#xff1a;要进…
阅读更多...
最新ChatGPT网站源码+支持GPT4.0+支持Midjourney绘画+支持国内全AI模型

最新ChatGPT网站源码+支持GPT4.0+支持Midjourney绘画+支持国内全AI模型

一、智能创作系统 SparkAi创作系统是基于国外很火的ChatGPT进行开发的Ai智能问答系统。本期针对源码系统整体测试下来非常完美&#xff0c;可以说SparkAi是目前国内一款的ChatGPT对接OpenAI软件系统。那么如何搭建部署AI创作ChatGPT&#xff1f;小编这里写一个详细图文教程吧&…
阅读更多...
Debian12系统下LAMP环境中Nubuilder4.5的安装

Debian12系统下LAMP环境中Nubuilder4.5的安装

一、环境搭建 按照官方的说法&#xff0c;Apache2和Nginx都可以的&#xff0c;实际上&#xff0c;你最好直接按照 Mariadb\Apache2\Php8.2 这个顺序&#xff0c;搭建LAMP环境较好。不然各种调试&#xff0c;还不一定能够成功。 相关搭建方法&#xff0c;属于一般操作&#xf…
阅读更多...
java类的命名规范

java类的命名规范

Java类的命名规范是一种编码规范&#xff0c;用于指导开发人员在命名Java类时遵循一致性和可读性的原则。以下是Java类的命名规范的主要要点&#xff1a; 类名应该使用大驼峰命名法&#xff08;UpperCamelCase&#xff09;&#xff1a; 类名的每个单词首字母都应该大写&#xf…
阅读更多...
js中如何判断一个变量是否为数字类型？

js中如何判断一个变量是否为数字类型？

聚沙成塔每天进步一点点 ⭐ 专栏简介⭐使用Number.isNaN()方法⭐使用正则表达式⭐使用isNaN()函数⭐ 写在最后 ⭐ 专栏简介 前端入门之旅&#xff1a;探索Web开发的奇妙世界 记得点击上方或者右侧链接订阅本专栏哦 几何带你启航前端之旅 欢迎来到前端入门之旅&#xff01;这个…
阅读更多...
LeetCode:1929.数组串联

LeetCode:1929.数组串联

1929. 数组串联 来源：力扣（LeetCode） 链接: https://leetcode.cn/problems/concatenation-of-array/description/ 给你一个长度为 n 的整数数组 nums 。请你构建一个长度为 2n 的答案数组 ans ，数组下标 从 0 开始计数 ，对于所有 0 < = i < n 0 <= i < n …
阅读更多...
MD5 算法流程

MD5 算法流程

先通过下面的命令对 md5算法有个感性的认识&#xff1a; $ md5sum /tmp/1.txt 1dc792fcaf345a07b10248a387cc2718 /tmp/1.txt$ md5sum // 从键盘输入&#xff0c;ctrl-d 结束输入 hello, world! 910c8bc73110b0cd1bc5d2bcae782511 -从上面可以看到&#xff0c;一个文件或一…
阅读更多...
MySQL（1） 索引结构

MySQL（1） 索引结构

1、索引结构 索引概念&#xff1a;是帮助mysql高效获取数据的排好序的数据结构 2、MySQL为什么用BTree 为什么不用二叉树&#xff0c;单边增长 为什么不用红黑树&#xff0c;树的高度不受控制 为什么不用B-Tree,为了节省空间 为什么不用Hash表&#xff0c;Hash不支持范围查询 …
阅读更多...
C++ - map 的 例题

C++ - map 的 例题

前言 本博客在 一下文章关于 map 和 set 讲解之下&#xff0c;对 map 当中的 operator[] &#xff08;&#xff09;函数的功能运用&#xff0c;感受 map 功能强大。 349. 两个数组的交集 - 力扣&#xff08;LeetCode&#xff09; 给定两个数组 nums1 和 nums2 &#xff0c;返回…
阅读更多...
AWT中常用组件

AWT中常用组件

笔记&#xff1a;https://www.yuque.com/huangzhanqi/rhwoir/repuodh23fz01wiv 仓库&#xff1a;Java图形化界面: Java图形化界面学习demo与资料 (gitee.com) 基本组件 组件名 功能 Button Button Canvas 用于绘图的画布 Checkbox 复选框组件&#xff08;也可当做单选…
阅读更多...
Java 使用 EMQX 实现物联网 MQTT 通信

Java 使用 EMQX 实现物联网 MQTT 通信

一、介绍 1、MQTT MQTT(Message Queuing Telemetry Transport, 消息队列遥测传输协议)&#xff0c;是一种基于发布/订阅(publish/subscribe)模式的"轻量级"通讯协议&#xff0c;该协议构建于TCP/IP协议上&#xff0c;由IBM在1999年发布。MQTT最大优点在于&#xff…
阅读更多...
第37章_瑞萨MCU零基础入门系列教程之DAC数模转换模块

第37章_瑞萨MCU零基础入门系列教程之DAC数模转换模块

本教程基于韦东山百问网出的 DShanMCU-RA6M5开发板 进行编写&#xff0c;需要的同学可以在这里获取&#xff1a; https://item.taobao.com/item.htm?id728461040949 配套资料获取&#xff1a;https://renesas-docs.100ask.net 瑞萨MCU零基础入门系列教程汇总&#xff1a; ht…
阅读更多...
MATLAB基础-MAT文件的读写操作

MATLAB基础-MAT文件的读写操作

简介 MAT文件是MATLAB格式的双精度二进制数据文件&#xff0c;由MATLAB软件创建&#xff0c;可以使用MATLAB软件再其他计算机上以其他浮点格式读取&#xff0c;同时也可以使用其他软件通过MATLAB的应用程序接口来进行读写操作。如果只是再MATLAB环境中处理数据&#xff0c;使用…
阅读更多...
【深度学习】树莓派Zero w深度学习模型Python推理

【深度学习】树莓派Zero w深度学习模型Python推理

在机器学习开发过程中&#xff0c;当模型训练好后&#xff0c;接下来就要进行模型推理了&#xff0c;根据部署环境可分为三类场景&#xff1a; 边缘计算&#xff1a;一般指手机&#xff0c;嵌入式设备&#xff0c;直接在数据生成的设备上进行推理&#xff0c;因为能避免将采集…
阅读更多...
SkyWalking安装部署

SkyWalking安装部署

一、概念 1、什么是 APM 系统&#xff1f; APM&#xff08;Application Performance Management&#xff09;即应用性能管理系统&#xff0c;是对企业系统即时监控以实现对应用程序性能管理和故障管理的系统化的解决方案。应用性能管理&#xff0c;主要指对企业的关键业务应用…
阅读更多...
不使用辅助变量的前提下实现两个变量的交换

不使用辅助变量的前提下实现两个变量的交换

package operator; //不用第三个辅助变量&#xff0c;实现两个数的交换 public class Demo08 {public static void change(int a, int b){a ab;b a-b;a a-b;System.out.println(a);System.out.println(b);}public static void main(String[] args) {change(900,3000);} }后续…
阅读更多...
UMA 2 - Unity Multipurpose Avatar☀️七.UMA API介绍 : 基本API与保存加载配置

UMA 2 - Unity Multipurpose Avatar☀️七.UMA API介绍 : 基本API与保存加载配置

文章目录 🟥 UMA Data DNA参数引用位置🟥 UMA API介绍🟥 UMA Data DNA参数引用位置 我们想通过代码去控制如图所示参数,达到捏脸的目的.下面就是可以控制的代码: _dna["headSize"].Set(1); _avatar.BuildCharacter();我们观察发现操控代码类似Material去设置…
阅读更多...
最新文章

Copyright @ 2022~2023