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

Beitragsersteller

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)

RedDevil1982

Beitragsersteller

20.04.2023, 14:50

"Habe kurz in die Doku geschaut"

Welche Doku meinst du hier? Link bitte.

Ähnliche Beiträge

Ist das ein gutes Programm für String Suche in einer Datei (Java)?

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.

...zum Beitrag

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 :)

...zum Beitrag

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.

...zum Beitrag

C# mit Benutzereingabe rechnen?

Hallo Allerseits,

ich arbeite in C# zurzeit am Rechnen mit Benutzereingaben. Dabei bin ich gleich zu Beginn auf ein Problem gestoßen..

Und zwar wenn ich vom Benutzer einen Integer einlesen möchte (z.B. 3) und dann einen zweiten Integer erstelle und diesem den Wert des ersten zuweise, dann ist der Wert des zweiten ein völlig anderer (z.B. 51 statt 3).

Hier Bilder zur Verdeutlichung:

---> Quellcode

Ausgabe:

Muss ich den eingelesenen Integer in irgenwas konvertieren oder wo liegt hier das Problem?

...zum Beitrag

GGT porgrammiern?

kann mir jmd erklären, was ich anders machen soll oder ob ich was vergessen hab, damit das Programm läuft? (es geht um den größten gemeinsamen Teiler)

Danke

...zum Beitrag

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

...zum Beitrag

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?

...zum Beitrag

Woran könnte es liegen, dass die Entschlüsselung der AES verschlüsselten Nachricht vom Client auf der Serverseite nicht korrekt funktioniert?

Beschreibung:

Ich habe eine Client-Server-Anwendung, bei der der Server einen Befehl an den Client sendet, der diesen Befehl auf dem Client ausführt und dann das Ausgaberesultat zurück an den Server schickt. Der Command-Output wird verschlüsselt, bevor er an den Server gesendet wird, und sollte auf der Serverseite entschlüsselt werden, um die Ausgabe anzuzeigen.

Ablauf:

Client:

public void executeCommand() {
    try {
        Process p = Runtime.getRuntime().exec("cmd /c " + commandInput);
        p.getOutputStream().close();


        InputStream processStdOutput = p.getInputStream();
        Reader r = new InputStreamReader(processStdOutput);
        BufferedReader br = new BufferedReader(r);
        String line;


        while ((line = br.readLine()) != null) {
            writeToServerSocket("cmd18721378231dcad2");
            writeToServerSocket(line + "\n");
            writer.flush();
        }


        p.waitFor();
    } catch (Exception ex) {
        System.out.println(ex.getLocalizedMessage());
    }
}

public void writeToServerSocket(String message) {
	try {
		String encodedMessage = EncryptionHelper.encrypt(message);
		writer.write(encodedMessage);
	} catch (Exception e) {
		// TODO Auto-generated catch block
		e.printStackTrace();
	}
}

Server:

In einer Dauerschleife wird überprüft:

...
String encryptedInput = scanner.nextLine();
            		String input = EncryptionHelper.decrypt(encryptedInput); // Hier vermutlich Fehler
...
else if (input.contains("cmd18721378231dcad2")) {
    String commandOutput = input.substring(19);
    // Problem: Die Entschlüsselung des commandOutput funktioniert nicht korrekt
    // Hier sollte der entschlüsselte Text angezeigt werden
    controller.updatejTextAreaAllChat(commandOutput + "\n");
}

...

Problem:

Der verschlüsselte Command-Output wird vermutlich (nicht komplett sicher da System.out.println zum debuggen beim Server nicht funktioniert aus welchem Grund auch immer) erfolgreich an den Server gesendet, aber die Entschlüsselung auf der Serverseite funktioniert nicht wie erwartet. Der entschlüsselte Text wird nicht korrekt angezeigt, und es wird sobald ich die Anwendung beende die Fehlermeldung "Input byte array has incorrect ending byte" angezeigt.

Code für die Verschlüsselung/Entschlüsselung:

public class EncryptionHelper {
    private static final String KEY = "mysecretkey";


    public static String encrypt(String plainText) throws Exception {
        // ... (Verschlüsselungslogik)
    }


    public static String decrypt(String encryptedText) throws Exception {
        // ... (Entschlüsselungslogik)
    }
}

Was habe ich bereits versucht:

Die Übertragung der verschlüsselten Daten wurde überprüft und scheint intakt zu sein.
Die Verschlüsselungslogik wurde überprüft und sie scheint korrekt zu sein.
Andere Bereiche des Codes wurden überprüft, um sicherzustellen, dass sie das Entschlüsselungsproblem nicht verursachen.

...zum Beitrag

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;
  }
}

...zum Beitrag

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);
    }
}

...zum Beitrag

