ZkServer服务启动的逻辑-ServerCnxnFactory.createFactory

这个方法里面是根据ZOOKEEPER_SERVER_CNXN_FACTORY 来决定创建NIO server还是Netty Server

而默认情况下，应该是创建一个NIOServerCnxnFactory 

static public ServerCnxnFactory createFactory() throws IOException { String serverCnxnFactoryName = System.getProperty(ZOOKEEPER_SERVER_CNXN_FACTORY); if (serverCnxnFactoryName == null) { serverCnxnFactoryName = NIOServerCnxnFactory.class.getName(); } try { ServerCnxnFactory serverCnxnFactory = (ServerCnxnFactory) Class.forName(serverCnxnFactoryName).getDeclaredConstructor().newInstance(); LOG.info("Using {} as server connection factory", serverCnxnFactoryName); return serverCnxnFactory; } catch (Exception e) { IOException ioe = new IOException("Couldn't instantiate " + serverCnxnFactoryName); ioe.initCause(e); throw ioe; } }

 

总结

以上是生活随笔为你收集整理的ZkServer服务启动的逻辑-ServerCnxnFactory.createFactory的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。