com.sinacloud.scs.http

类 HttpMethodReleaseInputStream

java.lang.Object

java.io.InputStream

com.sinacloud.scs.http.HttpMethodReleaseInputStream

所有已实现的接口:

Closeable, AutoCloseable

public class HttpMethodReleaseInputStream
extends InputStream

Utility class to wrap InputStreams obtained from an HttpClient library's HttpMethod object, and ensure the stream and HTTP connection are properly released.

This input stream wrapper is used to ensure that input streams obtained through HttpClient connections are cleaned up correctly once the caller has read all the contents of the connection's input stream, or closed the input stream. Additionally, this class attempts to release the connection and close the stream in this object's finalizer method, as a last resort to avoid leaking resources.

Important! This input stream must be completely consumed or closed to ensure the necessary cleanup operations can be performed.

构造器概要

构造器

构造器和说明
HttpMethodReleaseInputStream(org.apache.http.HttpEntityEnclosingRequest httpMethod) Constructs an input stream based on an HttpMethod object representing an HTTP connection.

方法概要

方法

限定符和类型	方法和说明
int	available() Standard input stream available method, except it ensures that releaseConnection() is called if any errors are encountered from the wrapped stream.
void	close() Standard input stream close method, except it ensures that releaseConnection() is called before the input stream is closed.
protected void	finalize() Tries to ensure a connection is always cleaned-up correctly by calling releaseConnection() on class destruction if the cleanup hasn't already been done.
org.apache.http.HttpEntityEnclosingRequest	getHttpRequest() Returns the underlying HttpMethod object that contains/manages the actual HTTP connection.
int	read() Standard input stream read method, except it calls releaseConnection() when the underlying input stream is consumed.
int	read(byte[] b, int off, int len) Standard input stream read method, except it calls releaseConnection() when the underlying input stream is consumed.
protected void	releaseConnection() Forces the release of an HttpMethod's connection in a way that will perform all the necessary cleanup through the correct use of HttpClient methods.

从类继承的方法 java.io.InputStream

mark, markSupported, read, reset, skip

从类继承的方法 java.lang.Object

clone, equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

构造器详细资料

HttpMethodReleaseInputStream

public HttpMethodReleaseInputStream(org.apache.http.HttpEntityEnclosingRequest httpMethod)

Constructs an input stream based on an HttpMethod object representing an HTTP connection. If a connection input stream is available, this constructor wraps the underlying input stream and makes that stream available. If no underlying connection is available, an empty ByteArrayInputStream is made available.

参数:

httpMethod - The HTTP method being executed, whose response content is to be wrapped.

方法详细资料

getHttpRequest

public org.apache.http.HttpEntityEnclosingRequest getHttpRequest()

Returns the underlying HttpMethod object that contains/manages the actual HTTP connection.

返回:

the HTTPMethod object that provides the data input stream.

releaseConnection

protected void releaseConnection()
                          throws IOException

Forces the release of an HttpMethod's connection in a way that will perform all the necessary cleanup through the correct use of HttpClient methods.

抛出:

IOException

read

public int read()
         throws IOException

Standard input stream read method, except it calls releaseConnection() when the underlying input stream is consumed.

指定者:

read 在类中 InputStream

抛出:

IOException

另请参阅:

InputStream.read()

read

public int read(byte[] b,
       int off,
       int len)
         throws IOException

Standard input stream read method, except it calls releaseConnection() when the underlying input stream is consumed.

覆盖:

read 在类中 InputStream

抛出:

IOException

另请参阅:

InputStream.read(byte[], int, int)

available

public int available()
              throws IOException

Standard input stream available method, except it ensures that releaseConnection() is called if any errors are encountered from the wrapped stream.

覆盖:

available 在类中 InputStream

抛出:

IOException

另请参阅:

InputStream.available()

close

public void close()
           throws IOException

Standard input stream close method, except it ensures that releaseConnection() is called before the input stream is closed.

指定者:

close 在接口中 Closeable

指定者:

close 在接口中 AutoCloseable

覆盖:

close 在类中 InputStream

抛出:

IOException

另请参阅:

InputStream.close()

finalize

protected void finalize()
                 throws Throwable

Tries to ensure a connection is always cleaned-up correctly by calling releaseConnection() on class destruction if the cleanup hasn't already been done.

This desperate cleanup act will only be necessary if the user of this class does not completely consume or close this input stream prior to object destruction. This method will log Warning messages if a forced cleanup is required, hopefully reminding the user to close their streams properly.

覆盖:

finalize 在类中 Object

抛出:

Throwable