一、RPC基本概念：

1、RPC，即Remote Procdure Call，中文名：遠端過程呼叫；
　　（1）它允許一臺計算機程式遠端呼叫另外一臺計算機的子程式，而不用去關心底層的網路通訊細節，對我們來說是透明的。因此，它經常用於分散式網路通訊中。
   （2）Hadoop的程序間互動都是通過RPC來進行的，比如Namenode與Datanode直接，Jobtracker與Tasktracker之間等。
因此，可以說：Hadoop的執行就是建立在RPC基礎之上的。
補充：RPC協議假定某些傳輸協議的存在，如TCP或UDP，為通訊程式之間攜帶資訊資料。在OSI網路通訊模型中，RPC跨越了傳輸層和應用層。RPC使得開發包括網路分散式多程式在內的應用程式更加容易。

二、RPC使用：

1、建立介面，該介面類在服務端和客戶端都必須有。介面必須繼承VersionedProtocol

public interface Serverif extends VersionedProtocol

2、在服務端實現介面類

public class ServerImpl implements Serverif

3、服務端，使用實現的類啟動服務，需要定義監聽的IP地址和埠

Server server = RPC.getServer(si, SERVERADDRESS, SERVERPORT, 10, true, conf);

server.start();

4、客戶端定義遠端連線

InetSocketAddress sa = new InetSocketAddress(SERVERADDRESS, SERVERPORT);

5、客戶端使用遠端連線，通過介面定義，呼叫服務端具體實現

Serverif si = (Serverif) RPC.getProxy(Serverif.class, versionID, sa, conf);

return si.method(args);

三、例項：

1、介面

package rpc;  
import org.apache.hadoop.ipc.VersionedProtocol;  
public interface IMyBiz extends VersionedProtocol{  
    public Long VERSION = 123L;  
    public String sayHello(String str);  
}  

package rpc;  
import java.io.IOException;  
public class MyBiz implements IMyBiz {  
    public String sayHello(String str) {  
        return "hello"+str;  
    }  
    @Override  
    public long getProtocolVersion(String s, long l) throws IOException {  
        // TODO Auto-generated method stub  
        return VERSION;  
    }  
}  

package rpc;  
import org.apache.hadoop.conf.Configuration;  
import org.apache.hadoop.ipc.RPC;  
import org.apache.hadoop.ipc.RPC.Server;  
public class MyServer {  
    public static final String HOSTNAME = "localhost";  
    public static final int PORT = 12345;  
    /** 
     * @param args 
     * @throws Exception  
     */  
    public static void main(String[] args) throws Exception {  
        Configuration con = new Configuration();  
        Server server = RPC.getServer(new MyBiz(), HOSTNAME, PORT, con);  
        server.start();  
    }  
}  

package rpc;  
import java.net.InetSocketAddress;  
import org.apache.hadoop.conf.Configuration;  
import org.apache.hadoop.ipc.RPC;  
public class MyClient {  
    /** 
     * @param args 
     * @throws Exception  
     */  
    public static void main(String[] args) throws Exception {  
        InetSocketAddress addr = new InetSocketAddress("localhost",12345);  
        IMyBiz proxy = (IMyBiz)RPC.waitForProxy(IMyBiz.class, IMyBiz.VERSION, addr, new Configuration());  
        String str = proxy.sayHello("word");  
        System.out.println("客戶端輸出："+str);  
        RPC.stopProxy(proxy);  
    }  
}