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

告警#p#

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

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

  
 
 
  1. warnService = new WarnServiceImpl();

网络告警的业务操作

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

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

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

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

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

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

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

告警处理方法

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

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

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

广告

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