SpringCloud——分布式搜索elasticsearch之RestClient

在Spring Cloud中使用Elasticsearch的RestClient进行操作，首先需要添加相关依赖，以下是Maven的依赖配置：

<dependencies>
    <!-- Spring Cloud Elasticsearch -->
    <dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-data-elasticsearch</artifactId>
    </dependency>
 
    <!-- Elasticsearch Rest Client -->
    <dependency>
        <groupId>org.elasticsearch.client</groupId>
        <artifactId>elasticsearch-rest-high-level-client</artifactId>
        <version>7.10.2</version> <!-- 请使用适合您的Elasticsearch版本 -->
    </dependency>
</dependencies>

以下是一个简单的使用RestClient进行索引创建和文档索引的例子：

import org.elasticsearch.client.RestClient;
import org.elasticsearch.client.RestClientBuilder;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.client.indices.CreateIndexRequest;
import org.elasticsearch.client.indices.CreateIndexResponse;
import org.elasticsearch.common.xcontent.XContentType;
 
public class ElasticsearchExample {
 
    public static void main(String[] args) throws IOException {
        // 构建RestClientBuilder
        RestClientBuilder builder = RestClient.builder(new HttpHost("localhost", 9200, "http"));
 
        // 构建RestHighLevelClient
        try (RestHighLevelClient client = new RestHighLevelClient(builder)) {
            // 创建索引请求
            CreateIndexRequest request = new CreateIndexRequest("my_index");
 
            // 设置索引的映射
            String jsonString = "{\"mappings\": {\"properties\": {\"message\": {\"type\": \"text\"}}}}";
            request.source(jsonString, XContentType.JSON);
 
            // 执行创建索引操作
            CreateIndexResponse createIndexResponse = client.indices().create(request, RequestOptions.DEFAULT);
 
            // 输出创建索引结果
            boolean acknowledged = createIndexResponse.isAcknowledged();
            System.out.println("索引创建是否被确认: " + acknowledged);
        }
    }
}

在这个例子中，我们首先构建了一个RestClientBuilder，然后通过这个构建器创建了一个RestHighLevelClient实例。接着，我们创建了一个CreateIndexRequest来定义索引创建的请求，并设置了索引的名称和映射。最后，我们使用RestHighLevelClient的indices().create方法来执行创建索引的操作，并输出了操作结果。

请注意，在实际应用中，你可能需要处理更多的异常情况，并且在实际部署中，Elasticsearch的地址、端口和映射可能会有所不同。此外，在生产环境中，你可能还需要考虑连接池的配置，以管理并发请求和提高性能。