在 Java 中解析无限长的输入

Question

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

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

非常感谢您的帮助！

编辑：无限长度是指未知长度。无限这个词被用来强调连接通常永远不会被服务器关闭。传输的数据并不多。

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

Answer 1

如果你打开一个到服务器的连接，那检查服务器并使用while(server.isSending) { respond();}然后关闭连接？

例子：

//Connection to the server
openConnection();

while(server.isSending()) {

    //Here can you respond in any way
    respond();
}

您可能还必须使用InputStream。

我对 InternetConnections 的工作不太熟悉，但我希望你走在正确的轨道上

Answer 2

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

编辑： HTTP 不是保持长期连接打开的最佳协议，您可能会遇到超时问题。下面的代码未经测试，但应该给你一个很好的起点。

编辑 2： 正如 cmets 中所指出的，线程池在这里可能是必要的或有用的，也可能不是。您应该注意，使用线程不会神奇地使事情变得更快或增加您可以处理的请求数量。使用线程池的好处是允许客户端在前一个命令仍在执行时立即接收新命令。如果处理命令需要一些 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时，表示底层输入流遇到文件尾，进而表示服务器关闭了socket。

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