美文网首页
代理模式的变体:JAVA RMI(Remote Method I

代理模式的变体:JAVA RMI(Remote Method I

作者: 爱撸码的zhu | 来源:发表于2020-03-11 20:11 被阅读0次

今天我们来介绍一下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上真正的服务。

上面的只是JDK1.5之前的一些用法,让大家理解它的作用,1.5以后的版本RMI会结合动态代理搭配使用,动态代理产生stub。

相关文章

网友评论

      本文标题:代理模式的变体:JAVA RMI(Remote Method I

      本文链接:https://www.haomeiwen.com/subject/fhmddhtx.html