Wie erstellt man einen Elasticsearch-Client und ruft die API mit Java auf?

elasticsearch bietet durch die Erstellung eines Clients einen umfangreichen Satz von Java-Aufrufschnittstellen zur Außenwelt. Im Allgemeinen werden Clients in zwei Typen unterteilt: Cluster-Informations-Clients und Daten-(Index-)Clients. Diese beiden Kategorien können in allgemeine Vorgänge und Verwaltungsvorgänge unterteilt werden.

Vererbungsbeziehung des Kunden

(Version 1.5, andere Versionen können abweichen):

#🎜🎜 #Anhand dieses Vererbungsdiagramms können Sie die Implementierung und Funktionen des Clients klar verstehen. Insgesamt gibt es drei Kategorien, nämlich Client, indexesAdminClient und ClusterAdminClient. Es verfügt über eine eigene Implementierungsklasse, stellt jedoch letztendlich externe Dienste über die Client-Schnittstelle bereit. Als allgemeine externe Schnittstelle kombiniert der Client zunächst admin-bezogene Vorgänge über die admin()-Methode. Außerdem stellt er alle gängigen Vorgänge für Daten und Cluster bereit.

Methodenimplementierung

Alle Schnittstellen implementieren asynchrone Aufrufe auf zwei Arten: Eine besteht darin, einen ActionFuture zurückzugeben, und die andere darin, einen ActionListener zu akzeptieren.

Nehmen Sie die Indexmethode als Beispiel

wie unten gezeigt

ActionFuture index(IndexRequest request) ;#🎜 🎜#

void index(IndexRequest request, ActionListener listener);

Die erste Methode gibt einen Future zurück und die zweite Methode muss einen Listener übergeben. Dies sind auch zwei grundlegende Möglichkeiten der asynchronen Implementierung. Der Client verwendet den Fassadenmodus. Am Beispiel der Indexmethode lautet der Code wie folgt:

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

Der Grund dafür ist Der sogenannte Fassadenmodus besteht darin, dass alle Methoden in den Client integriert sind, der Ausführungsprozess jedoch in der entsprechenden Aktion ausgeführt wird. In der Ausführungsmethode wird die entsprechende Aktionsinstanz abgerufen und die eigentliche Logik in der entsprechenden Transaktionsaktion implementiert.

Methodencode ausführen

lautet wie folgt:

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

Jede Operation entspricht einer entsprechenden Transportaktion, und diese Transportaktionen sind die endgültige Ausführung wer. Hier nehmen wir den Index als Beispiel für eine kurze Erklärung. Weitere Ergebnisse wie dieses werden wir später in der Analyse der Indexfunktion sehen.

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

In IndexAction definieren wir einfach einen NAMEN und mehrere einfache Methoden. Dieser Name wird beim Start im TransportService als Schlüssel für den transportHandler registriert. In der Ausführungsmethode wird die Transportaktion gemäß der im vorherigen Code gezeigten Aktion ausgeführt. Die eigentliche Ausführungslogik befindet sich in InternalTransportClient. Ihre Implementierung wird hier übersprungen und später im Detail analysiert. Die Registrierung all dieser Aktionen wird im actionModule implementiert und der Registrierungsprozess wird später zusammen mit der Aktion analysiert.

Das obige ist der detaillierte Inhalt vonWie erstellt man einen Elasticsearch-Client und ruft die API mit Java auf?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!