Python 实现一个简单的 RPC

何为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"))
最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • go rpc 入门 rpc(Romote Procedure Call,远程过程调用)。相对应的就是本地过程调用,...
    _AlphaBaby_阅读 2,029评论 0 0
  • WebService介绍 首先我们来谈一下为什么需要学习webService这样的一个技术吧.... 问题一 如果...
    Java3y阅读 9,700评论 5 139
  • RPC注册中心-- 检测服务是否存活=注册中心的职责,发现服务,监控服务变更状态、健康检查。 需要做到的是:总能通...
    消失er阅读 3,270评论 0 3
  • 需要原文的可以留下邮箱我给你发,这里的文章少了很多图,懒得网上粘啦 1数据库基础 1.1数据库定义 1)数据库(D...
    极简纯粹_阅读 7,640评论 0 46
  • 包含的重点内容:JAVA基础JVM 知识开源框架知识操作系统多线程TCP 与 HTTP架构设计与分布式算法数据库知...
    消失er阅读 4,425评论 1 10