Ich möchte eine SocketChannel verwenden und ein Timeout für seine Lese-/Schreibmethoden haben. Ich habe versucht, ein Timeout für den Sockel gesetzt, dass meine SocketChannel wie diese besitzt:Timeout für SocketChannel funktioniert nicht
channel.socket().setSoTimeout(TIMEOUT);
aber das funktioniert nicht. Gibt es eine andere Lösung?
Entsprechend dieser article, SocketChannel wird nicht Timeout für seine Lesevorgang, aber Sie können diesen Effekt vom Lesen aus dem Kanal auf andere Weise erhalten.
Lesen von dem WrappedChannel wird Timeout entsprechend dem SocketTimeOut, das Sie festgelegt haben.
gute Lösung. Java ist ... festgefahren –
Dies ist nicht der richtige Weg, dies zu tun, nur ein Workaround. Der richtige Weg ist, Selector.select (timeout) in einer Schleife zu verwenden und das soTimeout/connectTimeout mit einem if-check zu überprüfen. – wzona
'setSocketTimeout' ist jetzt' setSoTimeout', funktioniert aber genauso. –
Sie könnten auch in Betracht ziehen, Ihren Kanal nicht blockierbar zu machen und nur System.currentTimeMillis() zu verwenden.
Wenn Sie mit der Verwendung von Java Selector vertraut sind, können Sie das Socket-Timeout mithilfe des Selektors selbst emulieren. Es ist hilfreich, sun.nio.ch.SocketAdaptor zu sehen.
Es sollte vorsichtig sein, Thread.interrupt() zu verwenden. SocketChannel ist InterruptibleChannel. Wenn Sie die Beschreibung von InterruptibleChannel lesen, führt Thread.interrupt() zu Schließen SocketChannel. Wenn Sie SocketChannel nach einem Timeout verwenden möchten, können Sie die InterruptibleChannel-Funktion nicht verwenden.
SocketChannel unterstützt die setSoTimeout-Methode leider nicht direkt. Die Verwendung wird leider vernachlässigt. – casey
SocketChannel implementiert die InterruptibleChannel-Schnittstelle, was bedeutet, dass Sie vor dem Aufruf Ihres read() -Aufrufs einen separaten Thread erstellen konnten, der andere Thread einen Timer gesetzt hat und nach Ablauf des Timers den Thread, in dem Ihr SocketChannel read() Anruf blockiert. Wenn der Aufruf read() zuerst zurückkehrt, könnte der Timer-Thread beendet werden. –
@StevensMiller Und der Kanal wird geschlossen, und das Lesen wird 'ClosedByInterruptException.' werfen. Nicht sehr nützlich. Mir wurde gesagt, dass diese bizarre Implementierung durch das Verhalten von Linux bedingt ist. – EJP