Hadoop重温(4)--ipc

xinghe0

　　依赖于Hadoop Writable类型的支持。Hadoop Writable接口要求每个实现类都得确保将本类的对象正确序列化(writeObject)与反序列化(readObject)。因此，Hadoop RPC使用Java动态代理与反射实现对象调用方式，客户端到服务器数据的序列化与反序列化由Hadoop框架或用户自己来实现，也就是数据组装是定制的。
　　Hadoop IPC在org.apache.hadoop.ipc

• RemoteException：远程异常，表示远程调用过程中的错误。
  
• Status：枚举类，包括 SUCCESS (0) 成功,  ERROR (1)一般错误,  FATAL (-1)致命错误;三种状态
  
• VersionedProtocol：Hadoop IPC的远程接口都需继承
  
• ConnectionHeader：建立连接时发送的消息头。
  

　　IPC的核心类在Client，Server,RPC中，
　　Connection：
　　IPC连接时IPC Client和Server关系的一个抽象，Client调用Server上方法前，会创建Connection。同样server也存在Connection。Client.Connection和Server.Connection,各自提供了客户端和服务端管理连接需要的信息和方法。Hadoop的远程过程调用使用TCP协议通信，IPC建立在TCP连接之上。
　　（1）ConnectionId
　　通过ConnectionId来区分不同链接
　　
  

　　
            address：远程放服务器的地址。
　　ticket：包含了用户和用户组的信息
　　protocol：报错的是IPC接口对应的类对象。
　　在上述三个成员变量相等的情况，ConnectionId相等。
　　                    (2)ConnectionHeader
　　                         

                       是客户端和服务器间TCP链接建立后交换的第一条消息，内容包括ConnectionId的用户信息和IPC接口信息。
　　Call
　　       在客户端和服务器建立连接以后，通过Call进行远程调用，客户端和服务端分别定义了远程调用类Call，Client.Call和Server.Call。
　　      Client还定义了ParallelCall，用于并行处理。
　　      Client.Call是有IPC客户端接口实例上的方法调用产生的
　　      可以说Hadoop RPC=动态代理+定制二进制流