通過Java客戶端接入OpenSearch實例
更新時間 2024-11-26 11:25:24
最近更新時間: 2024-11-26 11:25:24
分享文章
本文為您介紹如何利用Java客戶端訪問OpenSearch實例
概述
使用 OpenSearch提供的Java客戶端,用戶可以通過Java應用與實例交互,進行索引管理、數據查詢、插入文檔等操作。適合大規模Java應用開發。
前提條件
- 已開通天翼云云搜索服務OpenSearch實例。
- 實例已綁定公網IP,具體可參考“實例公網訪問”章節。
- 已在本地安裝JDK(推薦JDK 8 及以上版本)。
- 已配置Maven或Gradle項目以支持OpenSearch Java客戶端。
操作步驟
- 在項目中引入OpenSearch客戶端依賴。Maven依賴配置如下:
<dependency>
<groupId>org.opensearch.client</groupId>
<artifactId>opensearch-rest-high-level-client</artifactId>
<version>2.9.0</version>
</dependency>
- 使用以下代碼連接到OpenSearch實例:
import org.apache.http.HttpHost;
import org.opensearch.client.RestClient;
import org.opensearch.client.RestHighLevelClient;
public class OpenSearchJavaClient {
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:OpenSearch 集群用戶名,例如 admin。
- password:用戶密碼,例如 admin 用戶的密碼。
- 執行創建索引的操作:
CreateIndexRequest request = new CreateIndexRequest("my_index");
CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
- 操作完成后記得關閉客戶端:
client.close();