当前位置：首页 > news >正文

java RMI 技术介绍和实践

news 来源：原创 2024/9/21 15:51:13

在项目上发现了使用rmi技术，充电一波

RMI 概述

RMI（Remote Method Invocation）是一种 Java 编程语言中的远程过程调用（RPC）协议，用于在不同的Java虚拟机（JVM）之间进行通信和交互。它允许远程计算机上的Java对象像本地对象一样进行访问和操作，从而使分布式应用程序的开发变得更加容易和方便。

RMI 基本思想

RMI 基本思想是远程方法调用，即客户端调用某个方法，其本质是将这个方法的调用请求，发送给服务器，由服务器代为执行，且，服务器将执行结果回送客户端。

对于客户端而言，RMI 只要求客户端针对方法本身，产生一种错觉：方法是在本地被调用的；
对于服务器而言，RMI 相当于要处理一个来自客户端的“请求”；这个请求针对某个方法。

RMI 设计分析

客户端功能：

连接 RMI 服务器；
远程方法的消费者，从Registry获取远程方法的相关信息并且调用
等待服务器返回这个方法在服务器端执行的结果。

服务器端功能：

建立 RMI 服务器；
侦听客户端连接请求；
连接 RMI 客户端；
接受客户端发送过来的要执行的方法名称、实参等信息；找到这个需要代理执行方法，并反射机制执行该方法，并将方法执行的结果回传给客户端，断开与客户端的连接。

Registry：

提供服务注册与服务获取。即Server端向Registry注册服务，比如地址、端口等一些信息，Client端从Registry获取远程对象的一些信息，如地址、端口等，然后进行远程调用。

工作流程：

首先，启动RMI Registry服务，启动时可以指定服务监听的端口，也可以使用默认的端口（1099）；
其次，Server端在本地先实例化一个提供服务的实现类，然后通过RMI提供的Naming/Context/Registry等类的bind或rebind方法将刚才实例化好的实现类注册到RMI Registry上并对外暴露一个名称；
最后，Client端通过本地的接口和一个已知的名称（即RMI Registry暴露出的名称），使用RMI提供的Naming/Context/Registry等类的lookup方法从RMI Service那拿到实现类。这样虽然本地没有这个类的实现类，但所有的方法都在接口里了，便可以实现远程调用对象的方法了；

Demo

定义一个接口

package com.cjian.rmi;import java.rmi.Remote;
import java.rmi.RemoteException;/*** @Author: cjian* @Date: 2023/11/8 10:17* @Des:*/
public interface PersonController extends Remote {// 注意这里必须抛出RemoteException，否则在查找服务的时候会提示 illegal remote method encountered 异常String queryName() throws RemoteException;
}

服务端有上面接口的具体实现，这里实现main方法运行

package com.cjian.rmi;import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.server.UnicastRemoteObject;/*** @Author: cjian* @Date: 2023/11/8 10:17* @Des:*/
public class PersonControllerImpl extends UnicastRemoteObject implements PersonController {protected PersonControllerImpl() throws RemoteException {}@Overridepublic String queryName() {System.out.println("Receive request");return "My name's CJ";}public static void main(String[] args) {try {//创建服务端PersonController personController = new PersonControllerImpl();//注册到8888端口，也注册可以注册到别的机器上。LocateRegistry.createRegistry(8888);//绑定服务端到指定的地址，这里的localhost对应的上一步注册端口号的机器java.rmi.Naming.rebind("rmi://localhost:8888/" + PersonController.class.getName(), personController);System.out.println("Ready...");} catch (Exception e) {e.printStackTrace();}}
}

启动：

客户端调用

package com.cjian.rmi;import java.rmi.Naming;/*** @Author: cjian* @Date: 2023/11/8 10:21* @Des:*/
public class ClientTest {public static void main(String[] args) {try {//客户端去查找指定的服务PersonController personController = (PersonController) Naming.lookup("rmi://localhost:8888/" + PersonController.class.getName());//打印的结果应该是 My name's CJSystem.out.println(personController.queryName());} catch (Exception e) {e.printStackTrace();}}
}

测试结果：

另一种写法：

package com.cjian.rmi.custom;import java.rmi.Remote;
import java.rmi.RemoteException;/*** @Author: cjian* @Date: 2023/11/8 10:17* @Des:*/
public interface PersonController2 extends Remote {// 注意这里必须抛出RemoteException，否则在查找服务的时候会提示 illegal remote method encountered 异常String queryName() throws RemoteException;
}

package com.cjian.rmi.custom;import com.cjian.rmi.PersonController;import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;
import java.rmi.server.UnicastRemoteObject;/*** @Author: cjian* @Date: 2023/11/8 10:17* @Des:*/
public class PersonControllerImpl2 implements PersonController {@Overridepublic String queryName() {System.out.println("Receive request");return "My name's CJ";}public static void main(String[] args) {try {//创建服务端PersonController personController = new PersonControllerImpl2();//注册到8888端口，也注册可以注册到别的机器上。UnicastRemoteObject.exportObject(personController, 8080);Registry registry = LocateRegistry.createRegistry(8888);registry.rebind(PersonController.class.getName(), personController);System.out.println("Ready...");} catch (Exception e) {e.printStackTrace();}}
}

package com.cjian.rmi.custom;import com.cjian.rmi.PersonController;import java.rmi.Naming;
import java.rmi.registry.LocateRegistry;
import java.rmi.registry.Registry;/*** @Author: cjian* @Date: 2023/11/8 10:21* @Des:*/
public class ClientTest2 {public static void main(String[] args) {try {Registry registry = LocateRegistry.getRegistry("localhost", 8888);PersonController personController = (PersonController) registry.lookup(PersonController.class.getName());System.out.println(personController.queryName());} catch (Exception e) {e.printStackTrace();}}
}

效果一样