使用RestHighLevelClient索引文档时遭遇UnknownHostException异常

你的问题核心在于HttpHost构造参数使用错误，直接导致了DNS解析失败，下面具体分析并给出修复方案：

错误原因拆解 #

• 你把完整的HTTPS URL（带https://前缀）传给了HttpHost的主机名字段，这会让系统把整个字符串当成需要解析的主机名，自然会抛出UnknownHostException——DNS服务器根本找不到这个格式的主机。
• AWS Elasticsearch VPC端点的默认HTTPS端口是443，而非开源ES常用的9200，端口设置错误也会引发后续连接问题。
• 你设置的setMaxRetryTimeoutMillis(30)过于极端，30毫秒几乎不可能完成网络请求，会直接触发超时失败。

修正后的完整代码 #

RestHighLevelClient client = null;

try {
    Header[] headers = { new BasicHeader(HttpHeaders.CONTENT_TYPE, "application/json")};

    // 关键修正：主机名仅保留域名部分，端口改为443
    RestClientBuilder restClientBuilder = RestClient.builder(
        new HttpHost("vpc-had-webapps-logs-umrm7skxqc2n5z6wc5jx632que.us-east-1.es.amazonaws.com", 443, "https")
    );
    // 修正超时时间为合理值（30秒），或注释掉使用默认配置
    restClientBuilder.setMaxRetryTimeoutMillis(30000);
    restClientBuilder.setDefaultHeaders(headers);

    client = new RestHighLevelClient(restClientBuilder);

    IndexRequest indexRequest = new IndexRequest(index, "doc", "1")
            .source(documentJson, XContentType.JSON);

    indexRequest.setRefreshPolicy(WriteRequest.RefreshPolicy.IMMEDIATE);

    IndexResponse indexResponse = client.index(indexRequest);
    // 添加日志打印响应，方便调试验证
    System.out.println("索引成功，响应信息：" + indexResponse.toString());

} catch(Exception e) {
    // 不要空捕获异常，至少打印堆栈信息便于排查
    e.printStackTrace();
} finally {
    if (client != null) {
        try {
            client.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

额外调试建议 #

1. 不要忽略异常捕获：空catch块会掩盖后续可能出现的权限、网络问题，一定要打印异常日志。
2. 验证网络权限：确保你的运行环境（EC2/Lambda等）所在的VPC与ES端点的VPC连通，安全组允许443端口访问。
3. 版本兼容性：你的客户端版本是6.2.2，ES集群是6.0，主版本一致问题不大，但尽量保持小版本对齐可以避免潜在兼容性bug。

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