您的位置 首页 > 娱乐休闲

Java 中最简单的分布式调用 RMI

官方微信:动力节点Java学院 关注官方微信免费领取Java视频教程

JAVA中最简单的分布式调用 RMI

摘要:本文属于原创,欢迎转载,转载请保留出处:

代码地址:

前言

我们先来看一个例子:

系统中目前存在两个 JAVA 服务,分别是服务A、服务B。现在服务A 想要调用服务B中的某个服务,我们怎么实现呢?

有人觉得这不很简单,服务B暴露一个服务接口,服务A通过 RPC 的方式来访问这个接口,这里的 RPC 可以引用第三方实现,也可以通过简单的 REST 请求的方式实现。

是的,解决这场景的方法有很多,其实 JAVA 自身也提供了一种更简单的方式,即通过 RMI 实现跨 JVM 虚拟机的远程调用。虽然它和现在主流的 RPC 相比,可能显得比较无力。但是其设计思想,加上它的简单易用,我们不妨来看一下。

RMI 简介

RMI(Remote Method Invocation)是一种用于实现远程过程调用的应用程序编程接口。它使客户机上运行的程序可以调用远程服务器上的对象。远程方法调用特性使Java编程人员能够在网络环境中分布操作。

特点

  • 是 JAVA 自带的功能,无需集成任何的外部扩展;

  • 数据传输是面向对象的;

  • 动态下载对象资源;

  • 仅限 JAVA 间通信;

通信协议

服务间的通信通过 TCP 传输。协议约定为 rmi://,仅限JAVA之间的远程通信;

成员

  • RMI registry:作为存储远程服务的代理对象的仓库

  • Server:服务端,暴露远程对象,并将其代理对象注册进 RMI Registry

  • Client:客户端,查找远程代理对象,远程调用服务对象

运行机制

从上图可以看出,虽然 RMI 目前看上去有点过时了,但其思想和现在的服务注册与发现还是很相似的。归纳起来,包含以下几点:

  1. 启动注册中心

  2. 服务端:暴露服务

  3. 服务端:服务注册

  4. 客户端:获取服务地址(代理对象)

  5. 客户端:远程调用服务

使用方法

  • 启动 RMI Registry

这里启动仓库有两种方式,一种是在程序中启动:

import java.rmi.regi;Registry registry = Loca(REGISTRY_PORT);

另一种通过命令启动:

/usr/bin/rmiregistry Registry_PORT
  • 获取 RMI Registry

  • 通过环境变量 java.rmi. 来设置仓库地址

import java.rmi.regi;Registry registry = Loca(REGISTRY_PORT)
  • 定义远程服务接口

  • 接口继承 Remote

  • 接口方法必须抛出 RemoteException

import java.rmi.Remote;public interface RemoteService extends Remote { //define your function
  • Unica(Remote obj, int port)

  • 创建 Remote 对象的代理类,并实现 Serializable 接口

  • 在 TCP 上暴露远程服务

  • port 为 0 表示使用匿名随机端口 ( 使用1~1023的已知端口时,注意权限问题 )

import java.rmi.;Remote remoteProxy = Unica(your_remote_service, 0);
  • 注册远程对象到 RMI Registry( 在 Registry 中的都是对象的远程代理类,并非真正的对象 )

获取 Registry 的远程代理类,然后调用它的 rebind 将代理对象注册进仓库中 ( Naming.rebind(String name, Remote obj) 本质上也是解析 name 中的仓库地址,获取仓库的代理对象,进而进行远程注册 )

// 本地创建或远程获取 RegistryRegistry registry = ...
  • 查找远程调用对象

Registry registry = Loca(REGISTRY_PORT);Remote obj = regi(REMOTE_NAME);

示例

###准备工作: 定义远程对象接口

package com.;import java.rmi.Remote;import java.rmi.RemoteException;public interface RemoteService extends Remote { Object run() throws RemoteException; Object run(Object obj) throws RemoteException;

###服务B:注册远程服务

  • 实现远程服务对象

package com.;import com..RemoteService;import java.rmi.RemoteException;public class pService1 implements RemoteService { public Object run() {
  • 启动服务

  • 创建 RMI Registry(也可在通过命令 rmiregistry 在应用外创建)

  • 实例化远程服务

  • 导出远程对象,使其能接受远程调用

  • 将导出的远程对象绑定到仓库中

  • 等待服务调用

public class Boot { private static final String REMOTE_P1 = "serviceB:p1"; private static final int REGISTRY_PORT = 9999; public static void main(String[] args) throws RemoteException {

###服务A:调用远程服务

  • 启动服务

  • 连接仓库

  • 在 Registry 中查找所调用服务的远程代理类

  • 调用代理类方法

public class Boot { private static final String REMOTE_P1 = "serviceB:p1"; private static final int REGISTRY_PORT = 9999; public static void main(String[] args) throws RemoteException { try {

演示结果

  • 启动服务B

service b bound
  • 启动服务A

The remote call for serviceB:p1 success
  • 查看服务B 调用情况

service b bound

高级用法

上面示例没有涉及到远程调用的传参问题。如果需要传参,且传参的类型不是基本类型时,远程服务就需要动态的去下载资源。

这里通过设置环境变量来实现远程下载:

  • java.rmi.:远程资源下载路径(必须是绝对路径),可以是file://, ftp://, http:// 等形式的;

  • java.rmi.:默认为 true, 表示仅依赖当前的 codebase, 如果使用外部的 codebase( 服务B 需要使用 服务A 提供的下载地址时 ),需将此参数设置为false;

对于跨主机的访问,RMI 加入了安全管理器(SecurityManager),那么也需要对应的安全策略文件

  • java.:指定策略文件地址;

其他设置:

  • java.rmi.:设置仓库的主机地址;

  • :设置连接仓库的超时时间;

核心代码

关于源码的阅读,网上曾经看到一句话讲的很好,“源码阅读的什么样程度算好,阅读到自己能放过自己了,那就够了。”

我一般喜欢带着问题来阅读,这里我从几个问题入手,简单分享下我的理解。

  • 获取到的 Registry 对象到底是什么东西?

从这段代码来分析:

Registry registry = Loca(REGISTRY_PORT);

  • 远程对象到底是什么,原始对象又在哪里呢?

从这段代码来分析:

Remote obj = Unica(Remote obj, int port);

  • 知道了仓库中存放、获取的都是 远程对象的代理类,那么实际的远程通信是如何完成的?

知道 JDK 动态代理的同学,肯定有一个 invoke 方法,是方法调用的关键。这里的 invoke() 具体代码在 UnicastRef 中。

问题

从源码中可以看出,远程调用每次都会 新建一个 connection,感觉这里会成为一个性能的瓶颈。

总结

虽然 RMI 在目前看来有些过时了,但它的思想:远程仓库、服务注册、服务查找、代理调用等,和目前主流的 RPC 是不是很相似呢?一种技术的过时,往往是跟不上业务的快速发展,但它的产生至少是满足了当时的需求。

个人觉得,技术的实现会随着业务的发展不断的变化,但是核心思想一定是小步的进行,毕竟这些都是不断积累的经验总结出来的。希望本篇对大家能有所收获!

责任编辑: 鲁达

1.内容基于多重复合算法人工智能语言模型创作,旨在以深度学习研究为目的传播信息知识,内容观点与本网站无关,反馈举报请
2.仅供读者参考,本网站未对该内容进行证实,对其原创性、真实性、完整性、及时性不作任何保证;
3.本站属于非营利性站点无毒无广告,请读者放心使用!

“rmi如何传引用”边界阅读