`

浅谈Java分布式计算(2)

 
阅读更多

服务端代码

定义接口

import java.rmi.Remote;  import java.rmi.RemoteException;   /**   *    *    MyRemote.java   *   *     功   能: TODO    *     类   名: MyRemote.java   *   *  ver     変更日       角色    担当者     変更内容   *     ──────────────────────────────────────────────   *  V1.00   2013-3-19   模块    苏若年     初版   *   *     Copyright (c) 2013 dennisit corporation All Rights Reserved.   *      *  Email:<a href="mailto:DennisIT@163.com">发送邮件</a>   *     *     *     Remote是个标记性的接口,意味着没有方法,然而它对RMI有特殊的意义,所以必须遵守这项规则,   *     注意这里用的是extends,接口是可以继承其他接口的   *    */ public interface MyRemote extends Remote{            /**       * 远程的接口定义了客户端可以远程调用的方法,它是作为服务的多态化类,也就是说,客户端会       * 调动有实现此接口的stub,而此stub因为会执行网络和输入/输出工作,所以可能会发生各种       * 问题,客户端鼻息处理或声明异常来认知这一类风险,如果该方法在接口中声明异常,调用该方       * 法的所有程序都必须处理或再声明此异常.       *        * 远程方法的参数和返回值必须是primitive或serializable的.任何远程方法的参数都会被       * 打包通过网络传送,而这时通过序列化完成的,返回值也是一样.所以,如果使用的是自定义类型       * 时,必须对其序列化       * @return       * @throws RemoteException           *                         所有接口中的方法都必须声明RemoteException       */     public String sayHello() throws RemoteException;            } 

 

 

业务实现

import java.rmi.Naming;  import java.rmi.RemoteException;  import java.rmi.server.UnicastRemoteObject;   /**   *    *    MyRemoteImpl.java   *   *     功   能: TODO    *     类   名: MyRemoteImpl.java   *   *  ver     変更日       角色    担当者     変更内容   *     ──────────────────────────────────────────────   *  V1.00   2013-3-19   模块    苏若年     初版   *   *     Copyright (c) 2013 dennisit corporation All Rights Reserved.   *      *  Email:<a href="mailto:DennisIT@163.com">发送邮件</a>   *     *  为了要成为远程服务对象,对象必须要有与远程有关的功能,其中最简单的方法就是继承UnicastRemoteObject   *  (来自java.rmi.server)以让这个父类处理这些工作   *   */ public class MyRemoteImpl extends UnicastRemoteObject implements MyRemote{       /**       * 父类的构造函数声明了异常,所有你必须写出构造函数,因为它代表你的构造函数会调用有风险的程序代码       *        * UnicastRemoteObject有个小问题,它的构造函数会抛出RemoteException.处理它的唯一方式就是       * 对自己的实现声明一个构造,如此才会有地方可以声明出RemoteException.当类被初始化的时候,父类       * 的构造函数一定会被调用,如果父类的构造函数抛出异常,我们也必须声明的自定义的构造函数会抛出异常       * @throws RemoteException       */     protected MyRemoteImpl() throws RemoteException {       }       /**       * 实现出接口所有的方法,但无需声明RemoteException       */     @Override     public String sayHello(){          return "server says, rmi hello world !";      }       public static void main(String[] args) {          try {              /**               * 我们已经有了远程服务,还必须要让远程用户存取,这可以通过将它初始化并加进RMI Registry               * (它一定要运行起来,不然此程序就会失败).当注册对象时,RMI系统会把stub加到registry中,               * 因为这是客户端所需要的.使用java.rmi.Naming的rebind()来注册服务               */             MyRemote service = new MyRemoteImpl();              /**               * 创建出远程对象,然后使用静态的Naming.rebind()来产生关联,所注册的名称会提供客户端查询               */             Naming.rebind("Remote Hello World", service);          } catch (Exception e) {              e.printStackTrace();          }      }        } 

 

客户端代码

import java.rmi.Naming;  /**   *    *    MyRemoteClient.java   *   *     功   能: TODO    *     类   名: MyRemoteClient.java   *   *  ver     変更日       角色    担当者     変更内容   *     ──────────────────────────────────────────────   *  V1.00   2013-3-19   模块    苏若年     初版   *   *     Copyright (c) 2013 dennisit corporation All Rights Reserved.   *      *  Email:<a href="mailto:DennisIT@163.com">发送邮件</a>   *   */ public class MyRemoteClient {       public void exec(){          try {              /**               * 客户端必须取得stub对象,因为客户端必须要调用它的方法.这就得靠RMI registry了.客户端会像查询电话               * 簿一样地搜索,找出上面有相符的名称的服务.               * 客户端查询RMIRegistry,返回stub对象               * Naming.lookup("rmi://127.0.0.1/Remote Hello World");               * 参数说明               * rmi://127.0.0.1/Remote Hello World               * 127.0.0.1表示主机名称或主机IP地址               * Remote Hello World必须要跟注册的名称一样               *                */             MyRemote service = (MyRemote)Naming.lookup("rmi://127.0.0.1/Remote Hello World");              String tmp = service.sayHello();              System.out.println(tmp);          } catch (Exception e) {              e.printStackTrace();          }      }            public static void main(String[] args) {          new MyRemoteClient().exec();      }  } 

 

对实现出的类(不是remote接口)执行rmic

伴随JDK而来的rmic工具会以服务的实现产生2个心的类stub和skeleton.它会按照命名规则在远程实现名称后面加上_Stub或_Skeleton。rmic有几个选项,包括了不产生skeleton、观察产生出类的源代码或使用IIOP作为通讯协议等.产生出的类会放在当前目录下,要记住rmic必须能够找到所实现的类,因此可能要从实现所在的目录执行rmic(实际中可能需要考虑到包目录结构和完整名称,为了简便这里没有运用到包)

 

调用命令行来启动rmiregistry,要确定是从可以存取到该类的目录来启动,最简单的方法就是从类这个目录来运行.

 

运行截图如下

注意:

客户端是使用接口来调用stub上的方法,客户端的Java虚拟机必须要有stub类,但客户端不会在程序代码中引用到stub类,客户端总是通过接口来操作真正的远程对象

服务器上必须要有stub和skeleton,以及服务与远程的接口,它会需要stub类是因为stub会被代换成连接在RMIRegistry上真正的服务.

使用RMI时常犯的错误:

1.忘记在启动远程服务钱启动rmiregistry(使用Naming.rebind()注册服务前rmiregistry必须启动)

2.忘记把参数和返回类型做成可序列化(编译不会检测到,执行时才会发现)

3.忘记将stub类交给客户端

RMI很适合编写并运行远程服务,但我们不会单独使用RMI来执行网站服务,对大型的企业级应用程序来说,我们需要更多更好的功能.像交易管理、大量并发处理、安全性和数据库管理等.这就需要用到Enterprise Application Server.

JavaEE服务器包括了Web服务器和Enterprise JavaBeans(EJB)服务器. EJB服务器作用于RMI调用和服务层之间.

 

RMI在JINI中的应用

Jini也是使用RMI(虽然也可以用别的协议),但多了几个关键功能.

1.自适应探索(adaptive discovery)

2.自恢复网络(self-healing networks)

RMI的客户端得先取得远程服务的地址和名称.客户端的查询程序代码就要带有远程服务的IP地址或主机名(因为RMIRegistry就在上面)以及服务所注册的名称

但是用JINI时,用户只需要知道一件事,服务所实现的接口!这样就行.

Jini是用lookup service,该查询服务比RMI Registry更强更有适应性.因为Jini会在网络上自动的广告.当查询服务上线是,它会使用IP组播技术送出信息给整个网络.不止这样,如果客户端在查询服务已经广播之后上线,客户端也可以发出消息给整个网络来询问.

当服务上线时,它会动态的探索网络上的JINI查询服务并申请注册,注册时,服务会送出一个序列化的对象给查询服务,此对象可以是RMI远程服务的stub、网络装置的驱动程序,甚或是可以在客户端执行的服务本身.并且注册的是所实现的接口.而不是名称.

 

自适应探索的运作

1.Jini查询服务在网络上启动,并使用IP组播技术为自己做宣传

2.已经启动的另外一个Jini服务会寻求向刚启动的查询服务注册.它注册的是功能而不是名称,也就是所实现的接口,然后送出序列化对象给查询服务

3.网络客户想要取得实现ScientificCalculator的东西,可是不知道哪里有,所以就问查询服务

4.查询服务响应查询的结果

自恢复网络的运作

1.某个Jini服务要求注册,查询服务会给一份租约,新注册的服务必须要定期更新租约,不然查询服务会假设此服务已经离线了,查询服务会力求呈现精确完整的可用服务网络状态

2.因为关机所以服务离线,因此没有更新租约,查询服务就把它踢掉.

原文链接:http://www.cnblogs.com/dennisit/archive/2013/03/19/2969175.html

分享到:
评论

相关推荐

    浅谈分布式操作系统的论文

    2. 中间件:中间件是分布式系统中的重要组成部分,如Java RMI、CORBA和Apache Thrift,它们提供标准化的服务接口,简化了分布式应用的开发和部署。 五、分布式系统的构建技术 1. 基于对象的分布式系统:将对象作为...

    浅谈计算机软件开发的JAVA编程语言.pdf

    远程方法调用(Java Remote Method Invocation, RMI)技术主要用于分布式计算结构中,解决程序、函数和数据的远程调用问题。该技术使得客户端和服务器能够实现互联互通,允许用户调用服务器上的JAVA程序中的任意类。...

    浅谈计算机软件开发中JAVA编程语言的应用.zip

    Java在云计算领域也有广泛应用,如在Amazon Web Services(AWS)、Google Cloud Platform(GCP)等云平台上,开发者可以使用Java SDK来操作各种云服务,如存储、计算、数据库等。 七、游戏开发 虽然Java可能不是...

    浅谈人工智能:现状、任务、构架与统一

    Java则是Hadoop等分布式计算框架的基础语言。 - **Python的Numpy和Scipy库**:提供了类似MATLAB的功能,但更加易于集成到Web服务中,并可在Hadoop环境下运行。 - **C++**:用于加速代码执行速度。 - **R**:适合...

    浅谈JAVA如何生成UUID唯一标识

    UUID 唯一标识在 JAVA 中的生成和应用非常广泛,通过 UUID,可以使分布式系统中的所有元素都能有唯一的辨识资讯,而不需要透过中央控制端来做辨识资讯的指定。同时,UUID 也可以作为数据库数据表主键,保证每次生成...

    大数据浅谈.pdf

    Hadoop是一个用Java编写的开源分布式计算平台,针对大数据存储和处理的两个核心问题,提供了HDFS和MapReduce两大核心组件。HDFS是分布式文件存储系统,适合存储大量数据,具有高吞吐量、容错性和可伸缩性,能够支持...

    浅谈guanyu中间件

    - **云计算**:作为云服务的基础设施,支持云存储、计算等功能。 ### 结语 中间件作为软件产业的重要组成部分,其发展对于信息技术的进步具有重要意义。随着技术的不断进步和社会需求的变化,中间件也在不断地演进...

    浅谈R语言在大数据处理中的运用.docx

    Hadoop是一个分布式计算框架,主要由HDFS(Hadoop Distributed File System)和MapReduce两部分组成。HDFS提供大规模数据存储,MapReduce则负责数据的并行处理。当面对海量数据时,Hadoop可以将任务拆分成多个子任务...

    浅谈云计算技术对软件开发的影响.pdf

    在云平台上,软件可以通过云服务来部署,实现了分布式处理,大大提高了资源的利用率和灵活性。通过云计算,软件开发不再局限于特定的硬件和位置,可以在任何时间、任何地点进行开发工作。 2. 开发工具的影响 传统...

    浅谈云计算开发服务平台的设计与实现.pdf

    以上知识点展示了云计算开发服务平台在构建过程中涉及的关键技术和组件,包括但不限于PaaS架构、开源框架的应用、分布式存储与计算、以及部署和安全配置等多个方面。通过了解和掌握这些知识点,可以更好地进行云计算...

    对大数据的透彻理解.zip

    除了Hadoop和Spark,Java还与其他大数据技术如Cassandra(分布式NoSQL数据库)、Hive(基于Hadoop的数据仓库工具)、Pig(用于Hadoop的高级数据分析工具)等紧密集成,提供了一整套完整的数据处理解决方案。...

    浅谈大数据技术在招聘岗位分析中的应用.pdf

    利用WebMagic技术,可以开发出高效的Java爬虫,用于采集互联网上的招聘岗位信息。这些信息采集完毕后,会经过处理转化为CSV格式,以便于存储到HDFS中。HDFS支持超大文件的分布式存储,能够将数据存储在不同的服务器...

    浅谈DataFrame和SparkSql取值误区

    2. Spark SQL执行查询后返回的也是一个DataFrame,不是具体的Java对象。需要配合Action操作来触发实际的数据处理。 3. 在使用DataFrame API或Spark SQL时,必须确保使用了至少一个Action操作来触发前面定义的所有...

    浅谈Mysql、SqlServer、Oracle三大数据库的区别

    然而,SQL Server的开放性较差,因为它仅限于Windows操作系统,这可能影响其在大规模分布式环境中的稳定性和可伸缩性。在安全性上,SQL Server没有获得特定的安全认证,而且在多用户环境下性能可能下降。此外,SQL ...

    淘宝技术嘉年华.part1.rar

    另外,《iOS界面设计浅谈-blacksnail.rar》关注的是移动端用户体验设计。在iOS平台上,良好的界面设计对于提升用户满意度至关重要。文件可能涵盖了设计原则、人机交互、色彩和排版等方面,以及如何利用Apple的设计...

    网络存储技术结课报告.docx

    1.2 **淘宝网浅谈**: - **个人网站**:淘宝网早期以个人店铺形式存在,依赖简单的网页技术。 - **Java时代**:随着业务扩张,淘宝采用了Java技术构建复杂的服务体系,提升系统稳定性。 - **创造技术**:淘宝不断...

    VC与Labview、Matlab编程论文资料[2].rar

    Java可视化集成开发环境的研究与实现.pdf Java调用VC_DLL实现串口GPS的访问.pdf LabVIEW_快速构建步进电机控制系统的利器.pdf LabVIEW下普通数据采集卡的驱动与调用.pdf LabVIEW下远程虚拟实验室的研究与实现....

    VC与Labview、Matlab编程论文资料

    Java可视化集成开发环境的研究与实现.pdf Java调用VC_DLL实现串口GPS的访问.pdf LabVIEW_快速构建步进电机控制系统的利器.pdf LabVIEW下普通数据采集卡的驱动与调用.pdf LabVIEW下远程虚拟实验室的研究与实现....

    VC与Labview、Matlab编程论文资料[4].rar

    Java可视化集成开发环境的研究与实现.pdf Java调用VC_DLL实现串口GPS的访问.pdf LabVIEW_快速构建步进电机控制系统的利器.pdf LabVIEW下普通数据采集卡的驱动与调用.pdf LabVIEW下远程虚拟实验室的研究与实现....

Global site tag (gtag.js) - Google Analytics