Eureka 学习笔记3：EurekaHttpClient

news2024/11/17 16:47:42

版本 awsVersion = ‘1.11.277’

EurekaTransport 用于客户端和服务端之间进行通信，封装了以下接口的实现：

  1. ClosableResolver 接口实现
  2. TransportClientFactory 接口实现
  3. EurekaHttpClient 接口实现及其对应的 EurekaHttpClientFactory 接口实现
private static final class EurekaTransport {
    // 服务端集群解析器，用于获取服务端列表
    private ClosableResolver bootstrapResolver;

    // 底层工厂，用于创建具体通信协议的实现
    private TransportClientFactory transportClientFactory;

    // EurekaHttpClient实现，用于注册实例、取消注册、续约
    private EurekaHttpClient registrationClient;
    // 上层工厂，用于创建registrationClient
    private EurekaHttpClientFactory registrationClientFactory;

    // EurekaHttpClient实现，用于全量拉取、增量拉取服务列表
    private EurekaHttpClient queryClient;
    // 上层工厂，用于创建queryClient
    private EurekaHttpClientFactory queryClientFactory;
}

EurekaHttpClientFactory 是上层工厂接口（A top level factory interface），用于创建 EurekaHttpClientDecorator 对象（to create http clients for application/eurekaClient use）。

public interface EurekaHttpClientFactory {

    EurekaHttpClient newClient();

    void shutdown();
}

例如 DiscoveryClient # scheduleServerEndpointTask 方法：

newRegistrationClientFactory = EurekaHttpClients
    .registrationClientFactory(
        eurekaTransport.bootstrapResolver,
        eurekaTransport.transportClientFactory,
        transportConfig
    );
newRegistrationClient = newRegistrationClientFactory.newClient();

TransportClientFactory 是底层工厂接口（A low level client factory interface），用于创建 JerseyApplicationClient（Eureka 原生实现）、Jersey2ApplicationClient（Eureka 原生实现）、RestTemplateEurekaHttpClient（SpringCloud 实现）等具体协议相关的实现。底层工厂创建的对象不建议直接使用（Not advised to be used by top level consumers），需要经过上层工厂加工。

public interface TransportClientFactory {

    EurekaHttpClient newClient(EurekaEndpoint serviceUrl);

    void shutdown();
}

例如 DiscoveryClient # scheduleServerEndpointTask 方法：

TransportClientFactories transportClientFactories = 
    argsTransportClientFactories == null
        ? new Jersey1TransportClientFactories()
        : argsTransportClientFactories;

EurekaHttpClient 接口，用于客户端和服务端之间进行通信，封装了注册、取消注册、续约、拉取服务列表等一系列操作。

public interface EurekaHttpClient {
    // 注册实例（服务注册）
    EurekaHttpResponse<Void> register(InstanceInfo info);
    // 取消注册（服务下线）
    EurekaHttpResponse<Void> cancel(String appName, String id);
    // 发送心跳（服务续约）
    EurekaHttpResponse<InstanceInfo> sendHeartBeat(String appName, String id, InstanceInfo info, InstanceStatus overriddenStatus);
    // 更新实例的服务状态InstanceStatus（服务状态更新）
    EurekaHttpResponse<Void> statusUpdate(String appName, String id, InstanceStatus newStatus, InstanceInfo info);
    // 删除实例的覆盖状态，overriddenStatus将变成UNKNOWN
    EurekaHttpResponse<Void> deleteStatusOverride(String appName, String id, InstanceInfo info);
    // 获取指定区域regions的注册表（全量获取）
    EurekaHttpResponse<Applications> getApplications(String... regions);
    // 获取指定区域regions的注册列表（增量获取）
    EurekaHttpResponse<Applications> getDelta(String... regions);

    EurekaHttpResponse<Applications> getVip(String vipAddress, String... regions);

