Python远程方法调用 RPyC

 

rpyc (Remote Python Call)为分布式计算环境提供了优良的基础平台。 使用rpyc编写c/s结构程序，彻底不用考虑老式的socket编程，如今只用编写简单的三、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以后仍然能 够调用的
若是为其余类型则不能访问了！