1、概述

1.1、簡(jiǎn)介

RMI 是 Java 提供的一個(gè)完善的簡(jiǎn)單易用的遠(yuǎn)程方法調(diào)用框架，采用客戶/服務(wù)器通信方式，在服務(wù)器上部署了提供各種服務(wù)的遠(yuǎn)程對(duì)象，客戶端請(qǐng)求訪問(wèn)服務(wù)器上遠(yuǎn)程對(duì)象的方法，它要求客戶端與服務(wù)器端都是 Java 程序。

RMI 框架采用代理來(lái)負(fù)責(zé)客戶與遠(yuǎn)程對(duì)象之間通過(guò) Socket 進(jìn)行通信的細(xì)節(jié)。RMI 框架為遠(yuǎn)程對(duì)象分別生成了客戶端代理和服務(wù)器端代理。位于客戶端的代理必被稱為存根（Stub），位于服務(wù)器端的代理類被稱為骨架（Skeleton）。

1.2、原理

當(dāng)客戶端調(diào)用遠(yuǎn)程對(duì)象的一個(gè)方法時(shí)，實(shí)際上是調(diào)用本地存根對(duì)象的相應(yīng)方法。存根對(duì)象與遠(yuǎn)程對(duì)象具有同樣的接口。存根采用一種與平臺(tái)無(wú)關(guān)的編碼方式，把方法的參數(shù)編碼為字節(jié)序列，這個(gè)編碼過(guò)程被稱為參數(shù)編組。RMI 主要采用Java 序列化機(jī)制進(jìn)行參數(shù)編組。

存根把以下請(qǐng)求信息發(fā)送給服務(wù)器：

• 被訪問(wèn)的遠(yuǎn)程對(duì)象的名字
• 被調(diào)用的方法的描述
• 編組后的參數(shù)的字節(jié)序列

服務(wù)器端接收到客戶端的請(qǐng)求信息，然后由相應(yīng)的骨架對(duì)象來(lái)處理這一請(qǐng)求信息，骨架對(duì)象執(zhí)行以下操作：

• 反編組參數(shù)，即把參數(shù)的字節(jié)序列反編碼為參數(shù)
• 定位要訪問(wèn)的遠(yuǎn)程對(duì)象
• 調(diào)用遠(yuǎn)程對(duì)象的相應(yīng)方法
• 獲取方法調(diào)用產(chǎn)生的返回值或者異常，然后對(duì)它進(jìn)行編組
• 把編組后的返回值或者異常發(fā)送給客戶

客戶端的存根接收到服務(wù)器發(fā)送過(guò)來(lái)的編組后的返回值或者異常，再對(duì)它進(jìn)行反編組，就得到調(diào)用遠(yuǎn)程方法的返回結(jié)果

JDK5.0 之后，RMI 框架會(huì)在運(yùn)行時(shí)自動(dòng)為運(yùn)程對(duì)象生成動(dòng)態(tài)代理類（包括存根和骨架類），從而更徹底地封裝了 RMI 框架的實(shí)現(xiàn)細(xì)節(jié)，簡(jiǎn)化了 RMI 框架的使用方式。

RMI交互圖

Stub和Skeleton通信過(guò)程

方法調(diào)用從客戶對(duì)象-經(jīng)-存根（stub）、遠(yuǎn)程引用層（Remote Reference Layer）和傳輸層（Transport Layer）向下，傳遞給主機(jī)，然后再次經(jīng)傳輸層，向上穿過(guò)遠(yuǎn)程調(diào)用層和骨干網(wǎng)（Skeleton），到達(dá)服務(wù)器對(duì)象。

• 存根：扮演著遠(yuǎn)程服務(wù)器對(duì)象的代理的角色，使該對(duì)象可被客戶激活。
• 遠(yuǎn)程調(diào)用層：處理語(yǔ)義、管理單一或多重對(duì)象的通信，決定調(diào)用是應(yīng)發(fā)往一個(gè)服務(wù)器還是多個(gè)。
• 傳輸層：管理實(shí)際的連接，并且追蹤可以接受方法調(diào)用的遠(yuǎn)程對(duì)象。
• 骨干網(wǎng)：完成對(duì)服務(wù)器對(duì)象實(shí)際的方法調(diào)用，并獲取返回值。返回值向下經(jīng)遠(yuǎn)程引用層、服務(wù)器端的傳輸層傳遞回客戶端，再向上經(jīng)傳輸層和遠(yuǎn)程調(diào)用層返回。最后，存根獲得返回值。

1.3、組成

RMI由3個(gè)部分構(gòu)成：

