设计远程接口

原文: https://docs.oracle.com/javase/tutorial/rmi/designing.html

计算引擎的核心是一个协议,它允许将任务提交给计算引擎,计算引擎运行这些任务,以及将这些任务的结果返回给客户端。此协议在计算引擎支持的接口中表示。该协议的远程通信如下图所示。

remote communication between a client and the compute engine

每个接口都包含一个方法。计算引擎的远程接口Compute允许将任务提交给引擎。客户端接口Task,定义计算引擎如何执行提交的任务。

compute.Compute 接口定义了远程可访问的部分,即计算引擎本身。这是Compute接口的源代码:

  1. package compute;
  2. import java.rmi.Remote;
  3. import java.rmi.RemoteException;
  4. public interface Compute extends Remote {
  5. <T> T executeTask(Task<T> t) throws RemoteException;
  6. }

通过扩展接口java.rmi.RemoteCompute接口将自身标识为可以从另一个 Java 虚拟机调用其方法的接口。实现此接口的任何对象都可以是远程对象。

作为远程接口的成员,executeTask方法是一种远程方法。因此,必须将此方法定义为能够抛出java.rmi.RemoteException。 RMI 系统从远程方法调用抛出此异常,以指示发生了通信故障或协议错误。 RemoteException是一个已检查的异常,因此任何调用远程方法的代码都需要通过捕获它或在其throws子句中声明它来处理此异常。

计算引擎所需的第二个接口是Task接口,它是Compute接口中executeTask方法的参数类型。 compute.Task 接口定义了计算引擎与其需要完成的工作之间的接口,提供了启动工作的方法。这是Task接口的源代码:

  1. package compute;
  2. public interface Task<T> {
  3. T execute();
  4. }

Task接口定义了一个方法execute,它没有参数,也没有抛出异常。由于接口不扩展Remote,因此该接口中的方法不需要在其throws子句中列出java.rmi.RemoteException

Task接口有一个类型参数T,它表示任务计算的结果类型。该接口的execute方法返回计算结果,因此其返回类型为T

反过来,Compute接口的executeTask方法返回传递给它的Task实例的执行结果。因此,executeTask方法有自己的类型参数T,它将自己的返回类型与传递的Task实例的结果类型相关联。

RMI 使用 Java 对象序列化机制在 Java 虚拟机之间按值传输对象。对于要被视为可序列化的对象,其类必须实现java.io.Serializable标记接口。因此,实现Task接口的类也必须实现Serializable,用于任务结果的对象类也必须如此。

只要它们是Task类型的实现,Compute对象就可以运行不同类型的任务。实现此接口的类可以包含计算任务所需的任何数据以及计算所需的任何其他方法。

以下是 RMI 如何使这个简单的计算引擎成为可能。因为 RMI 可以假设Task对象是用 Java 编程语言编写的,所以计算引擎以前不知道的Task对象的实现会根据需要由 RMI 下载到计算引擎的 Java 虚拟机中。此功能使计算引擎的客户端能够定义要在服务器计算机上运行的新类型的任务,而无需在该计算机上显式安装代码。

ComputeEngine类实现的计算引擎实现Compute接口,通过调用其executeTask方法使不同的任务能够提交给它。使用任务的execute方法实现运行这些任务,并将结果返回给远程客户端。