Hadoop源码分析之心跳机制

代码二：

public DatanodeProtocol namenode = null; 

namenode其实是一个DatanodeProtocol的引用，在对hadoop RPC机制分析的文章中我提到过，这是一个Datanode和Namenode通信的协议，其中有许多未实现的接口方法，sendHeartbeat()就是其中的一个。下面看看这个namenode对象是怎么被实例化的吧：

代码三：

this.namenode = (DatanodeProtocol)   
    RPC.waitForProxy(DatanodeProtocol.class,  
                     DatanodeProtocol.versionID,  
                     nameNodeAddr,   
                     conf); 

其实这个namenode并不是Namenode的一个对象，而只是一个Datanode端对Namenode的代理对象，正是这个代理完成了“心跳”。代理的底层实现就是RPC机制了。

三．Tasktracker、Jobtracker心跳源码分析

同样我们从Tasktracker入手，下面贴出Tasktracker.class的关键代码：

代码四：

代码一：  
State offerService() throws Exception {  
    long lastHeartbeat = System.currentTimeMillis();  
    while (running && !shuttingDown) {  
     •••  
          
        // 发送心跳，调用代码二  
        HeartbeatResponse heartbeatResponse = transmitHeartBeat(now);  
 
      •••  
    return State.NORMAL;  
  }  
 
代码二：  
HeartbeatResponse transmitHeartBeat(long now) throws IOException {  
   •••  
    HeartbeatResponse heartbeatResponse = jobClient.heartbeat(status,   
                                                              justStarted,  
                                                              justInited,  
                                                              askForNewTask,   
                                                         heartbeatResponseId);                                
•••  
    return heartbeatResponse;  
  } 

其