向高手进阶 从 0 开始手写实现一个 RPC 框架
作者:张丰哲
来源:https://www.jianshu.com/p/29d75a25eeaf

前言
在实际后台服务开发中,比如订单服务(开发者A负责)需要呼叫商品服务(开发者B负责),那么开发者B会和A约定呼叫API,以界面的形式提供给A。通常都是B把API上传到Maven私服,然后B开始写API的实现,A只需要引入API依赖进行开发即可。

上图简单的描述了RPC在实际场景中的应用,我们在开发中当然是利用现有的RPC框架来快速实现业务需求,比如百度开源了baidu-rpc,阿里的Dubbo早已声名在外,腾讯自己玩TAF。
动手实现RPC
商品服务工程

注意,我将商品服务的API以及实现分为Maven的2个模组来开发。这里,我们想给定一个商品ID,查询得到商品物件资讯。
商品物件


要注意的是,Product是可以被序列化的,Why?
很显然,订单系统呼叫商品系统的时候,需要商品系统返回一个商品,必然涉及到发生网络传输,这就涉及物件的序列化和反序列化了。
商品查询API界面

订单系统呼叫商品服务

在订单系统工程中需要引入商品服务API依赖。
在上图程式码中,最重要的就是rpc方法了!
rpc实现方法

第一,我们看到了Proxy.newProxyInstance
很显然在进行动态代理。也即是说,在订单服务呼叫商品服务的程式码中,我们先是通过动态代理返回一个代理的IProductService型别物件,这意味着当代理物件呼叫queryById方法的时候,会自动呼叫invoke方法!
第二,我们看看invoke到底做了些什么?
它本质上就是进行Socket通讯,那么它需要传递什么资讯给到商品服务呢?
我们知道订单系统就是想呼叫商品服务的某个类的某个方法,然后把这个方法的返回结果传输给订单系统!
想一想,如何呼叫某个类的某个方法呢?
只要我们能确定这个类的全限定类名、确定方法名、确定方法的引数型别,给定方法需要的具体引数,通过反射就能实现。
商品服务呼叫后得到的结果,我们序列化写入Socket流中,在订单系统中反序列化得到物件即可。
第三,这里需要思考一个问题
在订单系统中我们只知道商品服务的API,并不知道这背后的API到底是如何实现的,所以我们需要有一个对映,就是商品服务的API到商品服务的实现的一个对映关系,其实这就是所谓的服务的注册!


商品服务

从这里,可以清晰的看到,商品服务读取了订单系统呼叫商品系统时传送的资料,利用反射机制,进行方法呼叫,并把呼叫结果写入Socket输出流。
执行结果

启动商品服务后,通过订单系统发起对商品服务的呼叫。