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.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.[email protected]方法了,将存根绑定(注册)到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上传到虚拟机上编译运行

时间: 2024-10-27 06:21:40

Java RMI(远程方法调用)开发的相关文章

JAVA RMI远程方法调用简单实例[转]

RMI的概念 RMI(Remote Method Invocation)远程方法调用是一种计算机之间利用远程对象互相调用实现双方通讯的一种通讯机制.使用这种机制,某一台计算机上的对象可以调用另外 一台计算机上的对象来获取远程数据.RMI是Enterprise JavaBeans的支柱,是建立分布式Java应用程序的方便途径.在过去,TCP/IP套接字通讯是远程通讯的主要手段,但此开发方式没有使用面向对 象的方式实现开发,在开发一个如此的通讯机制时往往令程序员感觉到乏味,对此RPC(Remote

Java RMI(远程方法调用) 实例与分析 (转)

目的: 通过本文,可以加深对Java RMI的理解,知道它的工作原理,怎么使用等. 也为了加深我自己的理解,故整理成文.不足之处,还望指出. 概念解释: RMI(RemoteMethodInvocation):远程方法调用,顾名思义,通过远程的方式调用非本地对象的方法并返回结果.使用远程调用通常解决本地计算瓶颈问题,例如分布式记算,最近很火的阿尔法狗人机大战,据说运算使用上千个CPU. JRMP(java remote method protocol):java远程方法协议,这是完成java到j

Java的RMI远程方法调用实现和应用

最近在学习Dubbo,RMI是很重要的底层机制,RMI(Remote Method Invocation)远程方法调用是一种计算机之间利用远程对象互相调用实现双方通讯的一种通讯机制.使用这种机制,某一台计算机(即JVM虚拟机)上的对象可以调用另外一台计算机上的对象来获取远程数据. RMI的实现对建立分布式Java应用程序至关重要,是Java体系非常重要的底层技术. 1.RMI的概念和原理 RMI思路是在客户端安装一个代理(proxy),代理是位于客户端虚拟机中的一个对象,对于客户端对象,看起来就

java RMI 开发

一:服务端开发: <bean id="webImagesServiceImpl" class="com.yknet.llgo.service.rmi.impl.WebImagesServiceImpl" ></bean> <!-- 图片管理服务接口 --> <bean id="webImagesServiceExporter" class="org.springframework.remotin

Java之RMI(远程方法调用)

RMI(Remote Method Invocation)中文名称是远程方法调用,可用于分布式计算. 这里就不去详细介绍RMI了,本Blog主要讲叙RMI实战和有哪些需要注意的地方,如果想要查看详细介绍请查看:百度百科RMI RMI分为服务端和客户端 服务端: 创建服务端: LocateRegistry.createRegistry(端口); Naming.rebind("rmi://IP地址:端口/RMI服务名称",RMI服务对象);//rebind也可以用bind替代 示例: Lo

java RMI入门指南

感觉这篇文章不错,直接转了 RMI全称是Remote Method Invocation-远程方法调用,Java RMI在JDK1.1中实现的,其威力就体如今它强大的开发分布式网络应用的能力上,是纯Java的网络分布式应用系统的核心解决方式之中的一个.事实上它能够被看作是RPC的Java版本号.可是传统RPC并不能非常好地应用于分布式对象系统.而Java RMI 则支持存储于不同地址空间的程序级对象之间彼此进行通信.实现远程对象之间的无缝远程调用. RMI眼下使用Java远程消息交换协议JRMP

JAVA RMI分布式原理和应用

RMI(Remote Method Invocation)是JAVA早期版本(JDK 1.1)提供的分布式应用解决方案,它作为重要的API被广泛的应用在EJB中.随着互联网应用的发展,分布式处理任务也随之复杂起 来,WebService也得到普遍的推广和应用.        在某些方面,例如跨语言平台的分布式应用,RMI就显得力不从心了.在实际的应用中,是采用WebService还是传统的RMI来实现?这是一个需要权衡的问题,两者的比较如下所述:        1. 比起WebService,它

Java RMI之HelloWorld篇

Java RMI之HelloWorld篇 Java RMI 指的是远程方法调用 (Remote Method Invocation).它是一种机制,能够让在某个 Java 虚拟机上的对象调用另一个 Java 虚拟机中的对象上的方法.可以用此方法调用的任何对象必须实现该远程接口. Java RMI不是什么新技术(在Java1.1的时代都有了),但却是是非常重要的底层技术. 大名鼎鼎的EJB都是建立在rmi基础之上的,现在还有一些开源的远程调用组件,其底层技术也是rmi. 在大力鼓吹Web Serv

对JAVA RMI的认识

RMI的定义 RPC (Remote Procedure Call):远程方法调用,用于一个进程调用另一个进程中的过程,从而提供了过程的分布能力. RMI(Remote Method Invocation):远程方法调用,即在RPC的基础上有向前迈进了一步,提供分布式对象间的通讯.允许运行在一个java 虚拟机的对象调用运行在另一个java虚拟机上对象的方法.这两个虚拟机可以是运行在相同计算机上的不同进程中,也可以是运行在网络上的不同计算机中. RMI的全称宗旨就是尽量简化远程接口对象的调用.