读取响应

编辑

Response 对象,无论是同步 performRequest 方法返回的,还是在 ResponseListener#onSuccess(Response) 中作为参数接收的,都封装了 http 客户端返回的响应对象,并公开了一些额外的信息。

Response response = restClient.performRequest(new Request("GET", "/"));
RequestLine requestLine = response.getRequestLine(); 
HttpHost host = response.getHost(); 
int statusCode = response.getStatusLine().getStatusCode(); 
Header[] headers = response.getHeaders(); 
String responseBody = EntityUtils.toString(response.getEntity()); 

关于执行的请求的信息

返回响应的主机

响应状态行,您可以通过它检索状态码

响应头,也可以通过 getHeader(String) 按名称检索

封装在 org.apache.http.HttpEntity 对象中的响应主体

执行请求时,在以下情况下会抛出异常(或在 ResponseListener#onFailure(Exception) 中作为参数接收):

IOException
通信问题(例如 SocketTimeoutException)
ResponseException
返回了响应,但其状态码指示发生了错误(不是 2xx)。 ResponseException 源自有效的 http 响应,因此它公开了相应的 Response 对象,该对象允许访问返回的响应。

对于返回 404 状态码的 HEAD 请求,ResponseException 不会抛出,因为这是预期的 HEAD 响应,它只是表示未找到该资源。除非 ignore 参数包含 404,否则所有其他 HTTP 方法(例如,GET)都会为 404 响应抛出 ResponseExceptionignore 是一个特殊的客户端参数,不会发送到 Elasticsearch,并且包含一个以逗号分隔的错误状态码列表。它允许控制是否应将某些错误状态码视为预期响应而不是异常。这对于 get api 很有用,因为当文档丢失时它会返回 404,在这种情况下,响应正文不会包含错误,而是通常的 get api 响应,只是没有找到文档。

请注意,低级别客户端不公开任何用于 json 编组和解组的助手。用户可以自由使用他们喜欢的库来实现此目的。

底层 Apache 异步 Http 客户端附带不同的 org.apache.http.HttpEntity 实现,允许以不同的格式(流、字节数组、字符串等)提供请求主体。至于读取响应主体,HttpEntity#getContent 方法非常方便,它返回一个 InputStream,从先前缓冲的响应主体读取。作为替代方案,可以提供一个自定义的 org.apache.http.nio.protocol.HttpAsyncResponseConsumer,用于控制如何读取和缓冲字节。