Java连接ES教程：RestHighLevelClient使用指南

编程并不是一个机械性的工作，而是需要有思考，有创新的工作，语法是固定的，但解决问题的思路则是依靠人的思维，这就需要我们坚持学习和更新自己的知识。今天golang学习网就整理分享《Java连接ES教程：RestHighLevelClient使用详解》，文章讲解的知识点主要包括，如果你对文章方面的知识点感兴趣，就不要错过golang学习网，在这可以对大家的知识积累有所帮助，助力开发能力的提升。

如何使用Java中的RestHighLevelClient连接Elasticsearch？1.添加Maven依赖，引入elasticsearch-rest-high-level和elasticsearch对应版本；2.创建客户端实例，指定ES地址或集群节点，并建议单例使用；3.执行插入数据、查询数据、搜索数据等操作；4.注意版本匹配、资源关闭、异常处理及安全认证配置。

连接Elasticsearch（ES）是Java应用中常见的需求，特别是在做搜索、日志分析等场景。如果你用的是较老版本的ES（比如6.x或7.x），可能还会接触到一个叫 RestHighLevelClient 的客户端。

虽然现在官方已经不推荐使用这个客户端了（建议用新的 Java API Client），但很多老项目还在用它，所以还是有必要了解怎么用。

下面简单说说怎么在Java里用 RestHighLevelClient 连接ES。

添加Maven依赖

要使用这个客户端，首先得引入对应的依赖。一般项目都是用 Maven 或 Gradle 管理依赖，这里以 Maven 为例：

    org.elasticsearch.client
    elasticsearch-rest-high-level
    7.17.0 



    org.elasticsearch
    elasticsearch
    7.17.0

注意：版本号一定要跟你用的 ES 版本一致，不然容易出兼容性问题。

创建客户端实例

创建 RestHighLevelClient 实例时，需要指定 ES 的地址，通常是通过 HTTP 方式连接。

RestHighLevelClient client = new RestHighLevelClient(
    RestClient.builder(
        new HttpHost("localhost", 9200, "http")
    )
);

如果是集群部署，可以加多个节点：

RestClient.builder(
    new HttpHost("host1", 9200, "http"),
    new HttpHost("host2", 9200, "http")
)

• 建议把这个 client 做成单例，不要每次请求都新建。
• 使用完之后记得关闭，避免资源泄露。

常见操作示例

插入数据

可以用 IndexRequest 来插入一条记录：

IndexRequest request = new IndexRequest("my_index");
request.id("1"); // 可选，如果不指定会自动生成
request.source(Map.of("name", "张三", "age", 25), XContentType.JSON);

client.index(request, RequestOptions.DEFAULT);

查询数据

使用 GetRequest 获取某条记录：

GetRequest getRequest = new GetRequest("my_index", "1");
GetResponse response = client.get(getRequest, RequestOptions.DEFAULT);

if (response.isExists()) {
    Map source = response.getSource();
    System.out.println(source); // 输出：{name=张三, age=25}
}

搜索数据

可以用 SearchRequest 加上 SearchSourceBuilder 构建查询条件，比如按字段匹配：

SearchRequest searchRequest = new SearchRequest("my_index");
SearchSourceBuilder sourceBuilder = new SearchSourceBuilder();
MatchQueryBuilder matchQuery = QueryBuilders.matchQuery("name", "张三");

sourceBuilder.query(matchQuery);
searchRequest.source(sourceBuilder);

SearchResponse response = client.search(searchRequest, RequestOptions.DEFAULT);

这些只是基本操作，实际开发中还要处理异常、分页、聚合等等。

注意事项

• RestHighLevelClient 已被标记为过时，在新项目中建议考虑使用 Elasticsearch Java API Client。
• 客户端连接失败或超时，要配置重试机制和超时时间。
• 如果开启了安全认证（比如用户名密码或SSL），需要额外配置 RestClient。
• 不要频繁创建和销毁 client，最好在整个应用生命周期内复用一个实例。

基本上就这些。用起来不算太复杂，但有些细节容易忽略，比如版本匹配、连接池设置、异常处理等。写代码的时候多留意这些问题，能少踩不少坑。

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于文章的相关知识，也可关注golang学习网公众号。