ZkServer服务启动的逻辑-QuorumPeerMain.runFromConfig

在runFromConfig中，有构建了一个ServerCnxnFactory.

public void runFromConfig(QuorumPeerConfig config) throws IOException { //… LOG.info("Starting quorum peer"); try { ServerCnxnFactory cnxnFactory = ServerCnxnFactory.createFactory(); cnxnFactory.configure(config.getClientPortAddress(),config.getMaxClientCnxns()); //… quorumPeer.setCnxnFactory(cnxnFactory); 并且将这个factory设置给了quorumPeer的成员属性 //…

这个很明显是一个工厂模式，基于这个工厂类创建什么呢？打开createFactory方法看看就知道了

ZkServer服务启动的逻辑-QuorumPeerMain.runFromConfig相关推荐

ZkServer服务启动的逻辑-NIOServerCnxnFactory.configure
thread其实构建的是一个zookeeperThread线程,并且线程的参数为this,表示当前NIOServerCnxnFactory也是实现了线程的类,那么它必须要重写 run方法,因此定位到N ...
ZkServer服务启动的逻辑-NIOServerCnxnFactory.start
这里通过thread.start启动一个线程,那thread是一个什么对象呢? public void start() { // ensure thread is started once and o ...
ZkServer服务启动的逻辑-QuorumPeer.start
因此,我们再回到QuorumPeer.start()方法中,cnxnFactory.start(),应该会调用NIOServerCnxnFactory这个类去启动一个线程 public synchro ...
ZkServer服务启动的逻辑-ServerCnxnFactory.createFactory
这个方法里面是根据ZOOKEEPER_SERVER_CNXN_FACTORY 来决定创建NIO server还是Netty Server 而默认情况下,应该是创建一个NIOServerCnxnFact ...
DolphinScheduler服务启停
1. 服务启停 cd /home/hadoop/app/dolphinscheduler/bin ⼀键停⽌集群所有服务 sh ./bin/stop-all.sh ⼀键开启集群所有服务 sh ./bin ...
filebeat服务启停
filebeat的服务启停 filebeat的启动通过二进制文件来实现,如: ./filebeat -e -c filebeat.yml. 注:-e指定filebeat.yml配置文件实现后台启动可 ...
SFB 项目经验-18-三台前端服务器同时停止两台后-前端服务启不来
问题描述: 在企业中,针对Skype for business Server 2015的前端服务器一般使用3台加入前端服务器池中,再通过硬件负载均衡器进行前端服务器的Web服务器的负载. 但如果你关闭 ...
ceph——rgw服务启不起来
环境:SUSE SESv5版本--对应社区ceph的L版本(12.2) 故障背景:在给ceph集群扩充第四个节点的时候,运行到stage4,报错: sesadmin:~ # salt-run stat ...
脚本实现oracle服务启停,通用服务启停shell脚本
################################### #通用启停脚本 #david ################################### APP_NAME=myAp ...

ZkServer服务启动的逻辑-QuorumPeerMain.runFromConfig

ZkServer服务启动的逻辑-QuorumPeerMain.runFromConfig相关推荐

最新文章

热门文章