Java Streams Erklärung InputStream?

Kann mir jemand erklären, was hier passiert?

Bild zum Beitrag

Ich verstehe die Zeilen 11 bis 15 so.

Zeile 11: Ich legen eine Referenzvariable der Klasse FileInputStream fis an.

Diese bekommt eine .txt Datei übergeben. D. h. der Stream soll diese Text-Datei einlesen.

Zeile12: Warum erzeugt man jetzt nochmal einen StreamReader isr der den FileInputStream fis erfasst? Weil der InputStreamReader mehr Methoden zur verfügung stellt?

=> Unterschied InputStreamReader zu FileInputStream?

Zeile 13: Dann wird ein BufferedReader br erzeugt wo isr als Parameter eingelesen wird

=> Was ist ein BufferedReader? Unterschied InputStreamReader zu BufferedReader?

Zeile 15: String line = br.readLine();

Hier wird der Inhalt des br in den String eingelesen.

=> Wird hier der ganze Inhalt von br eingelesen?

2 Antworten

cmcta

20.04.2023, 12:55

Vorab: das ist eine Anwendung des Decorator-Patterns, das in java.io recht viel einsetzt wird.

Jede dieser Klassen stöpselt in eine andere (aber mit demselben Interface) und kann dann zusätzliche Dinge: schau dir die API-Dokumentation an. Beispielsweise kann nur ein BufferedReader zeilenweise lesen, mit der readLine()-Methode. Aber er muss nicht wissen, ob die Daten aus einer Datei oder vom Netzwerk kommen.

Der Code illustriert das Prinzip ganz gut, würde aber in produktiver Software so nicht verwendet werden, wenn man einfach eine Datei zeilenweise lesen will. Dafür gibt es viel bequemere Methoden (siehe Klasse Files).

flyaquarius

20.04.2023, 09:52

Habe kurz in die Doku geschaut und verstehe es so:

FileInputStream: Liest Bytes aus einer Datei.

InputStreamReader: Wandelt die Bytes in Textzeichen um. Kann aber nur ein Byte nach dem anderen auslesen.

BufferedReader: Liest mehrere Bytes auf einmal und speichert sie in einem Zwischenspeicher. Das ist effizienter.

flyaquarius

20.04.2023, 09:59

Übrigens gibt es einen bequemeren Weg eine Textdatei einzulesen und zwar mit der Klasse Scanner. Diese ist zwar nicht so schnell wie ein BufferedReader, aber oft spielt das keine Rolle:

Scanner scanner = new Scanner(new File("filename"));
while (scanner.hasNextLine()) {
   String line = scanner.nextLine();
   // process the line
}

cmcta

20.04.2023, 12:53

@flyaquarius

Der bequemste Weg sind immer noch die diversen statischen Methoden in File, etwa readLines() oder lines().

RedDevil1982

Fragesteller

20.04.2023, 14:50

"Habe kurz in die Doku geschaut"

Welche Doku meinst du hier? Link bitte.

RedDevil1982

Fragesteller

20.04.2023, 15:11

Welche Doku meinst du hier?

flyaquarius

20.04.2023, 16:10

@RedDevil1982

FileInputStream (Java SE 20 & JDK 20) (oracle.com)

InputStreamReader (Java SE 20 & JDK 20) (oracle.com)

BufferedReader (Java SE 20 & JDK 20) (oracle.com)

import java.io.BufferedReader;
import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStreamReader;

public class StringSearchInFile {

