3

我想向服务器发送命令，看看是否得到响应。

现在我正在使用BufferedReader'sreadline()函数，该函数会阻塞，直到有来自服务器的响应，但我要做的就是首先验证服务器是否有响应。

我尝试使用ready()或reset()避免这个块，但它没有帮助。

这导致我的程序卡在等待服务器响应，而这种情况永远不会发生。InputStreamReader根据我对事物的理解，似乎做同样的事情。

我在这里找到的关于这个主题的其他问题没有回答我的问题，所以如果你能回答我的问题，那就太好了。

4

4 回答 4

3

如果你想异步读取响应，我建议启动一个读取 BufferedReader 的线程。这更容易编码并且更容易控制。

于 2012-06-30T12:00:36.343 回答
1

可能您所需要的只是InputStream不将其包装在BufferedReader

while (inputStream.available() > 0) {
     int i = inputStream.read(tmp, 0, 1024);
     if (i < 0)
          break;
     strBuff.append(new String(tmp, 0, i));
}

我希望这有帮助。

于 2012-06-30T11:48:10.203 回答
0

我最近使用 CountDownLatch 做了类似的事情。可能有一些更好的方法，但这很容易，而且似乎工作得很好。您可以根据需要调整 CountDownLatch 的等待时间。

package com.whatever;

import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.net.URL;
import java.net.URLConnection;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.TimeUnit;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

public class TestRead {
    private static final Logger log = LoggerFactory.getLogger(TestRead.class);
    private CountDownLatch latch = new CountDownLatch(1);

    public void read() {
        URLReader urlReader = new URLReader();
        Thread listener = new Thread(urlReader);
        listener.setDaemon(true);
        listener.start();
        boolean success = false;
        try {
            success = latch.await(20000, TimeUnit.MILLISECONDS);
        } catch (InterruptedException e) {
            log.error("error", e);
        }
        log.info("success: {}", success);
    }

    class URLReader implements Runnable {
        public void run() {
            log.info("run...");
            try {
                URL oracle = new URL("http://www.oracle.com/");
                URLConnection yc = oracle.openConnection();
                BufferedReader in = new BufferedReader(new InputStreamReader(yc.getInputStream()));
                String inputLine;
                while ((inputLine = in.readLine()) != null)
                    System.out.println(inputLine);
                in.close();
                latch.countDown();
            } catch (Exception ex) {
                log.error("error", ex);
            }
            log.info("consumer is done");
        }

    }
    public static void main(String[] args) {
        TestRead testRead = new TestRead();
        testRead.read();
    }
}
于 2012-06-30T17:25:50.040 回答
0

如果您使用标准 java IO，那么不会阻塞是一项棘手的任务。常见的答案是迁移到 NIO 或 netty。Netty 是更可取的选择。但是有时您别无选择，因此我建议您尝试我的解决方法：

public String readResponse(InputStream inStreamFromServer, int timeout) throws Exception {
    BufferedReader reader = new BufferedReader(new InputStreamReader(inStreamFromServer, Charsets.UTF_8));
    char[] buffer = new char[8092];
    boolean timeoutNotExceeded;
    StringBuilder result = new StringBuilder();
    final long startTime = System.nanoTime();
    while ((timeoutNotExceeded = (TimeUnit.NANOSECONDS.toMillis(System.nanoTime() - startTime) < timeout))) {
        if (reader.ready()) {
            int charsRead = reader.read(buffer);
            if (charsRead == -1) {
                break;
            }
            result.append(buffer, 0, charsRead);
        } else {
            try {
                Thread.sleep(timeout / 200);
            } catch (InterruptedException ex) {
                LOG.error("InterruptedException ex=", ex);
            }
        }
    }
    if (!timeoutNotExceeded) throw new SocketTimeoutException("Command timeout limit was exceeded: " + timeout);

    return result.toString();
}

此解决方法不是灵丹妙药，但它具有一些重要功能：

  • 不使用 readline()。这种方法对网络通信很危险，因为有些服务器不返回LF/CR符号，你的代码会卡住。当您从文件中读取时，这并不重要，您无论如何都会到达文件的末尾。
  • 不使用char symbol = (char) fr.read();。这种方法比读取 char[] 慢
  • 它具有超时功能，您可能会在慢速连接时中断通信
于 2020-04-12T16:25:50.867 回答