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

 

目录
相关文章
|
16天前
|
Java
Java开发实现图片URL地址检验,如何编码?
【10月更文挑战第14天】Java开发实现图片URL地址检验,如何编码?
46 4
|
15天前
|
监控 Java 测试技术
Java开发现在比较缺少什么工具?
【10月更文挑战第15天】Java开发现在比较缺少什么工具?
30 1
|
16天前
|
Java
Java开发实现图片地址检验,如果无法找到资源则使用默认图片,如何编码?
【10月更文挑战第14天】Java开发实现图片地址检验,如果无法找到资源则使用默认图片,如何编码?
49 2
|
8天前
|
开发框架 JavaScript 前端开发
HarmonyOS UI开发:掌握ArkUI(包括Java UI和JS UI)进行界面开发
【10月更文挑战第22天】随着科技发展,操作系统呈现多元化趋势。华为推出的HarmonyOS以其全场景、多设备特性备受关注。本文介绍HarmonyOS的UI开发框架ArkUI,探讨Java UI和JS UI两种开发方式。Java UI适合复杂界面开发,性能较高;JS UI适合快速开发简单界面,跨平台性好。掌握ArkUI可高效打造符合用户需求的界面。
46 8
|
3天前
|
SQL Java 程序员
倍增 Java 程序员的开发效率
应用计算困境:Java 作为主流开发语言,在数据处理方面存在复杂度高的问题,而 SQL 虽然简洁但受限于数据库架构。SPL(Structured Process Language)是一种纯 Java 开发的数据处理语言,结合了 Java 的架构灵活性和 SQL 的简洁性。SPL 提供简洁的语法、完善的计算能力、高效的 IDE、大数据支持、与 Java 应用无缝集成以及开放性和热切换特性,能够大幅提升开发效率和性能。
|
4天前
|
存储 Java 关系型数据库
在Java开发中,数据库连接是应用与数据交互的关键环节。本文通过案例分析,深入探讨Java连接池的原理与最佳实践
在Java开发中,数据库连接是应用与数据交互的关键环节。本文通过案例分析,深入探讨Java连接池的原理与最佳实践,包括连接创建、分配、复用和释放等操作,并通过电商应用实例展示了如何选择合适的连接池库(如HikariCP)和配置参数,实现高效、稳定的数据库连接管理。
15 2
|
4天前
|
监控 Java 数据库连接
在Java开发中,数据库连接管理是关键问题之一
在Java开发中,数据库连接管理是关键问题之一。本文介绍了连接池技术如何通过预创建和管理数据库连接,提高数据库操作的性能和稳定性,减少资源消耗,并简化连接管理。通过示例代码展示了HikariCP连接池的实际应用。
9 1
|
12天前
|
Java 大数据 API
别死脑筋,赶紧学起来!Java之Steam() API 常用方法使用,让开发简单起来!
分享Java Stream API的常用方法,让开发更简单。涵盖filter、map、sorted等操作,提高代码效率与可读性。关注公众号,了解更多技术内容。
|
15天前
|
Java 关系型数据库 API
介绍一款Java开发的企业接口管理系统和开放平台
YesApi接口管理平台Java版,基于Spring Boot、Vue.js等技术,提供API接口的快速研发、管理、开放及收费等功能,支持多数据库、Docker部署,适用于企业级PaaS和SaaS平台的二次开发与搭建。
|
17天前
|
Java
Java开发如何实现文件的移动,但是在移动结束后才进行读取?
【10月更文挑战第13天】Java开发如何实现文件的移动,但是在移动结束后才进行读取?
40 2