我试图在多个线程中逐行读取套接字的输入.如何中断readLine()以便我可以优雅地阻止它阻塞的线程?
编辑(赏金):这可以在不关闭套接字的情况下完成吗?
如何在使用套接字连接创建的BufferedReader和PrintWriter上设置超时?这是我现在为服务器提供的代码,直到服务器或客户端崩溃为止:
while(isReceiving){
str = null;
BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
PrintWriter pw = new PrintWriter(socket.getOutputStream(), true);
while ((str = br.readLine()) != null){
System.out.println("Processing command " + str);
pw.println(client.message(str));
}
}
Run Code Online (Sandbox Code Playgroud)
在这段代码的范围之外,我已经施加了1000毫秒的套接字超时,它在等待初始连接时按预期工作.但程序阻塞在(str = br.readLine()).如果客户端挂起或崩溃,它永远不会停止阻止,除非我终止进程(即使这样也不总是有效).
有问题的客户端代码与此非常相似,并且以类似的方式阻塞.