基本上,我有一个 URL,可以在发布新消息时从聊天室流式传输 xml 更新。我想将该 URL 转换为 InputStream 并继续从中读取,只要保持连接并且只要我没有发送 Thread.interrupt()。我遇到的问题是,当有内容要从流中读取时,BufferedReader.ready() 似乎没有变为真。
我正在使用以下代码:
BufferedReader buf = new BufferedReader(new InputStreamReader(ins));
String str = "";
while(Thread.interrupted() != true)
{
connected = true;
debug("Listening...");
if(buf.ready())
{
debug("Something to be read.");
if ((str = buf.readLine()) != null) {
// str is one line of text; readLine() strips the newline character(s)
urlContents += String.format("%s%n", str);
urlContents = filter(urlContents);
}
}
// Give the system a chance to buffer or interrupt.
try{Thread.sleep(1000);} catch(Exception ee) {debug("Caught thread exception.");}
}
当我运行代码并向聊天室发布内容时,buf.ready() 永远不会变为 true,导致这些行永远不会被读取。但是,如果我跳过“buf.ready()”部分并直接读取行,它会阻止进一步的操作,直到读取行为止。
我该如何 a) 让 buf.ready() 返回 true,或者 b) 以防止阻塞的方式执行此操作?
提前致谢, 詹姆斯
最佳答案
How to create a Java non-blocking
InputStream
你不能。您的问题在术语上体现了矛盾。 Java 中的流是阻塞的。因此,不存在“非阻塞 InputStream
”这样的东西。
Reader.ready()
当可以无阻塞地读取数据时返回 true。时期。 InputStreams
和 Readers
是阻塞的。时期。这里的一切都按设计工作。如果您希望这些 API 具有更高的并发性,您将不得不使用多线程。或 Socket.setSoTimeout()
及其在 HttpURLConnection
中的近距离关系。
关于java - 如何从 HttpsURLConnection 创建 Java 非阻塞 InputStream?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/5049319/