Druid的代碼里面使用了大量的Google Guice依賴注入(DI),還是第一次接觸Guice。相比于Spring的DI,這是一個(gè)更加輕量的注入方案辅鲸。如果不了解它的工作流程,代碼閱讀理解起來(lái)還是有點(diǎn)困難的腹殿,找不到頭尾独悴。這里以CliOverlord為例子,看一下服務(wù)的啟動(dòng)流程锣尉。Druid版本是0.13.0刻炒。
類(lèi)繼承圖
先來(lái)看一下CliOverlord的類(lèi)繼承關(guān)系圖。Command注解來(lái)自命令行處理庫(kù)Airline悟耘,有興趣的可以深入了解一下落蝙。GuiceRunnable是所有服務(wù)的基類(lèi),從名字可以看出暂幼,這里主要還是定義了一些依賴注入處理的邏輯筏勒,核心是makeInjector和initLifecycle這兩個(gè)方法。GuiceRunnable的子類(lèi)通過(guò)重寫(xiě)getModules方法旺嬉,來(lái)定義服務(wù)自己特有的裝配邏輯管行,并實(shí)現(xiàn)Lifecycle.Handler接口,用于Lifecycle回調(diào)邪媳。出了實(shí)現(xiàn)Handler接口捐顷,lifecycle也會(huì)掃描注入的依賴中的方法或者注解荡陷,如果包含start/stop方法或者有被LifecycleStart/LifecycleStop注解修飾的方法,也會(huì)調(diào)用相應(yīng)的方法來(lái)啟動(dòng)或者停止服務(wù)組件迅涮。
ServerRunnable繼承GuiceRunnable废赞,實(shí)現(xiàn)了Runnable接口的run方法。實(shí)現(xiàn)邏輯只是簡(jiǎn)單的調(diào)用父類(lèi)的makeInjector和initLifecycle方法叮姑。除此之外還新增了一個(gè)DiscoverySideEffectsProvider類(lèi)唉地,實(shí)現(xiàn)的是Guice的Provider接口,用于將不同類(lèi)型的Druid節(jié)點(diǎn)注冊(cè)到zk或者從zk注銷(xiāo)传透,提供服務(wù)發(fā)現(xiàn)的功能耘沼。不同類(lèi)型的Druid服務(wù)繼承ServerRunnable,一般只需重寫(xiě)getModules方法綁定依賴關(guān)系即可朱盐。
CliOverlord啟動(dòng)流程
org.apache.druid.cli.Main server overlord
這是啟動(dòng)overlord服務(wù)的命令群嗤,通過(guò)airline解析命令參數(shù)后,會(huì)調(diào)用到類(lèi)CliOverlord的run方法兵琳,run方法里面進(jìn)一步調(diào)用父類(lèi)的makeInjector方法狂秘,在獲取注入器(Injector)時(shí),定義了一些所有服務(wù)共同擁有的Modules(defaultModules)躯肌,其中就有JettyServerModule用于啟動(dòng)web server赃绊。這個(gè)JettyServerModule內(nèi)部實(shí)現(xiàn)了Lifecycle.Handler(實(shí)現(xiàn)start和stop方法),Lifecycle會(huì)回調(diào)啟動(dòng)和停止方法管理羡榴。對(duì)于服務(wù)中包含哪些servlet則是在每個(gè)服務(wù)的實(shí)現(xiàn)重寫(xiě)getModules的時(shí)候,通過(guò)Jerseys.addResource方法指定运敢,比如CliOverlord增加了如下三個(gè)resource:
Jerseys.addResource(binder, OverlordResource.class);
Jerseys.addResource(binder, SupervisorResource.class);
Jerseys.addResource(binder, HttpRemoteTaskRunnerResource.class);
OverlordResource就是提供/druid/indexer/v1/task服務(wù)的地方校仑。
總結(jié)
從分析來(lái)看,Druid在代碼實(shí)現(xiàn)上統(tǒng)一了服務(wù)的啟動(dòng)流程传惠,盡可能的復(fù)用流程和代碼迄沫,其他druid節(jié)點(diǎn)的啟動(dòng)流程是類(lèi)似的。很像Hook機(jī)制卦方,用戶只需要實(shí)現(xiàn)handler中的方法羊瘩,處理流程會(huì)回調(diào)這些方法。