elasticsearch java 客戶端之action簡介

上一篇介紹了elasticsearch的client結構，client只是一個門面，在每個方法后面都有一個action來承接相應的功能。但是action也並非是真正的功能實現者，它只是一個代理，它的真正實現者是transportAction.本篇就對action及transportAction的實現做一個簡單的分析，

elasticsearch中的絕大部分操作都是通過相應的action，這些action在action包中。它的結構如下圖所示：

上圖是action包的部分截圖，這里面對應着各個功能的action。各個action的包也都非常類似於index。這些action的實現也非常類似，都是基礎自action，下圖是indexaction的繼承關系：

因為這些action並未真正實現相應的功能，只是一個代理，因此實現上也非常簡單。他們的主要作用是提供新建response和request的方法及對應的action名稱。還拿indexaction為例，它的方法圖如下所示：

可以看到它只是提供了兩個新建response和request的方法，及一個字NAME字段，這個NAME字段會用於后面action調用中。每個action對應的功能實現是在對應的transportAction中。

這些tansportAction都繼承了TransportAction接口。客戶端調用client的相關接口時，client會將請求發送到transportAction的execute上。每個功能的TransportAction實現了doExecute方法，功能的邏輯都在此方法中實現，這里先暫且不提，后面的功能分析中會看到對應的實現。

在client分析中有這樣一段代碼：

TransportAction<Request, Response> transportAction = actions.get((ClientAction)action)它的作用就是根據action獲取TransportAction。因為action只是代理。這些關聯關系是在ActionModule中實現的，代碼如下所示：

　　    registerAction(NodesInfoAction.INSTANCE, TransportNodesInfoAction.class);
        registerAction(NodesStatsAction.INSTANCE, TransportNodesStatsAction.class);
        registerAction(NodesShutdownAction.INSTANCE, TransportNodesShutdownAction.class);
        registerAction(NodesRestartAction.INSTANCE, TransportNodesRestartAction.class);
        registerAction(NodesHotThreadsAction.INSTANCE, TransportNodesHotThreadsAction.class);
        registerAction(ClusterStatsAction.INSTANCE, TransportClusterStatsAction.class);
        registerAction(ClusterStateAction.INSTANCE, TransportClusterStateAction.class);
        registerAction(ClusterHealthAction.INSTANCE, TransportClusterHealthAction.class)

這只是一小部分，可以看到在module中會將對應的action和TransportAction綁定。這樣在client需要收到請求時會根據對於的action實例來查找對應的tansportAction實例，最終請求在它們下面處理。

總結：這里對action及TransportAction做了簡單分析。作為elasticsearch對外的java客戶端的一部分，action作用是在客戶端相應的方法中接收相應的請求，然后轉發到對應的TransportAction中進行處理。這里使用了代理模式，通過guice注入解耦。