zoukankan      html  css  js  c++  java
  • python rpc 的实现

    一、介绍

             所谓RPC,是远程过程调用(Remote Procedure Call)的简写,网上解释很多,简单来说,就是在当前进程调用其他进程的函数时,体验就像是调用本地写的函数一般。
    本文实现的是在本地调用远端的类class对象的接口,也就是本地的client不实例化类对象,调用的是server端的类对象接口。
    为了达到让调用层无须关心底层实现,拥有丝滑般的体验,就需要以下几个部分:

    1客户端需要把类的接口提取出来,并将调用函数事件捕获存储起来;服务端需要把类的公有函数作为可远程调用的接口。
    2客户端把调用函数的事件(调用的函数,参数)进行序列化并发送给服务端;服务端将客户端的调用事件反序列化,并执行相应的接口,将返回值发送给客户端。
    3客户端与服务端通过某种方式(一般就是网络socket)进行通信。
    二、使用案例

    1 .安装  thriftpy2

    pip3 install thriftpy2

    2.服务端  server.pys

    import thriftpy2
    from thriftpy2.rpc import make_server
    
    pingpong_thrift = thriftpy2.load("pingpong.thrift", module_name="pingpong_thrift")
    
    class Dispatcher(object):
        def ping(self):
            return "pong"
    
    
    server = make_server(pingpong_thrift.PingPong,Dispatcher(),"127.0.0.1",6000)
    server.serve()
    

     3.pingpong.thrit 

    service PingPong{
        string ping(),
    }
    

      4.client.py

    import thriftpy2
    
    pingpong_thrift = thriftpy2.load("pingpong.thrift", module_name="pingpong_thrift")
    
    from thriftpy2.rpc import make_client
    
    client = make_client(pingpong_thrift.PingPong, '127.0.0.1', 6000)
    print(client.ping())
    

      

    启动server.py,运行client.py后即可查看到服务端函数的结果。

  • 相关阅读:
    C++中的内存分配
    进程间通信(IPC)
    一段重新开始的旅程
    状态压缩模版3:地雷
    状态压缩模版2:选数
    状态压缩模版1:滑块
    后缀数组练习4:Life Forms
    后缀数组练习3:连续重复子串
    后缀数组练习2:可重叠的k次最长重复子串
    后缀数组练习1:不可重叠最长重复子串
  • 原文地址:https://www.cnblogs.com/zlel/p/14841710.html
Copyright © 2011-2022 走看看