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

简介:

最近在学习Dubbo,RMI是很重要的底层机制,RMI(Remote Method Invocation)远程方法调用是一种计算机之间利用远程对象互相调用实现双方通讯的一种通讯机制。使用这种机制,某一台计算机(即JVM虚拟机)上的对象可以调用另外一台计算机上的对象来获取远程数据。

RMI的实现对建立分布式Java应用程序至关重要,是Java体系非常重要的底层技术。

>>RMI的概念和原理

RMI思路是在客户端安装一个代理(proxy),代理是位于客户端虚拟机中的一个对象,对于客户端对象,看起来就像访问的远程对象一样,客户端代理会使用网络协议与服务器进行通信。
同样的服务端也会有一个代理对象来进行通信的繁琐工作。

在RMI中,客户端的代理对象被称为存根(Stub),存根位于客户端机器上,它知道如何通过网络与服务器联系。存根会将远程方法所需的参数打包成一组字节。对参数编码的过程被称为参数编组(parameter marshalling),参数编组的目的是将参数转换成适合在虚拟机之间进行传递的形式。在RMI协议中,对象时使用序列化机制进行编码的。

总的来说,客户端的存根方法构造了一个信息块,它由以下几部分组成
被使用的远程对象的标识符;
被调用的方法的描述;
编组后的参数;

然后,存根将此信息发送给服务器。在服务器的一端,接收器对象执行以下动作:
定位要调用的远程对象;
调用所需的方法,并传递客户端提供的参数;
捕获返回值或调用产生的异常;
将返回值编组,打包送回给客户端存根;
客户端存根对来自服务器端的返回值或异常进行反编组,其结果就成为了调用存根返回值。

>>RMI体系结构

桩/框架(Stub/Skeleton)层:客户端的桩和服务器端的框架;
远程引用(remote reference)层:处理远程引用行为
传送层(transport):连接的建立和管理,以及远程对象的跟踪

 

>>RMI与代理模式

RMI的实现是典型的代理模式思想。

(1)代理模式的UML图

代理模式为其他对象提供一种代理以控制对这个对象的访问,把调用者与被调用者分离开,由代理负责传递信息来完成调用。
比如你想买美版Iphone6s,朋友出国,帮你海淘带回,整个过程就是代理模式,朋友作为代理,代你完成你想进行的操作。

代理模式能将代理对象与真正被调用的对象分离,在一定程度上降低了系统的耦合度;
在客户端和目标对象之间起到一个中介作用,这样可以起到保护目标对象的作用,代理对象也可以对目标对象调用之前进行其他操作。
代理模式在客户端和目标对象增加一个代理对象,会造成请求处理速度变慢;同时也增加了系统的复杂度。

(2)代理模式在RMI这种的体现

远程代理的内部机制是这样的:

下面的RMI实例,其实就是一个代理模式的应用。

>>RMI的简单实例

RMI的开发步骤如下:
先创建远程接口及声明远程方法,注意这是实现双方通讯的接口,需要继承Remote
开发一个类来实现远程接口及远程方法,值得注意的是实现类需要继承UnicastRemoteObject
通过javac命令编译文件,通过java -server 命令注册服务,启动远程对象
最后客户端查找远程对象,并调用远程方法

(1)服务端远程接口
创建远程接口SearchService,接口必须继承Remote类,每一个定义方法都要抛出RemoteException异常

1
2
3
4
5
6
import  java.rmi.Remote;
import  java.rmi.RemoteException;
 
public  interface  SearchService  extends  Remote {
     public  User findUser(String id)  throws  RemoteException;;
}

  

(2)建立SearchServiceImpl实现远程接口,注意此为远程对象实现类,需要继承UnicastRemoteObject

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
import  java.rmi.RemoteException;
public  class  SearchServiceImpl  implements  SearchService{
 
     /**
      * 抛出RemoteException
      * @throws RemoteException
      */
     public  SearchServiceImpl()  throws  RemoteException {
         super ();
         }
     
     @Override
     public  User findUser(String id)  throws  RemoteException {
         /**
          * 模拟查找返回数据
          */
         User user= new  User(id, "Tom" , "18岁" );
         return  user;
     }
 
}

  

(3)为服务建立一个Model层,此对象需要远程传输,所以必须实现implements Serializable序列化接口,也就是可以在client和server端进行传输的可序列化对象
新建User类,用于数据传输:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
public  class  User  implements  Serializable{
 
     private  static  final  long  serialVersionUID = 1L;
     
     private  String id;
     private  String name;
     private  String age;
     
     public  User(String id,String name,String age){
         this .id=id;
         this .name=name;
         this .age=age;
     }
     
     public  String getId() {
         return  id;
     }
 
     public  void  setId(String id) {
         this .id = id;
     }
 
     public  String getName() {
         return  name;
     }
 
     public  void  setName(String name) {
         this .name = name;
     }
 
     public  String getAge() {
         return  age;
     }
 
     public  void  setAge(String age) {
         this .age = age;
     }
     
