HSF:阿里RPC框架

简介

HSF(High-speed Service Framework)是一种广泛应用于阿里巴巴内部的分布式RPC服务框架。

作为阿里巴巴的基础中间件,HSF连接了不同的业务系统,解耦了系统间的实现依赖。HSF从分布式应用的角度统一了服务的发布和调用方式,从而帮助用户方便快速地开发分布式应用,并提供或使用公共功能模块。它屏蔽了分布式领域中的各种复杂技术细节,如远程通信、序列化实现、性能损耗以及同步/异步调用方式的实现等。

名称是否必须功能描述
服务消费方消费服务提供方提供的服务,服务消费者通过地址注册中心订阅服务,根据订阅到的地址信息发起调用,地址注册中心作为旁路不参与调用
服务提供方服务提供方会绑定一个端口(一般是12200),接受请求并提供服务,同时将地址信息发布到地址注册中心
地址注册中心接受服务提供方发布的地址,当服务消费方根据服务进行订阅时,会将地址信息推送给服务消费方,提供服务发现的能力
持久化配置中心持久化的配置中心用于存储 HSF 服务的各种治理规则,HSF 客户端在启动过程中会向持久化配置中心订阅各种服务治理规则,如路由规则、归组规则、权重规则等,从而根据规则对调用过程的选址逻辑进行干预
元数据存储中心元数据是指 HSF 服务对应的方法列表以及参数结构等信息,元数据不会对 HSF 的调用过程产生影响,因此元数据存储中心也并不是必须的。但考虑到服务运维的便捷性,HSF客户端在启动时会将元数据上报到元数据存储中心,以便提供给服务运维使用
HSF运维平台HSF 控制台通过打通地址注册中心 ConfigServer、持久化配置中心 Diamond、元数据存储中心 Redis,为用户提供了一系列服务运维功能,包括服务查询、服务治理规则管理、服务测试、服务 Mock、单机运维等,旨在提高 HSF 服务研发的效率、运维的便捷性

HSF架构

在这里插入图片描述
HSF功能结构上分为6个部分,分别是:服务消费方、服务提供方、地址注册中心、持久化配置中心、元数据存储中心和HSF运维平台(HSF 控制台),它们组合在一起可以提供全功能的分布式服务,其中必须的是服务消费方、服务提供方和地址注册中心。

调用过程

HSF一次调用过程会从服务消费方发起,经过网络抵达服务提供方,再将服务提供方的结果通过网络携带回来,最终返回给用户。这个过程会涉及到多个线程交互,也会涉及到HSF中的不同领域对象。
HSF一次调用过程如下图所示:
在这里插入图片描述

作为服务消费方,在客户端线程(例如:Tomcat线程)中,首先将用户的参数、即请求对象进行序列化,并将序列化后的内容放置到请求通信对象中。请求通信对象使用HSF协议,包含与请求对象无关的内容,如请求ID等。然后,将请求通信对象提交给I/O线程,在I/O线程中完成编码,并最终发送到服务提供方。此时,客户端线程进入等待状态,等待结果返回。

服务提供方的I/O线程接收到二进制内容,解码后生成通信请求对象,并将其交给HSF服务端线程。在HSF服务端线程中,完成反序列化还原为请求对象,然后发起反射调用,获得结果,即响应对象。HSF服务端线程会将响应对象序列化,并放置到通信响应对象中。然后,将通信响应对象提交给I/O线程,在I/O线程中完成编码,并最终发送回服务消费方。

服务消费方接收到二进制内容后,在I/O线程中完成解码,生成响应通信对象,并唤醒客户端线程。客户端线程根据响应通信对象的内容,完成反序列化,最终获取到响应对象,从而结束一次远程调用。

高级特性

请求拦截

在这里插入图片描述

流量控制

在这里插入图片描述

优雅上下线

在这里插入图片描述

调用方式

同步调用

在这里插入图片描述

异步调用

HSF发起调用后,用户可以在上下文中获取跟返回结果关联的HSFFuture对象,然后用户可以在任意时刻调用HSFFuture.getResponse(timeout)获取服务端的返回结果。Future异步调用的时序图如下所示:
在这里插入图片描述

Callback异步调用

客户端配置为callback方式调用时,需要配置一个实现了HSFResponseCallback接口的listener,结果返回之后,HSF会调用HSFResponseCallback中的方法。时序图如下所示:
在这里插入图片描述

泛化调用

相对于需要依赖业务客户端Jar包的正常调用,泛化调用,不要不依赖二方包,使用其特定的GenericService接口,传入需要调用的方法名,方法签名和参数值进行调用服务。 泛化调用适用于一些网关应用(没办法依赖所有服务的二方包),其中hsfops服务测试也是依赖泛化调用功能

注意

  1. 泛化调用,如果客户端没有接口类,路由规则默认不生效
  2. 泛化调用性能会比正常调用差

和其他RPC框架对比

