java通过xml-rpc远程过程调用python

1.XML-RPC是一个使用xml来对调用进行编码(服务函数名，参数，返回值结果等，一般也可以用json,序列化的形式)，用http协议来进行传输的远程过程协议。

Python建立RPC服务器或客户端的通用库，代码如下：

from SimpleXMLRPCServer import SimpleXMLRPCServer
from SocketServer import ThreadingMixIn
from xmlrpclib import ServerProxy
import thread

class ThreadXMLRPCServer(ThreadingMixIn, SimpleXMLRPCServer):
    pass


class RPCServer():
    def __init__(self, ip='127.0.0.1', port='8000'):
        self.ip = ip
        self.port = int(port)
        self.svr = None

    def start(self, func_lst):
        thread.start_new_thread(self.service, (func_lst, 0,))

    def resume_service(self, v1, v2):
        self.svr.serve_forever(poll_interval=0.001)

    def service(self, func_lst, v1):
        self.svr = ThreadXMLRPCServer((self.ip, self.port), allow_none=True)
        for func in func_lst:
            self.svr.register_function(func)
        self.svr.serve_forever(poll_interval=0.001)

    def activate(self):
        thread.start_new_thread(self.resume_service, (0, 0,))

    def shutdown(self):
        try:
            self.svr.shutdown()
        except Exception, e:
            print 'rpc_server shutdown:', str(e)


class RPCClient():
    def __init__(self, ip='127.0.0.1', port='8000'):
        self.svr = ServerProxy('http://' + ip + ':' + port + '/', allow_none=True, use_datetime=True)

    def get_svr(self):
        return self.svr


def get_hello(year):#有参数的传递，这里可以放置多个参数
    return year


if __name__ == "__main__":
    r = RPCServer('0.0.0.0', '8061')
    r.service([get_hello], 0)

启动test_rpc.py待用

python test_rpc.py

2.下面开始Java，首先下载jar包 ，在 https://archive.apache.org/dist/ws/xmlrpc/binaries/ 找到 apache-xmlrpc-3.1.3-bin.tar.gz 。

#apache-xmlrpc-3.1.3-bin.tar.gz包的API文档 http://ws.apache.org/xmlrpc/apidocs/index.html

解压这个压缩包，并把5个jar包导入到项目中
commons-logging-1.1.jar
xmlrpc-client-3.1.3.jar
xmlrpc-server-3.1.3.jar
ws-commons-util-1.0.2.jar
xmlrpc-common-3.1.3.jar

接下来是java代码：

package rpc;

import java.net.URL;
import java.net.MalformedURLException;
import org.apache.xmlrpc.XmlRpcException;
import org.apache.xmlrpc.client.XmlRpcClient;
import org.apache.xmlrpc.client.XmlRpcClientConfigImpl;

public class Test {
    public static void main(String[] args) throws MalformedURLException{
        XmlRpcClientConfigImpl config = new XmlRpcClientConfigImpl();
        config.setServerURL(new URL("http://127.0.0.1:8061/RPC2"));
        XmlRpcClient client = new XmlRpcClient();
        client.setConfig(config);

        //根据不同的python函数形式，构造参数，这例子是调用python函数get_hello(url):注意构造参数的数据类型
        Object[] params = new Object[]{new String("http://localhost/001.jpg")};
        try {
            // 返回的结果是字符串类型，强制转换res为String类型
            String res = (String) client.execute("get_hello", params);
            System.out.println(res);
        } catch (XmlRpcException e11) {
            e11.printStackTrace();
        }
    }
}