private final NamesrvConfig namesrvConfig;//主要指定 nameserver 的相關(guān)配置屬性
private final ScheduledExecutorService scheduledExecutorService = Executors.newSingleThreadScheduledExecutor(new ThreadFactoryImpl("NSScheduledThread"));//NameServer定時任務(wù)執(zhí)行線程池-->每隔10s掃描broker，對存活的Broker信息進行維護并且打印KVConfig
private final KVConfigManager kvConfigManager;//讀取或變更NameServer的配置屬性，加載 NamesrvConfig中配置到內(nèi)存
private final RouteInfoManager routeInfoManager;//NameServer 數(shù)據(jù)的載體，記錄 Broker、Topic 等信息。

private final NettyServerConfig nettyServerConfig;//與網(wǎng)絡(luò)通訊相關(guān)的配置
private RemotingServer remotingServer;//網(wǎng)絡(luò)通信服務(wù)
private ExecutorService remotingExecutor;//網(wǎng)絡(luò)通信服務(wù)

private String rocketmqHome = System.getProperty(MixAll.ROCKETMQ_HOME_PROPERTY, System.getenv(MixAll.ROCKETMQ_HOME_ENV));
private String kvConfigPath = System.getProperty("user.home") + File.separator + "namesrv" + File.separator + "kvConfig.json";
private String configStorePath = System.getProperty("user.home") + File.separator + "namesrv" + File.separator + "namesrv.properties";
private String productEnvName = "center";
private boolean clusterTest = false;
private boolean orderMessageEnable = false;

private int listenPort = 8888;
private int serverWorkerThreads = 8;
private int serverCallbackExecutorThreads = 0;
private int serverSelectorThreads = 3;
private int serverOnewaySemaphoreValue = 256;
private int serverAsyncSemaphoreValue = 64;
private int serverChannelMaxIdleTimeSeconds = 120;

private int serverSocketSndBufSize = NettySystemConfig.socketSndbufSize;
private int serverSocketRcvBufSize = NettySystemConfig.socketRcvbufSize;
private boolean serverPooledByteBufAllocatorEnable = true;

private final static long BROKER_CHANNEL_EXPIRED_TIME = 1000 * 60 * 2;
private final ReadWriteLock lock = new ReentrantReadWriteLock();
private final HashMap<String/* topic */, List<QueueData>> topicQueueTable;
private final HashMap<String/* brokerName */, BrokerData> brokerAddrTable;
private final HashMap<String/* clusterName */, Set<String/* brokerName */>> clusterAddrTable;
private final HashMap<String/* brokerAddr */, BrokerLiveInfo> brokerLiveTable;
private final HashMap<String/* brokerAddr */, List<String>/* Filter Server */> filterServerTable;

private String brokerName;			//broker名稱
private int readQueueNums;			//讀隊列個數(shù)
private int writeQueueNums;			//寫隊列個數(shù)
private int perm;				   //操作權(quán)限	
private int topicSysFlag;			//同步復(fù)制還是異步復(fù)制的標(biāo)識

private String cluster;				//當(dāng)前Broker所屬集群
private String brokerName;			//Broker名稱
//BrokerId=0表示主節(jié)點，BrokerId>0表示從節(jié)點
//記錄BrokerId與對應(yīng)節(jié)點地址的映射信息
private HashMap<Long/* brokerId */, String/* broker address */> brokerAddrs;

private long lastUpdateTimestamp;		//上次發(fā)送心跳包的時間戳
private DataVersion dataVersion;		//記錄數(shù)據(jù)版本信息
private Channel channel;
private String haServerAddr;			//Master節(jié)點地址

public static void main(String[] args) {
    main0(args);
}
public static NamesrvController main0(String[] args) {

    try {
        //創(chuàng)建NamesrvController的入口
        NamesrvController controller = createNamesrvController(args);
        start(controller);
        String tip = "The Name Server boot success. serializeType=" + RemotingCommand.getSerializeTypeConfigInThisServer();
        log.info(tip);
        System.out.printf("%s%n", tip);
        return controller;
    } catch (Throwable e) {
        e.printStackTrace();
        System.exit(-1);
    }
    return null;
}

