用RMI实现基于Java的分布式计算(2)

开发企业信息发布系统实例

在开发RMI进行分布式访问之前，需要将各项功能模块化，即把实际应用抽象成符合Java规范的类和接口模型，使这些类和接口之间互相协作，能实现各自独立的功能，最后，可以把它们组合成统一的网络Java分布式计算系统。

现在，我们就以开发公司信息发布系统为例，把主模块(主要的类文件)的名称暂定为InfoDistributeService(信息发布服务)，为了保持应用开发的数据一致性和清晰度，接下来涉及的其它模块命名也将以这个模块命名为基准。

1、定义远程接口

Java RMI运行环境要求任何可以远程调用的方法必须放在远程接口中。

该远程接口用来扩展java.rmi.Remote接口，在Java API中，可以发现它没有任何方法，只是个标志性接口，这样，可以让Java运行环境（JRE）认识每个接口的特殊属性，以便能够远程访问。

因此，按照信息发布服务的命名(InfoDistributeService)，首先须将InfoDistributeRemote定义为远程接口，同时仅放入一个供测试的方法 getRemoteInfo()来实现编码，将所有模块至于新建的enterprise.distribute包中，代码如下：

　// -----------InfoDistributeRemote.java-------------------

package enterprise. distribute;

import java.rmi.Remote;

import java.rmi.RemoteException;

public interface InfoDistributeRemote extends Remote{

public String getRemoteInfo() throws RemoteException;

}

2、实现远程接口

这是一个实现远程对象的类。如果实现了远程接口，就能够覆盖(override)该对象中的所有方法，因此，远程对象的实现类将真正包含我们希望导出的方法的代码。

在远程信息发布系统中，我们至少实现一个远程接口的对象，它就是远程可访问的对象。这里，InfoDistributeService类可以为我们生成远程可访问对象的实例：

// -----------InfoDistributeService.java------------------

package enterprise. distribute;

import java.rmi.RemoteException;

import java.rmi.server.UnicastRemoteObject;

public class InfoDistributeService

extends UnicastRemoteObject implements InfoDistributeRemote{

public InfoDistributeService() throws RemoteException{

super();

}

// The return value of the method only for testing...

public String getRemoteInfo(){

return "Hello! I am a remote object.";

}

}

InfoDistributeService类实现远程接口InfoDistributeRemote，并继承java.rmi.server.UnicastRemoteObject。由于符

Java 2 Enterprise Edition（J2EE）远程方法调用（Remote Method Invocation，RMI）框架允许你创建透明的、分布式的服务和应用程序。基于RMI的应用程序由Java对象构成，这些对象相互调用，同时忽略对方的位置。换言之，一个Java对象可调用另一个虚拟机上的某个Java对象的方法，整个过程和调用同一个虚拟机上的某个Java对象的方法无异。

驻留在不同虚拟机上的对象为了相互获得引用，可以使用RMI的查找服务，或者将对象引用作为方法调用的一个参数或者返回值来接收。参数和返回值借助Java的对象序列化机制由RMI来进行封送。

远程对象和接口

Java提供了一个完全限定名称为java.rmi.Remote的接口。任何对象要想参与Java分布式计算和另一个Java对象的远程会话，就必须直接或间接地实现该接口。尤其要注意的是，任何由java.rmi.Remote接口来标识的对象都暗示着它的方法可从其他任何虚拟机进行调用。实现了java.rmi.Remote接口的对象通常称为“远程对象”，必须采用以下方式来声明它的方法：

每个支持远程调用的方法都必须在其throws子句中声明java.rmi.RemoteException。

对于一个可远程调用的方法，它的每个非基本（nonprimitive）参数或者返回值都必须直接或间接地声明为实现了java.io.Serializable接口。

除了实现java.rmi.Remote接口和正确声明任何远程方法之外，Java分布式计算中远程对象必须提供一个无参数的构造函数，它能引发一个java.rmi.RemoteException异常。这就保证了对象可基于一种序列化状态来远程构造。

远程对象必须导出，以接收传入的远程方法调用。为此，你通常需要扩展java.rmi.server.UnicastRemoteObject或者java.rmi.activation.Activatable。通过对其中任何一个类进行扩展，远程对象就可在创建时自动导出。

RMI注册表

为了获取对远程对象的引用，RMI提供了名为注册表（registry）的一个远程对象，它将名称与远程对象关联起来。RMI服务器要向注册表注册每一个远程对象，以便定位和检索对象。RMI客户端希望调用远程对象上的一个方法时，首先必须根据远程对象的名称在注册表中定位远程对象。如果远程对象存在，注册表就返回对那个对象的一个引用。然后，要使用这个引用来发出对远程对象的方法调用。

RMI服务器

RMI采取一种客户机/服务器结构进行通信。这意味着在RMI会话的某一端，必须有一个对象充当服务器，另一端的对象则充当客户端。RMI服务器负责创建每个远程对象的实例，并将每个实例和RMI注册表中的一个名称绑定起来。RMI服务器可以自主，这要求它实现一个main方法，避免必须依赖其他类才能执行。

由于RMI服务器可从几乎任何主机下载和执行代码，所以每个RMI服务器的main方法都需要安装一个安全管理器，防止它所加载的类表现失常。下例展示了如何实例化一个安全管理器，以及如何在RMI注册表中绑定一个对象实例：

import java.rmi.RMISecurityManager;

import java.rmi.Naming;

public class SimpleRMIServer

{

public static void main(String[] args)

{

if (System.getSecurityManager() == null)

{

System.setSecurityManager(new RMISecurityManager());

}

try

{

TimeKeeperImplremoteObj = new TimeKeeperImpl();

// Bind the remote object to the name "TimeKeeper"

Naming.bind("//HostName/TimeKeeper", remoteObj);

System.out.println("TimeKeeper successfully bound in registry");

}

catch (Exception e)

{

System.err.println("Error binding TimeKeeper: " + e.getMessage());

}

}

}

小结

本文简单介绍了如何用RMI来隐藏远程交互问题，使程序员能将注意力集中在其他更重要的问题上，而不必过多地考虑通信基础结构。下一篇文章将进一步探索RMI，讲解RMI客户端如何定位远程对象，并调用其上的方法。