泛化调用

今天和同事讨论的时候遇到一个问题,API网关是如何把http协议转成rpc协议的?
在使用API网关时,对外提供的http接口,对内使用的公司的rpc协议,在调用方使用http发起请求后,是如何调用到内部服务的rpc接口的?

泛化调用

一般情况下我们通过RPC调用接口提供方的服务,首先在消费端嵌入提供方的Jar包,从而使用Jar包中的类和方法。

在通用的API网关系统中,考虑到扩展性和维护成本,不会使用服务提供方客户端的JAR包,而是通过另外一种方式实现调用,就是泛化调用

其中的原理跟普通的RPC调用时一致的,网络序列化反射这些底层的技术原理一致。区别在于参数和返回值都用Map来表示。任何一个成熟的RPC框架都会支持泛化调用,比如Dubbo提供的泛化。

Dubbo泛化调用

泛化接口调用方式主要用于客户端没有API接口及模型类元的情况,参数及返回值中的所有入参出参均用Map表示,通常用于框架集成,比如:实现一个通用的API网关或者服务测试框架。

可通过 GenericService 调用所有服务实现

import org.apache.dubbo.rpc.service.GenericService; 
... 
 
// 引用远程服务 
// 该实例很重量,里面封装了所有与注册中心及服务提供方连接,请缓存
ReferenceConfig<GenericService> reference = new ReferenceConfig<GenericService>(); 
// 弱类型接口名
reference.setInterface("com.xxx.XxxService");  
reference.setVersion("1.0.0");
// 声明为泛化接口 
reference.setGeneric(true);  

// 用org.apache.dubbo.rpc.service.GenericService可以替代所有接口引用  
GenericService genericService = reference.get(); 
 
// 基本类型以及Date,List,Map等不需要转换,直接调用 
Object result = genericService.$invoke("sayHello", new String[] {"java.lang.String"}, new Object[] {"world"}); 
 
// 用Map表示POJO参数,如果返回值为POJO也将自动转成Map 
Map<String, Object> person = new HashMap<String, Object>(); 
person.put("name", "xxx"); 
person.put("password", "yyy"); 
// 如果返回POJO将自动转成Map 
Object result = genericService.$invoke("findPerson", new String[]
{"com.xxx.Person"}, new Object[]{person}); 
 
...

API网关

网关系统与RPC环境起初是两个环境的系统,网关系统不需要依赖RPC的存在,各有各的生命周期
api-gateway-and-rpc

在泛化调用这种,网关系统需要知道服务的类名和方法名。还需要做的就是将API通过一种方式存储到网关系统能够访问的一种存储中。比如存储到Redis。
网关系统可以提供一个API发布平台入口,让API发布者将RPC环境下的API数据录入到API发布平台。

API信息 包括所有的方法、入参、出参、注释、描述、接口负责人信息等。

api-gateway-simple-design
如上图
API网关负责API接口获取、协议转换、泛化调用
RPC框架负责 编解码、序列化、反序列化、长连接等。

泛化调用源码解读

参考资料

[1] API网关基石:泛化调用
[2] 微服务中台技术解析之网关 (dubbo-rest) 实践
[3] 使用泛化调用
[4] Dubbo高性能网关–Flurry介绍
[5] dubbo网关演进之路