public static NamesrvController createNamesrvController(String[] args) throws IOException, JoranException {
    //....    
    //創(chuàng)建namesrvConfig
    final NamesrvConfig namesrvConfig = new NamesrvConfig();
    //創(chuàng)建nettyServerConfig
    final NettyServerConfig nettyServerConfig = new NettyServerConfig();
    
    //設(shè)置默認端口9876
    nettyServerConfig.setListenPort(9876);
    //-c 指定屬性配置文件的位置
    if (commandLine.hasOption('c')) {
        String file = commandLine.getOptionValue('c');
        if (file != null) {
            InputStream in = new BufferedInputStream(new FileInputStream(file));
            properties = new Properties();
            properties.load(in);
            MixAll.properties2Object(properties, namesrvConfig);
            MixAll.properties2Object(properties, nettyServerConfig);

            namesrvConfig.setConfigStorePath(file);

            System.out.printf("load config properties file OK, %s%n", file);
            in.close();
        }
    }
    //-p 屬性名=屬性值
    if (commandLine.hasOption('p')) {
        InternalLogger console = InternalLoggerFactory.getLogger(LoggerName.NAMESRV_CONSOLE_NAME);
        MixAll.printObjectProperties(console, namesrvConfig);
        MixAll.printObjectProperties(console, nettyServerConfig);
        System.exit(0);
    }
    //將啟動參數(shù)填充到namesrvConfig中
    MixAll.properties2Object(ServerUtil.commandLine2Properties(commandLine), namesrvConfig);

    //如果未指定'ROCKETMQ_HOME'環(huán)境變量
    if (null == namesrvConfig.getRocketmqHome()) {
        System.out.printf("Please set the %s variable in your environment to match the location of the RocketMQ installation%n", MixAll.ROCKETMQ_HOME_ENV);
        System.exit(-2);
    }
	//....
    //打印配置信息日志
    MixAll.printObjectProperties(log, namesrvConfig);
    MixAll.printObjectProperties(log, nettyServerConfig);
    //根據(jù)namesrvConfig和nettyServerConfig創(chuàng)建NamesrvController
    final NamesrvController controller = new NamesrvController(namesrvConfig, nettyServerConfig);
    // 將配置存入controller.configuration以防止配置丟失
    controller.getConfiguration().registerConfig(properties);
    return controller;
}

//NamesrvStartup#start
public static NamesrvController start(final NamesrvController controller) throws Exception {

    //進行簡單的檢查
    if (null == controller) {
        throw new IllegalArgumentException("NamesrvController is null");
    }	
    //controller初始化
    boolean initResult = controller.initialize();
    if (!initResult) {
        controller.shutdown();
        System.exit(-3);
    }    
    //....
    controller.start();		//開啟遠程服務(wù)-this.remotingServer.start();

    return controller;
}
//NamesrvController#initialize
public boolean initialize() {

    	//加載配置管理器
        this.kvConfigManager.load();
		//創(chuàng)建Netty遠程服務(wù)
        this.remotingServer = new NettyRemotingServer(this.nettyServerConfig, this.brokerHousekeepingService);
		//創(chuàng)建遠程服務(wù)線程池
        this.remotingExecutor =
            Executors.newFixedThreadPool(nettyServerConfig.getServerWorkerThreads(), new ThreadFactoryImpl("RemotingExecutorThread_"));

        //注冊線程池
        this.registerProcessor();
        //定時任務(wù)線程池--->每隔十秒掃描活躍狀態(tài)異常的Broker信息
        this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
            /**
             * 對Not Active Broker 進行掃描
             */
            @Override
            public void run() {
                NamesrvController.this.routeInfoManager.scanNotActiveBroker();
            }
        }, 5, 10, TimeUnit.SECONDS);
        //定時任務(wù)線程池--->每隔十秒打印KVConfig信息
        this.scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
            @Override
            public void run() {
                NamesrvController.this.kvConfigManager.printAllPeriodically();
            }
        }, 1, 10, TimeUnit.MINUTES);
       //....
        return true;
    }

public static NamesrvController start(final NamesrvController controller) throws Exception {
	//....    
    //JVM進程關(guān)閉之前,將線程池關(guān)閉,資源釋放
    Runtime.getRuntime().addShutdownHook/*注冊JVM鉤子函數(shù)*/(new ShutdownHookThread(log, new Callable<Void>() {
        @Override
        public Void call() throws Exception {
            controller.shutdown();
            return null;
        }
    }));	
    //....
}