Java RMI使用方式与技巧总结

RMI介绍

RMI全名Remote Method Invocation,用于java程序远程方法(不存在于本地中的方法)调用。是java实现分布式的实现方案之一。它可以被看作是RPC的Java版本。但是传统RPC并不能很好地应用于分布式对象系统。而Java RMI 则支持存储于不同地址空间的程序级对象之间彼此进行通信,实现远程对象之间的无缝远程调用。

RMI开发使用步骤:

RMI将一个基础的Java类通过实现相应的方式,使其可以被其它的外部项目使用。步骤很简单:

  • 步骤一
    制作远程接口。远程接口其实就是本地的一个需要RMI转化的普通接口。提供客户端需要的服务。这个远程接口必须要继承接口Remote

  • 步骤二
    实现远程接口在本地创建其远程接口的实现类。此处可以通过继承JDK中的超类UnicastRemoteObject,进行实现,跳过一些复杂的实现内容。此步骤需要考虑一下异常的处理。实现超类后其构造函数的异常需要捕获。

  • 步骤三
    开启注册。使用指令rmiregistry。

  • 步骤四

启动本地(服务端)的程序,生成对应的target编译文件。注意:第三步与第四步不可逆。不开启服务的情况下,注册是会失败的。导致远程(客户端)调用服务程序出现异常。

  • 步骤五

执行指令rmic +你对应的类的全名。需要注意的是,rmic指令执行的时候,需要把文件夹定位到其target的source下,对于我的尝试项目来说,就是编译后的classes文件夹下,不同的人可能会有不一样的编译路径,同时文件名必须用全名否则其编译指令将会报错找不到对应的文件

  • 步骤六
    为需要调用的远程提供服务端生成的文件。对于步骤五在执行过后,默认的情况下会在服务端的目录下生成一份.class文件。将这份class文件复制到对应的远程(客户端)下即可让客户端调用远程的服务了。

我的项目结构及代码

服务端需要处理的:

package com.model.design.agency;

import java.rmi.RemoteException;
import java.rmi.server.UnicastRemoteObject;

public class MyRemoteImpl extends UnicastRemoteObject implements MyRemote {

    public MyRemoteImpl() throws RemoteException {
    }

    public String doNothing() throws RemoteException {
        return "hasaki";
    }

    public String doSomething() throws RemoteException {
        return "hasai";
    }
}
package com.model.design.agency;

import java.rmi.Remote;
import java.rmi.RemoteException;

public interface MyRemote extends Remote {
    String doNothing() throws RemoteException;
    String doSomething() throws RemoteException;
}
package com.model.design.agency;

import java.net.MalformedURLException;
import java.rmi.AlreadyBoundException;
import java.rmi.Naming;
import java.rmi.RemoteException;
import java.rmi.registry.LocateRegistry;

public class TestClass {
    public static void main(String[] args) {
        try {
            MyRemote remote=new MyRemoteImpl();
            LocateRegistry.createRegistry(1100);
            Naming.rebind("rmi://127.0.0.1:1100/RHello",remote);
        } catch (RemoteException e) {
            e.printStackTrace();
        } catch (MalformedURLException e) {
            e.printStackTrace();
        }
        System.out.println("success");
    }
}

服务端的编译路径:


编译结构.png

客户端需要做的:

目录结构.png

其中MyRemote接口值与服务端内容一致。
服务端编译后生成的—Stub(在RMI中被称为桩的东西,此外还有被称为骨架的存在,但是因为版本迭代原因骨架貌似是被摒弃了)文件:


编译文件路径地址.png

编译后生成的文件内容如下:

//
// Source code recreated from a .class file by IntelliJ IDEA
// (powered by Fernflower decompiler)
//

package com.model.design.agency;

import java.lang.reflect.Method;
import java.rmi.Remote;
import java.rmi.RemoteException;
import java.rmi.UnexpectedException;
import java.rmi.server.RemoteRef;
import java.rmi.server.RemoteStub;

