java - 如何从 HttpsURLConnection 创建 Java 非阻塞 InputStream？

Question

基本上，我有一个 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) 以防止阻塞的方式执行此操作？

提前致谢，詹姆斯

Answer 1

How to create a Java non-blocking InputStream

你不能。您的问题在术语上体现了矛盾。 Java 中的流是阻塞的。因此，不存在“非阻塞 InputStream”这样的东西。

Reader.ready() 当可以无阻塞地读取数据时返回 true。时期。 InputStreams 和 Readers 是阻塞的。时期。这里的一切都按设计工作。如果您希望这些 API 具有更高的并发性，您将不得不使用多线程。或 Socket.setSoTimeout() 及其在 HttpURLConnection 中的近距离关系。