第一個(gè)是rmiregistry（JDK提供的一個(gè)可以獨(dú)立運(yùn)行的程序，在bin目錄下）

第二個(gè)是server端的程序，對(duì)外提供遠(yuǎn)程對(duì)象

第三個(gè)是client端的程序，想要調(diào)用遠(yuǎn)程對(duì)象的方法。

首先，先啟動(dòng)rmiregistry服務(wù)，啟動(dòng)時(shí)可以指定服務(wù)監(jiān)聽(tīng)的端口，也可以使用默認(rèn)的端口（1099）。其次，server端在本地先實(shí)例化一個(gè)提供服務(wù)的實(shí)現(xiàn)類，然后通過(guò)RMI提供的Naming/Context/Registry（下面實(shí)例用的Registry）等類的bind或rebind方法將剛才實(shí)例化好的實(shí)現(xiàn)類注冊(cè)到rmiregistry上并對(duì)外暴露一個(gè)名稱。最后，client端通過(guò)本地的接口和一個(gè)已知的名稱（即rmiregistry暴露出的名稱）再使用RMI提供的Naming/Context/Registry等類的lookup方法從RMIService那拿到實(shí)現(xiàn)類。這樣雖然本地沒(méi)有這個(gè)類的實(shí)現(xiàn)類，但所有的方法都在接口里了，便可以實(shí)現(xiàn)遠(yuǎn)程調(diào)用對(duì)象的方法了。

1.4、數(shù)據(jù)傳遞

Java程序中引用類型（不包括基本類型）的參數(shù)傳遞是按引用傳遞的，對(duì)于在同一個(gè)虛擬機(jī)中的傳遞時(shí)是沒(méi)有問(wèn)題的，因?yàn)榈膮?shù)的引用對(duì)應(yīng)的是同一個(gè)內(nèi)存空間，在分布式系統(tǒng)中，由于對(duì)象不存在于同一個(gè)內(nèi)存空間，虛擬機(jī)A的對(duì)象引用對(duì)于虛擬機(jī)B沒(méi)有任何意義，那么怎么解決這個(gè)問(wèn)題呢？

第一種：

將引用傳遞更改為值傳遞，也就是將對(duì)象序列化為字節(jié)，然后使用該字節(jié)的副本在客戶端和服務(wù)器之間傳遞，而且一個(gè)虛擬機(jī)中對(duì)該值的修改不會(huì)影響到其他主機(jī)中的數(shù)據(jù)；但是對(duì)象的序列化也有一個(gè)問(wèn)題，就是對(duì)象的嵌套引用就會(huì)造成序列化的嵌套，這必然會(huì)導(dǎo)致數(shù)據(jù)量的激增，因此我們需要有選擇進(jìn)行序列化。

在Java中一個(gè)對(duì)象如果能夠被序列化，需要滿足下面兩個(gè)條件之一：

–是Java的基本類型；

–實(shí)現(xiàn)java.io.Serializable接口（String類即實(shí)現(xiàn)了該接口）；

對(duì)于容器類，如果其中的對(duì)象是可以序列化的，那么該容器也是可以序列化的；

可序列化的子類也是可以序列化的；

第二種：

使用引用傳遞，每當(dāng)遠(yuǎn)程主機(jī)調(diào)用本地主機(jī)方法時(shí)，該調(diào)用還要通過(guò)本地主機(jī)查詢?cè)撘脤?duì)應(yīng)的對(duì)象，在任何一臺(tái)機(jī)器上的改變都會(huì)影響原始主機(jī)上的數(shù)據(jù)，因?yàn)檫@個(gè)對(duì)象是共享的；

RMI中的參數(shù)傳遞和結(jié)果返回可以使用的三種機(jī)制（取決于數(shù)據(jù)類型）：

簡(jiǎn)單類型：按值傳遞，直接傳遞數(shù)據(jù)拷貝；?

遠(yuǎn)程對(duì)象引用（實(shí)現(xiàn)了Remote接口）：以遠(yuǎn)程對(duì)象的引用傳遞；?

遠(yuǎn)程對(duì)象引用（未實(shí)現(xiàn)Remote接口）：按值傳遞，通過(guò)序列化對(duì)象傳遞副本，本身不允許序列化的對(duì)象不允許傳遞給遠(yuǎn)程方法；

在調(diào)用遠(yuǎn)程對(duì)象的方法之前需要一個(gè)遠(yuǎn)程對(duì)象的引用，如何獲得這個(gè)遠(yuǎn)程對(duì)象的引用在RMI中是一個(gè)關(guān)鍵的問(wèn)題，如果將遠(yuǎn)程對(duì)象的發(fā)現(xiàn)類比于IP地址的發(fā)現(xiàn)可能比較好理解一些。

