Hadoop 源代码分析（六）RPC-Client

连接被封装在类Client.Connection 中，所有的RPC 调用，都是通过Connection，进行通信。一个RPC 调用，自然有输入参数，
输出参数和可能的异常，同时，为了区分在同一个Connection 上的不同调用，每个调用都有唯一的id。调用是否结束也需要
一个标记，所有的这些都体现在对象Client.Call 中。Connection 对象通过一个Hash 表，维护在这个连接上的所有Call：
Java 代码
1. private Hashtable<Integer, Call> calls = new Hashtable<Integer, Call>();
一个RPC 调用通过addCall，把请求加到Connection 里。为了能够在这个框架上传输Java 的基本类型，String 和Writable 接
口的实现类，以及元素为以上类型的数组，我们一般把Call 需要的参数打包成为ObjectWritable 对象。
Client.Connection 会通过socket 连接服务器，连接成功后回校验客户端/服务器的版本号（Client.ConnectionwriteHeader()方
法），校验成功后就可以通过Writable 对象来进行请求的发送/应答了。注意，每个Client.Connection 会起一个线程，不断
去读取socket，并将收到的结果解包，找出对应的Call，设置Call 并通知结果已经获取。
Call 使用Obejct 的wait 和notify，把RPC 上的异步消息交互转成同步调用。
还有一点需要注意，一个Client 会有多个Client.Connection，这是一个很自然的结果。