    EurekaHttpResponse<Applications> getSecureVip(String secureVipAddress, String... regions);
    // 获取指定应用的实例列表
    EurekaHttpResponse<Application> getApplication(String appName);
    // 获取指定实例
    EurekaHttpResponse<InstanceInfo> getInstance(String appName, String id);
    // 获取指定实例
    EurekaHttpResponse<InstanceInfo> getInstance(String id);

    void shutdown();
}

EurekaHttpClient
HttpReplicationClient 用于服务端和服务端之间进行通信，在 EurekaHttpClient 的基础上封装了更新服务端实例状态、批量同步数据等操作。

public interface HttpReplicationClient extends EurekaHttpClient {
    // 更新服务端实例的状态
    EurekaHttpResponse<Void> statusUpdate(String asgName, ASGStatus newStatus);
    // 向其他服务端批量同步数据
    EurekaHttpResponse<ReplicationListResponse> submitBatchUpdates(ReplicationList replicationList);
}

Eureka 服务端集群节点是对等节点（peerNode），对等节点之间进行数据同步会产生循环问题和数据冲突问题。

  • 对于循环问题，Eureka 使用 Http 请求头 x-netflix-discovery-replication 表示是否是服务端同步数据操作，如果是服务端同步数据，就不会再继续向其他服务端进行同步数据。
// com.netflix.eureka.resources.InstanceResource
@PUT
public Response renewLease(
            @HeaderParam(PeerEurekaNode.HEADER_REPLICATION) String isReplication,
            @QueryParam("overriddenstatus") String overriddenStatus,
            @QueryParam("status") String status,
            @QueryParam("lastDirtyTimestamp") String lastDirtyTimestamp) {
    boolean isFromReplicaNode = "true".equals(isReplication);
    boolean isSuccess = registry.renew(app.getName(), id, isFromReplicaNode);
    // ...
}

// com.netflix.eureka.registry.PeerAwareInstanceRegistryImpl
private void replicateToPeers(Action action,
                              String appName,
                              String id,
                              InstanceInfo info /* optional */,
                              InstanceStatus newStatus /* optional */,
                              boolean isReplication) {
    // ...
    // If it is a replication already,
    // do not replicate again as this will create a poison replication
    if (peerEurekaNodes == Collections.EMPTY_LIST || isReplication) {
        return;
    }
    // ...
}
  • 对于数据冲突问题，Eureka 通过比较 ReplicationInstance 类的 lastDirtyTimestamp 属性解决。lastDirtyTimestamp 是服务实例 InstanceInfo 的属性，表示服务实例最近一次变更时间。

例如 Server A 向 Server B 同步数据：

  1. 如果 Server A 的数据比 Server B 的新，Server B 返回 Status.NOT_FOUND，Server A 重新将该服务实例注册到 Server B
  2. 如果 Server A 的数据比 Server B 的旧，Server B 返回 Status.CONFLICT，要求 Server A 同步 Server B 的数据
// com.netflix.eureka.resources.InstanceResource # renewLease
private Response validateDirtyTimestamp(Long lastDirtyTimestamp,
                                            boolean isReplication) {
    InstanceInfo appInfo = registry.getInstanceByAppAndId(app.getName(), id, false);
    if (appInfo != null) {
        if ((lastDirtyTimestamp != null) 
            && (!lastDirtyTimestamp.equals(appInfo.getLastDirtyTimestamp()))) {

            Object[] args = {
                                id,
                                appInfo.getLastDirtyTimestamp(),
                                lastDirtyTimestamp,
                                isReplication
                            };

            if (lastDirtyTimestamp > appInfo.getLastDirtyTimestamp()) {
                logger.debug(
                    "Time to sync, " + 
                    "since the last dirty timestamp differs - " + 
                    "ReplicationInstance id : {}," + 
                    "Registry: {} Incoming: {} Replication: {}",
                    args);
                return Response.status(Status.NOT_FOUND).build();
            } else if (appInfo.getLastDirtyTimestamp() > lastDirtyTimestamp) {
                // In the case of replication, 
                // send the current instance info in the registry 
                // for the replicating node to sync itself with this one.
                if (isReplication) {
                    logger.debug(
                        "Time to sync, " + 
                        "since the last dirty timestamp differs - " + 
                        "ReplicationInstance id : {}," + 
                        "Registry: {} Incoming: {} Replication: {}",
                        args);
                    return Response.status(Status.CONFLICT)
                                   .entity(appInfo)
                                   .build();
                } else {
                    return Response.ok().build();
                }
            }
        } // end if ((lastDirtyTimestamp != null)
    }// end if (appInfo != null)
    return Response.ok().build();
}