平常我們上網(wǎng)是通過(guò)域名來(lái)定位一個(gè)網(wǎng)站，實(shí)際上網(wǎng)絡(luò)是通過(guò)IP地址來(lái)定位網(wǎng)站，因此其中就存在一個(gè)映射的過(guò)程，域名系統(tǒng)（DNS）就是為了這個(gè)目的出現(xiàn)的，在域名系統(tǒng)中通過(guò)域名來(lái)查找對(duì)應(yīng)的IP地址來(lái)訪問(wèn)對(duì)應(yīng)的服務(wù)器。

對(duì)應(yīng)的，IP地址在這里就相當(dāng)于遠(yuǎn)程對(duì)象的引用，而DNS則相當(dāng)于一個(gè)注冊(cè)表（Registry）

而域名在RMI中就相當(dāng)于遠(yuǎn)程對(duì)象的標(biāo)識(shí)符，客戶端通過(guò)提供遠(yuǎn)程對(duì)象的標(biāo)識(shí)符訪問(wèn)注冊(cè)表，來(lái)得到遠(yuǎn)程對(duì)象的引用。這個(gè)標(biāo)識(shí)符是類似URL地址格式的，它要滿足的規(guī)范如下：

該名稱是URL形式的，類似于http的URL，schema是rmi；

格式類似于rmi://host:port/name，host指明注冊(cè)表運(yùn)行的注解，port表明接收調(diào)用的端口，name是一個(gè)標(biāo)識(shí)該對(duì)象的簡(jiǎn)單名稱

主機(jī)和端口都是可選的，如果省略主機(jī)，則默認(rèn)運(yùn)行在本地；如果端口也省略，則默認(rèn)端口是1099；

2、示例

2.1、創(chuàng)建接口

創(chuàng)建一個(gè)接口Hello，該接口需要繼承Remote接口，接口所定義的方法需要拋出RemoteException異常：

//遠(yuǎn)程接口，該接口需要繼承Remote接口，并且接口中的方法全都要拋出RemoteException異常
public interface Hello extends Remote {
    public String welcome(String name) throws RemoteException;
}

2.2、實(shí)現(xiàn)接口類

基于上面定義的接口實(shí)現(xiàn)一個(gè)類Helloimpl，該實(shí)現(xiàn)類需要繼承UnicastRemoteObject類，同樣重載的方法需要拋出RemoteException異常：

/**
 * 遠(yuǎn)程接口實(shí)現(xiàn)類，必須繼承UnicastRemoteObject
 * （繼承RemoteServer->繼承RemoteObject->實(shí)現(xiàn)Remote，Serializable），
 *  只有繼承UnicastRemoteObject類，才表明其可以作為遠(yuǎn)程對(duì)象，被注冊(cè)到注冊(cè)表中供客戶端遠(yuǎn)程調(diào)用
 * （補(bǔ)充：客戶端lookup找到的對(duì)象，只是該遠(yuǎn)程對(duì)象的Stub（存根對(duì)象），
 *  而服務(wù)端的對(duì)象有一個(gè)對(duì)應(yīng)的骨架Skeleton（用于接收客戶端stub的請(qǐng)求，以及調(diào)用真實(shí)的對(duì)象）對(duì)應(yīng)，
 *  Stub是遠(yuǎn)程對(duì)象的客戶端代理，Skeleton是遠(yuǎn)程對(duì)象的服務(wù)端代理，
 *  他們之間協(xié)作完成客戶端與服務(wù)器之間的方法調(diào)用時(shí)的通信。）
 */
public class HelloImpl extends UnicastRemoteObject implements Hello {
    //因?yàn)閁nicastRemoteObject的構(gòu)造方法拋出了RemoteException異常，
    //因此這里默認(rèn)的構(gòu)造方法必須寫(xiě)，也必須聲明拋出RemoteException異常
    public HelloImpl() throws RemoteException {
    }
    @Override
    public String welcome(String name) throws RemoteException {
        return "Hello " + name;
    }
}

如果一個(gè)遠(yuǎn)程類已經(jīng)繼承了其他類，無(wú)法再繼承 UnicastRemoteObiect 類，那么可以在構(gòu)造方法中調(diào)用 UnicastRemoteObject 類的靜態(tài) expotObject 方法，同樣，遠(yuǎn)程類的構(gòu)造方法也必須聲明拋出 RemoteException

public class HelloImpl2 implements Hello {
    @Override
    public String welcome(String name) throws RemoteException {
        return "Hello " + name;
    }
    public HelloImpl2() throws RemoteException{
        //參數(shù) port 指定監(jiān)聽(tīng)的端口，如果取值為0，就表示監(jiān)聽(tīng)任意一個(gè)匿名端口
        UnicastRemoteObject.exportObject(this, 0);
    }
}

