企業(yè)神奇中間件-RPC之RMI(上)

作者：大蕉 2018-06-12 15:10:49

RMI技術(shù)有兩種使用方式，分別是繼承 UnicastRemoteObject 的由服務(wù)端直接提供服務(wù)對象類，以及繼承 Activatable 的由注冊中心提供激活的服務(wù)對象的方式。

說了那么久，到底什么是 RMI （Java Remote Method Invocation）呢？我們來看看維基百科的解釋。

In computing, the Java Remote Method Invocation (Java RMI) is a Java API that performs remote method invocation, the object-oriented equivalent of remote procedure calls (RPC), with support for direct transfer of serialized Java classes and distributed garbage-collection.

emmm....，就是一個(gè)專門給 Java 提供的一個(gè)遠(yuǎn)程方法調(diào)用，以及進(jìn)行實(shí)現(xiàn) RPC 的一個(gè) Java API，可以用來遠(yuǎn)程傳輸序列化類，以及實(shí)現(xiàn)分布式垃圾回收。完全obbqk，咱今天也分成幾個(gè)階段來看看RMI，Java Remote Method Invocation，Java 遠(yuǎn)程方法調(diào)用。具體是怎么玩的，怎么去使用它，又是什么原理。

[[232665]]

說走咱就走啊，僅需體驗(yàn)三番鐘，你揍會(huì)甘我一樣，愛上介款 RPC 。首先，看到這個(gè)鏈接。https://github.com/CallMeDJ/BigBanana-rpc.git

小心翼翼打開命令行終端，就那么git clone 一下。

貼心的我已經(jīng)為你準(zhǔn)備好了，你拷貝一下就行了，當(dāng)然你要是沒有 git 那就下載一個(gè)。

git clone https://github.com/CallMeDJ/BigBanana-rpc.git

然后用 JetBrains 的 IntelliJ IDEA import 一下，喏就這個(gè)Import Project，瘋狂點(diǎn)下一步就好了。

等 IDEA 的界面打開后，然后右鍵點(diǎn)一下 Provider 的 Run 'Provider.main()'。

再右鍵點(diǎn)一下 Consumer 的 Run 'Consumer.main()'.

然后在 console 控制臺(tái)，瞎打一些東西。然后用全身的力氣按一下 Enter ，你會(huì)發(fā)現(xiàn)，咦，發(fā)現(xiàn)有一些數(shù)字回顯出來。喔雪特你這么這么厲害？？恭喜恭喜，你學(xué)會(huì)了RMI了。

emmm...好了，歡迎大家來到 RMI 第二層，上套路，講代碼，這上邊這玩意怎么寫出來的呢？

Service

首先定義一個(gè)服務(wù) HelloService ，有一個(gè)名字叫 hello 的方法，返回一個(gè) Integer 。

ServiceImpl

實(shí)現(xiàn)它！HelloServiceImpl 實(shí)現(xiàn)了 HelloService 的 hello 方法，直接返回字符串的 hashCode。

至于為什么要繼承 UnicastRemoteObject 呢。文檔上的注釋是這樣的。用來曝露一個(gè)擁有對象引用，然后用 JRMP 協(xié)議溝通的遠(yuǎn)程對象。當(dāng)然看不懂也沒關(guān)系，就當(dāng)沒看見繼續(xù)往下走。

