Java를 사용하여 Elasticsearch 클라이언트를 구축하고 API를 호출하는 방법은 무엇입니까?

elasticsearch는 클라이언트를 구성하여 외부 세계에 대한 풍부한 Java 호출 인터페이스 세트를 제공합니다. 일반적으로 클라이언트는 클러스터 정보 클라이언트와 데이터(인덱스) 클라이언트의 두 가지 유형으로 구분됩니다. 이 두 가지 범주는 일반 작업과 관리 작업으로 나눌 수 있습니다.

클라이언트의 상속 관계

(버전 1.5, 다른 버전은 다를 수 있음):

이 상속 관계 다이어그램을 통해 클라이언트의 구현 및 기능을 명확하게 이해할 수 있습니다. 총 세 가지 범주, 즉 클라이언트, indicesAdminClient 및 ClusterAdminClient가 있습니다. 자체 구현 클래스가 있지만 결국 클라이언트 인터페이스를 통해 외부 서비스를 제공합니다. 일반적인 외부 인터페이스로서 클라이언트는 먼저 admin() 메소드를 통해 관리 관련 작업을 결합하며 데이터 및 클러스터에 대한 모든 일반적인 작업도 제공합니다.

메서드 구현 측면에서

모든 인터페이스는 두 가지 방법으로 비동기 호출을 구현합니다. 하나는 ActionFuture를 반환하는 것이고, 다른 하나는 ActionListener를 수락하는 것입니다.

아래와 같이 인덱스 메소드를 예로 들어보세요

ActionFuture index(IndexRequest request) ;

void index(IndexRequest request, ActionListener Listener);

첫 번째 메소드가 반환됩니다. future의 경우 두 번째 메서드는 리스너를 전달해야 합니다. 이는 비동기 구현의 두 가지 기본 방법이기도 합니다. 클라이언트는 Facade 모드를 사용하는데, 모든 구현은 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);
    }

구현은 위와 같습니다. Facade 모드라고 불리는 이유는 다음과 같습니다. 모든 메소드는 클라이언트에 통합되지만 실행 프로세스는 해당 작업에서 실행됩니다. 실행 메소드에서는 해당 액션 인스턴스를 획득하고 해당 트랜잭션 액션에서 실제 로직을 구현합니다.

실행 메소드 코드

는 다음과 같습니다.

@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를 예로 들어 보겠습니다. 나중에 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의 키로 TransportService에 등록됩니다. 실행 메소드에서는 이전 코드와 같이 액션에 따라 TransportAction이 수행됩니다. 실제 실행 로직은 InternalTransportClient에 있습니다. 여기서는 구현을 건너뛰고 나중에 자세히 분석하겠습니다. 이러한 모든 액션의 등록은 actionModule에서 구현되며, 등록 프로세스는 나중에 액션과 함께 분석됩니다.

위 내용은 Java를 사용하여 Elasticsearch 클라이언트를 구축하고 API를 호출하는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!