Java分布式之RMI实例教程

作者：佚名 2010-08-25 17:08:18

企业动态

分布式最近的联通项目，下一阶段可能会涉及到和各省间的RMI接口，所以总结一下08年中国移动自动拨测系统用到的RMI技术，以备不时之需。

成都创新互联公司主要从事做网站、网站设计、网页设计、企业做网站、公司建网站等业务。立足成都服务邵阳,十余年网站建设经验,价格优惠、服务专业,欢迎来电咨询建站服务:13518219792

Java分布式之RMI实例教程，RMI的基础是接口，RMI构架基于一个重要的原理：定义接口和定义接口的具体实现是分开的。

编辑特别推荐:

关于Java性能监控不知道的五件事

Java运行时环境初始化时出现错误

SQLServe数据库到DB2连接服务器的实现过程全解

前言

最近的联通项目，下一阶段可能会涉及到和各省间的RMI接口，所以总结一下08年中国移动自动拨测系统用到的RMI技术，以备不时之需。同时也给广大初哥提供一些学习资料，哈哈。前几年，一直忙于项目，没怎么做系统总结。以后计划写一些以前项目用过的Java分布式技术实例教程，如：RMI、Socket、Mina、SNMP、SOAP、web Service、Hessian、JMS等。希望和大家一起交流，分享经验，一起提高。

RMI简介

RMI，远程方法调用（Remote Method Invocation）是Enterprise JavaBeans的支柱，是建立分布式Java应用程序的方便途径。RMI是非常容易使用的，但是它非常的强大。

RMI的基础是接口，RMI构架基于一个重要的原理：定义接口和定义接口的具体实现是分开的。看看jboss-remoting:

基本原理

要实现网络机器间的通讯，首先得来看看计算机系统网络通信的基本原理，在底层层面去看，网络通信需要做的就是将流从一台计算机传输到另外一台计算机，基于传输协议和网络IO来实现，其中传输协议比较出名的有http、tcp、udp等等，http、tcp、udp都是在基于Socket概念上为某类应用场景而扩展出的传输协议，网络IO，主要有bio、nio、aio三种方式，所有的分布式应用通讯都基于这个原理而实现，只是为了应用的易用，各种语言通常都会提供一些更为贴近应用易用的应用层协议。

主要步骤

分为以下几个步骤:

1. 创建远程接口及声明远程方法（RmiMonitorService.java）

2. 实现远程接口及远程方法（继承UnicastRemoteObject）(RmiMonitorServiceImpl.java)

3. 启动RMI注册服务，并注册远程对象（RmiServer.java）

4. 客户端查找远程对象，并调用远程方法（MonitorClient.java）

5. 运行实例#p#

业务场景

在移动拨测系统管理端中要融合实时显示。简单点说就是设备出现告警时，要采用不同方式实时展示。如Web界面(Ajax)、GIS等。

主要业务流程设计：

1. 设备告警

2. 调用RMI Client

3. 调用RMI Server

4. 调用业务处理接口

5. 告警信息入库

6. 实时显示(Ajax,Gis等技术)

技术设计

接口函数函数名称： int interactive( int funindex, string param )

参数说明：

funindex 功能号，整型。1为设备告警

param 交互参数，字符串型。

成功=1，失败=0。

说明：

param交互参数用键值对组成，每个键值对以“&”分割，如：Tsid=01&devid=002&warnid=102&warntype=01&warnlevel=1 。

测试点ID(tsid)

设备ID(devid)

告警ID(warnid)

告警类型(warntype)

告警级别(warnlevel)

代码实现#p#

