如何在Java Spring Boot中使用RestHighLevelClient向ElasticSearch插入文档

嘿，我帮你把RestHighLevelClient的文档索引操作拆解清楚，官方文档确实有点绕，咱们直接看实用的代码和步骤～

假设你已经在Spring Boot里完成了RestHighLevelClient的配置（比如通过@Bean注入了客户端实例），接下来直接看核心的操作实现：

1. 单文档索引（最常用场景） #

方式1：自动生成文档ID #

这种场景下ES会帮你自动生成唯一的文档ID，适合不需要绑定业务主键的场景：

import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.action.index.IndexResponse;
import org.elasticsearch.client.RequestOptions;
import org.elasticsearch.client.RestHighLevelClient;
import org.elasticsearch.xcontent.XContentType;
import com.fasterxml.jackson.databind.ObjectMapper;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class EsDocService {

    @Autowired
    private RestHighLevelClient esClient;
    @Autowired
    private ObjectMapper objectMapper; // Spring Boot默认会自动配置这个Bean

    // 插入文档，自动生成ES文档ID
    public String addDocAutoId(String indexName, Object docEntity) throws Exception {
        // 1. 构建索引请求，指定目标索引名
        IndexRequest request = new IndexRequest(indexName);
        
        // 2. 将实体类转为JSON字符串（用Jackson序列化）
        String jsonDoc = objectMapper.writeValueAsString(docEntity);
        
        // 3. 设置文档内容和格式
        request.source(jsonDoc, XContentType.JSON);
        
        // 4. 执行索引请求
        IndexResponse response = esClient.index(request, RequestOptions.DEFAULT);
        
        // 5. 返回ES生成的唯一文档ID
        return response.getId();
    }
}

方式2：手动指定文档ID #

如果需要用业务主键作为ES的文档ID（比如用户ID、订单ID），只需要在构建IndexRequest时加上ID即可：

// 插入文档，手动指定文档ID
public String addDocWithId(String indexName, String docId, Object docEntity) throws Exception {
    IndexRequest request = new IndexRequest(indexName)
            .id(docId); // 绑定自定义的文档ID
    
    String jsonDoc = objectMapper.writeValueAsString(docEntity);
    request.source(jsonDoc, XContentType.JSON);
    
    IndexResponse response = esClient.index(request, RequestOptions.DEFAULT);
    
    // 可以判断操作类型：CREATED是新插入，UPDATED是覆盖已有ID的文档
    if (response.getResult() == DocWriteResponse.Result.CREATED) {
        System.out.println("新文档插入成功");
    } else if (response.getResult() == DocWriteResponse.Result.UPDATED) {
        System.out.println("已有文档被更新");
    }
    
    return response.getId();
}

2. 批量插入文档 #

如果需要一次性插入大量文档，用BulkRequest会比循环单插高效得多：

import org.elasticsearch.action.bulk.BulkRequest;
import org.elasticsearch.action.bulk.BulkResponse;
import org.elasticsearch.action.index.IndexRequest;
import org.elasticsearch.client.RequestOptions;
import java.util.List;

// 批量插入文档
public void bulkAddDocs(String indexName, List<Object> docEntities) throws Exception {
    BulkRequest bulkRequest = new BulkRequest();
    
    for (Object doc : docEntities) {
        String jsonDoc = objectMapper.writeValueAsString(doc);
        // 这里用自动ID，要是需要手动指定ID，就在构建IndexRequest时加.id()
        IndexRequest indexRequest = new IndexRequest(indexName)
                .source(jsonDoc, XContentType.JSON);
        bulkRequest.add(indexRequest);
    }
    
    // 执行批量请求
    BulkResponse bulkResponse = esClient.bulk(bulkRequest, RequestOptions.DEFAULT);
    
    // 检查是否有失败的操作
    if (bulkResponse.hasFailures()) {
        for (BulkItemResponse item : bulkResponse.getItems()) {
            if (item.isFailed()) {
                System.out.println("文档插入失败：" + item.getFailure().getMessage());
            }
        }
    } else {
        System.out.println("所有文档批量插入成功");
    }
}

3. 几个关键注意点 #

• 实体类序列化：确保你的实体类字段能正确映射到ES的字段，比如用@JsonProperty指定ES里的字段名，避免驼峰和下划线的冲突。
• 异常处理：实际项目里别直接抛Exception，可以捕获IOException等ES客户端异常，做更友好的错误提示或重试逻辑。
• 索引提前创建：如果插入时索引不存在，ES会自动创建但用默认映射，建议提前创建好索引和自定义映射，避免字段类型不符合预期（比如把数字当成字符串存）。
• RequestOptions：一般用RequestOptions.DEFAULT就行，如果需要自定义请求头（比如权限验证），可以自己构建RequestOptions实例。

要是你之前尝试的代码有具体报错或者疑问，可以把代码贴出来，我再帮你排查～

内容的提问来源于stack exchange，提问作者GzAndy