? ? ? ? 社區(qū)版HBase-1.0.0里面的RPC跟hadoop中的RPC差不多，也是用了protobuffer雨让、nio等技術(shù)來(lái)實(shí)現(xiàn)的哀卫。下面主要通過客戶端跟服務(wù)器端兩個(gè)部分以及一次createtable請(qǐng)求來(lái)講解hbase中的RPC。
一矾兜、客戶端
? ? ? ? 這里客戶端做的事情非常簡(jiǎn)單托嚣，就是編寫java代碼巩检，生成一個(gè)隨機(jī)字符串，然后以該字符串為表名示启，發(fā)出一個(gè)建表的請(qǐng)求（HBase還沒有任何權(quán)限控制）兢哭。下面是用eclipse一直跟蹤到發(fā)出網(wǎng)絡(luò)請(qǐng)求的方法調(diào)用棧。
? ? ? ? 關(guān)于客戶端部分夫嗓，覺得最值得一提的還是使用protobuffer的部分（吐槽一句要不是因?yàn)檫@個(gè)迟螺，客戶端真的會(huì)簡(jiǎn)單很多）。下面是client端使用到的跟protobuffer有關(guān)的類的類圖：
? ? ? ? 首先是MasterProtos類啤月，這個(gè)類以protobuffer方式封裝了所有有關(guān)的請(qǐng)求與應(yīng)答煮仇，例如CreateTableRequest 以及CreateTableResponse；接著是MasterService這個(gè)類谎仲，這里以抽象方法的形式定義了差不多所有的操作HMaster的方法（感覺跟后面要講的Interface接口是一樣一樣的）浙垫，除此之外還提供了構(gòu)造Stub以及BlockingStub的方法；Interface以及BlockingInterface分別以非阻塞的方式以及阻塞的方式定義了操作HMaster的方法郑诺，接口的區(qū)別在于Interface的所有方法的最后一個(gè)參數(shù)都是一個(gè)callback函數(shù)夹姥，而BlockingInterface則沒有這個(gè)參數(shù)；Stub以及BlockingStub分別通過聚合不同的channel實(shí)現(xiàn)自己的接口辙诞，從繼承關(guān)系來(lái)看RpcChannel接口的繼承類只有CoprocessorRpcChnnel以及它的子類辙售，所以猜測(cè)非阻塞方式的接口八成都是給hbase里面endpoint（類似數(shù)據(jù)庫(kù)中的存儲(chǔ)過程與函數(shù)）調(diào)用的時(shí)候使用的，而普通的RPC例如這里的創(chuàng)建表就是通過BlockingRpcChannel實(shí)現(xiàn)的飞涂，上面方法的調(diào)用棧也說明了這一點(diǎn)旦部。
? ? ? ? 客戶端的實(shí)現(xiàn)還有很多細(xì)節(jié)祈搜，比如調(diào)用超時(shí)、共享連接等等士八，這里就不細(xì)講了容燕，可以自己看看代碼。
二婚度、服務(wù)器
? ? ? ? 以前再將HMaster的啟動(dòng)時(shí)蘸秘，講過HMaster啟動(dòng)很重要的一個(gè)過程就是啟動(dòng)自己的RPC服務(wù)-MasterRpcServices，其中相關(guān)協(xié)議注冊(cè)代碼如下：
? ? ? ? 可以看見這里有注冊(cè)上面講到的MasterService蝗茁，由于服務(wù)端在linux上以命令行的形式啟動(dòng)醋虏，所以不能像上面那樣截取棧調(diào)用信息。但是打開相關(guān)代碼哮翘，可以觀察到由MasterRpcServices調(diào)用HMaster中的createTable方法颈嚼，最后在后者的代碼中以如下方式處理請(qǐng)求：
? ? ? 這里最重要的就是service.submit這個(gè)方法了，其中service是ExecutorService類型的成員變量忍坷。按照代碼里面的注釋來(lái)看ExecutorService差不多就是一個(gè)模仿reactor模型（可以參考http://www.blogjava.net/DLevin/archive/2015/09/02/427045.html）實(shí)現(xiàn)的處理模型了粘舟，有一個(gè)可以提交請(qǐng)求的隊(duì)列以及一系列的處理請(qǐng)求線程（handler）熔脂。大數(shù)據(jù)中有很多組件都是模仿這種思路實(shí)現(xiàn)的RPC服務(wù)端佩研，例如hdfs以及yarn。
三霞揉、其他
? ? ? ? 這里沒有細(xì)節(jié)講述服務(wù)端是如何識(shí)別發(fā)過來(lái)的RPC請(qǐng)求的旬薯，這是因?yàn)橐郧皩戇^類似的Hadoop服務(wù)端處理請(qǐng)求時(shí)是如何是別的，主要還是客戶端在傳輸RPC請(qǐng)求的時(shí)候?qū)⒎椒ê灻麑懭刖W(wǎng)絡(luò)IO适秩，服務(wù)端會(huì)根據(jù)這個(gè)來(lái)判斷調(diào)用什么方法绊序。
