第七章：小朱笔记hadoop之源码分析-hdfs分析 DataNode 数据读写分析

?

sendChunks：
计算一个数据包能发送的最多个chunks，然后将packetLen数据包长度、offset数据包开始位置在块中的偏移、seqno数据包的编号、是不是最后一个数据包写到pkt，然后将块元数据文件中的校验数据读出到pkt中。计算出块数据在pkt中的位置(存放在校验数据之后)。然后根据BlockReader.blockInPosition变量值判断是否可以用FileChannel将数据发给块请求者。如果不可以，就将块数据读取到buf中，然后利用checksum对读出来的数据生成校验和，并与先前读出的块元数据文件进行校验，校验成功后将buf发送给请求者。如果可以，就先将buf中的校验和部分发送出去，然后再利用fileChannel将块文件中的数据发送出去。最后调用BlockTransferThrottler.throttle进行节流控制。

?

//计算数据包的长度 int len = Math.min((int) (endOffset - offset), bytesPerChecksum * maxChunks); //数据包头部信息写入缓存 // write packet header pkt.putInt(packetLen); pkt.putLong(offset); pkt.putLong(seqno); pkt.put((byte)((offset + len >= endOffset) ? 1 : 0)); //why no ByteBuf.putBoolean()? pkt.putInt(len); //发送数据包 //first write the packet sockOut.write(buf, 0, dataOff); // no need to flush. since we know out is not a buffered stream. sockOut.transferToFully(fileChannel, blockInPosition, len);//调整发送速度 if (throttler != null) { // rebalancing so throttle throttler.throttle(packetLen); }

?

?

..........................正在写

?

?

?

?

?