es的java调用
Elasticsearch Java 客户端调用方法
Elasticsearch 提供了两种主要的 Java 客户端调用方式:High Level REST Client(官方推荐)和 Java API Client(8.x 版本后新增)。以下分别介绍两种方式的使用方法。
High Level REST Client(7.x-8.x 兼容)
适用于 Elasticsearch 7.x 和 8.x 版本,需添加 Maven 依赖:
<dependency><groupId>org.elasticsearch.client</groupId><artifactId>elasticsearch-rest-high-level-client</artifactId><version>7.17.0</version>
</dependency>
初始化客户端
RestHighLevelClient client = new RestHighLevelClient(RestClient.builder(new HttpHost("localhost", 9200, "http"))
);
索引文档
IndexRequest request = new IndexRequest("index_name").id("1").source("field1", "value1", "field2", "value2");
IndexResponse response = client.index(request, RequestOptions.DEFAULT);
搜索文档
SearchRequest searchRequest = new SearchRequest("index_name");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
sourceBuilder.query(QueryBuilders.matchQuery("field1", "value1"));
searchRequest.source(sourceBuilder);
SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);
Java API Client(8.x+ 推荐)
Elasticsearch 8.x 推出的新客户端,需添加依赖:
<dependency><groupId>co.elastic.clients</groupId><artifactId>elasticsearch-java</artifactId><version>8.12.0</version>
</dependency>
初始化客户端
RestClient restClient = RestClient.builder(new HttpHost("localhost", 9200)).build();
ElasticsearchTransport transport = new RestClientTransport(restClient, new JacksonJsonpMapper());
ElasticsearchClient client = new ElasticsearchClient(transport);
索引文档
Product product = new Product("1", "Elasticsearch Guide");
IndexResponse response = client.index(i -> i.index("products").id(product.getId()).document(product));
搜索文档
SearchResponse<Product> response = client.search(s -> s.index("products").query(q -> q.match(t -> t.field("name").query("Guide"))),Product.class);
通用注意事项
- 连接池管理:确保客户端单例化,避免重复创建。
- 异常处理:捕获
IOException
和ElasticsearchException
。 - 版本兼容性:客户端版本应与 Elasticsearch 服务端主版本号一致。
- 异步操作:两种客户端均支持异步调用(如
client.indexAsync()
)。
示例代码完整结构
// 关闭客户端(finally 块中调用)
client.close();
两种方式均可实现完整 CRUD 操作,8.x 用户建议优先使用新 Java API Client 以获得更好的类型安全和流畅 API 体验。