Python如何实现远程方法调用资源-CSDN文库

199 浏览量 2020-12-17 06:01:38 上传评论收藏 67KB PDF 举报

资源详情

资源评论

资源推荐

Python如何实现远程方法调用如何实现远程方法调用

问题问题

你想在一个消息传输层如 sockets 、multiprocessing connections 或 ZeroMQ 的基础之上实现一个简单的远程过程调用

（RPC）。

解决方案解决方案

将函数请求、参数和返回值使用pickle编码后，在不同的解释器直接传送pickle字节字符串，可以很容易的实现RPC。下面是

一个简单的PRC处理器，可以被整合到一个服务器中去：

# rpcserver.py

import pickle

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:

# Receive a message

func_name, args, kwargs = pickle.loads(connection.recv())

# Run the RPC and send a response

try:

r = self._functions[func_name](*args,**kwargs)

connection.send(pickle.dumps(r))

except Exception as e:

connection.send(pickle.dumps(e))

except EOFError:

pass

要使用这个处理器，你需要将它加入到一个消息服务器中。你有很多种选择，但是使用 multiprocessing 库是最简单的。下面

是一个RPC服务器例子：

from multiprocessing.connection import Listener

from threading import Thread

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

def sub(x, y):

return x - y

# Register with a handler

handler = RPCHandler()

handler.register_function(add)

handler.register_function(sub)

# Run the server

rpc_server(handler, ('localhost', 17000), authkey=b'peekaboo')

为了从一个远程客户端访问服务器，你需要创建一个对应的用来传送请求的RPC代理类。例如

import pickle

本内容试读结束，登录后可阅读更多

下载后可阅读完整内容，剩余2页未读，立即下载

评论0

内容反馈

weixin_38743968

粉丝: 404
资源: 2万+

最新资源

资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！点击此处反馈

feedback-tip