博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
实现一个迷你版的RPC
阅读量:6123 次
发布时间:2019-06-21

本文共 1049 字,大约阅读时间需要 3 分钟。

前言

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

实现一个迷你版的RPC

动手实现RPC

商品服务工程

实现一个迷你版的RPC

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

商品对象

实现一个迷你版的RPC

实现一个迷你版的RPC

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

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

商品查询API接口

实现一个迷你版的RPC

订单系统调用商品服务

实现一个迷你版的RPC

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

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

rpc实现方法

实现一个迷你版的RPC

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

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

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

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

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

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

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

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

商品API的具体实现

实现一个迷你版的RPC

实现一个迷你版的RPC

商品服务

实现一个迷你版的RPC

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

运行结果

实现一个迷你版的RPC

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

以前总认为RPC是遥不可及的,感觉是个很神奇的东西,实际上它的底层实现不就是这样的么~

转载于:https://blog.51cto.com/zhangfengzhe/2059194

你可能感兴趣的文章
java学习笔记04--数组
查看>>
为什么解析 array_column不可用,
查看>>
android_Intent对象初步(Activity传统的价值观念)
查看>>
AVR文章7课时:动态数字化控制
查看>>
交互式命令 expect
查看>>
Activiti系列——如何在eclipse中安装 Activiti Designer插件
查看>>
listener.ora中PLSExtPro 和ExtProc的作用(转)
查看>>
Odoo(OpenERP)配置文件openerp-server.conf详解
查看>>
三思考,实现自己定义404页:Tomcat、SpringMVC精确匹配、重写DispatchServlet
查看>>
oracle record is locked by another user
查看>>
每天一个linux命令(30): chown命令
查看>>
15个网站性能测试工具
查看>>
无需Cygwin,如果没有在命令行,Eclipse编NDK
查看>>
[实战]MVC5+EF6+MySql企业网盘实战(8)——文件下载、删除
查看>>
Http的操作(不传递参数)
查看>>
MFC中的CDC详细教程
查看>>
解决:Linux版百度云客户端 BCloud网络错误 问题
查看>>
Kernel启动时 驱动是如何加载的module_init,加载的次序如何;略见本文
查看>>
使用 Inno Setup 快速打包你的应用程序(转载)
查看>>
第七章 概率图模型理论在计算机视觉中的应用
查看>>