Python 实现一个简单的 RPC

2020-10-07  本文已影响0人  RulerMike

何为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"))
上一篇下一篇

猜你喜欢

热点阅读