2.3、創(chuàng)建服務(wù)端

服務(wù)端創(chuàng)建了一個(gè)注冊(cè)表，并注冊(cè)了客戶端需要的對(duì)象：

public class Server {
    public static void main(String[] args) throws RemoteException {
        //創(chuàng)建對(duì)象
        Hello hello = new HelloImpl();
        // 本地主機(jī)上的遠(yuǎn)程對(duì)象注冊(cè)表Registry的實(shí)例，
        // 并指定端口，這一步必不可少（Java默認(rèn)端口是1099）
        Registry registry = LocateRegistry.createRegistry(1099);
        //綁定對(duì)象到注冊(cè)表，并給它取名為hello
        registry.rebind("hello", hello);
    }
}

向注冊(cè)器注冊(cè)遠(yuǎn)程對(duì)象有三種方式：

//創(chuàng)建遠(yuǎn)程對(duì)象
HelloService service1 = new HelloServiceImpl("service1");
//方式1:調(diào)用 java.i.registry.Registy 接口的 bind 或 rebind 方法
Registry registry = LocateRegistry.createRegistry(1099);
registry.rebind("HelloService1", service1);
//方式2:調(diào)用命名服務(wù)類 java.rmi.Naming 的 bind 或 rebind 方法
Naming.rebind("HelloService1"， service1);
//方式3:調(diào)用 JNDI API 的 javax.naming.Context 接口的 bind 或rebind 方法
Context namingContext = new InitialContext();
namingContext.rebind("rmi:HelloService1", service1);

2.4、客戶端調(diào)用遠(yuǎn)程對(duì)象

public class Client {
    public static void main(String[] args) throws RemoteException, NotBoundException {
        //獲取到注冊(cè)表的代理
        Registry registry = LocateRegistry.getRegistry("localhost", 1099);
        //利用注冊(cè)表的代理去查詢遠(yuǎn)程注冊(cè)表中名為hello的對(duì)象
        Hello hello = (Hello) registry.lookup("hello");
        //調(diào)用遠(yuǎn)程方法
        System.out.println(hello.welcome("tom"));
    }
}

2.5、運(yùn)行結(jié)果

先運(yùn)行服務(wù)端，再運(yùn)行客戶端：

3、其它

3.1、遠(yuǎn)程方法中的參數(shù)與返回值傳遞

當(dāng)客戶端調(diào)用服務(wù)器端的遠(yuǎn)程對(duì)象的方法時(shí)，客戶端會(huì)向服務(wù)器端傳遞參數(shù)，服務(wù)器端則會(huì)向客戶端傳遞返回值。RMI 規(guī)范對(duì)參數(shù)以及返回值的傳遞的規(guī)定如下所述：

• 只有基本類型的數(shù)據(jù)、遠(yuǎn)程對(duì)象以及可序列化的對(duì)象才可以被作為參數(shù)或者返回值進(jìn)行傳遞
• 如果參數(shù)或返回值是一個(gè)遠(yuǎn)程對(duì)象，那么把它的存根對(duì)象傳遞到接收方。也就是說(shuō)接收方得到的是遠(yuǎn)程對(duì)象的存根對(duì)象
• 如果參數(shù)或返回值是可序列化對(duì)象，那么直接傳遞該對(duì)象的序列化數(shù)據(jù)。也就是說(shuō)接收方得到的是發(fā)送方的可序列化對(duì)象的復(fù)制品
• 如果參數(shù)或返回值是基本類型的數(shù)據(jù)，那么直接傳遞該數(shù)據(jù)的序列化數(shù)據(jù)。也就是說(shuō)，接收方得到的是發(fā)送方的基本類型的數(shù)據(jù)的復(fù)制品

3.2、分布式垃圾收集

在 Java 虛擬機(jī)中，對(duì)于一個(gè)本地對(duì)象，只要不被本地 Java 虛擬機(jī)內(nèi)的任何變量引用，它就會(huì)結(jié)束生命周期，可以被垃圾回收器回收。而對(duì)于一個(gè)遠(yuǎn)程對(duì)象，不僅會(huì)被本地 Java 虛擬機(jī)內(nèi)的變量引用，還會(huì)被遠(yuǎn)程引用

服務(wù)器端的一個(gè)遠(yuǎn)程對(duì)象受到三種引用：

