QuorumPeerMain.runFromConfig

设置了一个值为config.getServers()

//… 

quorumPeer.setQuorumPeers(config.getServers()); 

//… 

config这个配置信息又是通过在initializeAndRun方法中初始化的,

protected void initializeAndRun(String[] args) throws ConfigException, IOException { 
QuorumPeerConfig config = new QuorumPeerConfig(); 
 if (args.length == 1) { 
	config.parse(args[0]); 
 }

猜你喜欢

转载自blog.csdn.net/Leon_Jinhai_Sun/article/details/112999245