何为RPC
RPC(Remote Procedure Call)—远程过程调用,它是一种通过网络从远程计算机程序上请求服务,而不需要了解底层网络技术的协议。
以上引用自百度,那么RPC有什么作用呢?我们来假设一个业务场景,A机器上的发送调用函数和参数,函数和参数为B机器上所定义的,然后A机器通过这样的方式(模块化调用)调用了B机器上的函数。
为什么要这样做?
http://www.sohu.com/a/253090689_481409,这是我看过一个比较好的解释。当然本篇文章只做最简单的实现,用这个简单实现来揭开RPC的神秘面纱。
如何用python来做?
python中有一类方法,称为类的隐藏方法(missing methods),其中有:
1.getattr(object, name[,default])
获取对象object的属性或者方法,如果存在打印出来,如果不存在,打印出默认值,默认值可选。
2.setattr(object, name, values)
给对象的属性赋值,若属性不存在,先创建再赋值。
似乎没什么关系,我们先不管,放着吧。
现在来思考一个RPC的过程:
假设我们从一个tcp client发送数据到tcp server,那么要经历以下几个阶段:
client端:
connect->set data->send
server端:
bind->accept->receive->parse->call
现在假设服务器上的函数 function
() ,格式为json,它是这么定义的:
{
'function_name':name,
'function_args':args,
'function_kwargs':kwargs
}
那么客户端该如何去做呢?
先定义客户端的socket:
import socket
class Client(object):
def __init__(self):
self.socket = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
def connect(self, host, port):
self.socket.connect(host, port)
def send(self, data):
self.socket.send(data)
if __name__ == "__main__":
# 测试连接
c = Client()
c.connect('127.0.0.1', 5000)
c.send("shit".encode("utf-8"))
网友评论