定義RPC協議

import java.io.IOException;

import org.apache.hadoop.ipc.VersionedProtocol;
/*
  DateTime: 2014年12月28日 上午9:32:12
 
 /
public interface ClientProtocol extends VersionedProtocol {
    //版本號，默認情況下，不同版本號的RPC客戶端與Server之間不能相互通信
    public static final long versionID = 1L;
    public String hello(String msg) throws IOException;
}</pre> 

實現RPC協議

import java.io.IOException;

import org.apache.hadoop.ipc.ProtocolSignature;
/*
  DateTime: 2014年12月28日 上午9:41:38
 
 /
public class ClientProtocolImpl implements ClientProtocol {

@Override
public long getProtocolVersion(String protocol, long clientVersion)
        throws IOException {
    return versionID;
}

@Override
public ProtocolSignature getProtocolSignature(String protocol,
        long clientVersion, int clientMethodsHash) throws IOException {
    return new ProtocolSignature(versionID, null);
}

@Override
public String hello(String msg) throws IOException {
    return "hello " + msg;
}



}</pre> 

構建并啟動RPC Server

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
import org.apache.hadoop.ipc.RPC.Server;
/*
  DateTime: 2014年12月28日 上午9:47:05
 
 /
public class RPCServer {
    private static final String HOST = "localhost";
    private static final int PORT = 2181;
    public static void main(String[] args) throws IOException {
        Configuration conf = new Configuration();

    Server server = new RPC.Builder(conf).setProtocol(ClientProtocol.class)
            .setInstance(new ClientProtocolImpl()).setBindAddress(HOST)
            .setNumHandlers(2)
            .setPort(PORT).build();
    server.start();
}

}</pre> 

構造并啟動RPC Clinet并發送RPC請求

import java.io.IOException;
import java.net.InetSocketAddress;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.ipc.RPC;
/*
  DateTime: 2014年12月28日 上午9:52:19
 
 /
public class RPCClient {
    private static final String HOST = "localhost";
    private static final int PORT = 2181;

public static void main(String[] args) throws IOException {
    Configuration conf = new Configuration();
    ClientProtocol proxy = RPC.getProxy(ClientProtocol.class, ClientProtocol.versionID,
            new InetSocketAddress(HOST, PORT), conf);
    String result = proxy.hello("world");
    System.out.println(result);
}

}</pre>