今天我们来介绍一下JAVA RMI,大家或许之前从来没听说过这个词,但是如果你用过dubbo、spring cloud等分布式服务治理框架,理解起来RMI是很轻松的,因为它们的概念是差不多的,只不过使用的底层协议不同。
一般情况下,在我们本地一个类在调用另一个类的方法时,调用方与被调用方都是在同一个堆上的。
如果要从服务器A调用服务器B的方法是办不到的,因为它们在两个不同的堆上,JVM虚拟机只能控制自己堆上面的引用地址应该如何传递的。
如果想调用不同的服务器上面的方法,要怎么办?如何设计?
下面我们来介绍一下,JAVA RMI是个啥,它是如何实现不同堆上的调用?
JAVA RMI(Remote Method Invocation):大致字面的意思就是执行远程服务器方法。
想要利用RMI实现远程调用,需要创建四个关键对象:
客服端、客户端辅助对象、服务端辅助对象、服务端。
.客户端:调用远程服务对象。
.服务端:带有客户端会调用的方法的对象。
.客户端辅助对象(stub):处理客户端的低层网络输出字节,连接远程服务端。
.服务端辅助对象(seleton):处理服务端的低层网络输入字节,连接远程客户端。
辅助对象实际上就是通信对象,没有任何的方法逻辑。
先简单描述一下调用方法的过程:
1.客户端对象对客户端辅助对象(stub)调用dothing()
2.客户端辅助对象把调用信息打包(序列化)通过网络送到服务器的服务端打辅助对象。
3.服务端辅助对象反序列化得到客户端辅助对象的信息,并以此调用真正的服务。
如何利用代码创建远程服务
1.创建Remote接口:
import java.rmi.Remote;
import java.rmi.RemoteException;
/**
* @Author:zhangyanan
* @Description: 定义远程服务接口
* @Date:Crated in 19:22 2020/3/11
* @Modified By:
*/
public interface MyRemote extends Remote {
/**
* 每个远程调用都被认为是有风险的,这样声明会强迫客户端注意到这件事
*
* @return
* @throws RemoteException
*/
String sayHello() throws RemoteException;
}
上面定义接口需要注意的是:
(1)任何远程方法的参数都会被打包通过网络传送,而这是需要序列化完成的。
(2)如果返回的是自定义类型需要自定义类实现serialzable接口。
2.实现Remote远程服务接口:
import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;
/**
* @Author:zhangyanan
* @Description: 远程服务端真实的服务实现
* @Date:Crated in 19:26 2020/3/11
* @Modified By:
*/
public class MyRemoteImpl extends UnicastRemoteObject implements MyRemote {
protected MyRemoteImpl() throws RemoteException {
}
@Override
public String sayHello() throws RemoteException {
return null;
}
//下面的main函数是为了向注册中心注册服务,以便客户端可以查找到远程服务并调用
public static void main(String[] args) {
try {
MyRemote service = new MyRemoteImpl();
Naming.rebind("Remote Hello",service);
} catch (RemoteException e) {
e.printStackTrace();
} catch (MalformedURLException e) {
e.printStackTrace();
}
}
}
(1)实现MyRemote,就是给客户端要调用的方法。
(2)继承UnicastRemoteObject类,为了要成为远程服务对象,你的类必须要有与远程有关的功能。其中最简单的方式就是继承UnicastRemoteObject,让它来处理远程连接这些工作。
(3)编写声明RemoteException无参构造函数:因为父类UnicastRemoteObject构造方法定义了异常,所以当类初始化的时候一定会被调用,如果父类抛出异常,那么子类也要声明构造函数可能会抛出异常。
3.利用JDK工具rmic产生stub和skeleton:
打开命令窗口,对远程服务实现类执行rmic:
rmic MyRemoteImpl
此时会生成MyRemoteImpl_Stub.class和MyRemoteImpl_skel.class两个辅助类class,它们是用于连接客户端和服务端的。
4.启动RMI registry(注册服务):
打开命令窗口,执行:
rmiregistry
意思是:打开了一个注册中心,类似于电话号码本,用于记录服务的地址,方便客户端查找服务。
5.启动远程服务:
java MyRemoteImpl
此操作会执行MyRemoteImpl类中的mian函数,使用rebind方法向注册中心注册服务。
以上就是服务端要做的事情。
下面我们来说一下客户端该如何调用服务:
public class Test {
public static void main(String[] args) {
try {
MyRemote myRemote = (MyRemote) Naming.lookup("rmi://127.0.0.1/Remote Hello");
} catch (NotBoundException e) {
e.printStackTrace();
} catch (MalformedURLException e) {
e.printStackTrace();
} catch (RemoteException e) {
e.printStackTrace();
}
}
}
1.客户端查询服务:
利用Naming.lookup()方法去registry(注册中心)寻找要调用的远程服务,客户端就像搜电话本一样,找出上面名称相符的名称的服务。
2.RMI registry返回stub对象,它不是真实的服务,是真实服务的代理,此对象没有任何的方法逻辑。它会将调用的信息传递过去(像是方法的名称和参数内容),等待服务器响应然后再返回到客户端。
3.客户端就像取用真正的服务一样的调用stub上的方法。
需要注意的是:
(1)客户端在查询服务的时候必须要有stub类(MyRemoteImpl_Stub.class),不然无法在客户端反序列化。
(2)服务端也必须同时要有stub类和seleton类,它会需要stub类是因为stub会被代换成连接在RMIregistry上真正的服务。