RMI介紹
遠(yuǎn)程方法調(diào)用（RMI）顧名思義是一臺(tái)機(jī)器上的程序調(diào)用另一臺(tái)機(jī)器上的方法。這樣可以大致知道RMI是用來干什么的，但是這種理解還不太確切蜡歹。RMI是Java支撐分布式系統(tǒng)的基石憨募，例如著名的EJB組件。RMI是遠(yuǎn)程過程調(diào)用（RPC）的一種面向?qū)ο髮?shí)現(xiàn)对扶，RMI底層是通過socket通信和對(duì)象序列化技術(shù)來實(shí)現(xiàn)的区赵。
RMI基本原理
RMI的目的就是要使運(yùn)行在不同的計(jì)算機(jī)中的對(duì)象之間的調(diào)用表現(xiàn)得像本地調(diào)用一樣。RMI應(yīng)用程序通常包括兩個(gè)獨(dú)立的程序:服務(wù)器程序和客戶機(jī)程序浪南。RMI 需要將行為的定義與行為的實(shí)現(xiàn)分別定義, 并允許將行為定義代碼與行為實(shí)現(xiàn)代碼存放并運(yùn)行在不同的 JVM 上笼才。在 RMI 中, 遠(yuǎn)程服務(wù)的定義是存放在繼承了 Remote的接口中。遠(yuǎn)程服務(wù)的實(shí)現(xiàn)代碼存放在實(shí)現(xiàn)該定義接口的類中络凿。
RMI 支持兩個(gè)類實(shí)現(xiàn)一個(gè)相同的遠(yuǎn)程服務(wù)接口: 一個(gè)類實(shí)現(xiàn)行為并運(yùn)行在服務(wù)器上, 而另一個(gè)類作為一個(gè)遠(yuǎn)程服務(wù)的代理運(yùn)行在客戶機(jī)上骡送。客戶程序發(fā)出關(guān)于代理對(duì)象的調(diào)用方法, RMI 將該調(diào)用請(qǐng)求發(fā)送到遠(yuǎn)程 JVM 上, 并且進(jìn)一步發(fā)送到實(shí)現(xiàn)的方法中絮记。實(shí)現(xiàn)方法將結(jié)果發(fā)送給代理, 再通過代理將結(jié)果返回給調(diào)用者各谚。
RMI 構(gòu)建三個(gè)抽象層, 高層覆蓋低層, 分別負(fù)責(zé)Socket通信, 參數(shù)和結(jié)果的序列化和反序列化等工作。存根( Stub) 和骨架( Skeleton) 合在一起形成了 RMI 構(gòu)架協(xié)議到千。下面的引用層被用來尋找各自的通信伙伴,在這一層還有一個(gè)提供名字服務(wù)的部分, 稱為注冊(cè)表( registry) 昌渤。最下一層是傳輸層, 是依賴于 TCP/IP 協(xié)議實(shí)現(xiàn)客戶機(jī)與服務(wù)器的互聯(lián)。
當(dāng)客戶端調(diào)用遠(yuǎn)程對(duì)象方法時(shí), 存根負(fù)責(zé)把要調(diào)用的遠(yuǎn)程對(duì)象方法的方法名及其參數(shù)編組打包,并將該包向下經(jīng)遠(yuǎn)程引用層憔四、傳輸層轉(zhuǎn)發(fā)給遠(yuǎn)程對(duì)象所在的服務(wù)器膀息。通過 RMI 系統(tǒng)的 RMI 注冊(cè)表實(shí)現(xiàn)的簡單服務(wù)器名字服務(wù), 可定位遠(yuǎn)程對(duì)象所在的服務(wù)器。
該包到達(dá)服務(wù)器后, 向上經(jīng)遠(yuǎn)程引用層, 被遠(yuǎn)程對(duì)象的 Skeleton 接收, 此 Skeleton 解析客戶包中的方法名及編組的參數(shù)后, 在服務(wù)器端執(zhí)行客戶要調(diào)用的遠(yuǎn)程對(duì)象方法, 然后將該方法的返回值( 或產(chǎn)生的異常) 打包后通過相反路線返回給客戶端, 客戶端的 Stub 將返回結(jié)果解析后傳遞給客戶程序了赵。事實(shí)上, 不僅客戶端程序可以通過存根調(diào)用服務(wù)器端的遠(yuǎn)程對(duì)象的方法, 而服務(wù)器端的程序亦可通過由客戶端傳遞的遠(yuǎn)程接口回調(diào)客戶端的遠(yuǎn)程對(duì)象方法潜支。在分布式系統(tǒng)中, 所有的計(jì)算機(jī)可以是服務(wù)器, 同時(shí)又可以是客戶機(jī)。
RMI示例
Remote接口用于標(biāo)識(shí)其方法可以從非本地虛擬機(jī)上調(diào)用的接口柿汛。任何遠(yuǎn)程對(duì)象都必須直接或間接實(shí)現(xiàn)此接口冗酿。只有在“遠(yuǎn)程接口”（擴(kuò)展 java.rmi.Remote 的接口）中指定的這些方法才可遠(yuǎn)程使用。 也就是說需要遠(yuǎn)程調(diào)用的方法必須在擴(kuò)展Remote接口的接口中聲名并且要拋出RemoteException異常才能被遠(yuǎn)程調(diào)用络断。
遠(yuǎn)程對(duì)象必須實(shí)現(xiàn)java.rmi.server.UniCastRemoteObject類裁替，這樣才能保證客戶端訪問獲得遠(yuǎn)程對(duì)象時(shí)，該遠(yuǎn)程對(duì)象將會(huì)把自身的一個(gè)拷貝序列化后以Socket的形式傳輸給客戶端貌笨，此時(shí)客戶端所獲得的這個(gè)拷貝稱為“存根”弱判，而服務(wù)器端本身已存在的遠(yuǎn)程對(duì)象則稱之為“骨架”。其實(shí)此時(shí)的存根是客戶端的一個(gè)代理锥惋，用于與服務(wù)器端的通信昌腰，而骨架也可認(rèn)為是服務(wù)器端的一個(gè)代理开伏，用于接收客戶端的請(qǐng)求之后調(diào)用遠(yuǎn)程方法來響應(yīng)客戶端的請(qǐng)求。 遠(yuǎn)程對(duì)象的接口和實(shí)現(xiàn)必須在客戶端和服務(wù)器端同時(shí)存在并且保持一致才行遭商。
public interface IService extends Remote {
//聲明服務(wù)器端必須提供的服務(wù)
String service(String content) throws RemoteException;
}
// UnicastRemoteObject用于導(dǎo)出的遠(yuǎn)程對(duì)象和獲得與該遠(yuǎn)程對(duì)象通信的存根固灵。
public class ServiceImpl extends UnicastRemoteObject implements IService {
private String name;
public ServiceImpl(String name) throws RemoteException {
this.name = name;
}
public String service(String content) {
return "server >> " + content;
}
}
public class Server {
public static void main(String[] args) {
try {
// 實(shí)例化實(shí)現(xiàn)了IService接口的遠(yuǎn)程服務(wù)ServiceImpl對(duì)象
IService service02 = new ServiceImpl("service02");
// 本地主機(jī)上的遠(yuǎn)程對(duì)象注冊(cè)表Registry的實(shí)例，并指定端口為8888劫流，這一步必不可少（Java默認(rèn)端口是1099）巫玻，必不可缺的一步，缺少注冊(cè)表創(chuàng)建困介，則無法綁定對(duì)象到遠(yuǎn)程注冊(cè)表上
LocateRegistry.createRegistry(8888);
// 把遠(yuǎn)程對(duì)象注冊(cè)到RMI注冊(cè)服務(wù)器上大审，并命名為service02
//綁定的URL標(biāo)準(zhǔn)格式為：rmi://host:port/name(其中協(xié)議名可以省略，下面兩種寫法都是正確的）
Naming.bind("rmi://localhost:8888/service02",service02);
} catch (Exception e) {
e.printStackTrace();
}
System.out.println("服務(wù)器向命名表注冊(cè)了1個(gè)遠(yuǎn)程服務(wù)對(duì)象座哩！");
}
}
public class Client {
public static void main(String[] args) {
String url = "rmi://localhost:8888/";
try {
// 在RMI服務(wù)注冊(cè)表中查找名稱為service02的對(duì)象徒扶，并調(diào)用其上的方法
IService service02 =(IService) Naming.lookup(url + "service02");
Class stubClass = service02.getClass();
System.out.println(service02 + " 是 " + stubClass.getName() + " 的實(shí)例！");
// 獲得本底存根已實(shí)現(xiàn)的接口類型
Class[] interfaces = stubClass.getInterfaces();
for (Class c : interfaces) {
System.out.println("存根類實(shí)現(xiàn)了 " + c.getName() + " 接口根穷！");
}
System.out.println(service02.service("你好姜骡！"));
} catch (Exception e) {
e.printStackTrace();
}
}
}
推薦閱讀
https://my.oschina.net/huangyong/blog/345164?p=1&temp=1478851200299#blog-comments-list
