博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
RPC应用的java实现
阅读量:6860 次
发布时间:2019-06-26

本文共 4776 字,大约阅读时间需要 15 分钟。

一、RPC介绍

  什么是RPC?Remote Procedure Call,远程过程调用。也就是说,调用过程代码并不是在调用者本地运行,而是要实现调用者与被调用者二地之间的连接与通信。比较严格的定义是:Remote procedure call (RPC) is a protocol that allows a computer programrunning on one computer to cause a subroutine on another computer to be executed without the programmer explicitly coding the details for this interaction. When the software in question is written using object-oriented principles, RPC may be referred to as remote invocation or remote method invocation. 这样一讲,容易联想到C/S模式的程序设计,我想是对的。RPC的基本通信模型是基于Client/Server进程间相互通信模型的一种同步通信形式;它对Client提供了远程服务的过程抽象,其底层消息传递操作对Client是透明的。在RPC中,Client即是请求服务的调用者(Caller),而Server则是执行Client的请求而被调用的程序 (Callee)。

下图是RPC调用协议图:

 

  首先是建立RPC服务,约定底层的RPC传输通道(UDP或是TCP)。客户端的调用参数根据传输前所提供的目的地址及RPC 上层应用程序号,通过底层的RPC传输通道转至相应的服务器,即RPC Application Porgramme Server。客户端随即处于等待状态,以服务器等待应答或Time Out超时信号。当服务器端获得了请求消息,会根据注册RPC时告诉RPC系统的程序入口地址执行相应的操作,并将结果返回至客户端。当一次RPC调用结束后,相应线程发送相应的信号,客户端程序便继续运行。

 

二、基于xml-rpc的应用简单实现

下载xml-rpc jar包  当前版本:3.1.3

 

1、业务处理接口

package com.flyoung.xmlrpc; public interface ServicesHandler {
public String execute(String str); }

2、业务接口实现

package com.flyoung.xmlrpc; public class HelloHandler implements ServicesHandler {
public String execute(String str) {
return "hello "+str+"!"; } }

3、客户端

package com.flyoung.xmlrpc; import java.net.MalformedURLException; import java.net.URL; import java.util.Vector; import org.apache.xmlrpc.XmlRpcException; import org.apache.xmlrpc.client.XmlRpcClient; import org.apache.xmlrpc.client.XmlRpcClientConfigImpl; public class TestClient {
/** * @param args */ public static void main(String[] args) {
try {
//配置客户端 XmlRpcClientConfigImpl config = new XmlRpcClientConfigImpl(); //设置服务器端地址 config.setServerURL(new URL("http://localhost:8080/Rpc/HelloHandler")); //创建XmlRpc客户端 XmlRpcClient client = new XmlRpcClient(); //绑定以上设置 client.setConfig(config); //创建参数列表 Vector
params = new Vector
(); params.addElement("flyoung"); //执行XML-RPC 请求 String result =(String) client.execute("HelloHandler.execute", params); System.out.println("result:"+result); } catch (MalformedURLException e) {
e.printStackTrace(); } catch (XmlRpcException e) {
e.printStackTrace(); } } }

4、服务器端

package com.flyoung.xmlrpc; import java.io.IOException; import javax.servlet.ServletConfig; import javax.servlet.ServletException; import javax.servlet.http.HttpServlet; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import org.apache.xmlrpc.XmlRpcException; import org.apache.xmlrpc.server.PropertyHandlerMapping; import org.apache.xmlrpc.server.XmlRpcServerConfigImpl; import org.apache.xmlrpc.webserver.XmlRpcServletServer; import com.flyoung.xmlrpc.HelloHandler; public class XmlRpcServicesServlet extends HttpServlet {
private XmlRpcServletServer server; @Override public void init(ServletConfig config) throws ServletException {
super.init(config); try {
//创建XmlRpcServletServer对象 server = new XmlRpcServletServer(); //set up handler mapping of XmlRpcServletServer object PropertyHandlerMapping pmp = new PropertyHandlerMapping(); pmp.addHandler("HelloHandler", HelloHandler.class); server.setHandlerMapping(pmp); //more config of XmlRpcServletServer object XmlRpcServerConfigImpl serverConfig = (XmlRpcServerConfigImpl)server.getConfig(); serverConfig.setEnabledForExtensions(true); serverConfig.setContentLengthOptional(false); } catch (XmlRpcException e) {
// TODO Auto-generated catch block e.printStackTrace(); } } @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
server.execute(req, resp); } @Override protected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {
server.execute(req, resp); } }

5、xml配置

index.jsp
XmlRpcServer
com.flyoung.xmlrpc.XmlRpcServicesServlet
XmlRpcServer
/HelloHandler

6、测试结果

result:hello flyoung!

  在RPC中,当一个请求到达RPC服务器时,这个请求就包含了一个参数集和一个文本值,通常形成“classname.methodname”的形式。这就向RPC服务器表明,被请求的方法在为“classname”的类中,名叫“methodname”。然后RPC服务器就去搜索与之相匹配的类和方法,并把它作为那种方法参数类型的输入。这里的参数类型是与RPC请求中的类型是匹配的。一旦匹配成功,这个方法就被调用了,其结果被编码后返回客户方。

  缺点:

  1)XML-RPC的消息系统过于简单,没有完整意义上的消息模型 

  2)XML-RPC调用服务的方式要求直接指定对象和方法,称不上完整的面向服务的体系 
  3)XML-RPC服务器端提供的服务实际上是特定对象的某个方法,限制了服务器端的开发 

转载地址:http://zdxyl.baihongyu.com/

你可能感兴趣的文章
WebWorker与WebSocket实现前端消息总线
查看>>
Selector
查看>>
Unity 2018.3.1 SyncVar没有同步服务器变量
查看>>
Linux命令(2) - 查看目录和文件大小: du -sh
查看>>
python的一些常用标准库
查看>>
最短路径--Floyd、Dijkstra、Bellman、SPFA算法
查看>>
gunzip
查看>>
使用CAShapeLayer绘制小人
查看>>
6.用递归实现求数组中的任意次最值。
查看>>
清华大学MBA在职班第一学年第二学期课表
查看>>
公开课:如何成为一名高级系统运维工程师(架构师)?
查看>>
深入Hadoop节点部署的策略
查看>>
Linux下高效数据恢复软件extundelete应用实战
查看>>
【REACT NATIVE 系列教程之五】NAVIGATOR(页面导航)的基本使用与传参
查看>>
由浅入深学优化之like‘%%’坑爹写法
查看>>
部署Hadoop高性能集群
查看>>
Determine Hadoop Memory Configuration Settings
查看>>
解析ActionResult子类JsonResult
查看>>
6.cadence原理图下[原创]
查看>>
Javascript图片裁切
查看>>