elasticsearch構造Client實現java使用者端呼叫介面範例分析

2022-04-21 19:00:24

client的繼承關係

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

通過這個繼承關係圖可以很清楚的瞭解client的實現，及功能。總共有三類即client， indicesAdminClient和ClusterAdminClient。它都有自己的實現類，但最後都是通過client介面對外提供服務。client作為對外的總介面，首先通過admin()方法組合了admin的相關操作，它本身也提供了所有對資料和cluster的通用操作。

方法實現上

所有的介面都通過兩種方式實現了非同步呼叫，一個是返回一個ActionFuture，另外一種方式是接受一個ActionListener。

以index方法為例

如下所示

ActionFuture<IndexResponse> index(IndexRequest request) ;

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

第一個方法會返回一個future，第二個方法則需要傳遞一個Listener。這也是非同步實現的兩個基本方式。client使用了門面模式，所有的實現都在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);
    }

實現如上所示，之所以說它是門面模式是因為所有的方法都被整合到了client中，但是執行過程都是在對應的action中執行。在execute方法中，獲取到相應的action範例，真正的邏輯是在對應的transportaction中實現。

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);
    }

每一種操作都對應有相應的transportAction，這些transportAction才是最終的執行者。這裡先以index為例簡單說明，在後面索引功能分析中會看到更多這種的結果。

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中只是簡單的定義了一個NAME，及幾個簡單的方法。這個名字會在啟動時作為對於的transportHandler的key註冊到TransportService中。在execute方法中，會根據action的將transportAction取出如上一段程式碼所示。真正的執行邏輯在InternalTransportClient中，這裡先略過它的實現，後面會有詳細分析。所有這些action的註冊都是在actionModule中實現，註冊過程會在後面跟action一起分析。

總結：

client模組通過代理模式，將所有的操作都整合到client介面中。這樣外部呼叫只需要初始化client就能夠完成所有的呼叫功能。這些介面的執行邏輯均在對應的transportAction中。這種精巧的設計給使用者帶來很大的便利。

以上就是elasticsearch構造Client實現java使用者端呼叫介面範例分析的詳細內容，更多關於elasticsearch構造java使用者端呼叫介面Client的資料請關注it145.com其它相關文章！

elasticsearch構造Client實現java使用者端呼叫介面範例分析

目錄

client的繼承關係

方法實現上

以index方法為例

execute方法程式碼

總結：

熱門文章