文章目录
Java RMI
背景
当不同JVM之间需要互相调用的时候,如何让JVMA中调用JVMB中的方法像在本地一样,这就出现了RMI-Remote Method Invoke
不同的JVM既可以指同一机器上的不同的JVM,也可以值不同机器上的JVM
基本原理
至于什么存根、骨架这些,我觉得很难让人记住并且这两个词也不容易望文生义,所以这里借助目前流行的微服务的概念说一下。
如果对微服务有所了解的,RMI的调用过程其实和它很类似。
- 需要有一个注册中心-RMI Registry。这里面保存着提供远程服务的名字和具体的实现类
- 服务端需要提供能够进行远程调用的接口
- 服务端同时需要对上述接口进行实现
- 客户端通过在RMI Registry中查找所需要的服务的名字,获得其实例,进行远程调用
如果真的想要了解其中的各种细节,强烈推荐阅读Head First 设计模式一书中的代理模式章节,里面生动详细介绍了RMI的基本原理和细节
示例
服务端提供远程调用的接口
- 继承Remote接口
- 提供远程服务的方法需要抛出 RemoteException
public interface RmiServerInterface extends Remote {
/**
* 所有提供RMI的方法,都要抛出RemoteException,否则会报
* Exception "remote object implements illegal remote interface"?
* 错误
* @return
* @throws RemoteException
*/
String sayHello() throws RemoteException;
}
服务端实现远程接口
- 继承UnicastRemoteObject
- 无参构造方法抛出RemoteException
public class RmiInterfaceImpl extends UnicastRemoteObject implements RmiServerInterface{
public RmiInterfaceImpl() throws RemoteException{
}
@Override
public String sayHello() {
return "hello, I'm Remote JVM Server";
}
}
注册中心
public class Server {
public static void main(String[] args) throws RemoteException {
// 启动注册中心
Registry registry = LocateRegistry.createRegistry(2001);
try {
// 绑定服务
registry.bind("hello", new RmiInterfaceImpl());
System.err.println("Server ready");
} catch (AlreadyBoundException e) {
System.out.println("Server bind fail" + e.getMessage());
}
}
}
客户端进行远程调用
- 直接在RMI Registry中进行查找
public class RmiClient {
public static void main(String[] args) {
try {
// 查找名字必须为在注册中心注册的名字
RmiServerInterface hello = (RmiServerInterface) Naming.lookup("rmi://localhost:2001/hello");
System.out.println("接收到服务器端的接口的返回信息是: " + hello.sayHello() +" "+ hello.getClass().getName());
} catch (RemoteException | NotBoundException | MalformedURLException e) {
System.out.println("Connect Server fail"+ e.getMessage());
}
}
}
验证
- 启动RMI Registry
- 启动客户端,观察打印信息,可以发现客户端拿到的类其实是一个代理类
其他
- 如果服务端返回的是一个类,那么该类必须实现序列化接口,因为设计网络传输、IO。所以必须实现序列化接口
- 代码仓库
- 由RMI可以想到RPC,那么二者之间的关系如何呢?个人认为,RMI属于RPC的子集,RMI是RPC针对Java语言以及对象特性的定制化开发,使得Java开发者非常方便的在不同的JVM之间进行调用
官方文档
说明:按照官方文档进行编码,总是在设置codebase那里有问题