首页 百科知识 源代码分析(一五)

源代码分析(一五)

时间:2022-09-22 百科知识 版权反馈
【摘要】:替换一个数据块是系统平衡操作的一部分,用于接收一个数据块。写数据块发起请求方也提供数据,替换数据块请求方不提供数据,而是提供了一个数据源,由replaceBlock发起一个拷贝数据块的请求,建立数据源。注意,我们在分析BlockReceiver是,讨论过client=””的情况,就是应用于这种场景。在创建BlockReceiver对象前,需要利用下面介绍的拷贝数据块的请求建立到数据源的socket连接并发送拷贝数据块请求。任务成功后将结果通知notifyNamenodeReceivedBlock。

DataXceiver支持的的6条操作,我们已经分析完最重要的两条。剩下的分别是:

OP_READ_METADATA (82):读数据块元文件

OP_REPLACE_BLOCK (83):替换一个数据块

OP_COPY_BLOCK(84):拷贝一个数据块

OP_BLOCK_CHECKSUM(85):读数据块检验码

我们逐个讨论。

读数据块元文件的请求如图(操作码82):

mhtml:file://I:\技术文章下载\2010-4-23整理到notebook\Hadoop汇总2010-4-22\Hadoop源码分析\Hadoop<a href=源代码分析(一五)%20-%20-%20JavaEye技术网站.mht!http://caibinbupt.javaeye.com/upload/attachment/56004/e44aad12-decb-37b6-b3c3-de358bf0d86e.jpg">

 

应答很简单,应答码(如OP_STATUS_SUCCESS),文件长度(int),数据。

拷贝数据块和替换数据块是一对相对应操作。

替换数据块的请求如图(操作码83)。这个比起上面的读数据块元文件请求,有点复杂。替换一个数据块是系统平衡操作的一部分,用于接收一个数据块。它和普通的数据块写的差别是,它只发生在两个节点上,一个写,一个读,而不需要建立数据链。我们可以比较一下它们在创建BlockReceiver对象时的差别:

 

Java代码 复制代码

blockReceiver = new BlockReceiver(block, proxyReply,  

              proxySock.getRemoteSocketAddress().toString(),  

              proxySock.getLocalSocketAddress().toString(),  

          false,     "", null, datanode);  //OP_REPLACE_BLOCK       

blockReceiver = new BlockReceiver(block, in,   

              s.getRemoteSocketAddress().toString(),  

              s.getLocalSocketAddress().toString(),  

          isRecovery, client, srcDataNode,     datanode);  //OP_WRITE_BLOCK 

 

 

首先,proxyReplyin不一样,这是因为发起请求的节点和提供数据的节点并不是同一个。写数据块发起请求方也提供数据,替换数据块请求方不提供数据,而是提供了一个数据源(proxySource参数),由replaceBlock发起一个拷贝数据块的请求,建立数据源。对于拷贝数据块操作,isRecovery=falseclient=”” srcDataNode=null。注意,我们在分析BlockReceiver是,讨论过client=””的情况,就是应用于这种场景。

在创建BlockReceiver对象前,需要利用下面介绍的拷贝数据块的请求建立到数据源的socket连接并发送拷贝数据块请求。然后通过BlockReceiver.receiveBlock接收数据。任务成功后将结果通知notifyNamenodeReceivedBlock。

拷贝数据块的请求如图(操作码84)。和读数据块操作请求类似,但是读取的是整个数据块,所以少了很多参数。

 

读数据块检验码的请求如图(操作码85)。它能够读取某个数据块的检验和的MD5结果,实现的方法很简单。


免责声明:以上内容源自网络,版权归原作者所有,如有侵犯您的原创版权请告知,我们将尽快删除相关内容。

我要反馈