in aliyun-sdk-opensearch/src/main/java/com/aliyun/opensearch/util/HttpClientFactory.java [407:445]
private HttpGetRequestResponse doGetForHttpGetRequestResponse(String url, Map<String, String> headers, String encoding, boolean isPB) throws IOException {
LOG.debug("GET url: " + url);
HttpGet httpget = new HttpGet(url);
// 请求开始
this.clientTracer.start(httpget.getMethod(), url);
httpget.setHeader("User-Agent", "opensearch/java sdk " + version);
if (this.gzip) {
httpget.setHeader("Accept-Encoding", "gzip");
}
for (Entry<String, String> header : headers.entrySet()) {
httpget.setHeader(header.getKey(), header.getValue());
}
LOG.debug("--------------- Get Headers: ---------------");
for (Header header : httpget.getAllHeaders()) {
LOG.debug(header.toString());
}
LOG.debug("--------------------------------");
LOG.debug(httpget.toString());
// 发送请求
this.clientTracer.send(httpget);
HttpResponse response;
try {
response = httpClient.execute(httpget);
validateResponse(response, httpget);
} catch (RuntimeException e) {
// 请求失败
this.clientTracer.fail();
throw e;
} catch (IOException e) {
// 请求失败
this.clientTracer.fail();
throw e;
}
return new HttpGetRequestResponse(httpget, response);
}