RestHighLevelClient执行Delete By Query无效但curl请求正常

高概率根因按优先级排序 #

• 异步请求未等待执行完成就校验结果
  你代码里用的deleteByQueryAsync是纯异步非阻塞方法，提交请求后不会等ES返回结果就继续往下执行。如果测试逻辑里提交请求后立刻查询文档数量，此时删除任务要么还在客户端队列没发出去，要么ES端还没执行完，自然会查到0条删除记录。
  修复方式：要么换成同步的deleteByQuery方法，要么给异步调用加超时阻塞，拿到返回结果后先校验删除条数：

  // 异步调用加阻塞等待，避免提前校验
  BulkByScrollResponse deleteResp = restHighLevelClient
          .deleteByQueryAsync(request, RequestOptions.DEFAULT)
          .get(30, TimeUnit.SECONDS);
  // 打印实际删除条数，确认执行结果
  long realDeleted = deleteResp.getDeleted();
  

• term查询参数类型序列化不匹配
  所谓“提取出完全一致的请求参数”大概率是debug看Java对象属性的错觉：RestHighLevelClient序列化query时不会自动做类型对齐，如果你的索引mapping里userId、productId是keyword类型，Java代码里直接传Long/Integer类型的参数，序列化出来的term查询值是不带引号的数值，而你curl里传的是带引号的字符串，ES的term查询是精确匹配不会做隐式类型转换，自然匹配不到任何文档。
  不要靠对象属性判断参数一致，直接加HTTP拦截器打印客户端实际发出的完整JSON请求体，和成功的curl逐字符对比。
  修复方式：传入term查询的参数类型和mapping字段类型严格对齐，字符串类型字段就传String值：

  BoolQueryBuilder deleteQuery = QueryBuilders.boolQuery()
          .filter(QueryBuilders.termQuery("userId", String.valueOf(userId)))
          .filter(QueryBuilders.termQuery("productId", String.valueOf(productId)));
  

• 客户端与服务端版本不兼容
  Spring Boot 2.2.5.RELEASE默认托管的RestHighLevelClient版本是7.6.x，和你用的7.10.2版本ES服务端存在小版本协议差异，这类差异不会直接报连接错误，但会出现查询、删除请求序列化后服务端无法正确解析查询条件的问题，最终导致匹配0条数据。
  修复方式：在pom.xml中强制指定ES客户端版本和服务端完全一致：

  <properties>
      <elasticsearch.version>7.10.2</elasticsearch.version>
  </properties>
  

• 基础配置校验错误
  检查构造DeleteByQueryRequest时传入的索引名是否和curl请求的索引名完全一致，有没有多余的空格、环境后缀；如果索引写入时指定了routing，删除请求也必须带上对应routing参数，否则会出现匹配遗漏。

快速定位技巧：给RestHighLevelClient配置请求拦截器，打印所有发往ES的请求路径、请求体、响应内容，和你验证成功的curl请求做逐字段对比，10分钟内就能定位到差异点。

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