抽象类 EurekaHttpClientDecorator 使用装饰者模式为 EurekaHttpClient 添加新的功能。

EurekaHttpClientDecorator

  • SessionedEurekaHttpClient 为 EurekaHttpClient 设置随机的会话时间，超过会话时间则调用 EurekaHttpClientFactory 的 newClient 方法创建一个新的 EurekaHttpClient 执行请求。随机的会话时间在配置 sessionedClientReconnectIntervalSeconds 的 0.5-1.5 之间。

  • RetryableEurekaHttpClient 为 EurekaHttpClient 提供重试功能，默认重试 3 次。当服务端响应异常时，将服务端添加到 quarantineSet 中，并从 ClusterResolver 解析得到的服务端列表中移除 quarantineSet ，选择其他的服务端创建一个新的 EurekaHttpClient 执行请求，超过重试次数则抛出 TransportException 异常。

  • RedirectingEurekaHttpClient 为 EurekaHttpClient 提供重定向功能，默认可重定向次数 10 次。当服务端响应 302 时，获取响应中的 targetUrl，创建一个新的 EurekaHttpClient 执行请求，超过重定向次数则抛出 TransportException 异常。

  • MetricsCollectingEurekaHttpClient 为 EurekaHttpClient 提供指标收集功能，用于集成 Netflix Servo 监控组件，统计各类型请求的耗时以及不同响应码和异常的计数。

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

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

相关文章

【雕爷学编程】MicroPython动手做（16）——掌控板之图片图像显示2

【雕爷学编程】MicroPython动手做（16）——掌控板之图片图像显示2

知识点&#xff1a;什么是掌控板&#xff1f; 掌控板是一块普及STEAM创客教育、人工智能教育、机器人编程教育的开源智能硬件。它集成ESP-32高性能双核芯片&#xff0c;支持WiFi和蓝牙双模通信&#xff0c;可作为物联网节点&#xff0c;实现物联网应用。同时掌控板上集成了OLED…
阅读更多...
第120天：免杀对抗-防朔源防流量防特征CDN节点SSL证书OSS存储上线

第120天：免杀对抗-防朔源防流量防特征CDN节点SSL证书OSS存储上线

知识点 #知识点&#xff1a; 1、CS-CDN节点-防拉黑 2、CS-SSL证书-防特征 3、CS-OSS存储-防流量#章节点&#xff1a; 编译代码面-ShellCode-混淆 编译代码面-编辑执行器-编写 编译代码面-分离加载器-编写 程序文件面-特征码定位-修改 程序文件面-加壳花指令-资源 代码加载面-D…
阅读更多...
springCloud Eureka注册中心配置详解

springCloud Eureka注册中心配置详解

1、创建一个springBoot项目 2、在springBoot项目中添加SpringCloud依赖 <dependency><groupId>org.springframework.cloud</groupId><artifactId>spring-cloud-dependencies</artifactId><version>2021.0.3</version><type>…
阅读更多...
IDEA 使用 maven 搭建 spring mvc

IDEA 使用 maven 搭建 spring mvc

1. 创建项目 1.1 创建成功之后配置 Spring MVC 1.2 勾选 Spring MVC 2.更改配置文件 2.1 更改web.xml配置 更改为 <servlet-mapping><servlet-name>dispatcher</servlet-name><url-pattern>/</url-pattern></servlet-mapping>2.2 dispat…
阅读更多...
CF1833 A-E