public final class MyRemoteImpl_Stub extends RemoteStub implements MyRemote, Remote {
    private static final long serialVersionUID = 2L;
    private static Method $method_doNothing_0;
    private static Method $method_doSomething_1;

    static {
        try {
            $method_doNothing_0 = (class$com$model$design$agency$MyRemote != null ? class$com$model$design$agency$MyRemote : (class$com$model$design$agency$MyRemote = class$("com.model.design.agency.MyRemote"))).getMethod("doNothing");
            $method_doSomething_1 = (class$com$model$design$agency$MyRemote != null ? class$com$model$design$agency$MyRemote : (class$com$model$design$agency$MyRemote = class$("com.model.design.agency.MyRemote"))).getMethod("doSomething");
        } catch (NoSuchMethodException var0) {
            throw new NoSuchMethodError("stub class initialization failed");
        }
    }

    public MyRemoteImpl_Stub(RemoteRef var1) {
        super(var1);
    }

    public String doNothing() throws RemoteException {
        try {
            Object var1 = super.ref.invoke(this, $method_doNothing_0, (Object[])null, 3201213088384021920L);
            return (String)var1;
        } catch (RuntimeException var2) {
            throw var2;
        } catch (RemoteException var3) {
            throw var3;
        } catch (Exception var4) {
            throw new UnexpectedException("undeclared checked exception", var4);
        }
    }

    public String doSomething() throws RemoteException {
        try {
            Object var1 = super.ref.invoke(this, $method_doSomething_1, (Object[])null, -5449258171918619596L);
            return (String)var1;
        } catch (RuntimeException var2) {
            throw var2;
        } catch (RemoteException var3) {
            throw var3;
        } catch (Exception var4) {
            throw new UnexpectedException("undeclared checked exception", var4);
        }
    }
}

这个不是一个java文件,并不符合java的编程语法,使用的时候将其放置在对应的编译,路径之下就好了。需要java文件的话,可以使用rmic -keep指令保存生成的java文件。默认情况下,这个生成的java文件是作为一个临时文件存在的,会被删除,使用keep指令就可以保证其不被删除了
客户端调用

package com.intretech.ums.mailsystem.controller;

import com.model.design.agency.MyRemote;
import com.model.design.agency.MyRemoteImpl;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;

import java.rmi.RemoteException;

@RestController
public class RMIController {
    @RequestMapping("/doSomething")
    public String doSomething(){
        String some=null;
        MyRemote remote=new MyRemoteImpl();
        try {
            some=remote.doSomething();
        } catch (RemoteException e) {
            e.printStackTrace();
        }
        return some;
    }
}

至于rmic指令只要你正确配置了jdk跟jre的环境变量路径就可以使用了,如果使用指令失败,请再三确认一下路径是否正常。transient关键字可以限制将一些对象不进行网络传输

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 面向对象编程(OOP) Java是一个支持并发、基于类和面向对象的计算机编程语言。下面列出了面向对象软件开发的优点...
    大家请叫我小杰阅读 4,814评论 0 0
  • 面向对象编程(OOP) Java是一个支持并发、基于类和面向对象的计算机编程语言。下面列出了面向对象软件开发的优点...
    hutuxiaogui阅读 4,447评论 0 2
  • Java是一个支持并发、基于类和面向对象的计算机编程语言。下面列出了面向对象软件开发的优点: 代码开发模块化,更易...
    安安静静写代码阅读 4,719评论 0 8
  • 大家好,我是IT修真院北京分院第31期的学员,一枚正直纯洁善良的JAVA程序员。今天给大家分享一下,修真...
    ve追风_685b阅读 8,155评论 0 1
  • JAVA面试题 1、作用域public,private,protected,以及不写时的区别答:区别如下:作用域 ...
    JA尐白阅读 4,860评论 1 0