Java RMI（远程方法调用）开发

参考

https://docs.oracle.com/javase/7/docs/platform/rmi/spec/rmi-arch2.html

http://www.cnblogs.com/wxisme/p/5296441.html

http://blog.****.net/qb2049_xg/article/details/3278672

http://classfoo.com/ccby/article/p1wgbVn

http://www.cnblogs.com/yin-jingyu/archive/2012/06/14/2549361.html

RMI与RPC

RMI在我看来更像Java专属的RPC，或者说纯面向对象的RPC。跟RPC一样是分布式非常重要的内容，也是Java消息中间件的基础。

RMI原理

本质就是在两处同步一个Java对象（可以基于 JDK 本身的对象序列化或者基于 HTTP 协议的数据序列化）A 和 A!，但其中一个Java对象A进行方法调用时，通过RMI的代理能力转发给另一个Java对象A!进行执行，并将A!的执行结果作为A的执行结果。这样就实现了，运算流程的分布式计算。一般这两个对象存在于两台机器上。

1. 将可以远程调用的对象进行序列化，然后绑定到RMI Server（被调方，运行者）中作为存根（stub）
2. RMI Client 会先去下载stub反序列化然后发起client调用，RMI 底层（RMI Interface Layer & Transport Layer）会讲请求参数封装发送到RMI Server
3. RMI Server 接收到封装的参数，传递给桩（skeleton），由桩解析参数并且以参数调用对应的存根（）stub方法。
4. 存根方法在RMI Server执行完毕之后，返回结果将被RMI底层封装并传输给RMI Client（也就是主调方，调用者）

目前的Java版本已经不需要创建skeleton，也不需要rmic来编译stub了，但是我学习的时候还是使用的rmic编译的stub，所以示例也是这样做的。

RMI Server编写

编写RMI Server Interface，这个也会被用在客户端（RMI Client），供客户端使用。列出了开放远程调用的接口

 package org.lyh.server;

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

 /**
  * Created by lvyahui on 2016/4/22.
  */
 public interface ITimeServer extends Remote {
     long getServerTime() throws RemoteException;
     int add(int a,int b) throws RemoteException;
 }

编写时间Server 接口

 package org.lyh.server.impl;

 import org.lyh.server.ITimeServer;

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

 /**
  * Created by lvyahui on 2016/4/22.
  */
 public class TimeServer extends UnicastRemoteObject implements ITimeServer {

     public TimeServer(int port) throws RemoteException {
         super(port);
     }

     public TimeServer() throws RemoteException {
     }

     public TimeServer(int port, RMIClientSocketFactory csf, RMIServerSocketFactory ssf) throws RemoteException {
         super(port, csf, ssf);
     }

     @Override
     public long getServerTime() throws RemoteException {
         return System.currentTimeMillis();
     }

     @Override
     public int add(int a, int b) throws RemoteException {
         return a + b;
     }
 }

将编写好的Server实现对象绑定到Java RMI的名字服务上

 package org.lyh;

 import org.lyh.server.impl.TimeServer;

 import java.net.MalformedURLException;
 import java.rmi.Naming;
 import java.rmi.RemoteException;

 public class Main {
     public static void main(String[] args) {
         try {
             TimeServer timeServer = new TimeServer();
             /* 绑定到JVM 的 RMI Server上*/
 //            Naming.bind("t1",timeServer);
 //            Naming.rebind("t1",timeServer);
             /* 当RMI注册server是指定了端口时或者不在本机运行时，需要这样写*/
             Naming.rebind("//localhost/t1",timeServer);
             System.out.println("Bind is Finish");
         } catch (RemoteException e) {
             e.printStackTrace();
         } catch (MalformedURLException e) {
             e.printStackTrace();
         }
     }
 }

这时，要用rmic进一步编译TimeServer.class文件，得到TimeServer_stub.class 存根对象文件。如果不用rmic编译的方式，也可以通过写代码的方式获取stub。

因为我是使用IDEA开发的，所以我进入了RMI\out\production\RMI目录编译，执行rmic org.lyh.server.impl.TimeServer

、

这样会在相同目录下生成TimeServer_stub.class 文件

然后启动RMI名字注册服务，执行 rmiregistry 命令（jdk\bin下的一个脚本）,可以执行 rmiregistry port执行端口，否则默认就是1099

下面可以执行org.lyh.Main@main方法了，将存根绑定（注册）到RMI 名字服务上，名字为t1

RMI Client编写

RMI client就简单了，拉取存根，然后发起调用，调用被传输到Server执行，并获取到执行结果，返回结果直接由接口方法return得到。

 package org.lyh.client;

 import org.lyh.server.ITimeServer;

 import java.net.MalformedURLException;
 import java.rmi.Naming;
 import java.rmi.NotBoundException;
 import java.rmi.RemoteException;

 /**
  * Created by lvyahui on 2016/4/22.
  */
 public class TimeClient {
     public static void main(String[] args) {
         try {
            ITimeServer iTimeServer = (ITimeServer) Naming.lookup("rmi://192.168.18.1/t1");
             System.out.println(iTimeServer.getServerTime());
             System.out.println(iTimeServer.add(3,7));
         } catch (NotBoundException e) {
             e.printStackTrace();
         } catch (MalformedURLException e) {
             e.printStackTrace();
         } catch (RemoteException e) {
             e.printStackTrace();
         }
     }
 }

为了更加真实，我将这个Client上传到虚拟机上编译运行