ES: spring boot中使用ElasticsearchClient
在Spring Boot中使用ElasticsearchClient
,你需要添加Spring Data Elasticsearch依赖,并配置Elasticsearch客户端。以下是一个基本的设置示例:
- 添加Spring Data Elasticsearch依赖到你的
pom.xml
文件中:
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-elasticsearch</artifactId>
</dependency>
</dependencies>
- 在
application.properties
或application.yml
中配置Elasticsearch的主机和端口:
# application.properties
spring.data.elasticsearch.cluster-name=your-cluster-name
spring.data.elasticsearch.cluster-nodes=localhost:9300
- 注入
ElasticsearchClient
到你的服务或组件中:
import org.elasticsearch.client.ElasticsearchClient;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
@Service
public class YourService {
private final ElasticsearchClient elasticsearchClient;
@Autowired
public YourService(ElasticsearchClient elasticsearchClient) {
this.elasticsearchClient = elasticsearchClient;
}
// 使用elasticsearchClient进行操作
}
- 使用
ElasticsearchClient
执行操作,例如索引文档、搜索文档:
public void indexDocument(String index, String id, Object document) {
elasticsearchClient.prepareIndex(index, index, id)
.setSource(document)
.get();
}
public void searchDocuments(String index, String query) {
SearchResponse response = elasticsearchClient.prepareSearch(index)
.setQuery(queryStringQuery(query))
.get();
// 处理搜索结果
}
确保你的Elasticsearch服务器正在运行,并且配置的节点地址是可达的。以上代码提供了一个简单的示例,展示了如何在Spring Boot应用程序中注入和使用ElasticsearchClient
。
评论已关闭