没人比我更懂RMI(上)

前言

参考文章1

参考文章2

每篇鸡汤：

万事开头难，当走出第一步你会发现，其实事情并没有你想象的那么糟糕

文章可能稍微有点长，一定要耐心看完 o.0

RMI概念

本来想把官方对RMI的概念贴在开头的，突然想了想开头就整臭长臭长的文字，谁顶得住。其实总的来说用一句话就可以概括。

——RMI就是负责远程调用对象的。

既然提到了远程调用对象，肯定不是调用自己本地的对象。先给大家举个生活中的例子渗透一下概念：

比如你在北京上学，你女神在西安，并且你想通过发送信息给女神告白。

你想告白，得通过手机发送信息（相当于调用远程方法;但是调用方法之前会先创建Stub(sun.rmi.registry.RegistryImpl_Stub)）这个stub就相当于你的手机；也就是说，你并不能直接面对面告诉女神，而手机只是你传递信息的一种媒介，相当于是一个代理。
然后你给女神里发了个信息，在你刚呼出的一瞬间，手机会将你的呼出信号交给三大运营商（相当于stub会将Remote对象传递给远程引用层(java.rmi.server.RemoteRef)并创建java.rmi.server.RemoteCall(远程调用)对象。）三大运营商会帮你找到你的女神。
运营商在收到你的信号后会将你这个呼出的动作转换成其他形式的信号进行传输（RemoteCall序列化RMI服务名称、Remote对象。）
然后运营商通过自己架设的线路进行通信（RMI客户端的远程引用层传输RemoteCall序列化后的请求信息通过Socket连接的方式传输到RMI服务端的远程引用层。）
在找到对方之后，对方手机会立刻响铃（RMI服务端的远程引用层(sun.rmi.server.UnicastServerRef)收到请求会请求传递给Skeleton(sun.rmi.registry.RegistryImpl_Skel#dispatch)；这个Skeleton就相当于女神的手机）
此时对方手机会将之前用其他形式传输的信号，转变为人能看懂的文字（Skeleton调用RemoteCall反序列化RMI客户端传过来的序列化。）
对方查看手机(Skeleton)信息，并用手机给你进行回复：“你是个好人”（Skeleton处理客户端请求：bind、list、lookup、rebind、unbind，如果是lookup则查找RMI服务名绑定的接口对象，序列化该对象并通过RemoteCall传输到客户端。）
你收到信息，并看到是女神给你的回复，非常激动！（RMI客户端反序列化服务端结果，获取远程对象的引用）
你双击信息打开进一步查看内容（RMI客户端调用远程方法，RMI服务端反射调用RMI服务实现类的对应方法并序列化执行结果返回给客户端。）
结果看到女神送给你的“好人卡”（RMI客户端反序列化RMI远程方法调用结果。）

在代码实现之前我们还需要明白一个在RMI中扮演着重要角色的”注册中心“，他在服务端创建。

我们知道java远程对象是基于socket来进行传输的，有socket就要有端口。

举个例子：

服务端现在有一个名为A的远程对象。现在你是客户端，你并不知道服务端把这个A开放在对应的哪个端口。就算你知道了A的开放端口。服务其上还有B、C、D……..难道你要记住每个远程对象的端口吗？很明显这是不现实的。

那么这个时候，就要用到我们的注册中心。他的作用就是将自己绑定在服务端的某个端口(默认1099)这样你只需要记住一个端口，他会帮我们记住这100个远程对象对应的开放端口。当客户端进行调用的时候，只需要告诉注册中心，我要找A，那么注册中心就会告诉你A所对应的端口。有点像交换机和路由器的原理。

在了解这个重要概念以后，我们再来接着往下看RMI具体是如何实现的。

RMI具体代码实现如下：

服务端代码：

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

public interface IRemoteObj extends Remote {
    //这个接口定义着你都能调用服务端的什么方法。需要抛出 RemoteException
    public String sayHello(String keywords) throws RemoteException;
}

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

public class RemoteObjImpl extends UnicastRemoteObject implements IRemoteObj {
    public RemoteObjImpl() throws RemoteException{
        //UnicastRemoteObject.exportObject(this,0);  //如果不继承UnicastRemoteObject就需要手动导出
    }


    @Override
    public String sayHello(String keywords){
        String upKeywords = keywords.toUpperCase();
        System.out.println(upKeywords);
        return upKeywords;
    }
}

import java.rmi.AlreadyBoundException;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;

public class RMIServer {
    public static void main(String[] args) throws RemoteException, AlreadyBoundException {
        IRemoteObj remoteObj = new RemoteObjImpl(); //创建远程对象
        Registry r = LocateRegistry.createRegistry(1099); //创建注册中心
        r.bind("remoteObj",remoteObj); //绑定远程对象
        System.out.println("server is OK");
    }
}

客户端代码：

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

public interface IRemoteObj extends Remote {
    public String sayHello(String keywords) throws RemoteException;
}

/*
    是不是有点眼熟，你可能会有疑问：为什么客户端还要创建一个和服务端相同的接口？
    通过共享接口定义，RMI 框架能够在编译时进行类型检查，确保方法调用的正确性。同时，RMI 框架能够自动生成代理对象和存根对象，它们负责处理远程方法的序列化、网络传输和反序列化等细节。

*/


import java.net.MalformedURLException;
import java.rmi.Naming;
import java.rmi.NotBoundException;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;

public class RMIClient {
    public static void main(String[] args) throws RemoteException, NotBoundException, MalformedURLException {
//写法一：
        //获取注册中心
        Registry registry = LocateRegistry.getRegistry("192.168.56.1",1099);
        //查找远程对象 
        IRemoteObj remoteObj = (IRemoteObj) registry.lookup("remoteObj");
        //调用远程方法
        String out = remoteObj.sayHello("hello");
        System.out.println(out);
//写法二：
        //直接查找远程对象
        IRemoteObj remoteObj1 = (IRemoteObj) Naming.lookup("rmi://127.0.0.1:1088/remoteObj");
        //调用远程方法
        String out1 = remoteObj1.sayHello("hi");
        System.out.println(out1);
    }
}