135-1821-9792

Java分布式之RMI实例教程

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相关的东西。

  
 
 
    
   
  
  
  1. Java代码 
    2. 
   
  
  
  2. RmiMonitorService.java 
    3. 
   
  
  
  3. package nbpt.ts.manager.message.service; 
    4. 
   
  
  
  4. import java.rmi.Remote; 
    5. 
   
  
  
  5. import java.rmi.RemoteException; 
    6. 
   
  
  
  6. /** 
    7. 
   
  
  
  7. * Description: 实时显示RMI服务接口. 
    8. 
   
  
  
  8. * 
    9. 
   
  
  
  9. * RMI接口必须扩展接口java.rmi.Remote 
    10. 
   
  
  
  10. * 
    11. 
   
  
  
  11. * @author Peter Wei 
    12. 
   
  
  
  12. * @version 1.0 Feb 25, 2009 
    13. 
   
  
  
  13. */ 
    14. 
   
  
  
  14. public interface RmiMonitorService extends Remote { 
    15. 
   
  
  
  15. /** 
    16. 
   
  
  
  16. * 实时显示对外接口 
    17. 
   
  
  
  17. * 
    18. 
   
  
  
  18. * @param funindex 
    19. 
   
  
  
  19. * 功能号 
    20. 
   
  
  
  20. * @param param 
    21. 
   
  
  
  21. * 键名列表，也就是实际传输的内容 
    22. 
   
  
  
  22. * @return 
    23. 
   
  
  
  23. * @throws RemoteException 
    24. 
   
  
  
  24. * 远程接口方法必须抛出java.rmi.RemoteException 
    25. 
   
  
  
  25. */ 
    26. 
   
  
  
  26. public int interactive(int funindex, String param) throws RemoteException; 
    27. 
   
  
  
  27. } 
    28. 
   
  
  
  28. RmiMonitorServiceImpl.java 
    29. 
   
  
  
  29. package nbpt.ts.manager.message.service.impl; 
    30. 
   
  
  
  30. import java.rmi.RemoteException; 
    31. 
   
  
  
  31. import java.rmi.server.UnicastRemoteObject; 
    32. 
   
  
  
  32. // import nbpt.ts.manager.base.util.AppContext; 
    33. 
   
  
  
  33. import nbpt.ts.manager.message.service.RmiMonitorService; 
    34. 
   
  
  
  34. import nbpt.ts.manager.message.service.WarnService; 
    35. 
   
  
  
  35. /** 
    36. 
   
  
  
  36. * Description: 实时显示RMI接口实现. 
    37. 
   
  
  
  37. * 
    38. 
   
  
  
  38. * 实现RMI接口及远程方法（继承UnicastRemoteObject） 
    39. 
   
  
  
  39. * 
    40. 
   
  
  
  40. * @author Peter Wei 
    41. 
   
  
  
  41. * @version 1.0 Feb 25, 2009 
    42. 
   
  
  
  42. */ 
    43. 
   
  
  
  43. public class RmiMonitorServiceImpl extends UnicastRemoteObject implements 
    44. 
   
  
  
  44. RmiMonitorService { 
    45. 
   
  
  
  45. private static final long serialVersionUID = -3771656108378649574L; 
    46. 
   
  
  
  46. public static final int SUCCSS = 1; 
    47. 
   
  
  
  47. public static final int FAIL = 0; 
    48. 
   
  
  
  48. public WarnService warnService; 
    49. 
   
  
  
  49. /** 
    50. 
   
  
  
  50. * 必须定义构造方法，因为要抛出RemoteException异常 
    51. 
   
  
  
  51. * 
    52. 
   
  
  
  52. * @throws RemoteException 
    53. 
   
  
  
  53. */ 
    54. 
   
  
  
  54. public RmiMonitorServiceImpl() throws RemoteException { 
    55. 
   
  
  
  55. super(); 
    56. 
   
  
  
  56. } 
    57. 
   
  
  
  57. public int interactive(int funindex, String param) throws RemoteException { 
    58. 
   
  
  
  58. int result = FAIL; 
    59. 
   
  
  
  59. switch (funindex) { 
    60.

告警#p#

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

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

  
 
 
    
   
  
  
  1. warnService = new WarnServiceImpl();
    2.

网络告警的业务操作

  
 
 
    
   
  
  
  1. warnService.dealWarn(param); 
    2. 
   
  
  
  2. result = SUCCSS; 
    3. 
   
  
  
  3. } 
    4. 
   
  
  
  4. break; 
    5. 
   
  
  
  5. case (2): 
    6. 
   
  
  
  6. // do other biz 
    7. 
   
  
  
  7. break; 
    8. 
   
  
  
  8. } 
    9. 
   
  
  
  9. // ...... 
    10. 
   
  
  
  10. return result; 
    11. 
   
  
  
  11. } 
    12. 
   
  
  
  12. public WarnService getWarnService() { 
    13. 
   
  
  
  13. return warnService; 
    14. 
   
  
  
  14. } 
    15. 
   
  
  
  15. public void setWarnService(WarnService warnService) { 
    16. 
   
  
  
  16. this.warnService = warnService; 
    17. 
   
  
  
  17. } 
    18. 
   
  
  
  18. } 
    19. 
   
  
  
  19. RmiServer.java 
    20. 
   
  
  
  20. package nbpt.ts.manager.message.service; 
    21. 
   
  
  
  21. import java.net.MalformedURLException; 
    22. 
   
  
  
  22. import java.rmi.AlreadyBoundException; 
    23. 
   
  
  
  23. import java.rmi.Naming; 
    24. 
   
  
  
  24. import java.rmi.RemoteException; 
    25. 
   
  
  
  25. import java.rmi.registry.LocateRegistry; 
    26. 
   
  
  
  26. import nbpt.ts.manager.message.service.impl.RmiMonitorServiceImpl; 
    27. 
   
  
  
  27. /** 
    28. 
   
  
  
  28. * Description: RMI服务端. 
    29. 
   
  
  
  29. * 
    30. 
   
  
  
  30. * @author Peter Wei 
    31. 
   
  
  
  31. * @version 1.0 Feb 25, 2009 
    32. 
   
  
  
  32. */ 
    33. 
   
  
  
  33. public class RmiServer { 
    34. 
   
  
  
  34. public String ip = "localhost"; 
    35. 
   
  
  
  35. public int port = 8889; 
    36. 
   
  
  
  36. /** 
    37. 
   
  
  
  37. * 启动RMI注册服务，并注册远程对象.实际应用中是在Spring初始化并启动 
    38. 
   
  
  
  38. */ 
    39. 
   
  
  
  39. public void init() { 
    40. 
   
  
  
  40. try { 
    41. 
   
  
  
  41. LocateRegistry.createRegistry(port); 
    42. 
   
  
  
  42. // 创建一个远程对象 
    43. 
   
  
  
  43. RmiMonitorService comm = new RmiMonitorServiceImpl(); 
    44. 
   
  
  
  44. Naming.bind("//" + ip + ":" + port + "/comm", comm); 
    45. 
   
  
  
  45. } catch (RemoteException e) { 
    46. 
   
  
  
  46. System.out.println("创建远程对象发生异常！" + e.toString()); 
    47. 
   
  
  
  47. e.printStackTrace(); 
    48. 
   
  
  
  48. } catch (AlreadyBoundException e) { 
    49. 
   
  
  
  49. System.out.println("发生重复绑定对象异常！" + e.toString()); 
    50. 
   
  
  
  50. e.printStackTrace(); 
    51. 
   
  
  
  51. } catch (MalformedURLException e) { 
    52. 
   
  
  
  52. System.out.println("发生URL畸形异常！" + e.toString()); 
    53. 
   
  
  
  53. e.printStackTrace(); 
    54. 
   
  
  
  54. } 
    55. 
   
  
  
  55. } 
    56. 
   
  
  
  56. public String getIp() { 
    57. 
   
  
  
  57. return ip; 
    58. 
   
  
  
  58. } 
    59. 
   
  
  
  59. public void setIp(String ip) { 
    60. 
   
  
  
  60. this.ip = ip; 
    61. 
   
  
  
  61. } 
    62. 
   
  
  
  62. public int getPort() { 
    63. 
   
  
  
  63. return port; 
    64. 
   
  
  
  64. } 
    65. 
   
  
  
  65. public void setPort(int port) { 
    66. 
   
  
  
  66. this.port = port; 
    67. 
   
  
  
  67. } 
    68. 
   
  
  
  68. public static void main(String[] args) { 
    69.

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

  
 
 
    
   
  
  
  1. RmiServer rmiServer = new RmiServer(); 
    2. 
   
  
  
  2. System.out.println("RMI服务初始化:"); 
    3. 
   
  
  
  3. rmiServer.init(); 
    4. 
   
  
  
  4. } 
    5. 
   
  
  
  5. } 
    6. 
   
  
  
  6. MonitorClient.java 
    7. 
   
  
  
  7. package nbpt.ts.manager.message.service; 
    8. 
   
  
  
  8. import java.net.MalformedURLException; 
    9. 
   
  
  
  9. import java.rmi.Naming; 
    10. 
   
  
  
  10. import java.rmi.NotBoundException; 
    11. 
   
  
  
  11. import java.rmi.RemoteException; 
    12. 
   
  
  
  12. /** 
    13. 
   
  
  
  13. * Description: RMI客户端. 
    14. 
   
  
  
  14. * 
    15. 
   
  
  
  15. * @author Peter Wei 
    16. 
   
  
  
  16. * @version 1.0 Feb 25, 2009 
    17. 
   
  
  
  17. */ 
    18. 
   
  
  
  18. public class MonitorClient { 
    19. 
   
  
  
  19. public RmiMonitorService monitorService; 
    20. 
   
  
  
  20. public String ip = "localhost"; 
    21. 
   
  
  
  21. public int port = 8889; 
    22. 
   
  
  
  22. public int interactive(int funindex, String param)  
    23. 
   
  
  
  23. int result = 0; 
    24. 
   
  
  
  24. try { 
    25. 
   
  
  
  25. getMonitorService().interactive(funindex, param); 
    26. 
   
  
  
  26. result = 1; 
    27. 
   
  
  
  27. } catch (RemoteException e) { 
    28. 
   
  
  
  28. e.printStackTrace(); 
    29. 
   
  
  
  29. } 
    30. 
   
  
  
  30. return result; 
    31. 
   
  
  
  31. } 
    32. 
   
  
  
  32. public RmiMonitorService getMonitorService() { 
    33. 
   
  
  
  33. try { 
    34.

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

  
 
 
    
   
  
  
  1. monitorService = (RmiMonitorService) Naming.lookup("rmi://" + ip 
    2. 
   
  
  
  2. + ":" + port + "/comm"); 
    3. 
   
  
  
  3. } catch (NotBoundException e) { 
    4. 
   
  
  
  4. e.printStackTrace(); 
    5. 
   
  
  
  5. } catch (MalformedURLException e) { 
    6. 
   
  
  
  6. e.printStackTrace(); 
    7. 
   
  
  
  7. } catch (RemoteException e) { 
    8. 
   
  
  
  8. e.printStackTrace(); 
    9. 
   
  
  
  9. } 
    10. 
   
  
  
  10. return monitorService; 
    11. 
   
  
  
  11. } 
    12. 
   
  
  
  12. public static void main(String args[]) throws RemoteException { 
    13. 
   
  
  
  13. MonitorClient client = new MonitorClient(); 
    14. 
   
  
  
  14. System.out.println("发送告警信息:"); 
    15. 
   
  
  
  15. String msg = "tsid=1022&devid=10001027&warnid=102&warntype=01&warnlevel=1&warnmsg=设备出错,请检查."; 
    16. 
   
  
  
  16. System.out.println(client.getValue(msg, "warnmsg")); 
    17. 
   
  
  
  17. client.interactive(1, msg); 
    18. 
   
  
  
  18. } 
    19. 
   
  
  
  19. public String getValue(String content, String key) { 
    20. 
   
  
  
  20. String value = ""; 
    21. 
   
  
  
  21. int begin = 0, end = 0; 
    22. 
   
  
  
  22. begin = content.indexOf(key + "="); 
    23. 
   
  
  
  23. end = content.indexOf("&", begin); 
    24. 
   
  
  
  24. if (end == -1) 
    25. 
   
  
  
  25. end = content.length(); 
    26. 
   
  
  
  26. value = content.substring(begin + key.length() + 1, end); 
    27. 
   
  
  
  27. return value; 
    28. 
   
  
  
  28. } 
    29. 
   
  
  
  29. } 
    30. 
   
  
  
  30. WarnService.java 
    31. 
   
  
  
  31. package nbpt.ts.manager.message.service; 
    32. 
   
  
  
  32. /** 
    33. 
   
  
  
  33. * Description: 告警服务 
    34. 
   
  
  
  34. * 
    35. 
   
  
  
  35. * @author Peter Wei 
    36. 
   
  
  
  36. * @version 1.0 2010-8-22 
    37. 
   
  
  
  37. */ 
    38. 
   
  
  
  38. public interface WarnService { 
    39. 
   
  
  
  39. /** 
    40.

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

  
 
 
    
   
  
  
  1. * 
    2. 
   
  
  
  2. * @param message 
    3. 
   
  
  
  3. * @return 
    4. 
   
  
  
  4. */ 
    5. 
   
  
  
  5. public int dealWarn(String message); 
    6. 
   
  
  
  6. } 
    7. 
   
  
  
  7. WarnServiceImpl.java 
    8. 
   
  
  
  8. package nbpt.ts.manager.message.service.impl; 
    9. 
   
  
  
  9. import nbpt.ts.manager.message.service.WarnService; 
    10. 
   
  
  
  10. /** 
    11. 
   
  
  
  11. * Description: 告警服务 
    12. 
   
  
  
  12. * 
    13. 
   
  
  
  13. * @author Peter Wei 
    14. 
   
  
  
  14. * @version 1.0 2010-8-22 
    15. 
   
  
  
  15. */ 
    16. 
   
  
  
  16. public class WarnServiceImpl implements WarnService { 
    17. 
   
  
  
  17. public int dealWarn(String message) { 
    18.

告警处理方法

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

分享标题：Java分布式之RMI实例教程
URL地址：http://www.wtcwzsj.com/article/dpgdspd.html

其他资讯


关于我们
我们的服务
网站建设案例
新闻动态
联系我们

135-1821-9792

公司服务热线
友情链接： 普特斯腐植酸   上市集团网站建设   自适应网站   贵阳联通机房   图文快印   天泽尚品装饰   绵阳发电机公司   成都网络营销   成都服务器租用   成都公司注册   

Copyright © 2009-2022 www.wtcwzsj.com 青羊区广皓图文设计工作室（个体工商户） 版权所有　蜀ICP备19037934号