概述
使用 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();