企業(yè)神奇中間件-RPC之RMI(上)
說了那么久,到底什么是 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)用。具體是怎么玩的,怎么去使用它,又是什么原理。
說走咱就走啊,僅需體驗(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è)擁有對(duì)象引用,然后用 JRMP 協(xié)議溝通的遠(yuǎn)程對(duì)象。當(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,用來對(duì)外暴露服務(wù)。
先初始化一個(gè) HelloService 服務(wù)。
- HelloService helloService = new HelloServiceImpl();
生成一個(gè)注冊(cè)表中心,用來將服務(wù)注冊(cè)到這個(gè)地方,注意這里一定要先寫,不然后邊的服務(wù)就沒法注冊(cè)上來了。
- Registry registry = LocateRegistry.createRegistry(8888);
將初始化完的服務(wù),注冊(cè)到注冊(cè)中心中,這樣,其他地方就可以通過注冊(cè)中心獲取到這個(gè)服務(wù)啦。
- Naming.bind("rmi://127.0.0.1:8888/hello",helloService);
線程池的作用是避免應(yīng)用被關(guān)掉,關(guān)鍵代碼其實(shí)就上邊那三行。
- Consumer
好了,輪到 Consumer 了。
啦。
尋找一下注冊(cè)中心。
- 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è)注冊(cè)中心,注冊(cè)一大堆服務(wù)上去,其他地方就可以通過這個(gè)注冊(cè)中心調(diào)用了了。
好了,歡迎大家來到 RMI 第三層,上原理,講設(shè)計(jì)。好了,能耐心看到這里的,估計(jì)還是對(duì)這個(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 端。
RMI技術(shù)有兩種使用方式,分別是繼承 UnicastRemoteObject 的 由服務(wù)端直接提供服務(wù)對(duì)象類,以及繼承 Activatable 的由注冊(cè)中心提供激活的服務(wù)對(duì)象的方式。
第一種:
1、啟動(dòng)一個(gè)注冊(cè)中心,這個(gè)注冊(cè)中心是用 rmi 協(xié)議的,可以啟動(dòng)在本地的JVM也可以啟動(dòng)在其他地方。都是使用這個(gè)。這就是 RMI 強(qiáng)大的地方所在了,不僅僅 Consumer 和 Provider 可以遠(yuǎn)程,連注冊(cè)中心都既可以運(yùn)行在本地,也可以運(yùn)行在遠(yuǎn)程。
- LocateRegistry.createRegistry(8888);
2、Provider 本地啟動(dòng)一個(gè) SocketServer ,用來進(jìn)行服務(wù)提供。找到注冊(cè)中心,然后向注冊(cè)中心,以某個(gè)服務(wù)名字(比如 hello) 將自己注冊(cè)到注冊(cè)中心中,本地保留一個(gè) stub 存根。
3、Consumer 找到注冊(cè)中心,找到后尋求某個(gè)服務(wù)名字(比如 hello),得到服務(wù)端 Provider 的 socket 地址,其實(shí)也就是 ip 和 端口。
4、Consumer 用 socket 調(diào)用 Provider ,請(qǐng)求某個(gè)服務(wù),Provider 用 JRMP(Java Remote Method Protocol)把本地服務(wù)的整個(gè) Java 對(duì)象進(jìn)行序列化打個(gè)大包,然后寫到 socket 中。
5、Consumer 拿到這個(gè)對(duì)象流后呢,用 JRMP 進(jìn)行反序列化,然后創(chuàng)建一個(gè)代理對(duì)象,交給調(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è)對(duì)象下載到本地,然后在本地跑這些方法。所以呢,你如果覺得每次都 hold 住這個(gè)代理,就可以了,那你就錯(cuò)了,一旦 Provider 有任何變更,你這樣干的話,是獲取不到最新的服務(wù)的。
雖然我感覺你的聽得云里霧里,但是我不管,我就繼續(xù)來說說第二種吧。。第二種會(huì)直接把類文件放到注冊(cè)中心,然后在恰當(dāng)?shù)膶?shí)際進(jìn)行"激活"。什么叫激活呢,我的理解就是對(duì)類進(jìn)行初始化,然后用序列化的方式交給調(diào)用方。
1、啟動(dòng)一個(gè)注冊(cè)中心,這個(gè)注冊(cè)中心是用 rmi 協(xié)議的,可以啟動(dòng)在本地的JVM也可以啟動(dòng)在其他地方。都是使用這個(gè)。這就是 RMI 強(qiáng)大的地方所在了,不僅僅 Consumer 和 Provider 可以遠(yuǎn)程,連注冊(cè)中心都既可以運(yùn)行在本地,也可以運(yùn)行在遠(yuǎn)程。
- LocateRegistry.createRegistry(8888);
2、Provider 初始化一個(gè)對(duì)象,然后類文件和自己的激活I(lǐng)D,激活組ID都放到注冊(cè)中心。
3、Consumer 找到注冊(cè)中心,找到后尋求某個(gè)激活I(lǐng)D,激活組ID的服務(wù),請(qǐng)求進(jìn)行存根請(qǐng)求。
4、Consumer 用 socket 從請(qǐng)求注冊(cè)中心取得存根,注冊(cè)中心對(duì)類進(jìn)行初始化(激活),然后 用 JRMP(Java Remote Method Protocol)把激活后的的整個(gè) Java 對(duì)象進(jìn)行序列化打個(gè)大包,然后寫到 socket 中。
5、Consumer 拿到來自注冊(cè)中心的這個(gè)對(duì)象流后呢,用 JRMP 進(jìn)行反序列化,然后創(chuàng)建一個(gè)代理對(duì)象,交給調(diào)用方。
6、調(diào)用方拿著這個(gè)代理,進(jìn)行本地調(diào)用。
綜上所述,RMI 就是把類下載到本地跑一波。
歡迎大家來到 RMI 第四層,講源碼。好了,下面很枯燥很枯燥,都是源碼,不開心的可以退出了,抓緊時(shí)間。要是不想退出,來都來了,看看唄反正也不吃虧。
算了,下次再說了,我要去吃飯了。有人問我既然不寫了為什么不刪掉上邊那段話,我覺得既然字被打出來了那就是有生命的,把它刪掉好像把它殺了似的,不忍心。。。
【本文為51CTO專欄作者“大蕉”的原創(chuàng)稿件,轉(zhuǎn)載請(qǐng)通過作者微信公眾號(hào)“一名叫大蕉的程序員”獲取授權(quán)】