elasticsearch啓動流程

本文基於ES2.3.2來描述。經過結合源碼梳理出ES實例的啓動過程。

elasticsearch的啓動過程是根據配置和環境組裝須要的模塊並啓動的過程。這一過程就是經過guice注入各個功能模塊並啓動這些模塊，從而獲得一個功能完整的node。正如以前所說elasticsearch的模塊化特色，它的各個功能都是獨立實現，而後實現經過guice對外提供。首先簡單的說一下guice，它是google的一個輕量級依賴注入框架。它的做者也是依賴注入標準（JSR-330）制定者。雖然它是輕量級框架，可是它的功能及性能卻很是好，這也是elasticsearch選用它做爲代碼主要框架的一個主要緣由。

 

 

 1.ES實例啓動

org.elasticsearch.Elasticsearch.main
org.elasticsearch.bootstrap
{
    啓動用戶線程keepAliveThread
    導入環境變量和配置參數
    建立pid文件
    檢查（jvm環境，安全、等等）
    nodeBuilder.build()
    node.start();
    keepAliveThread.start();
}

 

2.Node啓動

 

Node()
{
 更新setting和environment 構造pluginsService並動態加載plugin @1 加載並初始化modules（PluginsModule/ClusterModule/RestModule/TransportModule/ActionModule等） 使用guice構造各modules 構造client對象（performing actions/operations against the cluster } Node start() { 構造services和plugins實例。 @2
 TransportService啓動 @3 DiscoveryService啓動 @4 HttpServerTransport綁定地址，開始監聽 @5
}

能夠看到node的初始化過程主要包括三部分，第一是配置node環境，第二是啓動插件服務（es提供了插件功能來進行擴展功能，這也是它的一個亮點），加載須要的插件，最後就是經過guice加載各個模塊，啓動各個服務。

先說一下插件加載過程。每一個node在加載各個模塊前，會首先加載所須要的插件，若是有些插件加載不成功node會啓動失敗。這裏會加載三類插件：首先是配置插件，配置到節點配置文件中插件，如分詞插件等；而後查找classpath中能找到的插件，這些插件通常防止在plugin文件夾中；最後是加載site插件，site插件是不涉及java代碼的純網站式插件，如監控插件head，bigdesk等。任何使用者均可以開發本身須要的插件，只要按着elasticsearch相關版本的插件開發規範來實現便可。接下來首先說一下啓動各個模塊的過程。elasticsearch各個功能模塊實現的很是好，解耦很是完美，不少模塊都實現了生命週期接口，只有啓動它纔可以對外提供服務，它的啓動過程也是功能模塊初始化的過程。所以，node節點的啓動過程也就是這些模塊初始化的過程。

 

@1構造pluginsService並動態加載plugin

依次調用各插件的OnModule方法。在OnModule方法內部能夠針對多種model來依次操做，好比下面的添加過濾器或者替換TransportService。

爲RestModule添加一個過濾器
    public void onModule(RestModule module) {
        module.addRestAction(AuthorityRestFilter.class);
    }

爲actionModels添加自定義過濾器AuthorityActionFilter
public void onModule(final ActionModule module) {
    module.registerFilter(AuthorityActionFilter.class);
}

使用自定義AuthorityTransportService來代替默認的TransportService
public void onModule(final TransportModule module) {
    module.setTransportService(AuthorityTransportService.class, name());
}

 @2 啓動各項服務

for (Class<? extends LifecycleComponent> plugin : pluginsService.nodeServices()) {
     injector.getInstance(plugin).start();// 加載插件中的自定義服務並啓動
}

//經過guice獲取各個模塊的service接口並啓動

injector.getInstance(MappingUpdatedAction.class).setClient(client);
injector.getInstance(IndicesService.class).start();
injector.getInstance(IndexingMemoryController.class).start();
injector.getInstance(IndicesClusterStateService.class).start();
injector.getInstance(IndicesTTLService.class).start();
injector.getInstance(SnapshotsService.class).start();
injector.getInstance(SnapshotShardsService.class).start();
injector.getInstance(RoutingService.class).start();
injector.getInstance(SearchService.class).start();
injector.getInstance(MonitorService.class).start();
injector.getInstance(RestController.class).start();

// TODO hack around circular dependencies problems
injector.getInstance(GatewayAllocator.class).setReallocation(injector.getInstance(ClusterService.class), injector.getInstance(RoutingService.class));

injector.getInstance(ResourceWatcherService.class).start();
injector.getInstance(GatewayService.class).start();

 

@3 使用netty實現的 tcp 引擎  public class NettyTransport extends AbstractLifecycleComponent<Transport> implements Transport

       構造客戶端BootStrap，用於和其它節點間的通訊。若是是server模式，還要啓動ServerBootstrap用於接收其它客戶端發來的請求

@4 發現功能功能主要用於節點啓動後發現集羣，master向全部節點發布集羣狀態，選舉master節點並引起集羣節點變得事件

 @5 使用netty實現的 http 引擎  public class NettyHttpServerTransport extends AbstractLifecycleComponent<HttpServerTransport> implements HttpServerTransport

 

 3.ES實例退出

shutdownhook觸發
node.close，中止各類服務、插件、腳本、線程池
CountDownLatch減一，keepAliveThread退出
刪除pid文件