本文旨在讲述 RPC 框架设计中的几个核心问题及其解决方法,并基于 Golang 反射技术,构建了一个简易的 RPC 框架。
项目地址:Tiny-RPC
RPC
RPC(Remote Procedure Call),即远程过程调用,可以理解成,服务 A 想调用不在同一内存空间的服务 B 的函数,由于不在一个内存空间,不能直接调用,需要通过网络来表达调用的语义和传达调用的数据。
服务端
RPC 服务端需要解决 2 个问题:
- 由于客户端传送的是 RPC 函数名,服务端如何维护 函数名 与 函数实体 之间的映射
- 服务端如何根据 函数名 实现对应的 函数实体 的调用
核心流程
- 维护函数名到函数的映射
- 在接收到来自客户端的函数名、参数列表后,解析参数列表为反射值,并执行对应函数
- 对函数执行结果进行编码,并返回给客户端
方法注册
map
执行调用
一般来说,客户端在调用 RPC 时,会将 函数名 和 参数列表 作为请求数据,发送给服务端。
map[string]reflect.Value Value.Call()
具体实现
由于篇幅的限制,此处没有贴出服务端实现的具体代码,细节请查看项目地址。
客户端
RPC 客户端需要解决 1 个问题:
- 由于函数的具体实现在服务端,客户端只有函数的原型,客户端如何通过 函数原型 调用其 函数实体
核心流程
- 对调用者传入的函数参数进行编码,并传送给服务端
- 对服务端响应数据进行解码,并返回给调用者
生成调用
我们可以通过 reflect.MakeFunc 为指定的函数原型绑定一个函数实体。
具体实现
由于篇幅的限制,此处没有贴出客户端实现的具体代码,细节请查看项目地址。
数据传输格式
我们需要定义服务端与客户端交互的数据格式。
与交互数据相对应的编码与解码函数。
同时,我们需要定义简单的 TLV 协议(固定长度消息头 + 变长消息体),规范数据的传输。
以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持服务器之家。
原文链接:https://juejin.im/post/5c85ec1e5188257e937dd36a