Java RPC通信机制之RMI

以下文字摘自:http://blog.csdn.net/billdavid/archive/2006/08/18/1095706.aspx

大卫注1：<o:p></o:p>

写完CORBA系列后，本想接着写写其它几种典型的远程通信协议：RMI、XML-RPC、SOAP，但由于工作的原因，加之房子装修等麻烦事，一直没有心情动笔。今天接到装修公司老板电话说开工证要晚几天办下来，要停工4-5天，狂怒后突然有了静下心来完成原本想写的东西的想法，既来之，则安之（i.e.郁闷啊，郁闷啊，就习惯了...）<o:p></o:p>

大卫注2：<o:p></o:p>

这个系列基本上是一份笔记，没有加入太多我自己的东西，仅仅记录了自己在使用过程中遇到的问题，及其解决办法。<o:p></o:p>

 <o:p></o:p>

在传统的RPC编程接口逐渐淡出人们视线的同时，新的、更便于使用且附加了更多特性的RPC编程接口也不断涌现，CORBA作为分布式对象计算技术的典范，在很长一段时间内极大地吸引了大家的注意，但是由于CORBA规范试图覆盖过多的内容，使得CORBA显得过于复杂，也极大地限制了CORBA的应用范围，本系列将向大家介绍几种轻量级的，更适于在Java开发中使用的RPC编程接口：RMI、XML-RPC、SOAP。<o:p></o:p>

RMI（Remote Method Invocation）

与本系列将介绍的其它两种RPC编程接口不同，RMI（Remote Method Invocation）显得有些老旧，它是在Java-IDL加入J2SE之前被引入的。RMI开发流程与CORBA如出一辙（从出现的时间上无法确定RMI是否是按照CORBA规范定制的），因此，其开发过程相对比较烦琐，但是由于RMI是EJB的基础，因此，它在Java开发中具有十分重要的地位。<o:p></o:p>

以下是创建远程方法调用的5个步骤：<o:p></o:p>

1.   定义一个扩展了Remote接口的接口，该接口中的每一个方法必须声明它将产生一个RemoteException异常；<o:p></o:p>

2.   定义一个实现该接口的类；<o:p></o:p>

3.   使用rmic程序生成远程实现所需的存根和框架；<o:p></o:p>

4.   创建一个客户程序和服务器进行RMI调用；<o:p></o:p>

5.   启动rmiregistry并运行自己的服务程序和客户程序。<o:p></o:p>

下面举一个简单、而且被无数次引用的例子：Echo。<o:p></o:p>

1、定义Echo接口

//Echo.java<o:p></o:p>

//The Echo remote interface<o:p></o:p>

package demo.rmi;<o:p></o:p>

 <o:p></o:p>

import java.rmi.*;<o:p></o:p>

 <o:p></o:p>

public interface Echo extends Remote {<o:p></o:p>

      String echo(String msg) throws RemoteException;<o:p></o:p>

}<o:p></o:p>

2、实现Echo接口

//EchoServer.java<o:p></o:p>

//The implementation of the Echo remote object<o:p></o:p>

package demo.rmi;<o:p></o:p>

 <o:p></o:p>

import java.net.*;<o:p></o:p>

import java.rmi.*;<o:p></o:p>

import java.rmi.registry.*;<o:p></o:p>

import java.rmi.server.*;<o:p></o:p>

 <o:p></o:p>

public class EchoServer<o:p></o:p>

      extends UnicastRemoteObject<o:p></o:p>

      implements Echo {<o:p></o:p>

       //默认构件器，也要“掷”出RemoteException违例<o:p></o:p>

      public EchoServer() throws RemoteException {<o:p></o:p>

            super();<o:p></o:p>

      }<o:p></o:p>

 <o:p></o:p>

      public String echo(String msg) throws RemoteException {<o:p></o:p>

            return "Echo: " + msg;<o:p></o:p>

      }<o:p></o:p>

 <o:p></o:p>

      public static void main(String [] args) {<o:p></o:p>

            /*创建和安装一个安全管理器，令其支持RMI。作为Java开发包的一部分，适用于RMI唯一一个是RMISecurityManager.*/<o:p></o:p>

            System.setSecurityManager(new RMISecurityManager());<o:p></o:p>

 <o:p></o:p>

            try {<o:p></o:p>

                     /*创建远程对象的一个或多个实例，下面是EchoServer对象*/<o:p></o:p>

                  EchoServer es = new EchoServer();<o:p></o:p>

                  /*向RMI远程对象注册表注册至少一个远程对象。一个远程对象拥有的方法即可生成指向其他远程对象的句柄，这样，客户到注册表里访问一次，得到第一个远程对象即可.*/<o:p></o:p>

                  Naming.rebind("EchoServer", es);<o:p></o:p>

                  System.out.println("Ready to provide echo service...");<o:p></o:p>

            } catch (Exception e) {<o:p></o:p>

                  e.printStackTrace();<o:p></o:p>

            }<o:p></o:p>

      }<o:p></o:p>

}<o:p></o:p>

这个实现类使用了UnicastRemoteObject去连接RMI系统。在我们的例子中，我们是直接的从UnicastRemoteObject这个类上继承的，事实上并不一定要这样做，如果一个类不是从UnicastRmeoteObject上继承，那必须使用它的exportObject()方法去连接到RMI。（否则，运行时将被告知无法序列化。）<o:p></o:p>