Python: splitlines trennt nicht nach Zeilenumbruch?

Eine Textdatei mit Steuerzeichen hex 0D 0A 5B 31 als Zeilentrenner protestiert beim Einlesen als Textfile "wt", wenn ich dann die Zeilen lesen will

handle = open("cht.txt", "wt")
lines = handle.readlines()

Fehlermeldung, dass ein gewisses byte nicht eingelesen werden kann.

Wenn ich sie mit "wb" als Binary öffne, dann in ASCII umwandle, bekomme ich eine Datei vom Typ String.

Wende ich dann splitlines auf sie an, kommt nur eine Liste mit einem Element dabei raus.

handle = open("cht.txt", "wb")
chtlines = ascii(handle).splitlines()

Auch wenn ich ein split("\n") verwende, passiert dasselbe.

Warum wird der Zeilenumbruch nicht erkannt.

...zum Beitrag

Java Float ohne Nachkommastelle?

Hey,

ich habe einen Java-Code in der Schule und möchte, dass die letzte Ausgabe ohne Nachkommastellen ausgegeben wird.

Hier der Code:

import java.io.*;

public class Subtraktion {
  public static void main(String argv[]) throws IOException {
    float zahl1, zahl2, ergebnis;
    String str;
    BufferedReader eingabe = new BufferedReader(new InputStreamReader(System.in));

    System.out.println("Subtraktion zweier Zahlen");
    System.out.print("Zahl1: ");
    str = eingabe.readLine();
    zahl1 = Float.parseFloat(str);
    System.out.print("Zahl2: ");
    str = eingabe.readLine();
    zahl2 = Integer.parseInt(str);
    ergebnis = zahl1 - zahl2;
    System.out.println("Das Ergebnis der Subtraktion " + zahl1 + "-" + zahl2 + " ist " + ergebnis + "");
    System.out.println("Programmende Subtraktion.");
  } // end of main
} // end of class Benzinv

Danke

...zum Beitrag

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?

...zum Beitrag

Obejekt orienetiertes Programmieren... wäre das so richtig?

Hallo,

ich weiss das in dem Programmstück das jetzt kommt bestimmt viele fehler sein werden aber ich weiss nur nicht was die fehler sind. Ich arbeite mit Eclipse und es zeigt mir wo die Fehler sind nur weiss ich nicht wie ich diese beheben soll.... Ich hoffe man kann mir helfen. Bin gerade dabei OOP zu lernen und naja... Hier das Programmstück

import java.io.*;

public class Mensakarte { double guthaben; String besitzer; boolean gesperrt;

public Mensakarte(){ guthaben = 0.0; besitzer = "Helene"; gesperrt = true; } public static void main(String args[]) throws IOException {

BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
int choice = 0;
boolean erfolg;

do {
  
  System.out.println();
  System.out.println("Bitte waehlen:");
  System.out.println("(1) Karte aufladen");
  System.out.println("(2) Guthaben anzeigen");
  System.out.println("(3) Kaffee abbuchen");
  System.out.println("(4) Essen abbuchen");
  System.out.println("(5) Verbleibende Kaffees anzeigen");
  System.out.println("(6) Sperre toggeln");
  System.out.println("(0) Ende");
  choice = Integer.parseInt(in.readLine());
  System.out.println();
  
  switch (choice) {
    
    case 1:
    System.out.print("Aufladebetrag? ");
    double betrag = Double.parseDouble(in.readLine());
       aufladen(betrag);
    break;
    
    case 2:
       guthaben();
    break;
    
    case 3:
       kaffe_abbuchen();
    break;
    
    case 4:
    System.out.print("Essenspreis? ");
    double preis = Double.parseDouble(in.readLine());
       essen_abbuchen (guthaben);
    break;
    
    case 5:
      anzahl();
    break;
    
    case 6:
      toggeln();
    break;
    
  }
  
} while (choice!=0);

} public static double aufladen(double plus){ if (plus >=0) {

    guthaben = guthaben + plus;
return guthaben;
}

}
public double guthaben(){
double guthaben=guthaben; return guthaben; }
public boolean kaffe_abbuchen(){ if (guthaben>= 1.20) { guthaben = guthaben - 1.20;

  return true;
}
else {
  return false; 
}

} public boolean essen_abbuchen(double preis){ if (guthaben>=preis) { guthaben = guthaben - preis;

  return true;
}
else {
  return false;
}

} public int anzahl(){ int zahl; zahl = guthaben/1.20;

return guthaben;

}
public boolean toggeln(){ boolean gesperrt;

if (gesperrt=true) {
  return false;
    
  } 
  else {
   return true;   
  }

} }

...zum Beitrag

Was möchtest Du wissen?

Deine Frage stellen