3、namenode启动过程中的资源检查，以及如何退出安全模式

NameNode.main() // 入口函数
   　　　　|——createNameNode(); // 通过new NameNode()进行实例化
   　　　　　　|——initialize(); // 方法进行初始化操作
   　　　　　　　　|——startHttpServer(); // 启动HttpServer
   　　　　　　　　|——loadNamesystem(); // 加载元数据
   　　　　　　　　|——createRpcServer(); // 创建并初始化rpc server实例
   　　　　　　　　|——startCommonServices();
   　　　　　　　　　　|——namesystem.startCommonServices(); // 启动一些磁盘检查、安全模式等一些后台服务及线程
   　　　　　　　　　　　　|——new NameNodeResourceChecker(); // 实例化一个NameNodeResourceChecker并准备出所有需要检查的磁盘路径
   　　　　　　　　　　　　|——checkAvailableResources(); // 开始磁盘空间检查
   　　　　　　　　　　　　|——NameNode.getStartupProgress(); // 获取StartupProgress实例用来获取NameNode各任务的启动信息
   　　　　　　　　　　　　|——setBlockTotal(); // 设置所有的block，用于后面判断是否进入安全模式
   　　　　　　　　　　　　|——blockManager.activate(); // 启动BlockManager里面的一堆关于block副本处理的后台线程
   　　　　　　　　　　|——rpcServer.start(); // 启动rpcServer
   　　　　|——join()

1、 检查资源情况、判断是否进入安全状态、激活BlockManager
2、启动RPC服务

 1 /**
 2    * 1、 namesystem.startCommonServices(conf, haContext);
 3    * 检查资源情况、判断是否进入安全状态、激活BlockManager
 4    * 2、启动RPC服务
 5    * */
 6   private void startCommonServices(Configuration conf) throws IOException {
 7     //FSNamesystem是NameNode核心成员变量用来管理元数据（实现对DataNode、Block的管理以及读写日志）
 8     //创建NameNodeResourceChecker、激活BlockManager等
 9     namesystem.startCommonServices(conf, haContext);
10     registerNNSMXBean();//注册一个namenode的状态类
11     // 角色非`NamenodeRole.NAMENODE`的在此处启动HttpServer
12     if (NamenodeRole.NAMENODE != role) {
13       startHttpServer(conf);
14       httpServer.setNameNodeAddress(getNameNodeAddress());
15       httpServer.setFSImage(getFSImage());
16     }
17     //启动服务
18     rpcServer.start();//
19     plugins = conf.getInstances(DFS_NAMENODE_PLUGINS_KEY,
20         ServicePlugin.class);
21     for (ServicePlugin p: plugins) {
22       try {
23         p.start(this);
24       } catch (Throwable t) {
25         LOG.warn("ServicePlugin " + p + " could not be started", t);
26       }
27     }
28     LOG.info(getRole() + " RPC up at: " + rpcServer.getRpcAddress());
29     if (rpcServer.getServiceRpcAddress() != null) {
30       LOG.info(getRole() + " service RPC up at: "
31           + rpcServer.getServiceRpcAddress());
32     }
33   }

1、将需要检查的URL添加到volumes中 ， 后台有线程会一直执行hasAvailableDiskSpace来检查
2、checkAvailableResources(); 进行资源检查
3、NameNode启动，进入到safemode阶段，处于一个等待汇报blocks的状态
4、汇报所有的block，用于后面判断是否进入安全模式
5、激活BlockManager

/** 
   * 1、将需要检查的URL添加到volumes中 ， 后台有线程会一直执行hasAvailableDiskSpace来检查
   * 2、checkAvailableResources(); 进行资源检查
   * 3、NameNode启动，进入到safemode阶段，处于一个等待汇报blocks的状态
   * 4、汇报所有的block，用于后面判断是否进入安全模式
   * 5、激活BlockManager
   */
  void startCommonServices(Configuration conf, HAContext haContext) throws IOException {
      this.registerMBean(); // register the MBean for the FSNamesystemState
      writeLock();
      this.haContext = haContext;
      try {
          //NameNodeResourceChecker负责检查磁盘资源。
        // active状态的namenod会启动一个监控线程NameNodeResourceMonitor，
          // 定期执行NameNodeResourceChecker#hasAvailableDiskSpace()检查可用的磁盘资源。
          /**需要检查3个涉及到元数据的目录：
           * Namenode2个目录：fsimage、editlog（默认情况下这两个是在同一个目录）
           * 高可用模式下的journalNode里面也有存储袁术的目录
           * */
          nnResourceChecker = new NameNodeResourceChecker(conf);
          //检查可用资源是否足够：如果不够，日志打印警告信息，然后进入安全模式
          checkAvailableResources();
          // 判断是否进入安全模式，并且副本队列是否应该被同步/复制
          /**
           * 磁盘资源不足的情况下，任何对元数据修改所产生的日志都无法确保能够写入到磁盘，
           * 即新产生的edits log和fsimage都无法确保写入磁盘。所以要进入安全模式，
           * 来禁止元数据的变动以避免往磁盘写入新的日志数据
           * */
          assert safeMode != null && !isPopulatingReplQueues();
          //获取StartupProgress实例用来获取NameNode各任务的启动信息
          StartupProgress prog = NameNode.getStartupProgress();
          // 目前NameNode启动，进入到safemode阶段，处于一个等待汇报blocks的状态
          prog.beginPhase(Phase.SAFEMODE);
          //处于一个等待汇报blocks的状态
          prog.setTotal(Phase.SAFEMODE, STEP_AWAITING_REPORTED_BLOCKS, getCompleteBlocksTotal());
          //设置所有的block，用于后面判断是否进入安全模式
          setBlockTotal();
          //TODO 启动BlockManager里面关于block副本处理的后台线程
          //激活BlockManager
          blockManager.activate(conf);
      } finally {
          writeUnlock();
      }
    
    registerMXBean();
    DefaultMetricsSystem.instance().register(this);
    if (inodeAttributeProvider != null) {
      inodeAttributeProvider.start();
      dir.setINodeAttributeProvider(inodeAttributeProvider);
    }
    snapshotManager.registerMXBean();
  }

用于检查安全模式的状态：
1、判断阈值系数是否满足进入安全模式:needEnter
对于离开安全模式，有两个条件判断：
1、判断系数是否满足离开安全模式
2、启动SafeModeMonitor线程，每隔1秒去查看下，是否可以退出安全模式