com.iijgio.dag.services.storage.model

Class StorageObjectInputStream

java.lang.Object

java.io.InputStream

java.io.FilterInputStream

com.iijgio.dag.services.storage.model.StorageObjectInputStream

All Implemented Interfaces:

Closeable, AutoCloseable

public class StorageObjectInputStream
extends FilterInputStream

StorageObjectの内容を表す入力ストリームです。 InputStreamクラスによって提供されるメソッドに加えて、 StorageObjectInputStreamはIIJGIOオブジェクトへの HTTPコネクションを終了させるabort()メソッドを提供します。

Field Summary

Fields inherited from class java.io.FilterInputStream

in

Constructor Summary

Constructors

Constructor and Description
StorageObjectInputStream(InputStream in, org.apache.http.client.methods.HttpUriRequest httpRequest)

Method Summary

Modifier and Type	Method and Description
void	abort() これ以上データを読み出すことなく潜在的なHTTPリクエストを中断し、 ストリームを閉じます。
org.apache.http.client.methods.HttpUriRequest	getHttpRequest() この入力ストリームが得られるHTTPリクエストを返します。

Methods inherited from class java.io.FilterInputStream

available, close, mark, markSupported, read, read, read, reset, skip

Methods inherited from class java.lang.Object

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

Constructor Detail

StorageObjectInputStream

public StorageObjectInputStream(InputStream in,
                                org.apache.http.client.methods.HttpUriRequest httpRequest)

Method Detail

abort

public void abort()
           throws IOException

これ以上データを読み出すことなく潜在的なHTTPリクエストを中断し、 ストリームを閉じます。

デフォルトでは、ApacheのHttpClientは InputStream.close()の際にアタッチされた入力ストリームの終端まで 読み取ることでHTTPコネクションを再利用しようとします。これは ソケットプール管理の観点からは効率のよい方法ですが、 大きなペイロードを持つオブジェクトにとってはバイトデータが IIJ GIOストレージ＆アナリシスサービスから読み出される時と廃棄される時に 著しいオーバーヘッドを負うことになります。IIJ GIOストレージ＆アナリシスサービス から不必要な情報を読み出さないようにするために HTTPコネクションを再利用しないことに起因するパフォーマンスヒットを いつ受け入れるかを決めるのはクライアント次第です。

Throws:

IOException - リクエストの中断に失敗した場合

See Also:

EofSensorInputStream

getHttpRequest

public org.apache.http.client.methods.HttpUriRequest getHttpRequest()

この入力ストリームが得られるHTTPリクエストを返します。

Returns:

HTTPリクエスト