快捷導(dǎo)航

elasticsearch?java客戶端action的實(shí)現(xiàn)簡(jiǎn)單分析

更新時(shí)間：2022年04月21日 17:00:02 作者：zziawan

這篇文章主要為大家介紹了elasticsearch?java客戶端action的實(shí)現(xiàn)簡(jiǎn)單分析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

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

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

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

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

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

這些tansportAction都繼承了TransportAction接口?？蛻舳苏{(diào)用client的相關(guān)接口時(shí)，client會(huì)將請(qǐng)求發(fā)送到transportAction的execute上。每個(gè)功能的TransportAction實(shí)現(xiàn)了doExecute方法，功能的邏輯都在此方法中實(shí)現(xiàn)，這里先暫且不提，后面的功能分析中會(huì)看到對(duì)應(yīng)的實(shí)現(xiàn)。

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

TransportAction<Request, Response> transportAction = actions.get((ClientAction)action)它的作用就是根據(jù)action獲取TransportAction。因?yàn)閍ction只是代理。這些關(guān)聯(lián)關(guān)系是在ActionModule中實(shí)現(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中會(huì)將對(duì)應(yīng)的action和TransportAction綁定。這樣在client需要收到請(qǐng)求時(shí)會(huì)根據(jù)對(duì)于的action實(shí)例來(lái)查找對(duì)應(yīng)的tansportAction實(shí)例，最終請(qǐng)求在它們下面處理。

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

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

您可能感興趣的文章: