springboot 使用 resthighlevelclient 连接

Elasticsearch

在 Spring Boot 中使用 RestHighLevelClient 连接 Elasticsearch 非常简单。首先，需要在 pom.xml 文件中添加 Elasticsearch 客户端依赖：

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

然后，创建一个配置类来配置 Elasticsearch 客户端：

@Configuration
public class ElasticsearchConfig {

    @Value("${elasticsearch.host}")
    private String host;

    @Value("${elasticsearch.port}")
    private int port;

    @Bean(destroyMethod = "close")
    public RestHighLevelClient client() {
        RestClient restClient = RestClient.builder(new HttpHost(host, port)).build();
        RestHighLevelClient client = new RestHighLevelClient(restClient);
        return client;
    }
}

在上面的配置类中，我们使用 @Value 注解来注入 Elasticsearch 的主机地址和端口号。然后，我们创建一个 RestHighLevelClient 对象，它需要一个 RestClient 对象作为参数。我们使用 RestClient.builder() 方法创建一个 RestClient 对象，并将 Elasticsearch 的主机地址和端口号作为参数传递给 HttpHost 对象。

最后，我们将 RestClient 对象传递给 RestHighLevelClient 构造函数，创建一个 RestHighLevelClient 对象，并将其作为 Spring Bean 返回。

现在，我们可以在其他 Spring Bean 中注入 RestHighLevelClient 对象，并使用它来连接 Elasticsearch，例如：

@Service
public class MyService {

    @Autowired
    private RestHighLevelClient client;

    public void search() throws IOException {
        SearchRequest searchRequest = new SearchRequest("my-index");
        SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder();
        searchSourceBuilder.query(QueryBuilders.matchQuery("my-field", "my-value"));
        searchRequest.source(searchSourceBuilder);

        SearchResponse searchResponse = client.search(searchRequest, RequestOptions.DEFAULT);
        // process search response
    }
}

在上面的代码中，我们注入了 RestHighLevelClient 对象，并使用它来执行 Elasticsearch 查询。我们创建一个 SearchRequest 对象，指定要查询的索引和查询条件。然后，我们将 SearchRequest 对象传递给 client.search() 方法，并指定 RequestOptions.DEFAULT 参数。

最后，我们可以处理查询响应并执行其他操作。