一、rpyc的基本概念
RPC（Remote Procedure Call）是远程程序调用，RPYC是一个Python库，可以实现在不同的机器上运行的Python程序之间的通信。
二、rpyc安装
pip install rpyc讯享网
三、rpyc的使用
1，基本用法
服务器端代码
讯享网import rpyc from rpyc.utils.server import ThreadedServer, OneShotServer class MyServer(rpyc.Service): def exposed_myadd(self, x, y): print(x+y) return 'OK' if __name__ == '__main__': while True: t = ThreadedServer(MyServer, port=18862) t.start()
ThreadServer中增加配置protocol_config={'allow_public_attrs': True}，可以运行服务器中的方法不以exposed_开头
ThreadedServer(MyServer, port=18862, protocol_config={'allow_public_attrs': True})客户端代码
讯享网import rpyc if __name__ =='__main__': conn = rpyc.connect('192.168.31.100', 18862) res = conn.root.myadd(1,2) print(res)
2， 设置服务器同一时间只允许1个用户连接
服务器（使用OneShotServer方法）
import rpyc from rpyc.utils.server import ThreadedServer, OneShotServer class MyServer(rpyc.Service): def exposed_myadd(self, x, y): print(x+y) time.sleep(2) return x+y if __name__ == '__main__': while True: t = OneShotServer(MyServer, port=18862) t.start()客户端
讯享网import rpyc if __name__ =='__main__': conn = rpyc.connect('192.168.31.100', 18862) try: res = conn.root.myadd(3,2) print(res) except: print('服务器忙')
客户端 异步调用服务器方法
import rpyc if __name__ =='__main__': conn = rpyc.connect('192.168.31.100', 18862) add1 = rpyc.async_(conn.root.myadd) # 异步调用 res = add1(1,5) print(res.value)
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请联系我们，一经查实，本站将立刻删除。
如需转载请保留出处：https://51itzy.com/kjqy/23356.html