当前位置: 首页 > 工具软件 > RPyC > 使用案例 >

python远程方法调用_Python远程方法调用 RPyC

阴高寒
2023-12-01

rpyc (Remote Python Call)为分布式计算环境提供了优良的基础平台。 使用rpyc编写c/s结构程序,完全不用考虑老式的socket编程,现在只用编写简单的3、5行代码即可完成以前的数千行代码的功能。

Remote Python Call (RPyC) 是一个 Python 的库用来实现 RPC 和分布式计算的工具。支持同步和异步操作、回调和远程服务以及透明的对象代理。

1.写服务器端的方法如下:

#-*- encoding: gb2312 -*-

import time

from rpyc import Service

from rpyc.utils.server import ThreadedServer

class TimeService(Service):

def exposed_get_time(self):

return time.ctime()      #time模块中的一个内置方法

s=ThreadedServer(TimeService,port=12233,auto_register=False)

s.start()

RPYC 这个包是我导入的一个外部包的哦!不过通过help一样可以查看到这个包的内在的一些东西哈哈!

2.服务器开启现在来让客户端进行访问了!

import rpyc

c=rpyc.connect('localhost',12233)

c.root.get_time()

c.close()

现 在来想一个事情。之前在RO通讯模块中就是我们在服务器端写了一个方法然后我们就可在客户端直接调用了哦!

比如我们在服务器端写了一个计算sum 函数  然后我们就可以在客户端进行调用这个函数了哦!

那我们来看一下这里的机制吧!

RPYC重点:

1.Client一定要 close()连接哦! 2.Server中exposed_打头的函数才能被 客户端调用。 所以如果写服务端代码的时候想要让客户端调用 就要加这一个前缀哦 c=rpyc.connect('localhost',12233) #首先要连接服务器 3.client要访问服 务器端代码通过c.root才能访问哦! c.root.get_time()  调用服务器端方法了! 4.RPYC没有认证机制,任何客 户端都可以直接访问服务器端的暴露的方法了! OK,联系当前在RO中写过的一个方法哦! import time from rpyc import Service from rpyc.utils.server import ThreadedServer class TimeService(Service):     def exposed_sum(self,a,b):         return a+b s=ThreadedServer(TimeService,port=12233,auto_register=False) s.start() 我 先在服务器端写了一个方法求和操作! 让客户端进行直接调用 吧! import rpyc c=rpyc.connect('localhost',12233) print c.root.sum(1,2) c.close() 本质与RO原理是一样的哦! 以后我们只需要在服务器端定义好一些写好的方法 然后在客户端直接调用就可以了! v=c.root.function() 返回了一个值。如果是字符串,数字,在c.close之后仍然能 够调用的 如果为其他类型则不能访问了!

 类似资料: