概述

Java 是官方推薦的編程語言之一，使用 Elasticsearch提供的 Java REST 客戶端可以輕松與實例進行交互，包括索引管理、數據查詢、插入文檔等操作，適用于構建基于Java的大規模應用。

前提條件

• 已開通天翼云云搜索服務Elasticsearch實例。
• 集群已綁定公網 IP。具體可參考“實例公網訪問”章節。
• 已在本地安裝了JDK（推薦 JDK 8 及以上版本）。
• 已配置 Maven 或 Gradle 項目依賴以支持 Elasticsearch Java客戶端。

操作步驟

在項目中引入Elasticsearch客戶端依賴。Maven 依賴配置如下：

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

使用以下代碼連接到 Elasticsearch實例：

import org.apache.http.HttpHost;

import org.elasticsearch.client.RestClient;

import org.elasticsearch.client.RestHighLevelClient;

public class ElasticsearchJavaClient {
    public static void main(String[] args) {
        // 初始化客戶端
        RestHighLevelClient client = new RestHighLevelClient(
            RestClient.builder(new HttpHost("<host>", 9200, "http"))
                      .setDefaultCredentialsProvider(new BasicCredentialsProvider().setCredentials(
                          AuthScope.ANY, new UsernamePasswordCredentials("<user>", "<password>")
                      )));

        // 執行操作，例如創建索引等
        // ...

        // 關閉客戶端
        client.close();
    }
}

host：集群綁定的公網 IP。

user：Elasticsearch 集群用戶名，例如 admin。

password：用戶密碼，例如 admin 用戶的密碼。

在執行具體操作時，例如創建索引：

CreateIndexRequest request = new CreateIndexRequest("my_index");

CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);

操作完成后記得關閉客戶端：

client.close();