HSF:阿里RPC框架

简介: 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调用要好得多

相关文章
|
4月前
|
负载均衡 Dubbo Java
Dubbo 3.x:探索阿里巴巴的开源RPC框架新技术
随着微服务架构的兴起,远程过程调用(RPC)框架成为了关键组件。Dubbo,作为阿里巴巴的开源RPC框架,已经演进到了3.x版本,带来了许多新特性和技术改进。本文将探讨Dubbo 3.x中的一些最新技术,包括服务注册与发现、负载均衡、服务治理等,并通过代码示例展示其使用方式。
232 9
|
4月前
|
JSON 负载均衡 网络协议
Rpc编程系列文章第二篇:RPC框架设计目标
Rpc编程系列文章第二篇:RPC框架设计目标
|
4月前
|
设计模式 负载均衡 网络协议
【分布式技术专题】「分布式技术架构」实践见真知,手把手教你如何实现一个属于自己的RPC框架(架构技术引导篇)
【分布式技术专题】「分布式技术架构」实践见真知,手把手教你如何实现一个属于自己的RPC框架(架构技术引导篇)
179 0
|
4月前
|
Dubbo Java 应用服务中间件
Rpc编程系列文章第三篇:Hessian RPC一个老的RPC框架
Rpc编程系列文章第三篇:Hessian RPC一个老的RPC框架
|
24天前
|
Dubbo 网络协议 Java
RPC框架:一文带你搞懂RPC
这篇文章全面介绍了RPC(远程过程调用)的概念、原理和应用场景,解释了RPC如何工作以及为什么在分布式系统中广泛使用,并探讨了几种常用的RPC框架如Thrift、gRPC、Dubbo和Spring Cloud,同时详细阐述了RPC调用流程和实现透明化远程服务调用的关键技术,包括动态代理和消息的编码解码过程。
RPC框架:一文带你搞懂RPC
|
1月前
|
XML 存储 JSON
(十二)探索高性能通信与RPC框架基石:Json、ProtoBuf、Hessian序列化详解
如今这个分布式风靡的时代,网络通信技术,是每位技术人员必须掌握的技能,因为无论是哪种分布式技术,都离不开心跳、选举、节点感知、数据同步……等机制,而究其根本,这些技术的本质都是网络间的数据交互。正因如此,想要构建一个高性能的分布式组件/系统,不得不思考一个问题:怎么才能让数据传输的速度更快?
|
2月前
|
分布式计算 负载均衡 数据安全/隐私保护
什么是RPC?有哪些RPC框架?
RPC(Remote Procedure Call,远程过程调用)是一种允许运行在一台计算机上的程序调用另一台计算机上子程序的技术。这种技术屏蔽了底层的网络通信细节,使得程序间的远程通信如同本地调用一样简单。RPC机制使得开发者能够构建分布式计算系统,其中不同的组件可以分布在不同的计算机上,但它们之间可以像在同一台机器上一样相互调用。
111 8
|
2月前
|
网络协议 Dubbo Java
什么是RPC?RPC和HTTP对比?RPC有什么缺点?市面上常用的RPC框架?
选择合适的RPC框架和通信协议,对于构建高效、稳定的分布式系统至关重要。开发者需要根据自己的业务需求和系统架构,综合考虑各种因素,做出适宜的技术选型。
107 1
|
2月前
|
负载均衡 Java
使用Java实现RPC框架
使用Java实现RPC框架
|
3月前
|
存储 缓存 Linux
【实战指南】嵌入式RPC框架设计实践:六大核心类构建高效RPC框架
在先前的文章基础上,本文讨论如何通过分层封装提升一个针对嵌入式Linux的RPC框架的易用性。设计包括自动服务注册、高性能通信、泛型序列化和简洁API。框架分为6个关键类:BindingHub、SharedRingBuffer、Parcel、Binder、IBinder和BindInterface。BindingHub负责服务注册,SharedRingBuffer实现高效数据传输,Parcel处理序列化,而Binder和IBinder分别用于服务端和客户端交互。BindInterface提供简单的初始化接口,简化应用集成。测试案例展示了客户端和服务端的交互,验证了RPC功能的有效性。
314 4