Client 端发起的写请求通过流式接口到达Datanode后。Datanode的DataXceiverServer接受这个请求并构造DataXceiver对象, DataXceiver.writeBlock执行这个请求。
DataXceiverServer
DataXceiverServer 是个线程类,在run 方法里监听客户端的请求
public void run() {
...
peer = peerServer.accept();
...
//构造线程类对象DataXceiver
new Daemon(datanode.threadGroup,
DataXceiver.create(peer, datanode, this))
.start();
...
}
未完待续