使用simplexmlrpcserver实现rpc
模块
simplexmlrpcserver
python标准库中自带的模块，无需另外安装
在python3中 simplexmlrpcserver已经被合并到xmlrpc.server
定义
class simplexmlrpcserver.simplexmlrpcserver(addr[, requesthandler[, logrequests[, allow_none[, encoding[, bind_and_activate]]]])
方法
1.simplexmlrpcserver.register_function(function[, name])
- 注册一个方法，服务
2.simplexmlrpcserver.register_instance(instance[, allow_dotted_names])
- 注册实例
- 一个对象在register_function注册后则，不能再在register_instance注册
3.simplexmlrpcserver.register_introspection_functions()
- 注册一个反函数
4.simplexmlrpcserver.register_multicall_functions()
- 注册复合函数
例如：
服务端
from simplexmlrpcserver import simplexmlrpcserver
def respon_string(str):
return "get string :%s"%str
if __name__ == '__main__':
s = simplexmlrpcserver(('0.0.0.0', 8080))
s.register_function(respon_string,"get_string")
s.serve_forever()
客服端
from xmlrpclib import serverproxy
if __name__ == '__main__':
s = serverproxy("http://192.168.137.9:8080")
print s.get_string("hello")
结果：
# python get.py
get string :hello
服务端：
#coding=utf8
from simplexmlrpcserver import simplexmlrpcserver
from simplexmlrpcserver import simplexmlrpcrequesthandler
class requesthandler(simplexmlrpcrequesthandler):
rpc_paths = ('/rpc2',)
server = simplexmlrpcserver(("0.0.0.0", 8000),
requesthandler=requesthandler)
print "start service on 0.0.0.0:8000"
server.register_introspection_functions()
#注册pow，幂运算，实际调用的是已有的算数pow（）
server.register_function(pow)
def add(x,y):
return x + y
server.register_function(add, 'add')
#注方法在xml-rpc中都是public的
class fun:
def div(self, x, y):
return x // y
server.register_instance(fun())
server.serve_forever()
客服端：
可以使用下面的方法调用：
import xmlrpclib
s = xmlrpclib.serverproxy('http://192.168.137.9:8000')
print s.pow(3,5)
print s.add(3,9)
print s.div(7,3)
print s.system.listmethods()
结果：
243
12
2
['add', 'div', 'pow', 'system.listmethods', 'system.methodhelp', 'system.methodsignature']
register_multicall_functions实现复合调用，多个方法注册到一个调用里
#coding=utf8
from simplexmlrpcserver import simplexmlrpcserver
server = simplexmlrpcserver(("0.0.0.0", 8000))
server.register_function(pow)
server.register_function(lambda x,y: x+y, 'add')
server.register_multicall_functions()
server.serve_forever()
multicall调用复合方法
import xmlrpclib
s = xmlrpclib.serverproxy("http://192.168.137.9:8000")
print s
multi = xmlrpclib.multicall(s)
multi.pow(2, 5)
try:
for response in multi():
print response
except error, err:
print "error", err
结果：
# python jm.py
<serverproxy for 192.168.137.9:8000/rpc2>
32
python与rpc服务
rpc
1.什么是rpc
rpc 就是为解决服务之间信息交互而发明和存在的。
rpc（remote procedure call）——远程过程调用，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。
rpc采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个服务器。
首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。
在服务器端，进程保持睡眠状态直到调用信息到达为止。
当一个调用信息到达，服务器获得进程参数，计算结果，发送答复信息
然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。
rpc就是一种远程调用函数接口的方式，说白了，就是一种远程调用函数接口的方式，客户端和服务端之间约定一种契约（函数接口），然后服务端一直等待客户端的调用。
有点像平常的web网络请求。
一种用途是在多台服务器之间互相进行调用。
另一个用途则在于，不同编程语言之间都支持这种方式，像python更是内置对其的支持，不需要额外安装什么库，所以可以直接在多语言的服务器之间互相进行调用。
socket编程就是rpc通信
2.xmlrp库
简单的服务端
像web请求一样，我们需要确定供客户端访问的url和端口号，以及供客户端调用的方法实现，最后要让我们服务器一直处于等待被访问的状态：
rpc_server.py from xmlrpc.server import simplexmlrpcserver
调用函数
def respon_string(str): return “get string:%s”%str if name == ‘main': server = simplexmlrpcserver((‘localhost', 8888)) # 初始化 server.register_function(respon_string, “get_string”) # 注册get_string函数 print (“listening for client”) server.serve_forever() # 保持等待调用状态 rpc_client.py from xmlrpc.client import serverproxy if name == ‘main': server = serverproxy(“http://localhost:8888”) # 初始化服务器 print (server.get_string(“rpc rpc”)) # 调用get_string函数并传参，调用get_string让服务端通过respon_string函数处理请求，并返回。
操作
#服务端启动： [root@xujunk tmp]#python3 rpc_server.py listening for client #客户端启动： [root@xujunk tmp]#python3 rpc_client.py get string:rpc rpc #返回结果
以上为个人经验，希望能给大家一个参考，也希望大家多多支持。
