Hadoop培训教程：ipc.Client类分析

Hadoop RPC主要由三个大类组成，Client是其中一个，对应客户端实现，Client主要完成的功能是发送远程过程调用信息并接收执行结果。

Client类对外提供了一类执行远程调用的接口，这些接口的名称一样，仅仅是参数列表不同，比如其中一个的声明如下所示：

public Writable call(Writable param, ConnectionIdremoteId) throws InterruptedException, IOException;

Client内部有两个重要的内部类，分别是Call和Connection。

Call类：封装了一个RPC请求，它包含5个成员变量，分别是唯一标识id、函数调用信息param、函数执行返回值value、出错或者异常信息error和执行完成标识符done。由于Hadoop RPC Server采用异步方式处理客户端请求，这使远程过程调用的发生顺序与结果返回顺序无直接关系，而Client端正是通过id识别不同的函数调用的。当客户端向服务器端发送请求时，只需填充id和param两个变量，而剩下的3个变量(value、error和done)则由服务器端根据函数执行情况填充。

Connection类：Client与每个Server之间维护一个通信连接，与该连接相关的基本信息及操作被封装到Connection类中，基本信息主要包括通信连接唯一标识(remoteId)、与Server端通信的Socket(socket)、网络输入数据流(in)、网络输出数据流(out)、保存RPC请求的哈希表(calls)等。操作则包括：

addCall—将一个Call对象添加到哈希表中;

sendParam—向服务器端发送RPC请求;

receiveResponse —从服务器端接收已经处理完成的RPC请求;

run—Connection是一个线程类，它的run方法调用了receiveResponse方法，会一直等待接收RPC返回结果。

当调用call函数执行某个远程方法时，Client端需要进行(如图3-7所示)以下4个步骤。

1)创建一个Connection对象，并将远程方法调用信息封装成Call对象，放到Connection对象中的哈希表中;

2)调用Connection类中的sendRpcRequest()方法将当前Call对象发送给Server端;

3)Server端处理完RPC请求后，将结果通过网络返回给Client端，Client端通过receiveRpcResponse()函数获取结果;

4)Client检查结果处理状态(成功还是失败)，并将对应Call对象从哈希表中删除。