python rpyc远程调用(并行编程 37)

服务端

!/usr/bin/env python

-- encoding: utf-8 --

import time from rpyc import Service from rpyc.utils.server import ThreadedServer

class TimeService(Service): # 对于服务端来说， 只有以"exposed_"打头的方法才能被客户端调用，所以要提供给客户端的方法都得加"exposed_" def exposed_get_time(self): return time.ctime() #time模块中的一个内置方法

s=ThreadedServer(service=TimeService,port=12233,auto_register=False) s.start()

客户端

!/usr/bin/env python

-- encoding: utf-8 --

import rpyc

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

调用服务器端的方法，格式为：conn.root.xxx。xxx代表服务器端的方法名

get_time是服务端的那个以"exposed_"开头的方法

result = conn.root.get_time() print result

conn.close()