     public  String toString(){
         StringBuffer sb= new  StringBuffer();
         sb.append( "~用户id-" +id);
         sb.append( "~用户姓名-" +id);
         sb.append( "~用户年龄-" +id);
         return  sb.toString();
     }
 
}

  

(4)建立服务器端,在服务器端注册RMI通讯端口与通讯路径

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
import  java.net.MalformedURLException;
import  java.rmi.Naming;
import  java.rmi.RemoteException;
import  java.rmi.registry.LocateRegistry;
import  java.rmi.registry.Registry;
 
/**
  * @author BingYue
  */
public  class  Process {
     
     public  static  void  main(String[] args){
         
         try  {
             SearchService searchService= new  SearchServiceImpl();
             //注册通信端口
             Registry registry=LocateRegistry.createRegistry( 5678 );
             //注册通讯路径
             Naming.rebind( "rmi://127.0.0.1:5678/searchService" , searchService);
             System.out.println( "Service Start!" );
             
         catch  (RemoteException e) {
             e.printStackTrace();
         catch  (MalformedURLException e) {
             e.printStackTrace();
         }
     }
 
}

  

(5)创建客户端,导入上面的实体类和接口,通过Naming.lookup()的方式调用
如果使用IDE,就可以新建一个项目,Client代码如下:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
import  java.rmi.Naming;
 
/**
  * @author BingYue
  */
public  class  Client {
     
     public  static  void  main(String[] args){
         try  {
             //调用远程对象,注意RMI路径与接口必须与服务器配置一致
             SearchService searchService=(SearchService)Naming.lookup( "rmi://127.0.0.1:5678/searchService" );
             User user=searchService.findUser( "100" );
             System.out.println(user.toString());
         catch  (Exception e) {
             e.printStackTrace();
         }
     }
}

  

(6)分别运行服务端和客户端,获得远程调用结果

>>RMI应用程序的基本模型

(1)Remote接口:是一个不定义方法的标记接口

1
Public  interface  Remote{}

在RMI中,远程接口声明了可以从远程Java虚拟机中调用的方法集。远程接口满足下列要求:
远程接口必须直接或间接扩展Java.rmi.Remote接口,且必须声明为public,除非客户端于远程接口在同一包中;
在远程接口中的方法在声明时,除了要抛出与应用程序有关的一场之外,还必须包括RemoteException(或它的超类,IOExcepion或Exception)异常;
在远程方法声明中,作为参数或返回值声明的远程对象必须声明为远程接口,而非该接口的实现类。

(2)RemoteObject抽象类实现了Remote接口和序列化Serializable接口,它和它的子类提供RMI服务器函数。

(3)LocateRegistry final()类用于获得特定主机的引导远程对象注册服务器程序的引用(即创建stub),或者创建能在特定端口接收调用的远程对象注册服务程序。

服务器端:向其他客户机提供远程对象服务

1
2
3
4
5
6
7
8
9
10
11
SomeService servcie=……; //远程对象服务
Registry registry=LocateRegisty.getRegistry(); //Registry是个接口,他继承了Remote,此方法返回本地主机在默认注册表端口 1099 上对远程对象 Registry 的引用。
getRegistry( int  port) 返回本地主机在指定 port 上对远程对象 Registry 的引用;
getRegistry(String host) 返回指定 host 在默认注册表端口  1099  上对远程对象 Registry 的引用;
getRegistry(String host,  int  port) 返回指定的 host 和 port 上对远程对象 Registry 的引用
 
registry.bind(“I serve”,service); // bind(String name,Remote obj) 绑定对此注册表中指定 name 的远程引用。name : 与该远程引用相关的名称 obj : 对远程对象(通常是一个 stub)的引用
unbind(String name)移除注册表中指定name的绑定。
rebind(String name,Remote obj)重新绑定,如果name已存在,但是Remote不一样则替换,如果Remote一样则丢弃现有的绑定
lookup(String name) 返回注册表中绑定到指定 name 的远程引用,返回Remote
String[] list() 返回在此注册表中绑定的名称的数组。该数组将包含一个此注册表中调用此方法时绑定的名称快照。

  

客户机端:向服务器提供相应的服务请求

1
2
3
Registry registry=LocateRegisty.getRegistry();
SomeService servcie=(SomeService)registry.lookup(“I serve”);
Servcie.requestService();

(4) Naming类和Registry类类似

客户端:

1
2
Naming.lookup(String url)
url 格式如下 "rmi://localhost/" +远程对象引用

服务器端:

1
2
Registry registry=LocateRegistry.createRegistry( int  port);
Naming.rebind(“service”,service);

(5) RMISecurityManager类

在RMI引用程序中,如果没有设置安全管理器,则只能从本地类路径加载stub和类,这可以确保应用程序不受由远程方法调用所下载的代码侵害
在从远程主机下载代码之前必须执行以下代码来安装RMISecurityManager:

1
System.setSecurityManager( new  RMISecurityManager());

  

>>RMI的主要应用

RMI的用途是为分布式Java应用程序之间的远程通信提供服务,提供分布式服务。
目前主要应用时封装在各个J2EE项目框架中,例如Spring封装了RMI技术。

(1)在Spring中实现RMI

在服务器端定义服务的接口,定义特定的类实现这些接口;
在服务器端使用org.springframework.remoting.rmi.RmiServiceExporter类来注册服务;
在客户端使用org.springframework.remoting.rmi.RmiProxyFactoryBean来实现远程服务的代理功能;
在客户端定义访问与服务器端服务接口相同的类

(2)在Dubbo中的应用

Dubbo支持不同的协议,其中RMI协议底层就是Java RMI的实现,
RMI协议的Invoker转为Exporter发生在RmiProtocol类的export方法,
通过Spring或Dubbo或JDK来实现RMI服务,通讯细节由JDK底层来实现,节省了不少工作量。


目录
相关文章
|
6天前
|
JSON Java Apache
非常实用的Http应用框架,杜绝Java Http 接口对接繁琐编程
UniHttp 是一个声明式的 HTTP 接口对接框架,帮助开发者快速对接第三方 HTTP 接口。通过 @HttpApi 注解定义接口,使用 @GetHttpInterface 和 @PostHttpInterface 等注解配置请求方法和参数。支持自定义代理逻辑、全局请求参数、错误处理和连接池配置,提高代码的内聚性和可读性。
|
23天前
|
存储 Java
Java中的HashMap和TreeMap,通过具体示例展示了它们在处理复杂数据结构问题时的应用。
【10月更文挑战第19天】本文详细介绍了Java中的HashMap和TreeMap,通过具体示例展示了它们在处理复杂数据结构问题时的应用。HashMap以其高效的插入、查找和删除操作著称,而TreeMap则擅长于保持元素的自然排序或自定义排序,两者各具优势,适用于不同的开发场景。
39 1
|
15天前
|
人工智能 前端开发 Java
基于开源框架Spring AI Alibaba快速构建Java应用
本文旨在帮助开发者快速掌握并应用 Spring AI Alibaba,提升基于 Java 的大模型应用开发效率和安全性。
基于开源框架Spring AI Alibaba快速构建Java应用
|
9天前
|
SQL Java 数据库连接
从理论到实践:Hibernate与JPA在Java项目中的实际应用
本文介绍了Java持久层框架Hibernate和JPA的基本概念及其在具体项目中的应用。通过一个在线书店系统的实例,展示了如何使用@Entity注解定义实体类、通过Spring Data JPA定义仓库接口、在服务层调用方法进行数据库操作,以及使用JPQL编写自定义查询和管理事务。这些技术不仅简化了数据库操作,还显著提升了开发效率。
21 3
|
19天前
|
SQL 监控 Java
技术前沿:Java连接池技术的最新发展与应用
本文探讨了Java连接池技术的最新发展与应用,包括高性能与低延迟、智能化管理和监控、扩展性与兼容性等方面。同时,结合最佳实践,介绍了如何选择合适的连接池库、合理配置参数、使用监控工具及优化数据库操作,为开发者提供了一份详尽的技术指南。
29 7
|
16天前
|
SQL Java 数据库连接
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率
在Java应用中,数据库访问常成为性能瓶颈。连接池技术通过预建立并复用数据库连接,有效减少连接开销,提升访问效率。本文介绍了连接池的工作原理、优势及实现方法,并提供了HikariCP的示例代码。
31 3
|
16天前
|
存储 Java 关系型数据库
在Java开发中,数据库连接是应用与数据交互的关键环节。本文通过案例分析,深入探讨Java连接池的原理与最佳实践
在Java开发中,数据库连接是应用与数据交互的关键环节。本文通过案例分析,深入探讨Java连接池的原理与最佳实践,包括连接创建、分配、复用和释放等操作,并通过电商应用实例展示了如何选择合适的连接池库(如HikariCP)和配置参数,实现高效、稳定的数据库连接管理。
34 2
|
18天前
|
缓存 Java 数据库连接
Hibernate:Java持久层框架的高效应用
通过上述步骤,可以在Java项目中高效应用Hibernate框架,实现对关系数据库的透明持久化管理。Hibernate提供的强大功能和灵活配置,使得开发者能够专注于业务逻辑的实现,而不必过多关注底层数据库操作。
12 1
|
21天前
|
移动开发 前端开发 JavaScript
java家政系统成品源码的关键特点和技术应用
家政系统成品源码是已开发完成的家政服务管理软件,支持用户注册、登录、管理个人资料,家政人员信息管理,服务项目分类,订单与预约管理,支付集成,评价与反馈,地图定位等功能。适用于各种规模的家政服务公司,采用uniapp、SpringBoot、MySQL等技术栈,确保高效管理和优质用户体验。
|
22天前
|
SQL 监控 Java
Java性能优化:提升应用效率与响应速度的全面指南
【10月更文挑战第21】Java性能优化:提升应用效率与响应速度的全面指南