废话少说，上代码，为了演示方便，经过整理，省去了很多get，set之类的东东还有业务的东西以及Spring相关的东西。

  
 
 
   
  
  Java代码 
   
  
  RmiMonitorService.java 
   
  
  package nbpt.ts.manager.message.service; 
   
  
  import java.rmi.Remote; 
   
  
  import java.rmi.RemoteException; 
   
  
  /** 
   
  
  * Description: 实时显示RMI服务接口. 
   
  
  * 
   
  
  * RMI接口必须扩展接口java.rmi.Remote 
   
  
  * 
   
  
  * @author Peter Wei 
   
  
  * @version 1.0 Feb 25, 2009 
   
  
  */ 
   
  
  public interface RmiMonitorService extends Remote { 
   
  
  /** 
   
  
  * 实时显示对外接口 
   
  
  * 
   
  
  * @param funindex 
   
  
  * 功能号 
   
  
  * @param param 
   
  
  * 键名列表，也就是实际传输的内容 
   
  
  * @return 
   
  
  * @throws RemoteException 
   
  
  * 远程接口方法必须抛出java.rmi.RemoteException 
   
  
  */ 
   
  
  public int interactive(int funindex, String param) throws RemoteException; 
   
  
  } 
   
  
  RmiMonitorServiceImpl.java 
   
  
  package nbpt.ts.manager.message.service.impl; 
   
  
  import java.rmi.RemoteException; 
   
  
  import java.rmi.server.UnicastRemoteObject; 
   
  
  // import nbpt.ts.manager.base.util.AppContext; 
   
  
  import nbpt.ts.manager.message.service.RmiMonitorService; 
   
  
  import nbpt.ts.manager.message.service.WarnService; 
   
  
  /** 
   
  
  * Description: 实时显示RMI接口实现. 
   
  
  * 
   
  
  * 实现RMI接口及远程方法（继承UnicastRemoteObject） 
   
  
  * 
   
  
  * @author Peter Wei 
   
  
  * @version 1.0 Feb 25, 2009 
   
  
  */ 
   
  
  public class RmiMonitorServiceImpl extends UnicastRemoteObject implements 
   
  
  RmiMonitorService { 
   
  
  private static final long serialVersionUID = -3771656108378649574L; 
   
  
  public static final int SUCCSS = 1; 
   
  
  public static final int FAIL = 0; 
   
  
  public WarnService warnService; 
   
  
  /** 
   
  
  * 必须定义构造方法，因为要抛出RemoteException异常 
   
  
  * 
   
  
  * @throws RemoteException 
   
  
  */ 
   
  
  public RmiMonitorServiceImpl() throws RemoteException { 
   
  
  super(); 
   
  
  } 
   
  
  public int interactive(int funindex, String param) throws RemoteException { 
   
  
  int result = FAIL; 
   
  
  switch (funindex) {

告警#p#

  
 
 
   
  
  case (1): { 
   
  
  // warnService = (WarnService) AppContext.getAppContext().getBean( 
   
  
  // "warn.warnService");

实际应用是从Spring应用中获取告警Service,如上代码

  
 
 
   
  
  warnService = new WarnServiceImpl();

网络告警的业务操作

  
 
 
   
  
  warnService.dealWarn(param); 
   
  
  result = SUCCSS; 
   
  
  } 
   
  
  break; 
   
  
  case (2): 
   
  
  // do other biz 
   
  
  break; 
   
  
  } 
   
  
  // ...... 
   
  
  return result; 
   
  
  } 
   
  
  public WarnService getWarnService() { 
   
  
  return warnService; 
   
  
  } 
   
  
  public void setWarnService(WarnService warnService) { 
   
  
  this.warnService = warnService; 
   
  
  } 
   
  
  } 
   
  
  RmiServer.java 
   
  
  package nbpt.ts.manager.message.service; 
   
  
  import java.net.MalformedURLException; 
   
  
  import java.rmi.AlreadyBoundException; 
   
  
  import java.rmi.Naming; 
   
  
  import java.rmi.RemoteException; 
   
  
  import java.rmi.registry.LocateRegistry; 
   
  
  import nbpt.ts.manager.message.service.impl.RmiMonitorServiceImpl; 
   
  
  /** 
   
  
  * Description: RMI服务端. 
   
  
  * 
   
  
  * @author Peter Wei 
   
  
  * @version 1.0 Feb 25, 2009 
   
  
  */ 
   
  
  public class RmiServer { 
   
  
  public String ip = "localhost"; 
   
  
  public int port = 8889; 
   
  
  /** 
   
  
  * 启动RMI注册服务，并注册远程对象.实际应用中是在Spring初始化并启动 
   
  
  */ 
   
  
  public void init() { 
   
  
  try { 
   
  
  LocateRegistry.createRegistry(port); 
   
  
  // 创建一个远程对象 
   
  
  RmiMonitorService comm = new RmiMonitorServiceImpl(); 
   
  
  Naming.bind("//" + ip + ":" + port + "/comm", comm); 
   
  
  } catch (RemoteException e) { 
   
  
  System.out.println("创建远程对象发生异常！" + e.toString()); 
   
  
  e.printStackTrace(); 
   
  
  } catch (AlreadyBoundException e) { 
   
  
  System.out.println("发生重复绑定对象异常！" + e.toString()); 
   
  
  e.printStackTrace(); 
   
  
  } catch (MalformedURLException e) { 
   
  
  System.out.println("发生URL畸形异常！" + e.toString()); 
   
  
  e.printStackTrace(); 
   
  
  } 
   
  
  } 
   
  
  public String getIp() { 
   
  
  return ip; 
   
  
  } 
   
  
  public void setIp(String ip) { 
   
  
  this.ip = ip; 
   
  
  } 
   
  
  public int getPort() { 
   
  
  return port; 
   
  
  } 
   
  
  public void setPort(int port) { 
   
  
  this.port = port; 
   
  
  } 
   
  
  public static void main(String[] args) {

实际应用中是在Spring初始化并启动#p#

  
 
 
   
  
  RmiServer rmiServer = new RmiServer(); 
   
  
  System.out.println("RMI服务初始化:"); 
   
  
  rmiServer.init(); 
   
  
  } 
   
  
  } 
   
  
  MonitorClient.java 
   
  
  package nbpt.ts.manager.message.service; 
   
  
  import java.net.MalformedURLException; 
   
  
  import java.rmi.Naming; 
   
  
  import java.rmi.NotBoundException; 
   
  
  import java.rmi.RemoteException; 
   
  
  /** 
   
  
  * Description: RMI客户端. 
   
  
  * 
   
  
  * @author Peter Wei 
   
  
  * @version 1.0 Feb 25, 2009 
   
  
  */ 
   
  
  public class MonitorClient { 
   
  
  public RmiMonitorService monitorService; 
   
  
  public String ip = "localhost"; 
   
  
  public int port = 8889; 
   
  
  public int interactive(int funindex, String param)  
   
  
  int result = 0; 
   
  
  try { 
   
  
  getMonitorService().interactive(funindex, param); 
   
  
  result = 1; 
   
  
  } catch (RemoteException e) { 
   
  
  e.printStackTrace(); 
   
  
  } 
   
  
  return result; 
   
  
  } 
   
  
  public RmiMonitorService getMonitorService() { 
   
  
  try {

在RMI服务注册表中查找名称为RmiMonitorService的对象，并调用其上的方法#p#

  
 
 
   
  
  monitorService = (RmiMonitorService) Naming.lookup("rmi://" + ip 
   
  
  + ":" + port + "/comm"); 
   
  
  } catch (NotBoundException e) { 
   
  
  e.printStackTrace(); 
   
  
  } catch (MalformedURLException e) { 
   
  
  e.printStackTrace(); 
   
  
  } catch (RemoteException e) { 
   
  
  e.printStackTrace(); 
   
  
  } 
   
  
  return monitorService; 
   
  
  } 
   
  
  public static void main(String args[]) throws RemoteException { 
   
  
  MonitorClient client = new MonitorClient(); 
   
  
  System.out.println("发送告警信息:"); 
   
  
  String msg = "tsid=1022&devid=10001027&warnid=102&warntype=01&warnlevel=1&warnmsg=设备出错,请检查."; 
   
  
  System.out.println(client.getValue(msg, "warnmsg")); 
   
  
  client.interactive(1, msg); 
   
  
  } 
   
  
  public String getValue(String content, String key) { 
   
  
  String value = ""; 
   
  
  int begin = 0, end = 0; 
   
  
  begin = content.indexOf(key + "="); 
   
  
  end = content.indexOf("&", begin); 
   
  
  if (end == -1) 
   
  
  end = content.length(); 
   
  
  value = content.substring(begin + key.length() + 1, end); 
   
  
  return value; 
   
  
  } 
   
  
  } 
   
  
  WarnService.java 
   
  
  package nbpt.ts.manager.message.service; 
   
  
  /** 
   
  
  * Description: 告警服务 
   
  
  * 
   
  
  * @author Peter Wei 
   
  
  * @version 1.0 2010-8-22 
   
  
  */ 
   
  
  public interface WarnService { 
   
  
  /**

* 处理告警:告警来时的业务操作,实际操作是解析消息存库，然后界面Ajax定时刷新数据，获取实时告警展示#p#

  
 
 
   
  
  * 
   
  
  * @param message 
   
  
  * @return 
   
  
  */ 
   
  
  public int dealWarn(String message); 
   
  
  } 
   
  
  WarnServiceImpl.java 
   
  
  package nbpt.ts.manager.message.service.impl; 
   
  
  import nbpt.ts.manager.message.service.WarnService; 
   
  
  /** 
   
  
  * Description: 告警服务 
   
  
  * 
   
  
  * @author Peter Wei 
   
  
  * @version 1.0 2010-8-22 
   
  
  */ 
   
  
  public class WarnServiceImpl implements WarnService { 
   
  
  public int dealWarn(String message) {

告警处理方法

  
 
 
   
  
  System.out.println("已接收网络告警"); 
   
  
  // … 
   
  
  return 1; 
   
  
  } 
   
  
  }

分享名称：Java分布式之RMI实例教程
本文链接：http://www.hantingmc.com/qtweb/news5/282105.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容