在这里插入图片描述
发现从服务服务发现、服务治理和服务间调用这些功能上看三者基本都具备,只有Dubbo在服务治理方面稍弱。但其实Dubbo也可以和Spring Cloud Netflix Hystrix整合。而HSF和Dubbo使用RPC进行服务间调用,效率上比Spring Cloud使用的Http调用要好得多

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

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

相关文章

智慧工地安全生产与风险预警大平台的构建,需要哪些技术?

随着科技的不断发展,智慧工地已成为现代建筑行业的重要发展趋势。智慧工地方案是一种基于先进信息技术的工程管理模式,旨在提高施工效率、降低施工成本、保障施工安全、提升施工质量。一般来说,智慧工地方案的构建,需要通过集成物…

Rust编程(五)终章:查漏补缺

闭包 & 迭代器 闭包(Closure)通常是指词法闭包,是一个持有外部环境变量的函数。外部环境是指闭包定义时所在的词法作用域。外部环境变量,在函数式编程范式中也被称为自由变量,是指并不是在闭包内定义的变量。将自…

OpenHarmony中的LLDB高性能调试器

概述 LLDB(Low Lever Debugger)是新一代高性能调试器。详细说明参考 LLDB官方文档 。 当前OpenHarmony中的LLDB工具是在 llvm15.0.4 基础上适配演进出来的工具,是HUAWEI DevEco Studio工具中默认的调试器,支持调试C和C应用。 工…

将ENVI的roi转为mask图像

方法1: 直接使用ENVI step1: 将roi文件存储为.roi格式 [1] 链接: link step2: 将.roi转为mask [2] 链接: link [3] 链接: link 方法2: 使用Matlab step1: 将roi文件存储为.xlm 文件 step2:针对把每个roi存储为一个单独文件 [4] 读取xlm文…

【React】onClick点击事件传参的4种方式

记录React onClick 点击事件传参的 4 种方式 方式一&#xff1a;使用内联箭头函数 import React, { MouseEvent } from "react";function App() {const handleClick (event: MouseEvent<HTMLButtonElement>, name: string) > {console.log(event)console.…

HWOD:字符的排序

一、知识点 char的最大值是127&#xff0c;最小值是-128 自己填充的char型数组&#xff0c;以字符串打印&#xff0c;打印之前要手动在末尾加上 \0 二、题目 1、描述 Lily上课时使用字母数字图片教小朋友们学习英语单词&#xff0c;每次都需要把这些图片按照大小&#x…

【机器学习300问】55、介绍推荐系统中的矩阵分解算法是什么、有什么用、怎么用?

本来这篇文章我想先讲矩阵分解算法是什么东西的&#xff0c;但这样会陷入枯燥的定义中去&#xff0c;让原本非常有趣技术在业务场景中直观的使用路径被切断。所以我觉得先通过一个具体的推荐算法的例子&#xff0c;来为大家感性的介绍矩阵分解有什么用会更加合理。 如果你还不知…

Xcode删除原本的Git,再添加新的git

本文参考&#xff1a;Xcode怎么删除原本git,在重新设置新的git地址_ios xcode 删除原本git-CSDN博客 开发中会有一个问题。Xcode项目A 提交到Git服务器server1&#xff0c;此时项目A内部已经存在一个Git文件&#xff0c;与server1相关联。 此时你想将项目A提交到 另一个Git…

快速上手Spring Cloud 七:事件驱动架构与Spring Cloud

快速上手Spring Cloud 一&#xff1a;Spring Cloud 简介 快速上手Spring Cloud 二&#xff1a;核心组件解析 快速上手Spring Cloud 三&#xff1a;API网关深入探索与实战应用 快速上手Spring Cloud 四&#xff1a;微服务治理与安全 快速上手Spring Cloud 五&#xff1a;Spring …

智能设备配网保姆级教程

设备配网 简单来说&#xff0c;配网就是将物联网&#xff08;IoT&#xff09;设备连接并注册到云端&#xff0c;使其拥有与云端远程通信的能力。配网后&#xff0c;智能设备才能被手机应用或者项目管理后台控制&#xff0c;依托于智能场景创造价值。本文介绍了配网的相关知识&…

C++优先队列——priority_queue,函数对象,labmda表达式,pair等

头文件&#xff1a;#include<queue> 内部使用堆来实现&#xff0c;在需要或得最大的几个值或最小的几个值而不关心整个数组的顺序时非常好用。 用法&#xff1a; priority_queue<int, vector<int>, greater<int>>q; 第一个参数为堆中存储的元素。 …

UE RPC 外网联机(2)

外网联机配置测试 一、网络配置 开放外网端口开放端口是为了可以进行外网访问;端口包含一个预案管理服务器端口和多个预案服务器端口;(预案管理服务器类似于大厅,预案服务器类似于房间,大厅管理多个房间;) (1)预案管理服务器端口;(如:23001) (2)预案服务器端口…