一、RPC（Remote Procedure Call）簡介

RPC 是遠端過程呼叫(Remote Procedure Call)，即遠端呼叫其他虛擬機器中執行的javaobject。RPC 是一種客戶端/伺服器模式，那麼在使用時包括服務端程式碼和客戶端程式碼，還有我們呼叫的遠端過程物件。HDFS 的執行就是建立在此基礎之上的。本章通過分析實現一個簡單的RPC 程式來分析HDFS 的執行機理。

二、程式碼解析

1. 服務端程式碼

 　　程式碼如下：

1  public class MyServer {
2     public static final int SERVER_PORT
 
 = 12345;
3     public static final String SERVER_ADDRESS = "localhost";
4     public static void main(String[] args) throws IOException {
5     final Server server = RPC.getServer(new MyBiz(), SERVER_ADDRESS,
6     　　SERVER_PORT, new Configuration());
7　　　server.start();
8     }
9 }

核心在於第5 行的RPC.getServer 方法，該方法有四個引數：

第一個引數是被呼叫的java服務物件。

第二個引數是伺服器的地址。

第三個引數是伺服器的埠。

獲得伺服器物件後，啟動伺服器。這樣，伺服器就在指定埠監聽客戶端的請求。

2. 被呼叫的遠端物件類

程式碼如下：

 1 public class MyBiz implements MyBizable{
 2     public static long BIZ_VERSION = 2345234L;
 3     @Override
 4     public String hello(String name){
 5         System.out.println("我被呼叫了");
 
 6         return "hello "+name;
 7     }
 8     @Override
 9     public long getProtocolVersion(String protocol, long clientVersion)
10     throws IOException {
11         return BIZ_VERSION;
12     }
13 }    

被呼叫的遠端物件實現了介面MyBizable，這裡面有兩個方法被實現，一個就是hello方法，另一個是getProtocalVersion 方法。這個hello 方法內部有個輸出語句

3. 遠端呼叫類的介面

程式碼如下：

1 public interface MyBizable extends VersionedProtocol{
2     public abstract String hello(String name);
3 }

這個介面中的方法就是剛才的Biz 中實現的方法。介面繼承的VersionedProtocal，是hadoop 的RPC 的介面，所有的RPC 通訊必須實現這個一介面，用於保證客戶端和服務端的埠一致。服務端被呼叫的類必須繼承這個介面VersionedProtocal。

4. 客戶端程式碼，這裡使用的呼叫物件的介面

程式碼如下：

 1 public class MyClient {
 2     public static void main(String[] args) throws Exception {
 3     final MyBizable proxy = (MyBizable)RPC.getProxy(MyBizable.class,
 4　　　　MyBiz.BIZ_VERSION, new InetSocketAddress(MyServer.SERVER_ADDRESS,
 5 　　　 MyServer.SERVER_PORT), new Configuration());
 6 　　//呼叫介面中的方法
 7 　　final String result = proxy.hello("world");
 8 　　System.out.println(result);
 9 　　//本質是關閉網路連線
10　　  RPC.stopProxy(proxy);
11 　　}
12 }

以上程式碼中核心在於RPC.getProxy()，該方法有四個引數：

第一個引數是被呼叫的介面類。

第二個是客戶端版本號。

第三個是服務端地址。

返回的代理物件，就是服務端物件的代理，內部就是使用java.lang.Proxy 實現的。執行時，先啟動服務端，再啟動客戶端。讀者可以在服務端和客戶端輸出資訊。
從上面的RPC 呼叫中，可以看出：在客戶端呼叫的業務類的方法是定義在業務類的介面中的。該介面實現了VersionedProtocal 介面。

5. 現在我們在命令列執行jps 命令檢視輸出資訊

如圖2.1 所示。

圖 2.1

可以看到一個java 程序，是“MyServer”，該程序正是我們剛剛執行的rpc 的服務端類MyServer。大家可以聯想到我們搭建hadoop 環境時，也執行過該命令用來判斷hadoop 的程序是否全部啟動。那麼可以判斷，hadoop 啟動時產生的5 個java 程序也應該是RPC 的服務端。我們觀察NameNode 的原始碼，我們可以看到如圖下程式碼，可以看到NameNode 確實建立了RPC 的服務端。

 1   // create rpc server
 2     InetSocketAddress dnSocketAddr = getServiceRpcServerAddress(conf);
 3     if (dnSocketAddr != null) {
 4       int serviceHandlerCount =
 5         conf.getInt(DFSConfigKeys.DFS_NAMENODE_SERVICE_HANDLER_COUNT_KEY,
 6                     DFSConfigKeys.DFS_NAMENODE_SERVICE_HANDLER_COUNT_DEFAULT);
 7       this.serviceRpcServer = RPC.getServer(this, dnSocketAddr.getHostName(), 
 8           dnSocketAddr.getPort(), serviceHandlerCount,
 9           false, conf, namesystem.getDelegationTokenSecretManager());
10       this.serviceRPCAddress = this.serviceRpcServer.getListenerAddress();
11       setRpcServiceServerAddress(conf);
12     }