本篇内容介绍了“Python如何使用RPC”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
所谓RPC,是远程过程调用(Remote Procedure Call)的简写,网上解释很多,简单来说,就是在当前进程调用其他进程的函数时,体验就像是调用本地写的函数一般。
本文实现的是在本地调用远端的类class对象的接口,也就是本地的client不实例化类对象,调用的是server端的类对象接口。
为了达到让调用层无须关心底层实现,拥有丝滑般的体验,就需要以下几个部分:
客户端需要把类的接口提取出来,并将调用函数事件捕获存储起来;服务端需要把类的公有函数作为可远程调用的接口。
客户端把调用函数的事件(调用的函数,参数)进行序列化并发送给服务端;服务端将客户端的调用事件反序列化,并执行相应的接口,将返回值发送给客户端。
客户端与服务端通过某种方式(一般就是网络socket)进行通信。
from multiprocessing import Pool from rpyc import Service from rpyc.utils.server import ThreadedServer class RemoteService(Service): def on_connect(self, conn): print(conn) '''供客户端调用的方法前得加exposed_''' def exposed_search(self, data): print(data) data['result'] = 'ok' return data def main(port): sr = ThreadedServer(service=RemoteService, hostname='127.0.0.1', port=port, auto_register=False) print(f'Server IP: {(sr.host,sr.port)}') sr.start() if __name__ == '__main__': pool = Pool(processes=2) pool.apply_async(main, args=(9998,)) pool.apply_async(main, kwds={'port':9999}) pool.close() pool.join()
import rpyc import time from multiprocessing import Pool def search_db(query,port): conn = rpyc.connect('localhost',port) '''调用时省略exposed_''' result = conn.root.search(query) time.sleep(1) print(result) conn.close() if __name__ == '__main__': pool = Pool(processes=2) pool.apply_async(search_db, args=({"match": {'name': 'user'}}, 9998)) pool.apply_async(search_db, kwds={'query': {"match": {'name': 'user'}},'port':9999}) pool.close() pool.join()
“Python如何使用RPC”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站,小编将为大家输出更多高质量的实用文章!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。