CF1833 A-E

A题 题目链接&#xff1a;https://codeforces.com/problemset/problem/1833/A 基本思路&#xff1a;for循环遍历字符串s&#xff0c;依次截取字符串s的子串str&#xff0c;并保存到集合中&#xff0c;最后输出集合内元素的数目即可 AC代码&#xff1a; #include <iostrea…
阅读更多...
Michael.W基于Foundry精读Openzeppelin第15期——SignedMath.sol

Michael.W基于Foundry精读Openzeppelin第15期——SignedMath.sol

Michael.W基于Foundry精读Openzeppelin第15期——SignedMath.sol 0. 版本0.1 SignedMath.sol 1. 目标合约2. 代码精读2.1 max(int256 a, int256 b) && min(int256 a, int256 b)2.2 average(int256 a, int256 b)2.3 abs(int256 n) 0. 版本 [openzeppelin]&#xff1a;v…
阅读更多...
final的使用以及权限修饰符

final的使用以及权限修饰符

final表示最终的、不可改变的 final跟abstract不可以同时使用&#xff0c;因为二者是冲突的。final表示不可变&#xff0c;abstrac表示必须要重写、必须要变。 常见的四种用法 修饰一个类 格式&#xff1a; public final class 类名称{ }final修饰之后&#xff0c;这个类不能…
阅读更多...
杂谈项——关于我在bw上的见闻，以及个人对二次元游戏行业方面的前瞻

杂谈项——关于我在bw上的见闻，以及个人对二次元游戏行业方面的前瞻

君兮_的个人主页 勤时当勉励 岁月不待人 C/C 游戏开发 Hello,米娜桑们&#xff0c;这里是君兮_&#xff0c;今天为大家带来一点不一样的&#xff0c;首先先光速叠一下甲&#xff1a; 在此说明博主并不是一个什么都知道的大佬&#xff0c;只是一个普通的老二次元以及期望以后能…
阅读更多...
大数据-Spark批处理实用广播Broadcast构建一个全局缓存Cache

大数据-Spark批处理实用广播Broadcast构建一个全局缓存Cache

1、broadcast广播 在Spark中&#xff0c;broadcast是一种优化技术&#xff0c;它可以将一个只读变量缓存到每个节点上&#xff0c;以便在执行任务时使用。这样可以避免在每个任务中重复传输数据。 2、构建缓存 import org.apache.spark.sql.SparkSession import org.apache.s…
阅读更多...
Xshell配置ssh免密码登录-公钥与私钥登录linux服务器

Xshell配置ssh免密码登录-公钥与私钥登录linux服务器

目录 简介 提示 方法步骤 步骤1&#xff1a;生成密钥公钥&#xff08;Public key&#xff09;与私钥(Private Key) 方法1&#xff1a;使用xshell工具 方法2&#xff1a;使用命令行 步骤2&#xff1a;放置公钥(Public Key)到服务器 方法1&#xff1a;&#xff08;我使用的是…
阅读更多...
LeetCode551.Student-Attendance-Record-i＜学生出勤记录 I＞

LeetCode551.Student-Attendance-Record-i＜学生出勤记录 I＞

题目&#xff1a; 思路&#xff1a; 遍历就完事了.连续三天不来return false; 超过两次缺勤 fasle; 代码是&#xff1a; //codeclass Solution { public:bool checkRecord(string s) {int n s.length();int abtimes0,latimes0;for(int i0;i<n;i){switch(s[i]){case(A):l…
阅读更多...
总结942

总结942

5:40起床 6:00~7:00单词复习300个&#xff0c;记100个 7:15~8:00早读&#xff0c;《love is as strong as death》第一第二段 8:10~9:10三大计算回顾 9:15~10:06 习题880第一章基础选择纠错 10:10~10&#xff1a;30单词默写 10:30~11:40强化第一讲习题 11:40~12:30继续…
阅读更多...
【雕爷学编程】MicroPython动手做（16）——掌控板之图片图像显示3

