RPC 是構建 hadoop 體系結構的基石。

RPC（Remote Procedure Call Protocol）——遠端過程呼叫協議。所謂遠端過程呼叫，也即是遠端呼叫過程，它是一種通過網路從遠端計算機程式上請求服務（某一過程），而不需要了解底層網路技術的協議。RPC協議假定某些傳輸協議的存在，如TCP或UDP，為通訊程式之間攜帶資訊資料。在OSI網路通訊模型中，RPC跨越了傳輸層和應用層。

RPC採用客戶機/伺服器模式。請求程式就是一個客戶機，而服務提供程式就是一個伺服器。

遠端指不在同一個程序。Java 中通過呼叫 main 方法產生程序。遠端過程呼叫意味著對另一個 main 方法（另一個 Java 程序）中的程式進行呼叫。

遠端過程呼叫至少需要兩個過程（也即兩個 Java 程序）。

• （1）呼叫方（client），主動發起請求，呼叫（指定ip和埠port）server中的方法
• （2）被呼叫方（server），把呼叫結果返回給客戶端。

RPC 伺服器 與 http 伺服器

經典的 RPC 伺服器包括：hadoop 叢集結構的：

• NameNode、SecondaryNameNode、DataNode
• JobTracker、TaskTracker

職責介紹：

• （1）HTTP 伺服器提供的是資原始檔，需要儲存空間足夠大
• （2）RPC 伺服器提供的是計算過程的返回值，需要計算能力足夠強

RPC 再次明晰了客戶端和伺服器的職責。

RPC 機制的模擬

• （0）MyBiz、MyBizable

  package rpc;
  
  import java.io.IOException;
  
  import org.apache.hadoop.ipc.VersionedProtocol;
  
  public interface MyBizable extends VersionedProtocol{
      long VERSION = 12345L;
      public abstract String hello(String name);
  
  }

  package rpc;
  
  import java.io.IOException;
  
  import
   
   org.apache.hadoop.ipc.VersionedProtocol;
  
  public class MyBiz implements MyBizable {
      @Override
      public String hello(String name){
          System.out.println("我被呼叫了，猜猜看我會出現在哪一邊？");
          return "hello " + name;
      }
  
      @Override
      public long getProtocolVersion(String protocol, long clientVersion)
              throws IOException {
  
          return VERSION;
      }
  }

• （1）MyServer

  package rpc;
  
  import java.io.IOException;
  
  import org.apache.hadoop.conf.Configuration;
  import org.apache.hadoop.ipc.RPC;
  import org.apache.hadoop.ipc.RPC.Server;
  
  public class MyServer {
  
      static final String ADDR = "localhost";
      static final int PORT = 12345;
  
      public static void main(String[] args) throws Exception {
          Server server = RPC.getServer(new MyBiz(), ADDR, PORT, new Configuration());
          // 在指定的ip，指定的埠進行監聽
          server.start();
      }
  }

• （2）MyClient

  package rpc;
  
  import java.io.IOException;
  import java.net.InetSocketAddress;
  
  import org.apache.hadoop.conf.Configuration;
  import org.apache.hadoop.ipc.RPC;
  import org.apache.hadoop.ipc.VersionedProtocol;
  
  public class MyClient {
  
      public static void main(String[] args) throws Exception {
          MyBizable proxy = (MyBizable)RPC.waitForProxy(MyBizable.class,
                    MyBizable.VERSION,
                    new InetSocketAddress(MyServer.ADDR, MyServer.PORT),
                    new Configuration());
          System.out.println("客戶端結果："+proxy.hello("zch"));
          // 關閉網路連線
          RPC.stopProxy(proxy);
      }
  }

  注：

• （1）客戶端獲得的代理物件 proxy，呼叫其hello()成員函式，是在客戶端還是在伺服器端執行的呢？

  這正是RPC（遠端呼叫的精髓所在）。如果是以遠端呼叫的方式執行物件的方法，則應是在伺服器端執行，將結果返回給客戶端。

• （2）客戶端呼叫伺服器端的方法，意味著呼叫伺服器端的物件中的方法

• （3）如果伺服器端的物件允許客戶端呼叫，那麼這個物件必須實現介面

• （4）如果客戶端能夠呼叫伺服器端物件的方法，那麼這些方法一定位於物件的介面中。因為客戶端只能獲得介面（waitForProxy()）

• （5）在命令列介面，輸入jps（檢視 java 程序），會看到伺服器端的 java 程序名；