Hadoop的IPC：

（1）實(shí)現(xiàn)RPC的一種方法，具有快速、簡(jiǎn)單的特點(diǎn)。 它不像Sun公司提供的標(biāo)準(zhǔn)RPC包，基于Java序列化。

（2）IPC無需創(chuàng)建網(wǎng)絡(luò)stubs和skeletons。

（3）IPC中的方法調(diào)用要求參數(shù)和返回值的數(shù)據(jù)類型必須是Java的基本類型，String和Writable接口的實(shí)現(xiàn)類，以及元素為以上類型的數(shù)組。接口方法應(yīng)該只拋出IOException異常。

構(gòu)建思路：

（1）采用客戶/服務(wù)器模型

（2）Server：它把Java接口暴露給客戶端。指定好監(jiān)聽端口和接受遠(yuǎn)程調(diào)用的對(duì)象實(shí)例后，通過RPC.getServer()可以得到Server實(shí)例。

（3）Client：連接Server，調(diào)用它所暴露的方法。Client必須指定遠(yuǎn)程機(jī)器的地址，端口和Java接口類，通過RPC.getClient()可以得到Client實(shí)例。

（4）Server不可以向Client發(fā)出調(diào)用，但在Hadoop中，有雙向調(diào)用的需求。 比如在DFS，NameNode和DataNode需要互相了解狀態(tài)。

詳細(xì)設(shè)計(jì)：

（1）Writable接口，實(shí)現(xiàn)此接口的類可以把類中的域放入流中以及從流中讀數(shù)據(jù)到域中。

（2）對(duì)象在傳遞時(shí)按照：對(duì)象類名+對(duì)象類名長度+對(duì)象序列化數(shù)據(jù)，的格式傳輸，需要一個(gè)類可以解析這種格式，這個(gè)類是ObjectWritable，這個(gè)類需要知道所有實(shí)現(xiàn)Writable的類，以便可以通過類名生成新的對(duì)象，故此類依賴于WritableFactories，那存儲(chǔ)了Writable子類對(duì)應(yīng)的工廠。

（3）Client類用來和Server通信，一個(gè)Client可以發(fā)起多個(gè)連接，連接需要標(biāo)識(shí)，使用Client.ConnectionId（包含InetSocketAddress，UserGroupInformation，Class<?>）。每個(gè)連接有多個(gè)調(diào)用，使用Client.Call標(biāo)識(shí)（包含int<id>，Writable<param，value>，IOException，boolean<done>）。每個(gè)連接用Hashtable<Integer, Call>保存發(fā)起的調(diào)用。

（4）RPC是Server和Client的結(jié)合，waitForProxy方法用來返回一個(gè)所有可以采用這種IPC調(diào)用的所有接口的父接口VersionedProtocol，其他不同的接口繼承這個(gè)父接口，這些接口需要有一個(gè)版本號(hào)。waitForProxy方法的參數(shù)應(yīng)該有用戶想要調(diào)用方法的接口類<Class>，遠(yuǎn)程調(diào)用的地址<InetAddress>等等。waitForProxy方法返回的是一個(gè)動(dòng)態(tài)代理，真正完成方法遠(yuǎn)程調(diào)用的是RPC.Invoker因?yàn)椋鼘?shí)現(xiàn)了InvocationHandler接口。

（5）Invoker主要從緩存中取一個(gè)Client出來，然后調(diào)用Client.call方法，這個(gè)方法需要知道方法名，方法參數(shù)，方法聲明類以及遠(yuǎn)端地址。

（6）Client.call方法需要根據(jù)ConnectionId從緩存中獲得Connection，或者新建立一個(gè)Connection。Connection的sendParam方法供調(diào)用call的線程發(fā)送調(diào)用參數(shù)（方法名，方法參數(shù)，方法聲明類），在調(diào)用sendParam之前，Connection已經(jīng)建立好連接并發(fā)送ConnectionHeader，之后立刻啟動(dòng)接受線程，接受到的可能是函數(shù)調(diào)用的結(jié)果，也可能是連接上的異常消息。

（7）Server的Listen線程負(fù)責(zé)監(jiān)聽新連接并把讀取的調(diào)用參數(shù)放入BlockingQueue隊(duì)列，Handler線程負(fù)責(zé)從隊(duì)列中拿出Call對(duì)象進(jìn)行處理。

（8）Hadoop的IPC框架做得很好，接下來準(zhǔn)備仿照實(shí)現(xiàn)一個(gè)，更好的發(fā)現(xiàn)這個(gè)框架的實(shí)現(xiàn)技巧。