RPC简单学习文档.doc

RPC（Remote Procedure Call Protocol）远程过程调用协议，它是一种通过网络从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。RPC协议假定某些传输协议的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI网络通信模型中，RPC跨越了传输层和应用层，RPC使得开发网络分布式多程序更加容易。本文档使用Apache XML-RPC。下载地址：/apache-mirror/ws/xmlrpc/Jar包列表：commons-codec-1.4.jarcommons-httpclient-3.0.1.jarcommons-logging-1.1.jarws-commons-util-1.0.2.jarxmlrpc-client-3.1.3.jarxmlrpc-common-3.1.3.jarxmlrpc-properties.jarxmlrpc-server-3.1.3.jar代码分为四部分：rpc服务器端代码、被执行的类、rpc配置文件（myHperties）、rpc客户端代码rpc配置文件应该放在build path指定的路径下，比如src文件夹下。具体代码如下：rpc服务器端代码server.javaimport org.apache.xmlrpc.XmlRpcRequest;import mon.XmlRpcHttpRequestConfig;import org.apache.xmlrpc.server.AbstractReflectiveHandlerMapping;import org.apache.xmlrpc.server.PropertyHandlerMapping;import org.apache.xmlrpc.server.XmlRpcServer;import org.apache.xmlrpc.server.XmlRpcServerConfigImpl;import org.apache.xmlrpc.webserver.WebServer;public class Server private static final int port = 8399; public static void main(String args) throws Exception /RPC服务 WebServer webServer = new WebServer(port); XmlRpcServer xmlRpcServer = webServer.getXmlRpcServer(); PropertyHandlerMapping phm = new PropertyHandlerMapping(); /验证权限 AbstractReflectiveHandlerMapping.AuthenticationHandler handler = new AbstractReflectiveHandlerMapping.AuthenticationHandler() public boolean isAuthorized(XmlRpcRequest pRequest) XmlRpcHttpRequestConfig config = (XmlRpcHttpRequestConfig) pRequest.getConfig(); return isAuthenticated(config.getBasicUserName(), config.getBasicPassword(); ; ; phm.setAuthenticationHandler(handler); /* Load handler definitions from a property file. * The property file might look like: * myHandler=com.huan.RPC.MyHandler */ phm.load(Thread.currentThread().getContextClassLoader(), myHperties); /* You may also provide the handler classes directly, * like this: * phm.addHandler(myHandler, * com.huan.RPC.MyHandler); */ xmlRpcServer.setHandlerMapping(phm); XmlRpcServerConfigImpl serverConfig = (XmlRpcServerConfigImpl) xmlRpcServer.getConfig(); serverConfig.setEnabledForExtensions(true); serverConfig.setContentLengthOptional(false); webServer.start(); /用户名和密码验证 private static boolean isAuthenticated(String pUserName, String pPassword) return foo.equals(pUserName) & bar.equals(pPassword); 被执行类MyHandler.javapublic class MyHandler public String sayHello(String str)return Hello, + str;myHperties 文件myHandler=com.huan.RPC.MyHandle客户端代码：import .URL;import org.apache.xmlrpc.XmlRpcException;import org.apache.xmlrpc.XmlRpcRequest;import org.apache.xmlrpc.client.XmlRpcClient;import org.apache.xmlrpc.client.XmlRpcClientConfigImpl;import org.apache.xmlrpc.client.XmlRpcCommonsTransportFactory;import mon.XmlRpcHttpRequestConfig;import org.apache.xmlrpc.server.AbstractReflectiveHandlerMapping;import org.apache.xmlrpc.server.PropertyHandlerMapping;import org.apache.xmlrpc.server.XmlRpcHandlerMapping;import org.apache.xmlrpc.webserver.XmlRpcServlet;public class Client extends XmlRpcServlet public static void main(String args) throws Exception / create configuration XmlRpcClientConfigImpl config = new XmlRpcClientConfigImpl(); /xmlrpc服务在web.xml中配置 config.setServerURL(new URL(:8399/xmlrpc); config.setEnabledForExtensions(true); config.setConnectionTimeout(60 * 1000); config.setReplyTimeout(60 * 1000); /设置用户名和密码 config.setBasicUserName(foo); config.setBasicPassword(bar); XmlRpcClient client = new XmlRpcClient(); / use Commons HttpClient as transport client.setTransportFactory( new XmlRpcCommonsTransportFactory(client); / set configuration client.setConfig(config); / make the a regular call Object params = new Object Tom ; /调用服务器端sayHello方法 String result = (St