有什么方法可以使用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内置类实现此目标的方法,或者指出某些信息是不可能的,我将不胜感激。
我知道还有其他方法可以达到相同的效果,但是我很想知道这种方法是否可行。
相关文章:
1. ddos - apache日志很多其它网址,什么情况?2. boot2docker无法启动3. css - weui 用伪元素生成border,源码有点不理解4. java - list<Map<String, Object>> 排序5. javascript - 关于audio标签暂停的问题6. javascript - 调微信分享朋友接口,出现下面问题,求解答,7. webpack - vue-cli写的项目(本地跑没有问题),准备放到Nginx服务器上,有什么配置需要改的?还有怎么部署?8. 微信公众号发送模板消息返回错误410009. 这是什么情况???10. 问题Unknown column ’’ in ’where clause’
