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字段會(huì)用于后面action調(diào)用中。每個(gè)action對應(yīng)的功能實(shí)現(xiàn)是在對應(yīng)的transportAction中。

這些tansportAction都繼承了TransportAction接口??蛻舳苏{(diào)用client的相關(guān)接口時(shí),client會(huì)將請求發(fā)送到transportAction的execute上。每個(gè)功能的TransportAction實(shí)現(xiàn)了doExecute方法,功能的邏輯都在此方法中實(shí)現(xiàn),這里先暫且不提,后面的功能分析中會(huì)看到對應(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ì)將對應(yīng)的action和TransportAction綁定。這樣在client需要收到請求時(shí)會(huì)根據(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)文章
SpringBoot 調(diào)度任務(wù)及常用任務(wù)表達(dá)式
這篇文章主要介紹了SpringBoot 調(diào)度任務(wù)及常用任務(wù)表達(dá)式,需要的朋友可以參考下2017-12-12
SpringBoot整合Dubbo+Zookeeper實(shí)現(xiàn)RPC調(diào)用
這篇文章主要給大家介紹了Spring Boot整合Dubbo+Zookeeper實(shí)現(xiàn)RPC調(diào)用的步驟詳解,文中有詳細(xì)的代碼示例,對我們的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2023-07-07
IDEA中項(xiàng)目集成git提交代碼的詳細(xì)步驟
這篇文章主要介紹了IDEA中項(xiàng)目集成git提交代碼的詳細(xì)步驟,本文通過圖文并茂的形式給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值,需要的朋友可以參考下2020-10-10
使用feign傳遞參數(shù)類型為MultipartFile的問題
這篇文章主要介紹了使用feign傳遞參數(shù)類型為MultipartFile的問題,具有很好的參考價(jià)值,希望對大家有所幫助。如有錯(cuò)誤或未考慮完全的地方,望不吝賜教2022-03-03