如果一个类继承自UnicastRemoteObject，那么它必须提供一个构造函数并且声明抛出一个RemoteException对象（否则，会遇到编译错误）。当这个构造函数调用了super()，它就激活UnicastRemoteObject中的代码完成RMI的连接和远程对象的初始化。<o:p></o:p>

3、运行rmic编译实现类，产生_Stub类

在demo.rmi.EchoServer.java上级目录下运行如下命令：<o:p></o:p>

rmic demo.rmi.EchoServer<o:p></o:p>

4、编写客户程序

//EchoClient.java<o:p></o:p>

//Uses remote object EchoServer<o:p></o:p>

package demo.rmi;<o:p></o:p>

 <o:p></o:p>

import java.rmi.*;<o:p></o:p>

import java.rmi.registry.*;<o:p></o:p>

 <o:p></o:p>

public class EchoClient {<o:p></o:p>

      public static void main(String [] args) {<o:p></o:p>

            System.setSecurityManager(new RMISecurityManager());<o:p></o:p>

 <o:p></o:p>

            try {<o:p></o:p>

                  Echo t = (Echo)Naming.lookup("EchoServer");<o:p></o:p>

 <o:p></o:p>

                  for (int i = 0; i < 10; i++) {<o:p></o:p>

                        System.out.println(t.echo(String.valueOf(i)));<o:p></o:p>

                  }<o:p></o:p>

            } catch (Exception e) {<o:p></o:p>

                  e.printStackTrace();<o:p></o:p>

            }<o:p></o:p>

      }<o:p></o:p>

}<o:p></o:p>

5、运行

编码的工作就只有这些，现在可以依次启动rmiregistry（启动rmiregistry时可以附加一个端口，一般使用默认的端口1099即可，这是默认的Naming Service运行端口）、EchoServer、EchoClient了。但是，虽然有些RMI的资料没有提到，但你运行时不可避免会遇到如下两个错误：<o:p></o:p>

1）java.security.AccessControlException: access denied (java.net.SocketPermission 127.0.0.1:1099 connect,resolve)<o:p></o:p>

原因很简单，RMI Server/Client程序试图通过Socket连接访问本机的rmiregistry服务（即RMI的Naming Service，其运行的默认端口是1099）。要解决这个问题，可以在运行Server/Client时指定一个Policy文件（关于Policy的更多信息，见参考2），如下：<o:p></o:p>

java -Djava.security.policy=demo/rmi/policyfile.txt demo.rmi.EchoServer<o:p></o:p>

Policy文件的内容为：<o:p></o:p>

grant{<o:p></o:p>

      permission java.net.SocketPermission "localhost:1099", "connect, resolve";<o:p></o:p>

};<o:p></o:p>

即允许访问本机的1099端口。<o:p></o:p>

或者干脆来个彻底开放：<o:p></o:p>

grant {<o:p></o:p>

      permission java.security.AllPermission "", "";<o:p></o:p>

};<o:p></o:p>

2）java.rmi.ServerException: RemoteException occurred in server thread; nested exception is:<o:p></o:p>

        java.rmi.UnmarshalException: error unmarshalling arguments; nested exception is:<o:p></o:p>

        java.lang.ClassNotFoundException: demo.rmi.EchoServer_Stub<o:p></o:p>

        ...<o:p></o:p>

如果你凑巧用启动rmiregistry的终端窗口启动了EchoServer，那么你很走运，你看不到上面的错误，但如果你不是在看完这篇文章后就再也用不到RMI，那么，这个错误在那里等着你，:)。<o:p></o:p>

错误很明显，rmiregistry找不到与EchoServer放在同一目录下的EchoServer_Stub，因为package所在demo.rmi目录的上级目录不在rmiregistry的classpath中，这个问题有两种解决方案：<o:p></o:p>

a）在启动rmiregistry前先调整一下CLASSPATH环境变量，以目录E:\为例，执行：<o:p></o:p>

set CLASSPATH=%CLASSPATH%;E:\<o:p></o:p>

b）修改code，在EchoServer中通过如下代码：<o:p></o:p>

Registry r = LocateRegistry.createRegistry(8111);<o:p></o:p>

r.rebind("EchoServer", es);<o:p></o:p>

在程序内部创建一个LocateRegistry，并将自身注册到该LocateRegistry，其中的数值8111表示LocateRegistry运行的端口。<o:p></o:p>

同样，对于客户程序，也需要作相应的调整：<o:p></o:p>

Registry r = LocateRegistry.getRegistry("localhost", 8111);<o:p></o:p>

Echo e = (Echo)r.lookup("EchoServer");<o:p></o:p>

而不是像上面例子中一样访问Naming类的static方法来访问默认的rmiregistry服务。<o:p></o:p>

参考：

1.      Java RMI Tutorial, http://www.ccs.neu.edu/home/kenb/com3337/rmi_tut.html<o:p></o:p>

2.      Policy Tool - Policy File Creation and Management Tool. http://java.sun.com/j2se/1.4.2/docs/tooldocs/windows/policytool.html<o:p></o:p>

3.     Java RMI入门实战，http://www.huihoo.com/java/rmi/index.html