/** 
 * Used for exporting a remote object with JRMP and obtaining a stub 
 * that communicates to the remote object. 
 *

Provider

定義一個(gè) Provider，用來對外暴露服務(wù)。

先初始化一個(gè) HelloService 服務(wù)。

HelloService helloService  = new HelloServiceImpl();

生成一個(gè)注冊表中心，用來將服務(wù)注冊到這個(gè)地方，注意這里一定要先寫，不然后邊的服務(wù)就沒法注冊上來了。

Registry registry = LocateRegistry.createRegistry(8888);

將初始化完的服務(wù)，注冊到注冊中心中，這樣，其他地方就可以通過注冊中心獲取到這個(gè)服務(wù)啦。

Naming.bind("rmi://127.0.0.1:8888/hello",helloService);

線程池的作用是避免應(yīng)用被關(guān)掉，關(guān)鍵代碼其實(shí)就上邊那三行。

Consumer

好了，輪到 Consumer 了。

啦。

尋找一下注冊中心。

Registry registry = LocateRegistry.getRegistry(8888);

把那個(gè)名字叫 hello 的服務(wù)找出來

HelloService masterService = (HelloService)registry.lookup("hello");

把當(dāng)前 console 的那行值取出來，然后調(diào)用一下 HelloService 的服務(wù)，打印到 console。

String command = scanner.nextLine(); 
System.out.println(masterService.hello(command));

完美~你可以寫自己基于 RMI 的服務(wù)了。隨便找個(gè)地方搞一個(gè)注冊中心，注冊一大堆服務(wù)上去，其他地方就可以通過這個(gè)注冊中心調(diào)用了了。

好了，歡迎大家來到 RMI 第三層，上原理，講設(shè)計(jì)。好了，能耐心看到這里的，估計(jì)還是對這個(gè)技術(shù)有點(diǎn)想了解，那么我們繼續(xù)講，關(guān)于這個(gè) RMI 技術(shù)的原理。

還是回到這個(gè)圖，我們可以看到其實(shí)這個(gè)架構(gòu)還是蠻簡單的。首先 RMI 是基于 socket 技術(shù)進(jìn)行網(wǎng)絡(luò)通訊的。其次本地調(diào)用的是一個(gè)叫 Client stub (存根)，而這個(gè)存根跟客戶端是處于同一 JVM 的。第三 Server 端其實(shí)也有一個(gè)一模一樣的存根，從技術(shù)上來講，這兩個(gè)存根里邊的內(nèi)容是一摸一樣的，只是從 Server 端下載到了 Client 端。

第一種：

1、啟動(dòng)一個(gè)注冊中心，這個(gè)注冊中心是用 rmi 協(xié)議的，可以啟動(dòng)在本地的JVM也可以啟動(dòng)在其他地方。都是使用這個(gè)。這就是 RMI 強(qiáng)大的地方所在了，不僅僅 Consumer 和 Provider 可以遠(yuǎn)程，連注冊中心都既可以運(yùn)行在本地，也可以運(yùn)行在遠(yuǎn)程。

LocateRegistry.createRegistry(8888);

2、Provider 本地啟動(dòng)一個(gè) SocketServer ，用來進(jìn)行服務(wù)提供。找到注冊中心，然后向注冊中心，以某個(gè)服務(wù)名字(比如 hello) 將自己注冊到注冊中心中，本地保留一個(gè) stub 存根。

3、Consumer 找到注冊中心，找到后尋求某個(gè)服務(wù)名字(比如 hello)，得到服務(wù)端 Provider 的 socket 地址，其實(shí)也就是 ip 和端口。

4、Consumer 用 socket 調(diào)用 Provider ，請求某個(gè)服務(wù)，Provider 用 JRMP（Java Remote Method Protocol）把本地服務(wù)的整個(gè) Java 對象進(jìn)行序列化打個(gè)大包，然后寫到 socket 中。

5、Consumer 拿到這個(gè)對象流后呢，用 JRMP 進(jìn)行反序列化，然后創(chuàng)建一個(gè)代理對象，交給調(diào)用方。

6、調(diào)用方拿著這個(gè)代理，進(jìn)行本地調(diào)用。

好了，這就結(jié)束了第一種了。我們看到上邊的第6點(diǎn)，其實(shí)這些遠(yuǎn)程調(diào)用并不是遠(yuǎn)程調(diào)用，只是遠(yuǎn)程把整個(gè)對象下載到本地，然后在本地跑這些方法。所以呢，你如果覺得每次都 hold 住這個(gè)代理，就可以了，那你就錯(cuò)了，一旦 Provider 有任何變更，你這樣干的話，是獲取不到最新的服務(wù)的。

雖然我感覺你的聽得云里霧里，但是我不管，我就繼續(xù)來說說第二種吧。。第二種會(huì)直接把類文件放到注冊中心，然后在恰當(dāng)?shù)膶?shí)際進(jìn)行"激活"。什么叫激活呢，我的理解就是對類進(jìn)行初始化，然后用序列化的方式交給調(diào)用方。