您的位置:首页技术文章
文章详情页

有什么方法可以使用java.nio。*在不关闭套接字的情况下中断InputStream#read()?

浏览:42日期:2024-05-02 14:54:46
如何解决有什么方法可以使用java.nio。*在不关闭套接字的情况下中断InputStream#read()??

如果在读取过程中中断了InterruptibleChannel,它将被关闭并抛出ClosedByInterruptException。如果您只想读取超时,请不要使用任何通道,而只需使用常规的Socket;用较短的超时调用Socket.setSoTimeout(),并在每次超时触发时检查线程的isInterrupted()状态。更好的是,查看中断线程的要求。那个有什么用途?

解决方法

您是否知道在InputStream不关闭关联套接字的情况下中断Java读取的方法?

这是获取套接字输入流并转换为可中断的DataInputStream的当前构造策略:

InputStream interruptibleInputStream = Channels.newInputStream(Channels.newChannel(m_ConnectionData.getSocket().getInputStream()));DataInputStream myInterruptibleDIS = new DataInputStream(interruptibleInputStream);

这利用ReadableByteChannel提供了read(ByteBuffer)对ClosedByInterruptExceptionthrowable的支持的方法的a。

问题在于,在线程上调用中断再在原因read()上调用DataInputStream会导致底层套接字被关闭。

就我而言,我需要使套接字保持打开状态。该read呼叫正在等待即将到来的用户输入,因此我正在使用中断将控制权传递回更高的组件,然后最终read再次返回。

如果有人可以提出一种使用JDK内置类实现此目标的方法,或者指出某些信息是不可能的,我将不胜感激。

我知道还有其他方法可以达到相同的效果,但是我很想知道这种方法是否可行。

标签: java
相关文章: