开发者社区> 吕亚辉> 正文

Java RMI(远程方法调用)开发

简介: 参考 https://docs.oracle.com/javase/7/docs/platform/rmi/spec/rmi-arch2.html http://www.cnblogs.com/wxisme/p/5296441.
+关注继续查看

参考

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的执行结果。这样就实现了,运算流程的分布式计算。一般这两个对象存在于两台机器上。

  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),供客户端使用。列出了开放远程调用的接口

 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上传到虚拟机上编译运行

 

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
C# 子窗体中调用父窗体中的方法(或多窗体之间方法调用)
本文转载:http://www.csframework.com/archive/2/arc-2-20110805-1771.htm 文章侧重点主要是讨论“窗体”与“窗体”之间方法的调用,以及“MDI父窗体”与“Chilid子窗体”之间如何相互的调用方法。
1022 0
ubuntu 无法使用 SSH root 账户远程访问
SSH服务器,可以通过SSH协议来访问远程服务器,代替telnet和ftp。但是ubuntu默认是不启用root用户也不允许root远程登录的,这应该是出于安全考虑。 解决方案一: 使用其它用户登录 解决方案
1108 0
NHibernate 3.2 使用 Conformist 进行 CodeFirst 开发
NHibernate 3.2 GA 正式版于 2011-07-30 发布,这一版本对 CodeFirst 的支持性更好了,因为它提供了 Conformist 取代之前第三方的 ConfOrm。   NHibernate 3.2 下载地址:http://sourceforge.net/projects/nhibernate/files/NHibernate/   下面将讲一下如何使用这一新成员进行数据库的基本操作。
981 0
+关注
吕亚辉
主做Java 后台开发,熟悉并发与网络编程。乐于分享,爱钻研问题,喜欢技术上的挑战,属复合型开发工程师,擅长后端开发,也有一定web前端开发经验,曾独立开发多个项目,独立与全栈开发能力强。
81
文章
0
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载