ZkServer服务启动的逻辑-NIOServerCnxnFactory.configure
生活随笔
收集整理的這篇文章主要介紹了
ZkServer服务启动的逻辑-NIOServerCnxnFactory.configure
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
thread其實構建的是一個zookeeperThread線程,并且線程的參數為this,表示當前NIOServerCnxnFactory也是實現了線程的類,那么它必須要重寫
run方法,因此定位到NIOServerCnxnFactory.run。
到此,NIOServer的初始化以及啟動過程就完成了。并且對2181的這個端口進行監聽。一旦發現有請求進來,就執行相應的處理即可。這塊后續在分析數據同步的時候再做詳細了解
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); }?
總結
以上是生活随笔為你收集整理的ZkServer服务启动的逻辑-NIOServerCnxnFactory.configure的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: ZkServer服务启动的逻辑-NIOS
- 下一篇: 选举流程分析