基于Java8+RestTemplate调用Elasticsearch Multisearch API的问题咨询

嘿，我看你正在尝试用RestTemplate调用ES的多搜索（_msearch）API，先给你指出当前代码里的核心问题：Elasticsearch的_msearch要求请求体是换行分隔的JSON（也就是application/x-ndjson格式），你现在直接把所有JSON字符串拼接在一起，没有换行分隔，ES根本没法解析每个查询的边界。

下面是修正后的完整可运行代码，我还加了关键细节的说明：

完整实现代码 #

import org.springframework.web.client.RestTemplate;
import org.springframework.http.HttpHeaders;
import org.springframework.http.HttpEntity;
import org.springframework.http.ResponseEntity;

public class EsMultiSearchDemo {
    public static void main(String[] args) {
        // 初始化RestTemplate
        RestTemplate restTemplate = new RestTemplate();
        // 替换成你的ES集群地址和_msearch接口路径
        String esMsearchEndpoint = "http://your-es-host:9200/_msearch";

        // 构建符合要求的请求体：每个查询由「元数据行+查询DSL行」组成，每行单独换行
        StringBuilder requestBodyBuilder = new StringBuilder();
        
        // 第一个查询：指定索引+类型，然后是查询DSL
        requestBodyBuilder.append("{\"index\" : \"indexname\", \"type\": \"typename\"}\n");
        requestBodyBuilder.append("{\"query\" : {\"match_all\" : {}}, \"from\" : 0, \"size\" : 10}\n");
        
        // 第二个查询：同样的索引类型，可以重复指定（或者省略元数据行，直接写DSL，看你需求）
        requestBodyBuilder.append("{\"index\" : \"indexname\", \"type\": \"typename\"}\n");
        requestBodyBuilder.append("{\"query\" : {\"match_all\" : {}}}\n");

        String requestBody = requestBodyBuilder.toString();

        // 重点！设置正确的请求头，必须指定Content-Type为application/x-ndjson
        HttpHeaders headers = new HttpHeaders();
        headers.set("Content-Type", "application/x-ndjson");

        // 封装请求实体
        HttpEntity<String> requestEntity = new HttpEntity<>(requestBody, headers);

        // 发送POST请求并获取响应
        ResponseEntity<String> response = restTemplate.postForEntity(esMsearchEndpoint, requestEntity, String.class);
        System.out.println("ES多搜索响应结果: " + response.getBody());
    }
}

几个必须注意的关键点 #

• 请求体格式：_msearch不接受普通的JSON数组，必须是每个JSON对象单独占一行，元数据和查询DSL各一行，每个查询对之间用换行分隔，最后最好也加个换行（部分ES版本有这个要求）。
• 请求头设置：一定要把Content-Type设为application/x-ndjson，不然ES会直接返回格式错误的响应，这是很多人踩坑的点。
• ES版本兼容：如果你用的是ES 7.x及以上版本，type参数已经被废弃了，要把元数据里的"type": "typename"删掉，改成{"index": "indexname"}就行。

排查小技巧 #

如果还是报错，可以先把生成的requestBody打印出来，检查每个JSON是否合法，换行是否正确；另外确认你的RestTemplate能正常访问ES集群，没有被防火墙或者权限拦截。

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