RMI原理及实现

1 简介

远程调用就象将一个class放在A机器上，然后在B机器中调用这个class的方法

在RMI中，程序的所有部分都由Java编写

2 概念

如果机器A要调用机器B上的方法，则机器B必须将该对象导出到其远程注册服务器。注册服务器是服务器上运行的一种服务，它帮助客户端远程地查找和访问服务器上的对象

RMI需要使用占位程序和框架，占位程序在客户端，框架在服务器端

占位程序就象客户端机器上的一个本机对象，它就象服务器上的对象的代理，向客户端提供能够被服务器调用的方法

Stub和Skeleton之间通过远程调用层进行相互通讯，远程调用层遵循TCP/IP协议收发数据

在服务器端，我们将一个字符串变量与一个对象联系在一起（可以通过方法来实现），客户端通过将那个字符串传递给服务器来告诉服务器它要创建的对象，这样服务器就可以准确地知道客户端需要使用哪一个对象了

3 实现

只要一个类extends了java.rmi.Remote接口，即可成为存在于服务器端的远程对象，供客户端访问并提供一定的服务

任何远程对象都必须直接或间接实现此接口。只有在“远程接口”（扩展 java.rmi.Remote 的接口）中指定的这些方法才可远程使用

注意：extends了Remote接口的类或者其他接口中的方法若是声明抛出了RemoteException异常，则表明该方法可被客户端远程访问调用

远程对象必须实现java.rmi.server.UniCastRemoteObject类

该远程对象将会把自身的一个拷贝以Socket的形式传输给客户端，此时客户端所获得的这个拷贝称为“存根”，而服务器端本身已存在的远程对象则称之为“骨架”

package com.king.rmi;

import java.rmi.Remote;
import java.rmi.RemoteException;

public interface IService extends Remote {
//声明服务器端必须提供的服务
String service(String content) throws RemoteException;
}

package com.king.rmi;

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;

// UnicastRemoteObject用于导出的远程对象和获得与该远程对象通信的存根。
public class ServiceImpl extends UnicastRemoteObject implements IService {

private String name;

public ServiceImpl(String name) throws RemoteException {
this.name = name;
}

@Override
public String service(String content) {
return "server >> " + content;
}
}

package com.king.rmi;

import java.rmi.Naming;
import java.rmi.registry.LocateRegistry;

public class Server {
public static void main(String[] args) {
try {
// 实例化实现了IService接口的远程服务ServiceImpl对象
IService service02 = new ServiceImpl("service02");

// 本地主机上的远程对象注册表Registry的实例，并指定端口为8888，这一步必不可少（Java默认端口是1099），必不可缺的一步，缺少注册表创建，则无法绑定对象到远程注册表上
LocateRegistry.createRegistry(8888);

// 把远程对象注册到RMI注册服务器上，并命名为service02
//绑定的URL标准格式为：rmi://host:port/name(其中协议名可以省略，下面两种写法都是正确的）
Naming.bind("rmi://localhost:8888/service02",service02);
} catch (Exception e) {
e.printStackTrace();
}

System.out.println("服务器向命名表注册了1个远程服务对象！");
}
}

package com.king.rmi;

import java.rmi.Naming;

public class Client {
public static void main(String[] args) {
String url = "rmi://localhost:8888/";
try {
// 在RMI服务注册表中查找名称为service02的对象，并调用其上的方法
IService service02 =(IService) Naming.lookup(url + "service02");

Class stubClass = service02.getClass();
System.out.println(service02 + " 是 " + stubClass.getName() + " 的实例！");
// 获得本底存根已实现的接口类型
Class[] interfaces = stubClass.getInterfaces();
for (Class c : interfaces) {
System.out.println("存根类实现了 " + c.getName() + " 接口！");
}
System.out.println(service02.service("你好！"));
} catch (Exception e) {
e.printStackTrace();
}
}
}