向高手进阶,从 0 开始手写实现一个 RPC 框架!

前言

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


向高手进阶,从 0 开始手写实现一个 RPC 框架!


订单服务调用商品服务


上图简单的描述了RPC在实际场景中的应用,我们在开发中当然是利用现有的RPC框架来快速实现业务需求,比如百度开源了baidu-rpc,阿里的Dubbo早已声名在外,腾讯自己玩TAF。一文告诉你 RMI 和 RPC 的区别!本篇博客将实现一个迷你版的RPC,探索下RPC底层实现的奥秘!在Java技术栈微信公众号后台回复关键字:分布式,可以获取更多栈长整理的 Java 系列技术干货。


动手实现RPC

商品服务工程

向高手进阶,从 0 开始手写实现一个 RPC 框架!

商品服务工程


注意,我将商品服务的API以及实现分为Maven的2个模块来开发。这里,我们想给定一个商品ID,查询得到商品对象信息。


商品对象

向高手进阶,从 0 开始手写实现一个 RPC 框架!


商品API


向高手进阶,从 0 开始手写实现一个 RPC 框架!


Product


要注意的是,Product是可以被序列化的,Why?


很显然,订单系统调用商品系统的时候,需要商品系统返回一个商品,必然涉及到发生网络传输,这就涉及对象的序列化和反序列化了。


商品查询API接口


向高手进阶,从 0 开始手写实现一个 RPC 框架!

商品查询API


订单系统调用商品服务


向高手进阶,从 0 开始手写实现一个 RPC 框架!

订单服务调用商品服务


在订单系统工程中需要引入商品服务API依赖。


在上图代码中,最重要的就是rpc方法了!


rpc实现方法


向高手进阶,从 0 开始手写实现一个 RPC 框架!

rpc


第一,我们看到了Proxy.newProxyInstance


很显然在进行动态代理。也即是说,在订单服务调用商品服务的代码中,我们先是通过动态代理返回一个代理的IProductService类型对象,这意味着当代理对象调用queryById方法的时候,会自动调用invoke方法!


第二,我们看看invoke到底做了些什么?


它本质上就是进行Socket通信,那么它需要传递什么信息给到商品服务呢?


我们知道订单系统就是想调用商品服务的某个类的某个方法,然后把这个方法的返回结果传输给订单系统!


想一想,如何调用某个类的某个方法呢?


只要我们能确定这个类的全限定类名、确定方法名、确定方法的参数类型,给定方法需要的具体参数,通过反射就能实现。


商品服务调用后得到的结果,我们序列化写入Socket流中,在订单系统中反序列化得到对象即可。


第三,这里需要思考一个问题


在订单系统中我们只知道商品服务的API,并不知道这背后的API到底是如何实现的,所以我们需要有一个映射,就是商品服务的API到商品服务的实现的一个映射关系,其实这就是所谓的服务的注册!


向高手进阶,从 0 开始手写实现一个 RPC 框架!


商品服务


向高手进阶,从 0 开始手写实现一个 RPC 框架!


商品服务API实现


商品服务

向高手进阶,从 0 开始手写实现一个 RPC 框架!

商品服务


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


运行结果


向高手进阶,从 0 开始手写实现一个 RPC 框架!


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


推荐去我的博客阅读更多:


1.Java JVM、集合、多线程、新特性系列教程


2.Spring MVC、Spring Boot、Spring Cloud 系列教程


3.Maven、Git、Eclipse、Intellij IDEA 系列工具教程


4.Java、后端、架构、阿里巴巴等大厂最新面试题


觉得不错,别忘了点赞+转发哦! 推荐去我的博客阅读更多:


1.Java JVM、集合、多线程、新特性系列教程


2.Spring MVC、Spring Boot、Spring Cloud 系列教程


3.Maven、Git、Eclipse、Intellij IDEA 系列工具教程


4.Java、后端、架构、阿里巴巴等大厂最新面试题


上一篇:用 ThreadLocal 管理用户session


下一篇:《CCNP安全Secure 642-637认证考试指南》——8.4节考试要点回顾