【雕爷学编程】MicroPython动手做（16）——掌控板之图片图像显示3

知识点&#xff1a;什么是掌控板&#xff1f; 掌控板是一块普及STEAM创客教育、人工智能教育、机器人编程教育的开源智能硬件。它集成ESP-32高性能双核芯片&#xff0c;支持WiFi和蓝牙双模通信&#xff0c;可作为物联网节点&#xff0c;实现物联网应用。同时掌控板上集成了OLED…
阅读更多...
Android 设备兼容性使用详解

Android 设备兼容性使用详解

和你一起终身学习&#xff0c;这里是程序员Android 经典好文推荐&#xff0c;通过阅读本文&#xff0c;您将收获以下知识点: 一、设备兼容性分类二、硬件设备兼容三、软件 APP 兼容四、兼容不同语言五、兼容不同分辨率六、兼容不同屏幕方向布局七、兼容不同硬件 Feature八、兼容…
阅读更多...
TortoiseGit安装与配置

TortoiseGit安装与配置

注&#xff1a;在安装TortoiseGit之前我已经安装了git工具。 二、Git的诞生及环境配置_tortoisegit安装包_朱嘉鼎的博客-CSDN博客 1、TortoiseGit简介 TortoiseGit是基于TortoiseSVN的Git版本的Windows Shell界面。它是开源的&#xff0c;可以完全免费使用。 TortoiseGit 支持…
阅读更多...
redis突然变慢问题定位

redis突然变慢问题定位

CPU 相关&#xff1a;使用复杂度过高命令、数据的持久化&#xff0c;都与耗费过多的 CPU 资源有关 内存相关&#xff1a;bigkey 内存的申请和释放、数据过期、数据淘汰、碎片整理、内存大页、内存写时复制都与内存息息相关 磁盘相关&#xff1a;数据持久化、AOF 刷盘策略&…
阅读更多...
v.sqlflow.cn 上线试用

v.sqlflow.cn 上线试用

马哈鱼数据血缘工具从2023年8月开始开通国内云版本的服务&#xff0c;相比国外版本&#xff0c;访问速度有很大的提升&#xff0c;访问域名为 https://v.sqlflow.cn. 2023年8月和9月注册的用户可免费获得价值 3000 元的一年高级帐户&#xff0c;可以使用马哈鱼数据血缘工具全部…
阅读更多...
DCGAN对抗网络用于生成动漫卡通人物（Python代码）

DCGAN对抗网络用于生成动漫卡通人物（Python代码）

DCGAN全称Deep Convolutional Generative Adversarial Networks&#xff0c;中文名深度卷积对抗网络。 1.1 DCGAN的特点 DCGAN除了G网络与CNN不同之外&#xff0c;它还有以下的不同&#xff1a; 1.取消所有pooling层。G网络中使用转置卷积&#xff08;transposed convolutiona…
阅读更多...
集合中的数据结构

集合中的数据结构

栈 先进后出入口跟出口在同一侧 队列 先进先出入口跟出口在不同的一层 数组 查询快、增删慢查询快是因为数组的地址是连续的&#xff0c;我们通过数组的首地址就可以找到数组&#xff0c;之后通过数组的下标就可以访问数组的每一个元素。增删慢是因为数组的长度是固定的&…
阅读更多...
计算机论文中名词翻译和解释笔记

计算机论文中名词翻译和解释笔记

看论文中一些英文的简写不知道中文啥意思&#xff0c;或者一个名词不知道啥意思。 于是自己做了一个个人总结。 持续更新 目录 SoftmaxDeep Learning(深度学习)循环神经网络(Recurrent Neural Network简称 RNN)损失函数/代价函数(Loss Function)基于手绘草图的三维模型检索(Ske…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023