ファイル

Java – BufferedInputStreamの使い方をわかりやすく解説

BufferedInputStreamは、Javaでデータを効率的に読み取るためのクラスです。

InputStreamをラップしてバッファリングを行い、ディスクやネットワークからの読み取り回数を減らすことでパフォーマンスを向上させます。

使用する際は、通常FileInputStreamなどのストリームをコンストラクタに渡します。

例えば、new BufferedInputStream(new FileInputStream("file.txt"))のように使用します。

read()メソッドでデータを1バイトずつ、またはバイト配列にまとめて読み取ることが可能です。

使用後はclose()でリソースを解放します。

目次から探す

BufferedInputStreamとは
- 主な特徴
BufferedInputStreamの基本的な使い方
BufferedInputStreamの主要メソッド
- 各メソッドの詳細
BufferedInputStreamの応用例
BufferedInputStreamを使用する際の注意点
まとめ

BufferedInputStreamとは

BufferedInputStreamは、JavaのI/O(入出力)パッケージに含まれるクラスで、バッファリング機能を提供します。

これにより、データの読み込みを効率的に行うことができ、特にファイルやネットワークからのデータストリームを扱う際にパフォーマンスを向上させることができます。

主な特徴

バッファリング: データを一時的にメモリに保存し、まとめて読み込むことで、I/O操作の回数を減らします。
効率的な読み込み: 小さなデータを何度も読み込むよりも、大きなデータを一度に読み込む方が効率的です。
他のストリームとの組み合わせ: InputStreamをラップすることで、既存のストリームにバッファリング機能を追加できます。

BufferedInputStreamは、ファイルの読み込みやネットワーク通信など、さまざまな場面で利用されます。

特に、大きなファイルを扱う際にその効果を発揮します。

このクラスを使用することで、プログラムのパフォーマンスを向上させることができるため、Javaプログラミングにおいて非常に重要な役割を果たします。

BufferedInputStreamの基本的な使い方

BufferedInputStreamを使用することで、データの読み込みを効率的に行うことができます。

以下に、基本的な使い方を示すサンプルコードを紹介します。

import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.IOException;
public class App {
    public static void main(String[] args) {
        // 読み込むファイルのパスを指定
        String filePath = "sample.txt";
        
        // BufferedInputStreamを使用してファイルを読み込む
        try (BufferedInputStream bufferedInputStream = new BufferedInputStream(new FileInputStream(filePath))) {
            int data;
            // データを1バイトずつ読み込む
            while ((data = bufferedInputStream.read()) != -1) {
                // 読み込んだデータを表示
                System.out.print((char) data);
            }
        } catch (IOException e) {
            // エラーメッセージを表示
            System.err.println("ファイルの読み込み中にエラーが発生しました: " + e.getMessage());
        }
    }
}

FileInputStreamを使用してファイルを開き、そのストリームをBufferedInputStreamでラップします。
read()メソッドを使用して、ファイルから1バイトずつデータを読み込みます。
読み込んだデータは、キャストして文字として表示します。
try-with-resources文を使用して、ストリームを自動的に閉じるようにしています。

以下は、sample.txtファイルの内容が表示される例です。

Hello, World!
This is a sample text file.

このように、BufferedInputStreamを使うことで、ファイルからのデータ読み込みを効率的に行うことができます。

BufferedInputStreamの主要メソッド

BufferedInputStreamには、データの読み込みやバッファ管理に関連するいくつかの主要なメソッドがあります。

以下に、よく使用されるメソッドをまとめました。

メソッド名	説明
`int read()`	1バイトのデータを読み込み、次のバイトを返します。ファイルの終わりに達した場合は-1を返します。
`int read(byte[] b)`	指定したバイト配列にデータを読み込み、読み込んだバイト数を返します。
`void close()`	ストリームを閉じ、関連するリソースを解放します。
`int available()`	ストリームから読み込むことができるバイト数を返します。
`void mark(int readlimit)`	ストリームの現在の位置をマークし、指定した制限内で戻ることができるようにします。
`void reset()`	マークされた位置にストリームを戻します。マークが設定されていない場合は`IOException`をスローします。
`boolean markSupported()`	ストリームがマークとリセットをサポートしているかどうかを返します。

各メソッドの詳細

