python远程调用rpc模块xmlrpclib的方法

rpc（remote procedure call protocol）是远程调用协议，它通过网络请求服务到远端服务器，服务器根据请求做出响应，将结果返回

它是一种c/s模式，客户端可以调用远程服务器上的参数（类似url）并返回结果

利用rpc可以实现系统的分布式架构，可以将功能分解到多台服务器上进行实现，同时也将也可以将负载打散，分布到不同服务器上，整合计算资源

在openstack中就大量使用了rpc

rpc多使用http传输请求，格式有xml，json等,这里是xml

模块：

xmlrpclib

注：xmlrpclib模块在python3中重命名为xmlrpc.client

xmlrpc并不是很安全，但在2.7.9 https url中默认加入了证书，主机名验证

定义：

class xmlrpclib.serverproxy(uri[, transport[, encoding[, verbose[, allow_none[, use_datetime[, context]]]]]])

1.uri，即服务端的url地址

2.transport 传输实例，可选，https urls/http

3.encoding

4.verbose 是debug模式

5.allow_none 是否请求空 ，若为true，那么常量none将被翻译成xml，默认如果是none则抛出异常 typeerror

6.use_datetime 可以使用date/time values记录调用时间datetime.datetime，默认是false

serverproxy对象提供一些默认的方法：

1.serverproxy.system.listmethods() 返回远端服务器方法列表

2.serverproxy.system.methodsignature(name) 方法签名，是一个数组类型

3.serverproxy.system.methodhelp(name) 方法帮助信息

例如一个简单的示例：

服务端：

import xmlrpclib
from simplexmlrpcserver import simplexmlrpcserver

def get_power(n,m):
 return n**m

server = simplexmlrpcserver(("0.0.0.0", 8081))
print "start service get power on 0.0.0.0 8081..."
server.register_function(get_power, "get_power")
server.serve_forever()

客服端：

import xmlrpclib

server_power = xmlrpclib.serverproxy("http://192.168.137.9:8081/")
print "3**2 = %d" %(server_power.get_power(3,2))
print "2**5 = %d" %(server_power.get_power(2,5))

结果：

服务端：

# python xml_server.py 
start service get power on 0.0.0.0 8081...

192.168.137.9 - - [22/may/2017 10:37:47] "post / http/1.1" 200 -
192.168.137.9 - - [22/may/2017 10:37:47] "post / http/1.1" 200 -

客服端：

# python xml_client.py 
3**2 = 9
2**5 = 32

xmlrpclib提供的一些方法：

class xmlrpclib.datetime 时间对象

例如：

服务端：

import datetime
from simplexmlrpcserver import simplexmlrpcserver
import xmlrpclib

def today():
 today = datetime.datetime.today()
 return xmlrpclib.datetime(today)

server = simplexmlrpcserver(("0.0.0.0", 8081))
print "start service on 0.0.0.0 8081..."
server.register_function(today, "today")
server.serve_forever()

客服端：

import xmlrpclib
import datetime

s = xmlrpclib.serverproxy("http://192.168.137.9:8081/")

today = s.today()
converted = datetime.datetime.strptime(today.value, "%y%m%dt%h:%m:%s")
print "today: %s" % converted.strftime("%d.%m.%y, %h:%m")

结果：

服务端

# python rpc_time.py 
start service on 0.0.0.0 8081...

192.168.137.9 - - [22/may/2017 10:43:19] "post / http/1.1" 200 -

客服端：

# python rpc_time_client.py 
today: 22.05.2017, 10:43

2.class xmlrpclib.binary 二进制对象

3.class xmlrpclib.fault fault对象

如：

客服端：

import xmlrpclib

s = xmlrpclib.serverproxy("http://192.168.137.9:8081/")
try:
 s.add(2, 5)
except xmlrpclib.fault as err:
 print "a fault occurred"
 print "fault code: %d" % err.faultcode
 print "fault string: %s" % err.faultstring

class xmlrpclib.multicall(server) 提供多个调用,复合调用：

例如：

from simplexmlrpcserver import simplexmlrpcserver

def add(x,y):
 return x+y

def subtract(x, y):
 return x-y

def multiply(x, y):
 return x*y

def divide(x, y):
 return x/y

def get_power(n,m):
 return n**m

server = simplexmlrpcserver(("0.0.0.0", 8081))
print "start service on 0.0.0.0 8081..."

server.register_multicall_functions()
server.register_function(add, 'add')
server.register_function(subtract, 'subtract')
server.register_function(multiply, 'multiply')
server.register_function(divide, 'divide')
server.register_function(get_power, 'get_power')
server.serve_forever() 

客服端：

import xmlrpclib

s = xmlrpclib.serverproxy("http://192.168.137.9:8081/")
multicall = xmlrpclib.multicall(s)
multicall.add(7,3)
multicall.subtract(7,3)
multicall.multiply(7,3)
multicall.divide(7,3)
multicall.get_power(7,3)
result = multicall()

print "7+3=%d, 7-3=%d, 7*3=%d, 7/3=%d 7**3=%d" % tuple(result)

服务端：

# python mul_xmlserver.py 
start service on 0.0.0.0 8081...

192.168.137.9 - - [22/may/2017 10:51:59] "post / http/1.1" 200 -

客服端：

# python mul_xmlclient.py 
7+3=10, 7-3=4, 7*3=21, 7/3=2 7**3=343

另外xmlrpc还提供有比较快捷的函数：

1.xmlrpclib.boolean(value) 将任意的python值转换成xmlrpc的布尔类型true/false

2.xmlrpclib.dumps(params[, methodname[, methodresponse[, encoding[, allow_none]]]])

params请求转换为xml

3.xmlrpclib.loads(data[, use_datetime])

将一个xml-rpc的请求转换成python对象

例如：

from xmlrpclib import serverproxy, error

server = serverproxy("http://betty.userland.com")

print server

try:
 print server.examples.getstatename(41)
except error as err:
 print "error", err

客服端：

import xmlrpclib, httplib

class proxiedtransport(xmlrpclib.transport):
 def set_proxy(self, s):
  self.s = s

 def make_connection(self, host):
  self.realhost = host
  h = httplib.httpconnection(self.s)
  return h

 def send_request(self, connection, handler, request_body):
  connection.putrequest("post", 'http://%s%s' % (self.realhost, handler))

 def send_host(self, connection, host):
  connection.putheader('host', self.realhost)

p = proxiedtransport()
p.set_proxy('proxy-server:8080')
server = xmlrpclib.serverproxy('http://time.xmlrpc.com/rpc2', transport=p)
print server.currenttime.getcurrenttime()

以上这篇python远程调用rpc模块xmlrpclib的方法就是小编分享给大家的全部内容了，希望能给大家一个参考，也希望大家多多支持。