InputStream

(KAB-studioからのおしらせです)

// Sample.java
import java.io.InputStream;
import java.io.PushbackInputStream;
import java.io.IOException;

public class Sample
{
    public static void main( String[] args )
    {
        NormalInputStream normalInputStream = null;
        PushbackInputStream pushbackInputStream = null;
        try
        {
            // NormalInputStreamクラスを作ります。
            // 本当の「入力元」はないので、単独で作ります。
            normalInputStream = new NormalInputStream();

            // このクラスを対象とするPushbackInputStreamクラスを用意します。
            pushbackInputStream = new PushbackInputStream( normalInputStream );

            while( true )
            {
                // 1バイト取得します。
                int i = pushbackInputStream.read();
                if( i == -1 )
                {
                    // -1が返されてきたら終わりです。
                    break;
                }

                // 出力します。
                System.out.println( "0x" + Integer.toHexString( i ) + " ( " + i + " )" );
            }
            // NormalInputStream#read() : 1
            // 0x1 ( 1 )
            // NormalInputStream#read() : 2
            // 0x2 ( 2 )
            // NormalInputStream#read() : 3
            // 0x3 ( 3 )
            // NormalInputStream#read() : 4

            // このように、pushbackInputStreamのread()メソッドを呼ぶと、
            // normalInputStreamのread()メソッドを呼び出します。
        }
        catch( IOException e )
        {
            // 読み込みに失敗した際に、read()メソッドが
            // IOException例外を投げます。
            e.printStackTrace();
        }
        finally
        {
            // 処理が終わったら、最後にclose()メソッドを呼んで
            // 後処理をします。また、これは必ず行うため、
            // finally内で行います。
            try
            {
                if( pushbackInputStream != null )
                {
                    pushbackInputStream.close();
                }
            }
            catch( IOException e )
            {
                // close()メソッドはIOExceptionがthrows指定されているので
                // 一応受け取ります。
                e.printStackTrace();
            }

            // 処理が終わったら、最後にclose()メソッドを呼んで
            // 後処理をします。また、これは必ず行うため、
            // finally内で行います。
            try
            {
                if( normalInputStream != null )
                {
                    normalInputStream.close();
                }
            }
            catch( IOException e )
            {
                // close()メソッドはIOExceptionがthrows指定されているので
                // 一応受け取ります。
                e.printStackTrace();
            }
        }
    }
}

/**
*   NormalInputStreamクラス。
*   InputStreamクラスのサブクラスです。
*/
class NormalInputStream extends InputStream
{
    // カウンター。
    private int counter = 1;
    
    /**
    *   read()メソッド。
    *   InputStreamクラスのread()メソッドをオーバーライドしたものです。
    *   このクラスを利用するバイト入力ストリームクラスの
    *   read()メソッドから呼び出されます。
    */
    public int read() throws IOException
    {
        System.out.println( "NormalInputStream#read() : " + counter );

        // カウンターの最大値を3にします。
        if( counter > 3 )
        {
            // 3を超えたら「最後」の印として-1を返します。
            return -1;
        }

        // カウンターの数を返します。
        // 通常は、こればbyte型の配列だったり、ファイルだったり
        // するわけです。
        int i = counter;
        ++counter;
        return i;
    }
}