java - 在 Java 中解析一个无限长的输入

Question

我写了一个“推送服务器”，当客户端打开连接时，它在服务器写入流时保持打开状态。我想知道如何用 Java 编写一个客户端，该客户端在通过这种无限长的响应接收命令时对命令使用react。

问题是我不知道从哪里开始。如果您能指出我可以阅读 Javadoc 的类(class)的方向，那就太好了。我希望它能够立即响应，因此线程可能是必须的。

非常感谢您的帮助!

编辑:无限长度是指未知长度。无限这个词被用来强调服务器通常永远不会关闭连接这一点。没有传输大量数据。

另一个编辑: 指出这是一个运行 PHP 脚本的 HTTP 服务器可能会有所帮助。

Answer 1

如果它们是由换行符分隔的简单命令，那么滚动您自己的客户端应该相当简单:

编辑:HTTP 不是保持长期连接打开的最佳协议(protocol)，您可能会遇到超时问题。下面的代码未经测试，但应该能为您提供一个良好的起点。

编辑 2: 正如评论中所指出的，线程池在这里可能是必要的或有用的，也可能不是。您应该注意，使用线程不会神奇地使事情变得更快或增加您可以处理的请求量。使用线程池的好处是允许客户端在先前的命令仍在执行时立即接收新命令。如果处理命令需要一些 I/O 任务，这可能很重要，例如调用另一台服务器，但在您的情况下，这可能有点矫枉过正。

ExecutorService svc = Executors.newCachedThreadPool();

URLConnection c = 
    new URL("http://192.168.1.122/push/out.php?nduid=1").openConnection();
c.setReadTimeout(30 * 60 * 1000); // Set the read timeout to 30 minutes
c.connect();
InputStream is = c.getInputStream();
BufferedReader r = new BufferedReader(new InputStreamReader(is, "UTF-8"));

String cmd = null;
while ((cmd = r.readLine()) != null) {
  svc.execute(new Runnable() {
    public void run() {
      processCmd(cmd); // work happens here in a different thread.
    }
  });
}

is.close();

这里的关键是只要底层 TCP 连接保持打开状态，从套接字返回的输入流就保持打开状态。客户端可以继续从流中读取，readLine 调用将根据需要简单地阻塞，直到新数据到达。当 readLine 返回 null 时，这意味着底层输入流遇到文件结尾，这反过来意味着服务器关闭了套接字。

一旦你有了整行数据，你就可以将它提交到线程池中，在不同的线程中解析和执行。以这种方式分解工作可以让您专注于从一行文本解析和执行命令，这比尝试处理任意大的数据流更易于管理。