Python远程方法调用实现过程解析

阿澈

发布时间：2026-10-14| 4人浏览过

原创

本文解析了Python中基于multiprocessing模块的远程过程调用（RPC）实现机制。通过RPCHandler与RPCProxy类，客户端将函数名及参数序列化后通过网络发送，服务器端反序列化并执行对应注册函数，最后将结果或异常序列化返回。代码示例展示了服务端监听与客户端代理的核心逻辑，适用于理解分布式通信基础。

RPC核心机制与数据流程

RPCHandler与RPCProxy的设计逻辑相对直观。当客户端需要调用远程函数（例如执行foo(1, 2, z=3)）时，代理类会构建一个包含函数名和参数的元组，格式为('foo', (1, 2), {'z': 3})。该元组经过序列化处理后，通过网络连接发送出去。这一过程在RPCProxy的getattr()方法所返回的do_rpc()闭包中实现。

服务器端接收到数据后，进行反序列化操作，查找对应的函数名以确认是否已注册，随后执行相应的函数。执行产生的结果（或捕获到的异常）会被再次序列化，并通过网络返回给客户端。该实例依赖于multiprocessing模块进行通信，但此架构可适配其他任何消息系统。例如，若希望在ZeroMQ之上实现RPC，仅需将连接对象替换为相应的ZeroMQ socket对象即可。

服务器端实现

首先实现服务器端代码。


import json
from multiprocessing.connection import Listener
from threading import Thread


class RPCHandler:
  def __init__(self):
    self._functions = {}

  def register_function(self, func):
    self._functions[func.__name__] = func

  def handle_connection(self, connection):
    try:
      while True:
        func_name, args, kwargs = json.loads(connection.recv())
        # Run the RPC and send a response
        try:
          r = self._functions[func_name](*args, **kwargs)
          connection.send(json.dumps(r))
        except Exception as e:
          connection.send(json.dumps(e))
    except EOFError:
      pass


def rpc_server(handler, address, authkey):
  sock = Listener(address, authkey=authkey)
  while True:
    client = sock.accept()
    t = Thread(target=handler.handle_connection, args=(client,))
    t.daemon = True
    t.start()
# Some remote functions
def add(x,y):
  return x+y


if __name__ == '__main__':
  handler = RPCHandler()
  handler.register_function(add)
  # Run the server
  rpc_server(handler, ('127.0.0.1', 17000), authkey=b'peekaboo')

客户端实现

接着实现客户端代码。


import json
from multiprocessing.connection import Client


class RPCProxy:

  def __init__(self, connection):
    self._connection = connection

  def __getattr__(self, name):
    def do_rpc(*args, **kwargs):
      self._connection.send(json.dumps((name, args, kwargs)))
      result = json.loads(self._connection.recv())
      if isinstance(result, Exception):
        raise result
      return result

    return do_rpc
if __name__ == '__main__':
  c = Client(('127.0.0.1', 17000), authkey=b'peekaboo')
  proxy = RPCProxy(c)
  res = proxy.add(2, 3)
  print(res)

以上内容为本文的核心知识点，旨在帮助读者理解相关技术原理，希望对大家的学习有所启发，同时也欢迎大家继续支持本站。