Wie lese ich aus einem Java InputStream mit Timeout?

Lesen aus einem InputStream mit Timeout

Spezifische Probleme erfordern maßgeschneiderte Lösungen. Ziel dieser Frage ist es, eine Methode zu konstruieren, die innerhalb des vorgegebenen Zeitlimits Daten von einem InputStream abruft und bei Überschreitung ordnungsgemäß mit einem Fehlercode fehlschlägt.

Spezifische Überlegungen für Javas InputStream

Um dieses Problem zu lösen, ist Verständnis erforderlich Javas InputStream-Klasse:

• Die Methode read() kann nicht allgemein sein unterbrochen.
• Das Einschließen von InputStream in Reader- oder InterruptibleChannel-Klassen erweitert nicht die verfügbaren Optionen.
• available() kann jederzeit 0 zurückgeben.
• close() kann oder blockieren Nichts tun.
• Das bedingungslose Beenden eines anderen Threads ist nicht möglich.

Eingabe Verfügbarkeitsprüfung mit available()

Im Gegensatz zur Behauptung in der Problemstellung gibt InputStream.available() nicht immer 0 zurück. Es liefert eine Schätzung leicht verfügbarer Daten ohne Blockierung. Es kann jedoch sein, dass die tatsächliche Datenanzahl unterschätzt wird.

Die einfachste Lösung

Dieser unkomplizierte Ansatz erfordert keine Blockierungs- oder Timeout-Einschränkungen:

byte[] inputData = new byte[1024];
int result = is.read(inputData, 0, is.available());

Timeout-Aware Lösung

Für eine genauere Steuerung kann eine Methode einen Puffer innerhalb eines angegebenen Zeitraums mit verfügbaren Daten füllen timeout:

public static int readInputStreamWithTimeout(InputStream is, byte[] b, int timeoutMillis)
     throws IOException  {
     int bufferOffset = 0;
     long maxTimeMillis = System.currentTimeMillis() + timeoutMillis;
     while (System.currentTimeMillis() < maxTimeMillis &amp;&amp; bufferOffset < b.length) {
         int readLength = java.lang.Math.min(is.available(), b.length - bufferOffset);
         int readResult = is.read(b, bufferOffset, readLength);
         if (readResult == -1) break;
         bufferOffset += readResult;
     }
     return bufferOffset;
 }

Lösungsauslastung

byte[] inputData = new byte[1024];
int readCount = readInputStreamWithTimeout(System.in, inputData, 6000);  // 6 second timeout

Dies bietet eine Möglichkeit, aus einem InputStream mit einem Timeout sowohl für blockierende als auch nicht blockierende Eingabequellen zu lesen.

Das obige ist der detaillierte Inhalt vonWie lese ich aus einem Java InputStream mit Timeout?. Für weitere Informationen folgen Sie bitte anderen verwandten Artikeln auf der PHP chinesischen Website!