#先上一個總體的Python代碼,它能夠做爲Python創建RPC服務器或客戶端的通用庫html
#test_rpc.py #coding=utf-8 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(): return 'hello!' if __name__ == "__main__": r = RPCServer('0.0.0.0', '8061') r.service([get_hello], 0) #這裏僅僅載入get_hello函數
#啓動test_rpc.py待用
java
python test_rpc.py
#下面開始Java,首先下載jar包 ,在 https://archive.apache.org/dist/ws/xmlrpc/binaries/ 找到 apache-xmlrpc-3.1.3-bin.tar.gz 。python
#apache-xmlrpc-3.1.3-bin.tar.gz包的API文檔 http://ws.apache.org/xmlrpc/apidocs/index.html shell
#若是使用Eclipse,經過 「右鍵項目根目錄->properties->Java Build Path->Libraries->add External JARs" 導入jar包apache
commons-logging-1.1.jarapi
xmlrpc-client-3.1.3.jar服務器
xmlrpc-server-3.1.3.jar函數
ws-commons-util-1.0.2.jarui
xmlrpc-common-3.1.3.jarspa
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; import org.apache.xmlrpc.client.XmlRpcHttpTransportException; public class Test { public static void main(String[] args) throws MalformedURLException, XmlRpcHttpTransportException { XmlRpcClientConfigImpl config = new XmlRpcClientConfigImpl(); config.setServerURL(new URL("http://127.0.0.1:8061/RPC2")); XmlRpcClient client = new XmlRpcClient(); client.setConfig(config); // 根據不一樣的python函數形式,構造參數 // 兩個整形參數 //Object[] params = new Object[] {new Integer(1), new Integer(2)}; // 單個字符串參數 //Object[] params = new Object[] {new String("HELLO")}; // 無參數 Object[] params = null; try { // 返回的結果是字符串類型,強制轉換res爲String類型 String res = (String) client.execute("get_hello", params); System.out.println(res); } catch (XmlRpcException e11) { e11.printStackTrace(); } } }
參考: