hadoop rpc 学习

Hadoop rpc 学习（版本2.6.0）

客户端部分

1.生成动态代理类（org.apache.hadoop.ipc.WritableRpcEngine.class 311行）

2.代理类执行任务入口（org.apache.hadoop.ipc.WritableRpcEngine.class 245行）

3.hadoop rpc client 给服务端发送请求 调用（org.apache.hadoop.ipc.Client.class 998行）

public void sendRpcRequest(final Call call){......}

服务端部分

1.Server server = builder.build();开放服务端口，注册接口协议

2.等待客户端请求，将请求内容放到队列中

3.从队列callQueue取出calll去执行

4.执行完客户端请求的任务，返回执行结果

附：hadoop rpc 动态代理类反编译出来的结果