• 服務(wù)器端的一個(gè)本地對(duì)象持有它的本地引用
• 這個(gè)遠(yuǎn)程對(duì)象已經(jīng)被注冊(cè)到 RMI 注冊(cè)器，可以理解為，RMI 注冊(cè)器持有它的引用
• 客戶端獲得了這個(gè)遠(yuǎn)程對(duì)象的存根對(duì)象，可以理解為，客戶端持有它的遠(yuǎn)程引用

RMI 框架采用分布式垃圾收集機(jī)制來(lái)管理遠(yuǎn)程對(duì)象的生命周期，當(dāng)一個(gè)遠(yuǎn)程對(duì)象不受到任何本地引用和遠(yuǎn)程引用時(shí)，這個(gè)遠(yuǎn)程對(duì)象才會(huì)結(jié)束生命周期，并且可以被本地 Java 虛擬機(jī)的垃圾回收器回收。

服務(wù)器端如何知道客戶端持有一個(gè)遠(yuǎn)程對(duì)象的遠(yuǎn)程引用呢？當(dāng)客戶端獲得了一個(gè)服務(wù)器端的遠(yuǎn)程對(duì)象的存根后，就會(huì)向服務(wù)器發(fā)送一條租約通知，告訴服務(wù)器自己持有這個(gè)遠(yuǎn)程對(duì)象的引用了?？蛻舳藢?duì)這個(gè)遠(yuǎn)程對(duì)象有一個(gè)租約期限，默認(rèn)值為 600000ms。當(dāng)至達(dá)了租約期限的一半時(shí)間，客戶如果還持有遠(yuǎn)程引用，就會(huì)再次向服務(wù)器發(fā)送租約通知?？蛻舳瞬粩嘣诮o定的時(shí)間間隔中向服務(wù)器發(fā)送租約通知，從而使腸務(wù)器知道客戶端一直持有遠(yuǎn)程對(duì)象的引用。如果在租約到期后，服務(wù)器端沒(méi)有繼續(xù)收到客戶端的新的租約通知，服務(wù)器端就會(huì)認(rèn)為這個(gè)客戶已經(jīng)不再持有遠(yuǎn)程對(duì)象的引用了

3.3、動(dòng)態(tài)加載

遠(yuǎn)程對(duì)象一般分布在服務(wù)器端，當(dāng)客戶端試圖調(diào)用遠(yuǎn)程對(duì)象的方法時(shí)，如果在客戶端還不存在遠(yuǎn)程對(duì)象所依賴的類文件，比如遠(yuǎn)程方法的參數(shù)和返回值對(duì)應(yīng)的類文件，客戶就會(huì)從 java.rmi.server.codebase 系統(tǒng)屬性指定的位貿(mào)動(dòng)態(tài)加載該類文件

同樣，當(dāng)服務(wù)器端訪問(wèn)客戶端的遠(yuǎn)程對(duì)象時(shí)，如果服務(wù)器端不存在相關(guān)的類文件，腐務(wù)器就會(huì)從 java.rmi.server.codebase 屬性指定的位置動(dòng)態(tài)加載它們

此外，當(dāng)服務(wù)器向 RMI 注冊(cè)器注冊(cè)遠(yuǎn)程對(duì)象時(shí)，注冊(cè)器也會(huì)從 java.rmi.server.codebase 屬性指定的位置動(dòng)態(tài)加載相關(guān)的遠(yuǎn)程接口的類文件

前面的例子都是在同一個(gè) classpath 下運(yùn)行服務(wù)器程序以及客戶程序的，這些程序都能從本地 classpath 中找到相應(yīng)的類文件，因此無(wú)須從 java.rmi.server.codebase 屬性指定的位置動(dòng)態(tài)加載類。而在實(shí)際應(yīng)用中，客戶程序與服務(wù)器程序運(yùn)行在不同的主機(jī)上，因此當(dāng)客戶端調(diào)用服務(wù)器端的遠(yuǎn)程對(duì)象的方法時(shí)，有可能需要從遠(yuǎn)程文件系統(tǒng)加載類文件。同樣，當(dāng)服務(wù)器端調(diào)用客戶端的遠(yuǎn)程對(duì)象的方法時(shí)，也有可能從遠(yuǎn)程文件系統(tǒng)加載類文件

我們可以且把這些需要被加載的類的文件都集中放在網(wǎng)絡(luò)上的同一地方，啟動(dòng)時(shí)將java.rmi.server.codebase 設(shè)置為指定位置，從而實(shí)現(xiàn)動(dòng)態(tài)加載

start java -Djava.rmi.server.codebase=http://www.javathinker.net/download/

到此這篇關(guān)于Java中的RMI使用方法詳解的文章就介紹到這了,更多相關(guān)Java RMI使用內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

最新評(píng)論