    public static void main(String[] args) {
        String filePath = "text.txt"; // Pfad zur Textdatei
        String searchString = "gesuchterString"; // Der zu suchende String

        try {
            FileInputStream fis = new FileInputStream(filePath);
            InputStreamReader isr = new InputStreamReader(fis);
            BufferedReader br = new BufferedReader(isr);

            String line;
            int lineNumber = 1;
            boolean found = false;
            while ((line = br.readLine()) != null) {
                if (line.contains(searchString)) {
                    System.out.println("String gefunden in Zeile " + lineNumber + ": " + line);
                    found = true;
                    break; // Abbruch nach dem ersten Fund
                }
                lineNumber++;
            }

            if (!found) {
                System.out.println("String nicht gefunden.");
            }

            br.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

Als Lösung für ein Übungsbeispiel. Es soll das erste Vorkommen eines Text in einer Datei gefunden werden.

...zur Frage

Was ist ein Stream und ein BufferedReader in Java?

Hi, ich wollte fragen, um was es sich bei einem FileInputStream, InputStreamReader und BufferedReader handelt, beziehungsweise was ein Stream in Java ist.

Danke im Voraus für eure Antworten :)

...zur Frage

Kann mir jemand bei dem JUnit-Test helfen?

Ich muss eine JUnit-Test für die Klasse NumberInputStream. Kann mir einer helfen. Ich habe schon. Im Datei"zahlen_1.txt"steht diese Zahlen?

import java.io.FileInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.Reader;


public class NumberInputStream extends InputStream {
    Reader in;


    public NumberInputStream(String fileName) throws IOException {
        in = new InputStreamReader(new FileInputStream(fileName));
    }


    @Override
    public int read() throws IOException, NumberToLargeException {
        int c;
        String t = "";
        while ((c = in.read()) != -1) {
            if ((char) c == ' ' || (char) c == '\n' || Character.isWhitespace(c)) {
                if (!t.trim().equals("")) {
                    break;
                }
            } else {
                t += (char) c;
            }
        }


        if (t.trim().equals("")) {
            return -1;
        }


        int value = Integer.parseInt(t.trim());
        if (value > 255) {
            throw new NumberToLargeException();
        }


        return value;
    }


   
}

...zur Frage

CURL Code in Java umwandeln?

Ich versuche über die DEEP API ein Bild generieren zu lassen.

Der Curl code dazu ist:

curl \
    -F 'text=YOUR_TEXT_URL' \
    -H 'api-key:quickstart-QUdJIGlzIGNvbWluZy4uLi4K' \
    https://api.deepai.org/api/text2img

Mein Java Code ist:

URL url = new URL("https://api.deepai.org/api/text2img");
HttpURLConnection con = (HttpURLConnection)url.openConnection();
con.setRequestMethod("POST");
con.setRequestProperty("Content-Type", "application/json");

JSONObject data = new JSONObject();
data.put("text", "TEXT");
data.put("api-key", "quickstart-QUdJIGlzIGNvbWluZy4uLi4K");

con.setDoOutput(true);
con.getOutputStream().write(data.toString().getBytes());

try(BufferedReader br = new BufferedReader(
        new InputStreamReader(con.getInputStream(), "utf-8"))) {
    StringBuilder response = new StringBuilder();
    String responseLine = null;
    while ((responseLine = br.readLine()) != null) {
        response.append(responseLine.trim());
    }
    return response.toString();
}

Ich bekomme jedoch folgende Fehlermeldung:

Server returned HTTP response code: 401 for URL: https://api.deepai.org/api/text2img

Kann mir jemand weiterhelfen?

...zur Frage

wie erzeugt man eine leere zeile zwischen jedem char in einem string (c#)?

...zur Frage

Java mit einem Stream eine .text Datei kopieren?

Ich möchte per Stream die Datei Hallo wie gehts.txt kopieren und eine neue Datei copy.txt erzeugen. Warum funktioniert dies nicht? FileNotFoundException?

Code ist unten angehängt:

package de.thws;                     // Von mir zum testen von Streams

import java.io.*;

public class PerStreamDateiEinlesen {

    public static void main(String[] args) throws FileNotFoundException {

        copyFileWithErrorHandling3Modularized();
    }

    public static void copyFileWithErrorHandling3Modularized()
    {
        // try-with-resource statement
        try (InputStream fis = new FileInputStream("Hallo wie gehts.text");
             OutputStream fos = new FileOutputStream("copy.txt");)
        {
            copyImproved(fis, fos);
        }
        catch (IOException e)
        {
            e.printStackTrace();
        }
    }
    // Hier kopiere ich die Datei
    static void copyImproved(InputStream is, OutputStream os) throws IOException
    {
        byte[] b = new byte[1024];
        int n;
        do
        {
            n = is.read(b); //kann maximal 1024 bytes lesen
            if (n != -1) os.write(b, 0, n);
        }
        while (n != -1);
    }
}

...zur Frage

Java: Connection reset by peer: socket write error?

Ich habe bei folgenden (das ist um einen zip Datei zu verschicken) den Error:

java.net.SocketException: Connection reset by peer: socket write error
	at java.net.SocketOutputStream.socketWrite0(Native Method)
	at java.net.SocketOutputStream.socketWrite(Unknown Source)
	at java.net.SocketOutputStream.write(Unknown Source)
	at java.nio.file.Files.copy(Unknown Source)
	at java.nio.file.Files.copy(Unknown Source)
	at x46.Server.Server_in.run(Server_in.java:59)
	at java.lang.Thread.run(Unknown Source)

Mein Client (senden der Datei):

		try {
    Socket client = new Socket("localhost", 16102);

    // strems
    // out
    OutputStream outStream = client.getOutputStream();
    PrintWriter out = new PrintWriter(outStream);

    // in

    InputStream inStream = client.getInputStream();
    BufferedReader in = new BufferedReader(new InputStreamReader(inStream));


    // -------------------------------------------------------
    
			File file = new File("send.zip");
			// init array with file length
			byte[] bytesArray = new byte[(int) file.length()];
			  FileInputStream fis = new FileInputStream(file);
			  fis.read(bytesArray); //read file into bytes[]
			  fis.close();
		

			  outStream.write(bytesArray);
			  outStream.flush();

    } catch (IOException e) {
        // TODO Auto-generated catch block
        e.printStackTrace();
    }

Server(empfängt die Datei):

		try {
			ExecutorService executor = Executors.newFixedThreadPool(2);
        // server starten
        ServerSocket server01 = new ServerSocket(16102);

        System.out.println("Warte auf clients auf dem Port " + server01.getLocalPort());
        // --------------------------------------------------------------
        while (true) {

            // connection aktiviren
            Socket connection = server01.accept();
            System.out.println("Client verbingung unter: " + connection.getRemoteSocketAddress());

            // -------------------------------------------------------------

            // strems
            // out
            OutputStream outStream = connection.getOutputStream();
            PrintWriter out = new PrintWriter(outStream);

            ObjectOutputStream oos = new ObjectOutputStream(outStream);
            // in

            InputStream inStream = connection.getInputStream();
            BufferedReader in = new BufferedReader(new InputStreamReader(inStream));

            // ------------------------------------------------------------

            // Path path = Paths.get("test.zip");
            File f = new File("test.zip");
            Files.copy(f.toPath(), outStream);
        }
    } catch (IOException e) {
        e.printStackTrace();

    }

Also woher kommt der Error?

...zur Frage

Java Strings vergleichen mit == und .equals?

Ein String ist in Java ein Klasse.

Neue String-Objekte, bzw. Referenzvariablen können einfach per Zuweisung erzeugt werden

String str3 = "iwas";

String str4 = "iwas"

statt String strx = new String("...");

str3 und str4 sind doch nun zwei verschiedene Referenzvariablen.

Mit str3.equals(str4) vergleicht man den Inhalt der Strings. true klar!

Schreibt man nun

System.out.println(str4==str3);

kommt auch true heraus. D. h. str4 und str3 sind zwei verschiedene Referenzvariablen, die auf das selbe Objekt im Speicher "iwas" verweisen?

Deshalb true?

String str5 = new String("iwas");
System.out.println(str3==str5);

Hier kommt jetzt false heraus?

...zur Frage

Wie kriege ich den Response der API in mein TextViewField in Android Studio?

Hallo,

momentan sitze ich daran, eine Android App mit Android Studio zu entwickeln. Die App soll GET und POST benutzen können, um mit einer API arbeiten zu können.

Soweit funktioniert das auch alles. Meine Frage bezieht sich hier auf Folgendes:

Ich habe in der MainActivity den TextView TW_Rueckgabe. Hier soll der Response der POST-Funktion gespeichert werden, da ich den gerne in der App anzeigen lassen will.

Nun habe ich aber bereits ein paar Sachen ausprobiert, allerdings vergebens.

Nun zu meiner eigentlichen Frage:

Wie kriege ich hin, das der Response der POST-Klasse in dem TextView TW_Rueckgabe gespeichert wird?

Danke im Voraus.

MfG

MainActivity.java

final TextView[] TW_Rueckgabe = {
  findViewById(R.id.textViewRueckgabe)
};
Button sendBtn = findViewById(R.id.sendBtn);
sendBtn.setOnClickListener(v -> {
  String POST_url = "http://dphost.ddns.net:1573/cool/post.php";
  String requestData = "data=" + TW_Benutzername.getText().toString();
  POSTRequestTask test = (POSTRequestTask) new POSTRequestTask().execute(POST_url, requestData);
  TW_Rueckgabe[0].setText(test.fetching_data);
});

POSTRequestTask.Java

class POSTRequestTask extends AsyncTask<String, Void, String> {
  @Override
  protected String doInBackground(String... params) {
    String url = params[0];
    String requestData = params[1];
    String response = "";

    try {
      URL obj = new URL(url);
      HttpURLConnection con = (HttpURLConnection) obj.openConnection();

      // add request header
      con.setRequestMethod("POST");
      con.setDoOutput(true);

      // add request data
      DataOutputStream wr = new DataOutputStream(con.getOutputStream());
      wr.writeBytes(requestData);
      wr.flush();
      wr.close();

      int responseCode = con.getResponseCode();
      System.out.println("\nSending 'POST' request to URL : " + url);
      System.out.println("Response Code : " + responseCode);

      BufferedReader in = new BufferedReader(new InputStreamReader(con.getInputStream()));
      String inputLine;
      StringBuffer responseBuffer = new StringBuffer();

      while ((inputLine = in.readLine()) != null) {
        responseBuffer.append(inputLine);
      }

      in.close();
      response = responseBuffer.toString();
    }
    catch (IOException e) {
      e.printStackTrace();
    }

    return response;
  }

  @Override
  protected void onPostExecute(String result) {
    // print result
    System.out.println("\n\n\n" + result + "\n\n\n");
    fetching_data = result;
  }

  public String returnString() {
    return fetching_data;
  }
}

...zur Frage

Zeile in einer Datei löschen?

Moinsen,

ich bin grerade dabei eine Datenbank zu programmieren. Die einzelnen Einträge werden in eine Datei gespeichert. Jetzt soll das Programm natürlich die Funktion haben Einträge zu löschen. Und genau da liegt das Problem. Um die gewünschte Zeile zu bekommen, lasse ich den User einen String übergeben, der in dieser Zeile vorkommt. Dann gehe ich mit einem BufferedReader die ganze Datei durch und suche die entsprechende Zeile. Ich weiß jetzt aber nicht, wie ich diese Zeile löschen kann, wenn ich sie gefunden habe. hat jemand ne Idee?

...zur Frage

Java: In eine HTML-Datei schreiben?

Ich möchte mit Java eine HTML-Datei schreiben.

Also, wenn man mein Programm öffnet, wird angezeigt: "Wie soll der Titel für die Seite sein?". Dann schreibt man einen Titel. Jetzt sollte in eine HTML-Datei geschrieben worden sein:

<title>derTitel</titel>

Aber in der Datei steht trotzdem nichts drin. Im Internet habe ich herausgefunden, dass es mit writer.newLine(); und writer.write und so geht.

Die betroffene Stelle:

BufferedWriter writer = new BufferedWriter(new FileWriter(webn, false)); //webn ist der String für den Dateiname.
command = zeile.replaceAll(".\((.)\).", "$1" + ".html");

try {
  writer.write("<title>" + command + "</title>");
  writer.newLine(); //im String command ist der Titel
} //Titel enthalten.
catch(IOException ioe) {
  System.err.println(ioe);
}

zeile = br.readLine();

Und das ist die Stelle, an der der gewählte Dateiname festgelegt wird (klappt auch nicht; falls diese Datei schon existiert, wird sie überschrieben):

webn = zeile.replaceAll(".\((.)\).", "$1" + ".html");
File web = new File(webn);
BufferedWriter writer = new BufferedWriter(new FileWriter(webn, false));

try {
  writer.write("<!DOCTYPE html>");
  writer.newLine();
}
catch(IOException ioe) {
  System.err.println(ioe);
}

zeile = br.readLine();

...zur Frage

VBA Laufzeitfehler 52: Dateipfad nicht gefunden?

Unten seht ihr das ganze sub. Bei der Stelle "Open QuellDatei For Input As #1"(fett) kommt immer der Fehler und ich weiß nicht wieso/was ich dagegen tun kann...

Sub Wetterdaten_Importieren()

Dim QuellDatei As String 'Speicherort der Datei

Dim Zeile As Integer 'Laufvariable

Dim Inhalt As String 'Inhalt der Datei

'Tabellenblatt aktivieren

ThisWorkbook.Worksheets("Wetterdaten").Activate

'Startwert zuweisen

Zeile = 2

'Quelldatei ansprechen

QuellDatei = ThisWorkbook.Path & "C:\Users\oliMa\Downloads\stundenwerte_ST_00183_row.zip\produkt_st_stunde_19810101_20210930_00183.txt"

'Quelldatei öffnen

Open QuellDatei For Input As #1

'Informationen in das Tabellenblatt eintragen

'Schleife bis DatenEnde

Do While Not EOF(1)

'Inhalt wird Zeilenweise eingelesen

Line Input #1, Inhalt

'Wert in das Tabellenblatt eintragen

ActiveSheet.Cells(Zeile, 1) = Inhalt

Zeile = Zeile + 1

Loop

'Quelldatei schließen

Close #1

...zur Frage

In Java eine TXT Datei auslesen?

Habe eine TXT Datei, die ungefähr so aufgebaut ist:

und so einen Code:

String text = "";
int lineNumber;
try {
    FileReader readfile = new FileReader("C:\\Users\\****.txt");
    BufferedReader readbuffer = new BufferedReader(readfile);
    for (lineNumber = 1; lineNumber < 10; lineNumber++) {
        if (lineNumber == 7) {
            text = readbuffer.readLine();
        } else
            readbuffer.readLine();
    }
} catch (IOException e) {
    e.printStackTrace();
}

Ich möchte aber nicht die gleiche Zeile immer auslesen, wie hier die 7. Zeile sondern immer die unterste Zeile also die letzte Zeile und die vorletzte Zeile, da sich die Datei immer ändert und immer neue Zeilen dazu kommen.

...zur Frage

java Objkte als csv ausgeben lassen?

Also meine Aufgabe lautet, dass ich eine csv Datei einlesen soll diese in 2 Klassen zu unterteilen und dann wieder als csv Datei auszugeben.

Ich bin nun soweit dass ich für jede Zeile der eingelesen csv Datei ein objekt erstellt habe. Wie kann ich jz diese Objekte als csv ausgeben lassen bzw den Inhalt der Objekte

...zur Frage

Was möchtest Du wissen?

Deine Frage stellen