从懵逼到恍然大悟之Java中RMI的使用
此处讲的是Java
中的RMI
,而不是通用意义上的RMI
,关于通用的RMI
可以参考分布式之RPC的协议以及错误处理 这篇文章。
一、Java RMI
简介
Java RMI
用于不同虚拟机之间的通信,这些虚拟机可以在不同的主机上、也可以在同一个主机上;一个虚拟机中的对象调用另一个虚拟上中的对象的方法,只不过是允许被远程调用的对象要通过一些标志加以标识。这样做的特点如下:
- 优点:避免重复造轮子;
- 缺点:调用过程很慢,而且该过程是不可靠的,容易发生不可预料的错误,比如网络错误等;
在RMI
中的核心是远程对象(remote object),除了对象本身所在的虚拟机,其他虚拟机也可以调用此对象的方法,而且这些虚拟机可以不在同一个主机上。每个远程对象都要实现一个或者多个远程接口来标识自己,声明了可以被外部系统或者应用调用的方法(当然也有一些方法是不想让人访问的)。
1.1 RMI
的通信模型
从方法调用角度来看,RMI
要解决的问题,是让客户端对远程方法的调用可以相当于对本地方法的调用而屏蔽其中关于远程通信的内容,即使在远程上,也和在本地上是一样的。
从客户端-服务器模型来看,客户端程序直接调用服务端,两者之间是通过JRMP
( Java Remote Method Protocol)协议通信,这个协议类似于HTTP协议,规定了客户端和服务端通信要满足的规范。
但是实际上,客户端只与代表远程主机中对象的Stub
对象进行通信,丝毫不知道Server
的存在。客户端只是调用Stub
对象中的本地方法,Stub
对象是一个本地对象,它实现了远程对象向外暴露的接口,也就是说它的方法和远程对象暴露的方法的签名是相同的。客户端认为它是调用远程对象的方法,实际上是调用Stub
对象中的方法。可以理解为Stub
对象是远程对象在本地的一个代理,当客户端调用方法的时候,Stub
对象会将调用通过网络传递给远程对象。
在java 1.2
之前,与Stub
对象直接对话的是Skeleton
对象,在Stub
对象将调用传递给Skeleton
的过程中,其实这个过程是通过JRMP
协议实现转化的,通过这个协议将调用从一个虚拟机转到另一个虚拟机。在Java 1.2
之后,与Stub
对象直接对话的是Server
程序,不再是Skeleton
对象了。
所以从逻辑上来看,数据是在Client
和Server
之间横向流动的,但是实际上是从Client
到Stub
,然后从Skeleton
到Server
这样纵向流动的。
1.2 重要的问题
1.2.1 数据的传递问题
我们都知道在Java
程序中引用类型(不包括基本类型)的参数传递是按引用传递的,对于在同一个虚拟机中的传递时是没有问题的,因为的参数的引用对应的是同一个内存空间,但是对于分布式系统中,由于对象不再存在于同一个内存空间,虚拟机A的对象引用对于虚拟机B没有任何意义,那么怎么解决这个问题呢?
- 第一种:将引用传递更改为值传递,也就是将对象序列化为字节,然后使用该字节的副本在客户端和服务器之间传递,而且一个虚拟机中对该值的修改不会影响到其他主机中的数据;但是对象的序列化也有一个问题,就是对象的嵌套引用就会造成序列化的嵌套,这必然会导致数据量的激增,因此我们需要有选择进行序列化,在
Java
中一个对象如果能够被序列化,需要满足下面两个条件之一:- 是
Java
的基本类型; - 实现
java.io.Serializable
接口(String
类即实现了该接口); - 对于容器类,如果其中的对象是可以序列化的,那么该容器也是可以序列化的;
- 可序列化的子类也是可以序列化的;
- 是
- 第二种:仍然使用引用传递,每当远程主机调用本地主机方法时,该调用还要通过本地主机查询该引用对应的对象,在任何一台机器上的改变都会影响原始主机上的数据,因为这个对象是共享的;
RMI
中的参数传递和结果返回可以使用的三种机制(取决于数据类型):
- 简单类型:按值传递,直接传递数据拷贝;
- 远程对象引用(实现了
Remote
接口):以远程对象的引用传递; - 远程对象引用(未实现
Remote
接口):按值传递,通过序列化对象传递副本,本身不允许序列化的对象不允许传递给远程方法;
1.2.2 远程对象的发现问题
在调用远程对象的方法之前需要一个远程对象的引用,如何获得这个远程对象的引用在RMI
中是一个关键的问题,如果将远程对象的发现类比于IP
地址的发现可能比较好理解一些。
在我们日常使用网络时,基本上都是通过域名来定位一个网站,但是实际上网络是通过IP
地址来定位网站的,因此其中就需要一个映射的过程,域名系统(DNS
)就是为了这个目的出现的,在域名系统中通过域名来查找对应的IP
地址来访问对应的服务器。那么对应的,IP
地址在这里就相当于远程对象的引用,而DNS
则相当于一个注册表(Registry)。而域名在RMI中就相当于远程对象的标识符,客户端通过提供远程对象的标识符访问注册表,来得到远程对象的引用。这个标识符是类似URL
地址格式的,它要满足的规范如下:
- 该名称是
URL
形式的,类似于http
的URL
,schema是rmi; - 格式类似于
rmi://host:port/name
,host
指明注册表运行的注解,port
表明接收调用的端口,name
是一个标识该对象的简单名称。 - 主机和端口都是可选的,如果省略主机,则默认运行在本地;如果端口也省略,则默认端口是1099;
二、编程实现
2.1 基本内容
实现RMI
所需的API
几乎都在:
java.rmi
:提供客户端需要的类、接口和异常;java.rmi.server
:提供服务端需要的类、接口和异常;java.rmi.registry
:提供注册表的创建以及查找和命名远程对象的类、接口和异常;
其实在RMI
中的客户端和服务端并没有绝对的界限,与Web应用中的客户端和服务器还是有区别的。这两者其实是平等的,客户端可以为服务端提供远程调用的方法,这时候,原来的客户端就是服务器端。
2.2 基本实现之一(注册表单独运行)
2.2.1 构建服务器端
什么是远程对象?首先从名称上来看,远程对象是存在于服务端以供客户端调用。那么什么对象可以被客户端进行远程调用?这个问题从编程的角度来看,实现了java.rmi.Remote
接口的类或者继承了java.rmi.Remote
接口的所有接口都是远程对象。这些继承或者实现了该接口的类或者接口中定义了客户端可以访问的方法。这个远程对象中可能有很多个方法,但是只有在远程接口中声明的方法才能从远程调用,其他的公共方法只能在本地虚拟机中使用。
实现过程中的注意事项:
- 子接口的每个方法都必须声明抛出
java.rmi.RemoteException
异常,该异常是使用RMI
时可能抛出的大多数异常的父类。 - 子接口的实现类应该直接或者间接继承
java.rmi.server.UnicastRemoteObject
类,该类提供了很多支持RMI
的方法,具体来说,这些方法可以通过JRMP
协议导出一个远程对象的引用,并通过动态代理构建一个可以和远程对象交互的Stub
对象。具体的实现看如下的例子。
首先远程接口如下:
public interface UserHandler extends Remote {String getUserName(int id) throws RemoteException;int getUserCount() throws RemoteException;User getUserByName(String name) throws RemoteException;
}
远程接口的实现类如下:
public class UserHandlerImpl extends UnicastRemoteObject implements UserHandler {// 该构造期必须存在,因为集继承了UnicastRemoteObject类,其构造器要抛出RemoteExceptionpublic UserHandlerImpl() throws RemoteException {super();}@Overridepublic String getUserName(int id) throws RemoteException {return "lmy86263";}@Overridepublic int getUserCount() throws RemoteException{return 1;}@Overridepublic User getUserByName(String name) throws RemoteException{return new User("lmy86263", 1);}
}
为了测试在使用RMI
的序列化的问题,这里特别设置了一个引用类型User
:
public class User implements Serializable {// 该字段必须存在private static final long serialVersionUID = 42L;// setter和getter可以没有String name;int id;public User(String name, int id) {this.name = name;this.id = id;}
}
在Java 1.4
及 以前的版本中需要手动建立Stub
对象,通过运行rmic
命令来生成远程对象实现类的Stub
对象,但是在Java 1.5
之后可以通过动态代理来完成,不再需要这个过程了。
运行该远程对象的服务器代码如下:
UserHandler userHandler = null;
try {userHandler = new UserHandlerImpl();Naming.rebind("user", userHandler);System.out.println(" rmi server is ready ...");
} catch (Exception e) {e.printStackTrace();
}
这里面的核心代码为Naming.rebind("user", userHandler)
,通过一个名称映射到该远程对象的引用,客户端通过该名称获取该远程对象的引用。
在远程对象中有三个方法:getUserName(int id)
和getUserCount()
的参数和返回结果都是基本类型,因此是默认序列化的,但是对于getUserByName(String name)
方法,返回的结果是一个引用类型,因此会涉及到序列化与反序列的问题,对于User类,必须满足以下条件:
必须实现
java.io.Serializable
接口;其中必须有
serialVersionUID
字段,格式如下:private static final long serialVersionUID = 42L;
如果没有该字段,则默认该类会随机生成一个整数,且在客户端和服务器生成的整数不相同,则会抛出异常如下:
而且在服务器和客户端这个字段必须保持一致才能进行反序列化,如果两端都有该字段,但是数据不一致,则会抛出异常如下:
这个类在服务器和客户端都必须可用;
在序列化的时候,如果在字段前加入了
transient
关键字,则该数据不会被序列化;
2.2.2 构建注册表
注册表其实不用写任何代码,在你的JAVA_HOME
下bin
目录下有一个rmiregistry.exe
程序,需要在你的程序的classpath
下运行该程序。
在启动服务器的时候,实际上需要运行两个服务器:
- 一个是远程对象本身;
- 一个是允许客户端下载远程对象引用的注册表;
由于远程对象需要与注册表对话,所以必须首先启动注册表程序。当注册表程序没有启动的时候,如果强行启动远程对象服务器时,会抛出如下错误:
确保远程对象类可以被注册表程序发现,当远程对象类没有被注册表程序发现时,则会发现如下错误:
如果是使用maven
管理工程,则在target/classes
目录中启动该程序。
这说明注册表程序时运行在一个单独的进程中的,它作为一个第三方的组件,来协调客户端和服务器之间的通信,但是与它们两个之间是完全解决解耦的。
rmiregistry.exe默认情况下是监听1099端口,如果已经该端口已经被使用了,可以通过命令
rmiregistry 1020
指定其他的端口来运行。
可以通过
start rmiregistry
命令在后台运行
运行完注册表程序后,就可以运行远程对象所在的服务器,以便接受客户端的连接。
2.2.3 构建客户端
客户端的代码如下:
try {UserHandler handler = (UserHandler) Naming.lookup("user");int count = handler.getUserCount();String name = handler.getUserName(1);System.out.println("name: " + name);System.out.println("count: " + count);System.out.println("user: " + handler.getUserByName("lmy86263"));
} catch (NotBoundException e) {e.printStackTrace();
} catch (MalformedURLException e) {e.printStackTrace();
} catch (RemoteException e) {e.printStackTrace();
}
在上边的代码中通过Naming.lookup(...)
获取该远程对象的引用。这个方法通过一个指定的名称来获取,该名称必须与远程对象服务器绑定的名称一致。可以通过Naming.list(...)
方法列出所有可用的远程对象。
在使用客户端连接服务器调用远程方法的时候,需要注意的问题如下:
UserHandler
类在客户端本地必须可用,不然无法指定要调用的方法,而且其全限定名必须与服务器上的对象完全相同,不然抛出如下异常:从注册表中获取的对象引用已经失去类型信息,需要强制转化为远程对象类型。这样运行客户端的时候才能获得相应的响应;
如果在方法中使用到了引用类型,比如这里的
User
,那么该类型的全限定名也必须与服务器的相同,如果不相同则会抛出如下异常:客户端的引用类型的
serialVersionUID
字段要与服务器端的对象保持一致;
在客户端的User
对象如下:
public class User implements Serializable {// 与客户端的serialVersionUID字段数据一致private static final long serialVersionUID = 42L;// setter和getter可以没有String name;int id;@Overridepublic String toString() {return "User{" + "name='" + name + '\'' + ", id=" + id + '}';}
}
2.3 基本实现之二(服务端运行注册表程序)
对于实现二,和实现一的主要区别在注册表程序的运行,不再是通过rmiregistry.exe
单独运行,而是通过编程来实现,而远程接口以及其实现类与实现一完全相同。
这里注册表的实现是通过java.rmi.registry
包中的Registry
接口和以及其实现类LocateRegistry
来完成的。如果你详细查看JDK的源码的话,就会发现其实我们之前使用的java.rmi.Naming
类中的方法实际上都是间接通过Registry
和LocateRegistry
实现的。
其中获取根据主机和端口获取注册表引用的源码如下:
/**
* Returns a registry reference obtained from information in the URL.
*/
private static Registry getRegistry(ParsedNamingURL parsed) throws RemoteException {return LocateRegistry.getRegistry(parsed.host, parsed.port);
}
而且Naming中的方法和Registry中是一一对应的。
而如果要创建一个注册表,这里要使用的是LocateRegistry
,该类中只要两类方法:
创建本地注册表并且获取该注册表的引用;
createRegistry(int port)
createRegistry(int port, RMIClientSocketFactory csf, RMIServerSocketFactory ssf)
直接获取注册表引用,该注册表可以是本地运行的,也可以是远程运行的,这类方法是不能够创建注册表的,只能等注册表程序运行起来之后,和它进行通信来获取引用,否则抛出异常如下:
其中的方法如下:
getRegistry()
getRegistry(int port)
getRegistry(String host)
getRegistry(String host, int port)
getRegistry(String host, int port, RMIClientSocketFactory csf)
由于是可能从远程主机获取注册表引用,因此可能需要指定
Socket
套接字来和远程主机进行沟通,在这个过程中也有可能因为各种原因造成调用过程失败;
运行远程对象的服务器代码如下:
UserHandler userHandler = null;
Registry registry = null;
try {registry = LocateRegistry.createRegistry(1099);userHandler = new UserHandlerImpl();registry.rebind("user", userHandler);System.out.println(" rmi server is ready ...");
} catch (RemoteException e) {e.printStackTrace();
}
除此之外,其他服务器端和客户端的代码与实现一完全相同。
关于RMI
的实际使用,其中一种方式可以参考相关文章第6个,通过和ZooKeeper
结合使用RMI
。
相关文章:
What is a serialVersionUID and why should I use it?
Java 序列化的高级认识
java.rmi.Naming和java.rmi.registry.LocateRegistry的区别
RMI教程:入门与编译方法
Java深度历险(十)——Java对象序列化与RMI
使用 RMI + ZooKeeper 实现远程调用框架
从懵逼到恍然大悟之Java中RMI的使用相关推荐
- java rmi jrmp_关于Java 中 RMI、JNDI、LDAP、JRMP、JMX、JMS那些事儿(上)看后的一些总结-1...
1.java rmi 关于rmi客户端和服务端通信的过程,java的方法都实现在rmi服务端,客户端实际上是通过访问rmi注册表拿到stub,然后再通过它调用服务端方法,那么调用方法时要传递参数,参数 ...
- 【java】RMI教程:入门与编译方法 远程
1.概述 转载:RMI教程:入门与编译方法 2.分布式对象和RMI 分布式对象技术主要是在分布式异构环境下简历应用系统框架和对象构件.在应用系统框架的支撑下,开发者可以将软件功能封装为更易于管理和使用 ...
- 深究Java中的RMI底层原理
原博客地址:http://blog.csdn.net/sinat_34596644/article/details/52599688 前言:随着一个系统被用户认可,业务量.请求量不断上升,那么单机系统 ...
- java中使用rmi进行远程方法调用
java中进行远程方法调用,能支持分布式计算.并且可以实现在server的修改,能反应到各个client. 假如server的ip是:192.168.11.2, server端的代码如下: /*** ...
- Java中的序列化到底是什么
我们都知道,新建一个对象的时候实现 Serializeable 接口,但为什么要这么做?什么时候这样子做?这样子做会不会出现幺蛾子?阿淼一个三连差点把自己都问懵逼了-- 那接下来,大家就和阿淼一起简单 ...
- java中调用python
在Java中调用Python </h1><div class="clear"></div><div class="postBod ...
- java中properties作用,java中Properties类的使用
java中Properties类的使用 在java.util 包下面有一个类 Properties,该类主要用于读取以项目的配置文件(以.properties结尾的文件和xml文件). Propert ...
- Java 中几种常用的 RPC 框架介绍
RPC是远程过程调用的简称,广泛应用在大规模分布式应用中,作用是有助于系统的垂直拆分,使系统更易拓展.Java中的RPC框架比较多,各有特色,广泛使用的有RMI.Hessian.Dubbo等.RPC还 ...
- java中int和integer的区别_Java异常中throw和throws关键字的区别
Java中常常弄混的两个关键字,throw和throws,它们有什么区别呢?如何记忆他们,而不至于出错呢? throw和throws 区别 throws:出现在方法的签名中,声明当前方法可能抛出的所有 ...
最新文章
- 11月12日云栖精选夜读 | 2135亿!新技术的力量刚刚开始
- Eclipse搭建android环境及Genymotion模拟器安装问题解决方法
- keras从入门到放弃(六)多层感知器(神经网络)
- delphi 安卓图片保存数据库_delphi 把图片存入数据库
- sklearn自学指南(part38)--OPTICS
- [渝粤题库]陕西师范大学《商业银行经营学》作业
- Visual C#设计多功能关机程序
- Tornado 高并发源码分析之六---异步编程的几种实现方式
- js delete删除对象属性,delete删除不了变量及原型链中的变量
- 打开 VMware Workstation 14 Pro 中的虚拟机出现 “此主机支持 Intel VT-x,但 Intel VT-x 处于禁用状态” 解决方法
- 大型公司网路架构浅谈
- esp8266开发入门教程(基于Arduino)——编程基础介绍
- Android 系统分析工具:Systrace
- 《SteamVR2.0/Input》(Yanlz+SteamVR+Input+OpenVR+Runtime+SteamVR_Action+立钻哥哥+==)
- U盘重装centos7系统(开发者模式)
- SQL开发管理工具,SQL Studio成数据库管理工具热门
- MATLAB应用实战系列(六十)-MATLAB数学建模常用的四大模型
- Java连接阿里云大数据计算服务Maxcompute(ODPS)
- 51单片机可以用来练手的60个小设计
- MD5验证文件是否重复