java操作elasticsearch代码示例（High-Level REST Client）

落日映苍穹つ 2023-10-12 10:47 24阅读 0赞

## 依赖 ##

在 Java 项目中使用 Elasticsearch 的 High-Level REST Client，你需要在项目的 pom.xml 文件中添加以下 Maven 依赖：

<dependencies>
        
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-high-level-client</artifactId>
            <version>7.4.2</version>
        </dependency>
        
        
        <dependency>
            <groupId>org.elasticsearch.client</groupId>
            <artifactId>elasticsearch-rest-client</artifactId>
            <version>7.4.2</version>
        </dependency>
    </dependencies>

上述依赖中包含了 Elasticsearch High-Level REST Client 和 Elasticsearch Low-Level REST Client（可选，用于更底层的操作）。请确保将版本号（version）与你使用的 Elasticsearch 版本相匹配。

添加这些依赖后，Maven 将自动下载所需的库文件，并使你能够在 Java 代码中使用 Elasticsearch 的 High-Level REST Client。

## 代码 ##

以下是一个使用 Java 操作 Elasticsearch 的示例代码：

import org.elasticsearch.action.index.IndexRequest;
    import org.elasticsearch.action.index.IndexResponse;
    import org.elasticsearch.client.RequestOptions;
    import org.elasticsearch.client.RestHighLevelClient;
    import org.elasticsearch.common.xcontent.XContentBuilder;
    import org.elasticsearch.common.xcontent.XContentFactory;
    import org.elasticsearch.common.xcontent.XContentType;
    import org.elasticsearch.index.IndexNotFoundException;
    import org.elasticsearch.rest.RestStatus;
    import org.elasticsearch.client.RestClient;
    import org.elasticsearch.client.RestClientBuilder;
    import org.elasticsearch.client.RestClientBuilder.HttpClientConfigCallback;
    
    import java.io.IOException;
    
    public class ElasticsearchExample {
        
        private static final String INDEX_NAME = "my_index";
        private static final String TYPE_NAME = "_doc";
    
        public static void main(String[] args) {
        
            // 创建 RestHighLevelClient 客户端
            RestHighLevelClient client = createClient();
    
            // 添加文档
            String document = "{\"title\": \"Elasticsearch Example\", \"content\": \"This is an example document for Elasticsearch.\"}";
            try {
        
                IndexResponse response = indexDocument(client, INDEX_NAME, TYPE_NAME, document);
                if (response != null && response.status() == RestStatus.CREATED) {
        
                    System.out.println("Document indexed successfully.");
                }
            } catch (IOException e) {
        
                System.out.println("Failed to index document: " + e.getMessage());
            }
    
            // 关闭客户端连接
            try {
        
                client.close();
            } catch (IOException e) {
        
                System.out.println("Failed to close Elasticsearch client: " + e.getMessage());
            }
        }
    
        private static RestHighLevelClient createClient() {
        
            RestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 9200, "http"));
    
            // 如果你的 Elasticsearch 集群有需要身份验证的配置，可以在这里设置用户名和密码
    
            // 设置其他可选配置，如请求超时时间、连接超时时间等
    
            return new RestHighLevelClient(builder);
        }
    
        private static IndexResponse indexDocument(RestHighLevelClient client, String index, String type, String document)
                throws IOException {
        
            IndexRequest request = new IndexRequest(index, type)
                    .source(document, XContentType.JSON);
    
            try {
        
                return client.index(request, RequestOptions.DEFAULT);
            } catch (IndexNotFoundException e) {
        
                // 处理索引不存在的情况
                throw new IOException("Index not found: " + e.getMessage());
            }
        }
    }

以上示例代码演示了如何使用 Java High-Level REST Client 来连接 Elasticsearch，创建一个索引，并添加一个文档到索引中。请确保将 `localhost:9200` 替换为你 Elasticsearch 实例的正确主机和端口。

你可以根据自己的需要，添加更多的操作和配置来满足特定的业务需求。还可以参考 Elasticsearch 官方文档和 Java High-Level REST Client 的文档，了解更多关于 Elasticsearch 的操作和可用选项。

## 解释 ##

上述代码是一个简单的 Java 示例，演示了如何使用 Elasticsearch 的 High-Level REST Client 连接 Elasticsearch、创建索引并添加文档。

代码中的关键部分如下：

1.  引入必要的依赖：  
    通过 Maven 依赖引入 Elasticsearch 的 High-Level REST Client 和 Low-Level REST Client（可选）。
2.  创建 RestHighLevelClient 客户端：  
    使用 RestClientBuilder 创建一个 RestHighLevelClient 实例，指定 Elasticsearch 的主机和端口。可以在 RestClientBuilder 中设置其他可选配置，如请求超时时间、连接超时时间等。
3.  添加文档：  
    在 `indexDocument()` 方法中，创建一个 IndexRequest 对象，指定要添加文档的索引、类型和文档内容。然后使用 RestHighLevelClient 的 `index()` 方法将文档添加到 Elasticsearch 中。
4.  关闭客户端连接：  
    在程序结束时，使用 `client.close()` 方法关闭 RestHighLevelClient 客户端连接。