read(): 単一のバイトを読み込むための基本的なメソッドです。

ファイルの終わりに達すると-1を返すため、ループ処理に便利です。

read(byte[] b): 複数のバイトを一度に読み込むことができ、パフォーマンスを向上させます。

配列に読み込まれたバイト数を返します。

close(): ストリームを閉じる際には必ず呼び出すべきメソッドで、リソースのリークを防ぎます。
available(): 読み込むことができるバイト数を確認するために使用します。

これにより、ストリームの状態を把握できます。

mark(int readlimit): ストリームの現在の位置を記録し、指定したバイト数以内で戻ることができるようにします。
reset(): mark()で記録した位置に戻るためのメソッドです。

マークが設定されていない場合は例外が発生します。

markSupported(): ストリームがマークとリセットをサポートしているかどうかを確認するために使用します。

これらのメソッドを活用することで、BufferedInputStreamを効果的に利用し、データの読み込みを効率化することができます。

BufferedInputStreamの応用例

BufferedInputStreamは、さまざまなシナリオで活用できます。

ここでは、いくつかの具体的な応用例を紹介します。

1. 大きなファイルの読み込み

大きなファイルを効率的に読み込むために、BufferedInputStreamを使用することが一般的です。

以下のサンプルコードでは、ファイルの内容を一度に読み込んで表示します。

import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.IOException;
public class App {
    public static void main(String[] args) {
        String filePath = "largefile.txt"; // 大きなファイルのパス
        
        try (BufferedInputStream bufferedInputStream = new BufferedInputStream(new FileInputStream(filePath))) {
            byte[] buffer = new byte[1024]; // 1KBのバッファを作成
            int bytesRead;
            
            // バッファを使ってデータを読み込む
            while ((bytesRead = bufferedInputStream.read(buffer)) != -1) {
                // 読み込んだデータを表示
                System.out.write(buffer, 0, bytesRead);
            }
        } catch (IOException e) {
            System.err.println("ファイルの読み込み中にエラーが発生しました: " + e.getMessage());
        }
    }
}

2. ネットワークからのデータ受信

BufferedInputStreamは、ネットワークからのデータ受信にも利用できます。

以下の例では、ソケットからデータを受信する際に使用します。

import java.io.BufferedInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.ServerSocket;
import java.net.Socket;
public class App {
    public static void main(String[] args) {
        try (ServerSocket serverSocket = new ServerSocket(12345)) {
            System.out.println("クライアントからの接続を待っています...");
            Socket clientSocket = serverSocket.accept(); // クライアントの接続を受け入れる
            System.out.println("クライアントが接続しました。");
            
            try (BufferedInputStream bufferedInputStream = new BufferedInputStream(clientSocket.getInputStream())) {
                byte[] buffer = new byte[1024]; // 1KBのバッファを作成
                int bytesRead;
                
                // クライアントからのデータを読み込む
                while ((bytesRead = bufferedInputStream.read(buffer)) != -1) {
                    // 読み込んだデータを表示
                    System.out.write(buffer, 0, bytesRead);
                }
            }
        } catch (IOException e) {
            System.err.println("エラーが発生しました: " + e.getMessage());
        }
    }
}

3. データのフィルタリング

BufferedInputStreamを使用して、データをフィルタリングすることも可能です。

特定の条件に基づいてデータを読み込む例を示します。

import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.IOException;
public class App {
    public static void main(String[] args) {
        String filePath = "sample.txt"; // 読み込むファイルのパス
        
        try (BufferedInputStream bufferedInputStream = new BufferedInputStream(new FileInputStream(filePath))) {
            int data;
            
            // データを1バイトずつ読み込み、特定の条件でフィルタリング
            while ((data = bufferedInputStream.read()) != -1) {
                if (data >= 'A' && data <= 'Z') { // 大文字のアルファベットのみ表示
                    System.out.print((char) data);
                }
            }
        } catch (IOException e) {
            System.err.println("ファイルの読み込み中にエラーが発生しました: " + e.getMessage());
        }
    }
}

これらの応用例からもわかるように、BufferedInputStreamは大きなファイルの読み込みやネットワーク通信、データのフィルタリングなど、さまざまな場面で活用できる強力なツールです。

効率的なデータ処理を実現するために、ぜひ活用してみてください。