elasticsearch?java客戶端action的實(shí)現(xiàn)簡單分析
上一篇介紹了elasticsearch的client結(jié)構(gòu),client只是一個(gè)門面,在每個(gè)方法后面都有一個(gè)action來承接相應(yīng)的功能。但是action也并非是真正的功能實(shí)現(xiàn)者,它只是一個(gè)代理,它的真正實(shí)現(xiàn)者是transportAction.本篇就對action及transportAction的實(shí)現(xiàn)做一個(gè)簡單的分析,
elasticsearch中的絕大部分操作都是通過相應(yīng)的action,這些action在action包中。它的結(jié)構(gòu)如下圖所示:
上圖是action包的部分截圖,這里面對應(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)上也非常簡單。他們的主要作用是提供新建response和request的方法及對應(yīng)的action名稱。還拿indexaction為例,它的方法圖如下所示:
可以看到它只是提供了兩個(gè)新建response和request的方法,及一個(gè)字NAME字段,這個(gè)NAME字段會用于后面action調(diào)用中。每個(gè)action對應(yīng)的功能實(shí)現(xiàn)是在對應(yīng)的transportAction中。
這些tansportAction都繼承了TransportAction接口??蛻舳苏{(diào)用client的相關(guān)接口時(shí),client會將請求發(fā)送到transportAction的execute上。每個(gè)功能的TransportAction實(shí)現(xiàn)了doExecute方法,功能的邏輯都在此方法中實(shí)現(xiàn),這里先暫且不提,后面的功能分析中會看到對應(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中會將對應(yīng)的action和TransportAction綁定。這樣在client需要收到請求時(shí)會根據(jù)對于的action實(shí)例來查找對應(yīng)的tansportAction實(shí)例,最終請求在它們下面處理。
總結(jié):這里對action及TransportAction做了簡單分析。作為elasticsearch對外的java客戶端的一部分,action作用是在客戶端相應(yīng)的方法中接收相應(yīng)的請求,然后轉(zhuǎn)發(fā)到對應(yīng)的TransportAction中進(jìn)行處理。這里使用了代理模式,通過guice注入解耦。
以上就是elasticsearch java客戶端action的實(shí)現(xiàn)簡單分析的詳細(xì)內(nèi)容,更多關(guān)于elasticsearch java客戶端action實(shí)現(xiàn)的資料請關(guān)注腳本之家其它相關(guān)文章!
相關(guān)文章
Flink實(shí)現(xiàn)特定統(tǒng)計(jì)的歸約聚合reduce操作
這篇文章主要介紹了Flink實(shí)現(xiàn)特定統(tǒng)計(jì)的歸約聚合reduce操作,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友們下面隨著小編來一起學(xué)習(xí)吧2023-02-02Spring中使用事務(wù)嵌套時(shí)需要警惕的問題分享
最近項(xiàng)目上有一個(gè)使用事務(wù)相對復(fù)雜的業(yè)務(wù)場景報(bào)錯(cuò)了。在絕大多數(shù)情況下,都是風(fēng)平浪靜,沒有問題。其實(shí)內(nèi)在暗流涌動(dòng),在有些異常情況下就會報(bào)錯(cuò),這種偶然性的問題很有可能就會在暴露到生產(chǎn)上造成事故,那究竟是怎么回事呢?本文就來簡單講講2023-04-04springboot使用shiro-整合redis作為緩存的操作
這篇文章主要介紹了springboot使用shiro-整合redis作為緩存的操作,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2021-06-06MyBatis緩存實(shí)現(xiàn)原理及代碼實(shí)例解析
這篇文章主要介紹了MyBatis緩存實(shí)現(xiàn)原理及代碼實(shí)例解析,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2020-08-08Java 使用POI生成帶聯(lián)動(dòng)下拉框的excel表格實(shí)例代碼
本文通過實(shí)例代碼給大家分享Java 使用POI生成帶聯(lián)動(dòng)下拉框的excel表格,代碼簡單易懂,非常不錯(cuò),具有參考借鑒價(jià)值,需要的朋友參考下吧2017-09-09Maven方式構(gòu)建SpringBoot項(xiàng)目的實(shí)現(xiàn)步驟(圖文)
Maven是一個(gè)強(qiáng)大的項(xiàng)目管理工具,可以幫助您輕松地構(gòu)建和管理Spring Boot應(yīng)用程序,本文主要介紹了Maven方式構(gòu)建SpringBoot項(xiàng)目的實(shí)現(xiàn)步驟,具有一定的參考價(jià)值,感興趣的可以了解一下2023-09-09