Java 客户端

<dependency>
  <groupId>co.elastic.clients</groupId>
  <artifactId>elasticsearch-java</artifactId>
  <version>8.10.0</version>
</dependency>

import co.elastic.clients.elasticsearch.ElasticsearchClient;
import co.elastic.clients.elasticsearch._types.ElasticsearchException;
import co.elastic.clients.elasticsearch.core.GetResponse;
import co.elastic.clients.json.jackson.JacksonJsonpMapper;
import co.elastic.clients.transport.rest_client.RestClientTransport;
import org.apache.http.HttpHost;
import org.elasticsearch.client.RestClient;

public class ElasticsearchExample {
    public static void main(String[] args) throws Exception {
        RestClient restClient = RestClient.builder(
            new HttpHost("localhost", 9200)).build();

        RestClientTransport transport = new RestClientTransport(
            restClient, new JacksonJsonpMapper());

        ElasticsearchClient client = new ElasticsearchClient(transport);

        // 示例：获取文档
        try {
            GetResponse<Object> response = client.get(g -> g
                .index("my-index")
                .id("1"), Object.class);
            if (response.found()) {
                System.out.println(response.source());
            } else {
                System.out.println("Document not found");
            }
        } catch (ElasticsearchException e) {
            e.printStackTrace();
        }

        restClient.close();
    }
}