• Client-NameNode之间，其中NameNode是服务器
• Client-DataNode之间，其中DataNode是服务器
• DataNode-NameNode之间，其中NameNode是服务器
• DataNode-DateNode之间，其中某一个DateNode是服务器，另一个是客户端

如果我们考虑Hadoop 的Map/Reduce以后，这些系统间的通信就更复杂了。为了解决这些客户机/服务器之间的通信，Hadoop引入了一个RPC框架。该RPC框架利用 的Java的反射能力，避免了某些RPC解决方案中需要根据某种接口语言（如CORBA的IDL）生成存根和框架的问题。但是，该RPC框架要求调用的参 数和返回结果必须是Java的基本类型，String和Writable接口的实现类，以及元素为以上类型的数组。同时，接口方法应该只抛出 IOException异常。（参考自http://zhangyu8374.javaeye.com/blog/86306）

既然是RPC，当然就有客户端和服务器，当然，org.apache.hadoop.rpc也就有了类Client和类Server。但是类Server是一个抽象类，类RPC封装了Server，利用反射，把某个对象的方法开放出来，变成RPC中的服务器。

下图是org.apache.hadoop.rpc的类图。

hadoop中RPC的使用方法

1publicclass UseRPC {
2
3//hadoop配置信息
4 privatestatic Configuration conf=new Configuration();
5
6//定义接口
7 publicinterface Serverif{
8public String method(String args);
9 }
10
11//服务器端的实现
12publicstaticclass ServerImpl implements Serverif{
13
14//业务逻辑的实现
15public String method(String args){
16return args;
17 }
18
19 }
20
21publicstaticvoid main(String args[]) throws Exception {
22 ServerImpl si =new ServerImpl();
23int port=8668;
24 org.apache.hadoop.ipc.Server server = RPC.getServer(si, port, 10, true,conf);
25 server.start();
26 server.join();
27 }
28
29//客户端的实现
30publicstaticclass Client {
31
32privatestaticfinal Method GETTASK;
33
34
35//利用代理的方式调用,如果通过代理方式，服务器只能有一个
36public String method_proxy(String args) throws Exception{
37 InetSocketAddress sa=new InetSocketAddress("192.168.1.1",8668);
38 Serverif si=(Serverif) RPC.getProxy(Serverif.class, sa, conf);
39return si.method(args);
40 }
41
42//利用反射的方式调用,如果通过反射方式，服务器可以有多个，
43//参数为一个二维数据，相对应每个服务器的方法
44public String method_reflected(String args) throws Exception{
45 InetSocketAddress[] sa=new InetSocketAddress[]{
46new InetSocketAddress("192.168.1.1",8668),
47new InetSocketAddress("192.168.1.2",8668)};
48 Object[][] params =new Object[2][1];
49 params[0][0]=String.class;
50 params[1][0]=String.class;
51//得方法的反射
52 METHOD = Serverif.class.getMethod("method", new Class[] {String.class});
53return (String)RPC.call(METHOD, params, sa, conf);
54 }
55
56publicstaticvoid main(String args[]) throws Exception {
57 String remoteIP="192.168.1.1";
58int port=8668;
59 Client c=new Client();
60 System.out.println(c.method_proxy("hello world"));
61 }
62
63 }
64
65}

【2- 反射方式】该RPC框架利用 的Java的反射能力，避免了某些RPC解决方案中需要根据某种接口语言（如CORBA的IDL）生成存根和框架的问题。为什么Corba使用IDL要生 成存根和框架？因为调用对象方法在编译期间会做静态检查，所以生成存根作为代理，可以使用代理通过静态检查。同【1-代理方式】，不过Hadoop的 RPC可以直接通过传递参数在运行时生成本地代理，这样使用更加方便。

http://labs.chinamobile.com/groups/10216_20254

http://www.tbdata.org/archives/1413

【异步消息机制兼谈Hadoop RPC】http://blog.csdn.net/historyasamirror/archive/2011/01/22/6159248.aspx