Java Language
InputStreams i OutputStreams

Składnia

• int read (byte [] b) zgłasza wyjątek IOException

Uwagi

Odczytywanie InputStream w ciąg

Czasami możesz chcieć odczytać dane wejściowe bajtu w ciągu znaków. Aby to zrobić, musisz znaleźć coś, co konwertuje między byte a „natywną” Java Codepoints UTF-16 używaną jako char . Odbywa się to za pomocą InputStreamReader .

Aby nieco przyspieszyć proces, „zwykle” przydziela się bufor, abyśmy nie mieli zbyt dużego narzutu podczas odczytu z Input.

public String inputStreamToString(InputStream inputStream) throws Exception {
     StringWriter writer = new StringWriter();

     char[] buffer = new char[1024];
     try (Reader reader = new BufferedReader(new InputStreamReader(inputStream, "UTF-8"))) {
           int n;
           while ((n = reader.read(buffer)) != -1) {
                // all this code does is redirect the output of `reader` to `writer` in
                // 1024 byte chunks
                writer.write(buffer, 0, n);
           }
     }
     return writer.toString();
}

Przekształcenie tego przykładu w kod kompatybilny z Java SE 6 (i niższymi wersjami) jest pomijane jako ćwiczenie dla czytelnika.

Zapisywanie bajtów do OutputStream

Zapisywanie bajtów do OutputStream jednym bajcie

OutputStream stream = object.getOutputStream();

byte b = 0x00;
stream.write( b );

Pisanie tablicy bajtów

byte[] bytes = new byte[] { 0x00, 0x00 };

stream.write( bytes );

Pisanie sekcji tablicy bajtów

int offset = 1;
int length = 2;
byte[] bytes = new byte[] { 0xFF, 0x00, 0x00, 0xFF };

stream.write( bytes, offset, length );

Zamykanie strumieni

Większość strumieni musi zostać zamknięta po ich zakończeniu, w przeciwnym razie możesz wprowadzić wyciek pamięci lub pozostawić otwarty plik. Ważne jest, aby strumienie były zamykane, nawet jeśli zostanie zgłoszony wyjątek.

try(FileWriter fw = new FileWriter("outfilename");
    BufferedWriter bw = new BufferedWriter(fw);
    PrintWriter out = new PrintWriter(bw))
{
    out.println("the text");
    //more code
    out.println("more text");
    //more code
} catch (IOException e) {
    //handle this however you 
}

FileWriter fw = null;
BufferedWriter bw = null;
PrintWriter out = null;
try {
    fw = new FileWriter("myfile.txt");
    bw = new BufferedWriter(fw);
    out = new PrintWriter(bw);
    out.println("the text");
    out.close();
} catch (IOException e) {
    //handle this however you want
}
finally {
    try {
        if(out != null)
            out.close();
    } catch (IOException e) {
        //typically not much you can do here...
    }
}

Pamiętaj, że zamknięcie strumienia opakowania również zamknie jego strumień bazowy. Oznacza to, że nie można owinąć strumienia, zamknąć opakowania, a następnie kontynuować korzystanie z oryginalnego strumienia.

Kopiowanie strumienia wejściowego do strumienia wyjściowego

Ta funkcja kopiuje dane między dwoma strumieniami -

void copy(InputStream in, OutputStream out) throws IOException {
    byte[] buffer = new byte[8192];
    while ((bytesRead = in.read(buffer)) > 0) {
        out.write(buffer, 0, bytesRead);
    }
}

Przykład -

 // reading from System.in and writing to System.out
copy(System.in, System.out);

Zawijanie strumieni wejściowych / wyjściowych

OutputStream i InputStream mają wiele różnych klas, z których każda ma unikalną funkcjonalność. Owijając strumień wokół drugiego, zyskujesz funkcjonalność obu strumieni.

Możesz owinąć strumień dowolną liczbę razy, po prostu zanotuj jego kolejność.

Przydatne kombinacje

Zapisywanie znaków do pliku podczas używania bufora

File myFile = new File("targetFile.txt");
PrintWriter writer = new PrintWriter(new BufferedOutputStream(new FileOutputStream(myFile)));

Kompresowanie i szyfrowanie danych przed zapisaniem do pliku przy użyciu bufora

Cipher cipher = ... // Initialize cipher
File myFile = new File("targetFile.enc");
BufferedOutputStream outputStream = new BufferedOutputStream(new DeflaterOutputStream(new CipherOutputStream(new FileOutputStream(myFile), cipher)));

Lista opakowań Strumienia wejścia / wyjścia

Przykład DataInputStream

package com.streams;  
import java.io.*;    
public class DataStreamDemo {  
  public static void main(String[] args) throws IOException {  
    InputStream input = new FileInputStream("D:\\datastreamdemo.txt");  
    DataInputStream inst = new DataInputStream(input);  
    int count = input.available();  
    byte[] arr = new byte[count];  
    inst.read(arr);  
    for (byte byt : arr) {  
      char ki = (char) byt;  
      System.out.print(ki+"-");  
    }  
  }  
}