thread其實構建的是一個zookeeperThread線程，并且線程的參數(shù)為this，表示當前NIOServerCnxnFactory也是實現(xiàn)了線程的類，那么它必須要重寫

run方法，因此定位到NIOServerCnxnFactory.run。

到此，NIOServer的初始化以及啟動過程就完成了。并且對2181的這個端口進行監(jiān)聽。一旦發(fā)現(xiàn)有請求進來，就執(zhí)行相應的處理即可。這塊后續(xù)在分析數(shù)據(jù)同步的時候再做詳細了解

Thread thread; @Override public void configure(InetSocketAddress addr,int maxcc) throws IOException { configureSaslLogin(); thread = new ZooKeeperThread(this, "NIOServerCxn.Factory:" + addr); thread.setDaemon(true); maxClientCnxns = maxcc; this.ss = ServerSocketChannel.open(); ss.socket().setReuseAddress(true); LOG.info("binding to port " + addr); ss.socket().bind(addr); ss.configureBlocking(false); ss.register(selector, SelectionKey.OP_ACCEPT); }

?

總結(jié)

以上是生活随笔為你收集整理的ZkServer服务启动的逻辑-NIOServerCnxnFactory.configure的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。