参考
https://docs.oracle.com/javase/7/docs/platform/rmi/spec/rmi-arch2.html
http://www.cnblogs.com/wxisme/p/5296441.html
http://blog.csdn.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的执行结果。这样就实现了,运算流程的分布式计算。一般这两个对象存在于两台机器上。
- 将可以远程调用的对象进行序列化,然后绑定到RMI Server(被调方,运行者)中作为存根(stub)
- RMI Client 会先去下载stub反序列化然后发起client调用,RMI 底层(RMI Interface Layer & Transport Layer)会讲请求参数封装发送到RMI Server
- RMI Server 接收到封装的参数,传递给桩(skeleton),由桩解析参数并且以参数调用对应的存根()stub方法。
- 存根方法在RMI Server执行完毕之后,返回结果将被RMI底层封装并传输给RMI Client(也就是主调方,调用者)
目前的Java版本已经不需要创建skeleton,也不需要rmic来编译stub了,但是我学习的时候还是使用的rmic编译的stub,所以示例也是这样做的。
RMI Server编写
编写RMI Server Interface,这个也会被用在客户端(RMI Client),供客户端使用。列出了开放远程调用的接口
1 package org.lyh.server; 2 3 import java.rmi.Remote; 4 import java.rmi.RemoteException; 5 6 /** 7 * Created by lvyahui on 2016/4/22. 8 */ 9 public interface ITimeServer extends Remote { 10 long getServerTime() throws RemoteException; 11 int add(int a,int b) throws RemoteException; 12 }
编写时间Server 接口
1 package org.lyh.server.impl; 2 3 import org.lyh.server.ITimeServer; 4 5 import java.rmi.RemoteException; 6 import java.rmi.server.RMIClientSocketFactory; 7 import java.rmi.server.RMIServerSocketFactory; 8 import java.rmi.server.UnicastRemoteObject; 9 10 /** 11 * Created by lvyahui on 2016/4/22. 12 */ 13 public class TimeServer extends UnicastRemoteObject implements ITimeServer { 14 15 public TimeServer(int port) throws RemoteException { 16 super(port); 17 } 18 19 public TimeServer() throws RemoteException { 20 } 21 22 public TimeServer(int port, RMIClientSocketFactory csf, RMIServerSocketFactory ssf) throws RemoteException { 23 super(port, csf, ssf); 24 } 25 26 @Override 27 public long getServerTime() throws RemoteException { 28 return System.currentTimeMillis(); 29 } 30 31 @Override 32 public int add(int a, int b) throws RemoteException { 33 return a + b; 34 } 35 }
将编写好的Server实现对象绑定到Java RMI的名字服务上
1 package org.lyh; 2 3 import org.lyh.server.impl.TimeServer; 4 5 import java.net.MalformedURLException; 6 import java.rmi.Naming; 7 import java.rmi.RemoteException; 8 9 public class Main { 10 public static void main(String[] args) { 11 try { 12 TimeServer timeServer = new TimeServer(); 13 /* 绑定到JVM 的 RMI Server上*/ 14 // Naming.bind("t1",timeServer); 15 // Naming.rebind("t1",timeServer); 16 /* 当RMI注册server是指定了端口时或者不在本机运行时,需要这样写*/ 17 Naming.rebind("//localhost/t1",timeServer); 18 System.out.println("Bind is Finish"); 19 } catch (RemoteException e) { 20 e.printStackTrace(); 21 } catch (MalformedURLException e) { 22 e.printStackTrace(); 23 } 24 } 25 }
这时,要用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得到。
1 package org.lyh.client; 2 3 import org.lyh.server.ITimeServer; 4 5 import java.net.MalformedURLException; 6 import java.rmi.Naming; 7 import java.rmi.NotBoundException; 8 import java.rmi.RemoteException; 9 10 /** 11 * Created by lvyahui on 2016/4/22. 12 */ 13 public class TimeClient { 14 public static void main(String[] args) { 15 try { 16 ITimeServer iTimeServer = (ITimeServer) Naming.lookup("rmi://192.168.18.1/t1"); 17 System.out.println(iTimeServer.getServerTime()); 18 System.out.println(iTimeServer.add(3,7)); 19 } catch (NotBoundException e) { 20 e.printStackTrace(); 21 } catch (MalformedURLException e) { 22 e.printStackTrace(); 23 } catch (RemoteException e) { 24 e.printStackTrace(); 25 } 26 } 27 }
为了更加真实,我将这个Client上传到虚拟机上编译运行