elasticsearch?java客戶端action怎么實現(xiàn)

這篇文章主要介紹“elasticsearch java客戶端action怎么實現(xiàn)”的相關知識，小編通過實際案例向大家展示操作過程，操作方法簡單快捷，實用性強，希望這篇“elasticsearch java客戶端action怎么實現(xiàn)”文章能幫助大家解決問題。

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

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

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

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

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

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

TransportAction<Request, Response> transportAction = actions.get((ClientAction)action)它的作用就是根據action獲取TransportAction。因為action只是代理。這些關聯(liá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中會將對應的action和TransportAction綁定。這樣在client需要收到請求時會根據對于的action實例來查找對應的tansportAction實例，最終請求在它們下面處理。

關于“elasticsearch java客戶端action怎么實現(xiàn)”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關的知識，可以關注億速云行業(yè)資訊頻道，小編每天都會為大家更新不同的知識點。