上一篇介紹了elasticsearch的client結(jié)構(gòu)，client只是一個門面，在每個方法后面都有一個action來承接相應(yīng)的功能。但是action也并非是真正的功能實現(xiàn)者，它只是一個代理，它的真正實現(xiàn)者是transportAction.本篇就對action及transportAction的實現(xiàn)做一個簡單的分析，

elasticsearch中的絕大部分操作都是通過相應(yīng)的action，這些action在action包中。它的結(jié)構(gòu)如下圖所示：

上圖是action包的部分截圖，這里面對應(yīng)著各個功能的action。各個action的包也都非常類似于index。這些action的實現(xiàn)也非常類似，都是基礎(chǔ)自action，下圖是indexaction的繼承關(guān)系：

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

可以看到它只是提供了兩個新建response和request的方法，及一個字NAME字段，這個NAME字段會用于后面action調(diào)用中。每個action對應(yīng)的功能實現(xiàn)是在對應(yīng)的transportAction中。

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

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

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

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中會將對應(yīng)的action和TransportAction綁定。這樣在client需要收到請求時會根據(jù)對于的action實例來查找對應(yīng)的tansportAction實例，最終請求在它們下面處理。

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

以上就是elasticsearch java客戶端action的實現(xiàn)簡單分析的詳細內(nèi)容，更多關(guān)于elasticsearch java客戶端action實現(xiàn)的資料請關(guān)注腳本之家其它相關(guān)文章！

最新評論