类 HttpComponentsHttpInvokerRequestExecutor

构造器详细资料

• HttpComponentsHttpInvokerRequestExecutor

  public HttpComponentsHttpInvokerRequestExecutor()

  Create a new instance of the HttpComponentsHttpInvokerRequestExecutor with a default HttpClient that uses a default org.apache.http.impl.conn.PoolingClientConnectionManager.

• HttpComponentsHttpInvokerRequestExecutor

  public HttpComponentsHttpInvokerRequestExecutor​(HttpClient httpClient)

  Create a new instance of the HttpComponentsClientHttpRequestFactory with the given HttpClient instance.

  参数:

  httpClient - the HttpClient instance to use for this request executor

方法详细资料

• setHttpClient

  public void setHttpClient​(HttpClient httpClient)

  Set the HttpClient instance to use for this request executor.

• getHttpClient

  public HttpClient getHttpClient()

  Return the HttpClient instance that this request executor uses.

• setConnectTimeout

  public void setConnectTimeout​(int timeout)

  Set the connection timeout for the underlying HttpClient. A timeout value of 0 specifies an infinite timeout.

  Additional properties can be configured by specifying a RequestConfig instance on a custom HttpClient.

  参数:

  timeout - the timeout value in milliseconds

  另请参阅:

  RequestConfig.getConnectTimeout()

• setConnectionRequestTimeout

  public void setConnectionRequestTimeout​(int connectionRequestTimeout)

  Set the timeout in milliseconds used when requesting a connection from the connection manager using the underlying HttpClient. A timeout value of 0 specifies an infinite timeout.

  Additional properties can be configured by specifying a RequestConfig instance on a custom HttpClient.

  参数:

  connectionRequestTimeout - the timeout value to request a connection in milliseconds

  另请参阅:

  RequestConfig.getConnectionRequestTimeout()

• setReadTimeout

  public void setReadTimeout​(int timeout)

  Set the socket read timeout for the underlying HttpClient. A timeout value of 0 specifies an infinite timeout.

  Additional properties can be configured by specifying a RequestConfig instance on a custom HttpClient.

  参数:

  timeout - the timeout value in milliseconds

  另请参阅:

  DEFAULT_READ_TIMEOUT_MILLISECONDS, RequestConfig.getSocketTimeout()

• doExecuteRequest

  protected RemoteInvocationResult doExecuteRequest​(HttpInvokerClientConfiguration config,
                                                    ByteArrayOutputStream baos)
                                             throws IOException,
                                                    ClassNotFoundException

  Execute the given request through the HttpClient.

  This method implements the basic processing workflow: The actual work happens in this class's template methods.

  指定者:

  doExecuteRequest 在类中 AbstractHttpInvokerRequestExecutor

  参数:

  config - the HTTP invoker configuration that specifies the target service

  baos - the ByteArrayOutputStream that contains the serialized RemoteInvocation object

  返回:

  the RemoteInvocationResult object

  抛出:

  IOException - if thrown by I/O operations

  ClassNotFoundException - if thrown during deserialization

  另请参阅:

  createHttpPost(org.springframework.remoting.httpinvoker.HttpInvokerClientConfiguration), setRequestBody(org.springframework.remoting.httpinvoker.HttpInvokerClientConfiguration, org.apache.http.client.methods.HttpPost, java.io.ByteArrayOutputStream), executeHttpPost(org.springframework.remoting.httpinvoker.HttpInvokerClientConfiguration, org.apache.http.client.HttpClient, org.apache.http.client.methods.HttpPost), validateResponse(org.springframework.remoting.httpinvoker.HttpInvokerClientConfiguration, org.apache.http.HttpResponse), getResponseBody(org.springframework.remoting.httpinvoker.HttpInvokerClientConfiguration, org.apache.http.HttpResponse)

• createHttpPost

  protected HttpPost createHttpPost​(HttpInvokerClientConfiguration config)
                             throws IOException

  Create a HttpPost for the given configuration.

  The default implementation creates a standard HttpPost with "application/x-java-serialized-object" as "Content-Type" header.

  参数:

  config - the HTTP invoker configuration that specifies the target service

  返回:

  the HttpPost instance

  抛出:

  IOException - if thrown by I/O methods

• createRequestConfig

  protected RequestConfig createRequestConfig​(HttpInvokerClientConfiguration config)

  Create a RequestConfig for the given configuration. Can return null to indicate that no custom request config should be set and the defaults of the HttpClient should be used.

  The default implementation tries to merge the defaults of the client with the local customizations of the instance, if any.

  参数:

  config - the HTTP invoker configuration that specifies the target service

  返回:

  the RequestConfig to use

• setRequestBody

  protected void setRequestBody​(HttpInvokerClientConfiguration config,
                                HttpPost httpPost,
                                ByteArrayOutputStream baos)
                         throws IOException

  Set the given serialized remote invocation as request body.

  The default implementation simply sets the serialized invocation as the HttpPost's request body. This can be overridden, for example, to write a specific encoding and to potentially set appropriate HTTP request headers.

  参数:

  config - the HTTP invoker configuration that specifies the target service

  httpPost - the HttpPost to set the request body on

  baos - the ByteArrayOutputStream that contains the serialized RemoteInvocation object

  抛出:

  IOException - if thrown by I/O methods

• executeHttpPost

  protected org.apache.http.HttpResponse executeHttpPost​(HttpInvokerClientConfiguration config,
                                                         HttpClient httpClient,
                                                         HttpPost httpPost)
                                                  throws IOException

  Execute the given HttpPost instance.

  参数:

  config - the HTTP invoker configuration that specifies the target service

  httpClient - the HttpClient to execute on

  httpPost - the HttpPost to execute

  返回:

  the resulting HttpResponse

  抛出:

  IOException - if thrown by I/O methods

• validateResponse

  protected void validateResponse​(HttpInvokerClientConfiguration config,
                                  org.apache.http.HttpResponse response)
                           throws IOException

  Validate the given response as contained in the HttpPost object, throwing an exception if it does not correspond to a successful HTTP response.

  Default implementation rejects any HTTP status code beyond 2xx, to avoid parsing the response body and trying to deserialize from a corrupted stream.

  参数:

  config - the HTTP invoker configuration that specifies the target service

  response - the resulting HttpResponse to validate

  抛出:

  IOException - if validation failed

• getResponseBody

  protected InputStream getResponseBody​(HttpInvokerClientConfiguration config,
                                        org.apache.http.HttpResponse httpResponse)
                                 throws IOException

  Extract the response body from the given executed remote invocation request.

  The default implementation simply fetches the HttpPost's response body stream. If the response is recognized as GZIP response, the InputStream will get wrapped in a GZIPInputStream.

  参数:

  config - the HTTP invoker configuration that specifies the target service

  httpResponse - the resulting HttpResponse to read the response body from

  返回:

  an InputStream for the response body

  抛出:

  IOException - if thrown by I/O methods

  另请参阅:

  isGzipResponse(org.apache.http.HttpResponse), GZIPInputStream

• isGzipResponse

  protected boolean isGzipResponse​(org.apache.http.HttpResponse httpResponse)

  Determine whether the given response indicates a GZIP response.

  The default implementation checks whether the HTTP "Content-Encoding" header contains "gzip" (in any casing).

  参数:

  httpResponse - the resulting HttpResponse to check

  返回:

  whether the given response indicates a GZIP response