有什么方法可以使用java.nio。*在不關(guān)閉套接字的情況下中斷InputStream#read()?
如果在讀取過(guò)程中中斷了InterruptibleChannel,它將被關(guān)閉并拋出ClosedByInterruptException。如果您只想讀取超時(shí),請(qǐng)不要使用任何通道,而只需使用常規(guī)的Socket;用較短的超時(shí)調(diào)用Socket.setSoTimeout(),并在每次超時(shí)觸發(fā)時(shí)檢查線程的isInterrupted()狀態(tài)。更好的是,查看中斷線程的要求。那個(gè)有什么用途?
解決方法您是否知道在InputStream不關(guān)閉關(guān)聯(lián)套接字的情況下中斷Java讀取的方法?
這是獲取套接字輸入流并轉(zhuǎn)換為可中斷的DataInputStream的當(dāng)前構(gòu)造策略:
InputStream interruptibleInputStream = Channels.newInputStream(Channels.newChannel(m_ConnectionData.getSocket().getInputStream()));DataInputStream myInterruptibleDIS = new DataInputStream(interruptibleInputStream);
這利用ReadableByteChannel提供了read(ByteBuffer)對(duì)ClosedByInterruptExceptionthrowable的支持的方法的a。
問(wèn)題在于,在線程上調(diào)用中斷再在原因read()上調(diào)用DataInputStream會(huì)導(dǎo)致底層套接字被關(guān)閉。
就我而言,我需要使套接字保持打開(kāi)狀態(tài)。該read呼叫正在等待即將到來(lái)的用戶輸入,因此我正在使用中斷將控制權(quán)傳遞回更高的組件,然后最終read再次返回。
如果有人可以提出一種使用JDK內(nèi)置類(lèi)實(shí)現(xiàn)此目標(biāo)的方法,或者指出某些信息是不可能的,我將不勝感激。
我知道還有其他方法可以達(dá)到相同的效果,但是我很想知道這種方法是否可行。
相關(guān)文章:
1. nignx - docker內(nèi)nginx 80端口被占用2. docker images顯示的鏡像過(guò)多,狗眼被亮瞎了,怎么辦?3. 關(guān)于docker下的nginx壓力測(cè)試4. android - 百度地圖加載完成監(jiān)聽(tīng)5. 跟蹤器怎么開(kāi)啟無(wú)反應(yīng)6. java - 阿里的開(kāi)發(fā)手冊(cè)中為什么禁用map來(lái)作為查詢的接受類(lèi)?7. macos - mac下docker如何設(shè)置代理9. dockerfile - [docker build image失敗- npm install]10. python3.x - git bash如何運(yùn)行.bat文件?
