使用Java调用Python服务器RPC
jopen
10年前
使用Java调用Python服务器RPC，附带Python建立RPC服务器或客户端的通用库
#先上一个整体的Python代码，它可以作为Python建立RPC服务器或客户端的通用库
#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待用
python test_rpc.py
#下面开始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
#如果使用Eclipse，通过 “右键项目根目录->properties->Java Build Path->Libraries->add External JARs" 导入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
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(); } } }
参考：