当前位置: Oracle DBA培训网-优技培训 >> Hadoop大数据 > Hadoop培训教程 >

Hadoop入门教程:ipc.Client类介绍

Hadoop入门教程:ipc.Client类介绍

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对象从哈希表中删除。

技术沙龙MORE+

Oracle技术沙龙:【数据保护顶尖技术-MAA】首次全国首播12c MAA技术 云数据库加上MAA技术组成最豪华的技...
Oracle技术沙龙第49期:【Oracle 数据库云技术分享】Oracle技术沙龙第49期:【Oracle 数据库云技术分享】本次技术沙...
Oracle技术沙龙第48期:【Oracle 12c RAC安装】小编:今天讲什么内容呢?以后有什么用呢? 大师:今天讲的是12c...
我要参加技术沙龙

关闭