elasticsearch通過構(gòu)造一個(gè)client對(duì)外提供了一套豐富的java調(diào)用接口。總體來說client分為兩類cluster信息方面的client及數(shù)據(jù)（index）方面的client。這兩個(gè)大類由可以分為通用操作和admin操作兩類。

client的繼承關(guān)系

（1.5版本，其它版本可能不一樣）：

通過這個(gè)繼承關(guān)系圖可以很清楚的了解client的實(shí)現(xiàn)，及功能?？偣灿腥惣碿lient， indicesAdminClient和ClusterAdminClient。它都有自己的實(shí)現(xiàn)類，但最后都是通過client接口對(duì)外提供服務(wù)。client作為對(duì)外的總接口，首先通過admin()方法組合了admin的相關(guān)操作，它本身也提供了所有對(duì)數(shù)據(jù)和cluster的通用操作。

方法實(shí)現(xiàn)上

所有的接口都通過兩種方式實(shí)現(xiàn)了異步調(diào)用，一個(gè)是返回一個(gè)ActionFuture，另外一種方式是接受一個(gè)ActionListener。

以index方法為例

如下所示

 ActionFuture<IndexResponse>  index(IndexRequest request) ;

 void index(IndexRequest request, ActionListener<IndexResponse> listener);

第一個(gè)方法會(huì)返回一個(gè)future，第二個(gè)方法則需要傳遞一個(gè)Listener。這也是異步實(shí)現(xiàn)的兩個(gè)基本方式。client使用了門面模式，所有的實(shí)現(xiàn)都在AbstractClient類中，還以index方法為例，代碼如下所示：

@Override
    public ActionFuture<IndexResponse> index(final IndexRequest request) {
        return execute(IndexAction.INSTANCE, request);
    }
    @Override
    public void index(final IndexRequest request, final ActionListener<IndexResponse> listener) {
        execute(IndexAction.INSTANCE, request, listener);
    }

實(shí)現(xiàn)如上所示，之所以說它是門面模式是因?yàn)樗械姆椒ǘ急患傻搅薱lient中，但是執(zhí)行過程都是在對(duì)應(yīng)的action中執(zhí)行。在execute方法中，獲取到相應(yīng)的action實(shí)例，真正的邏輯是在對(duì)應(yīng)的transportaction中實(shí)現(xiàn)。

execute方法代碼

如下所示：

@SuppressWarnings("unchecked")
    @Override
    public <Request extends ActionRequest, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder, Client>> ActionFuture<Response> execute(Action<Request, Response, RequestBuilder, Client> action, Request request) {
        headers.applyTo(request);
        TransportAction<Request, Response> transportAction = actions.get((ClientAction)action);
        return transportAction.execute(request);
    }
    @SuppressWarnings("unchecked")
    @Override
    public <Request extends ActionRequest, Response extends ActionResponse, RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder, Client>> void execute(Action<Request, Response, RequestBuilder, Client> action, Request request, ActionListener<Response> listener) {
        headers.applyTo(request);
        TransportAction<Request, Response> transportAction = actions.get((ClientAction)action);
        transportAction.execute(request, listener);
    }

每一種操作都對(duì)應(yīng)有相應(yīng)的transportAction，這些transportAction才是最終的執(zhí)行者。這里先以index為例簡(jiǎn)單說明，在后面索引功能分析中會(huì)看到更多這種的結(jié)果。

public class IndexAction extends ClientAction<IndexRequest, IndexResponse, IndexRequestBuilder> {
    public static final IndexAction INSTANCE = new IndexAction();
    public static final String NAME = "indices:data/write/index";
    private IndexAction() {
        super(NAME);
    }
    @Override
    public IndexResponse newResponse() {
        return new IndexResponse();
    }
    @Override
    public IndexRequestBuilder newRequestBuilder(Client client) {
        return new IndexRequestBuilder(client);
    }
}

在IndexAction中只是簡(jiǎn)單的定義了一個(gè)NAME，及幾個(gè)簡(jiǎn)單的方法。這個(gè)名字會(huì)在啟動(dòng)時(shí)作為對(duì)于的transportHandler的key注冊(cè)到TransportService中。在execute方法中，會(huì)根據(jù)action的將transportAction取出如上一段代碼所示。真正的執(zhí)行邏輯在InternalTransportClient中，這里先略過它的實(shí)現(xiàn)，后面會(huì)有詳細(xì)分析。所有這些action的注冊(cè)都是在actionModule中實(shí)現(xiàn)，注冊(cè)過程會(huì)在后面跟action一起分析。

總結(jié)：

client模塊通過代理模式，將所有的操作都集成到client接口中。這樣外部調(diào)用只需要初始化client就能夠完成所有的調(diào)用功能。這些接口的執(zhí)行邏輯均在對(duì)應(yīng)的transportAction中。這種精巧的設(shè)計(jì)給使用者帶來很大的便利 。

以上就是elasticsearch構(gòu)造Client實(shí)現(xiàn)java客戶端調(diào)用接口示例分析的詳細(xì)內(nèi)容，更多關(guān)于elasticsearch構(gòu)造java客戶端調(diào)用接口Client的資料請(qǐng)關(guān)注腳本之家其它相關(guān)文章！

最新評(píng)論