jakarta-ee - 如何将文本数据连续流式传输到 servlet？

Question

我有一个连接到服务器并连续发送一些信号数据的 Android 应用程序(使用 HttpURLConnection)。在服务器上，一个脚本(shell 或 python，不完全知道，这不是我的部分)当前正在处理这个流，并且为每个传入的数据包设置一个 curl 请求以将这个包发布到一个 servlet(在 Jetty 8 web 中运行)容器)。这只是一个临时解决方案，因为我不知道如何直接连接并将数据流式传输到 servlet。作为要求，数据传输应使用HTTP协议(protocol)，以免被任何防火墙阻止。

那么，是否有可能最初连接到一个 servlet，然后在很长一段时间内(比如几分钟或几小时)流式传输数据？我想知道我没有找到类似的问题/解决方案。我的意思是这不是特殊情况。这与将大文件上传到 servlet 的操作相同吗？

Servlet 实际上是这样的:

protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException
{
    System.out.println("StreamingServlet#doPost(): IN");
    BufferedReader reader = request.getReader();
    String data = "";

    while ((data = reader.readLine()) != null)
    {
        System.out.println("Data: " + data);
    }
    reader.close();

    System.out.println("StreamingServlet#doPost(): OUT");
}

Android 应用程序有 3 个使用 HttpURLConnection 的方法:

private Boolean connect(URL URLdest)
{
    try
    {
        connection = (HttpURLConnection) URLdest.openConnection();
        connection.setDoOutput(true);
        connection.setChunkedStreamingMode(0);
        oSWout = new OutputStreamWriter(connection.getOutputStream());
    }
    catch (IOException e)
    {
        return false;
    }
    return true;
}   

public void send(String packet)
{
    try
    {
        // TODO clOSWout.write and clOSWout.flush block may freeze if connection is lost. Somehow no exception is thrown and thread hangs instead.
        // It only occurs if the Server breaks the connection

        oSWout.write(packet);
        oSWout.flush();
    }
    catch (IOException e)
    {
        ...
    }
}

public void stopConnection()
{
    try
    {
        oSWout.close();
        connection.disconnect();
    }
    catch (IOException e)
    {
        ...
    }
}

我最终期望的是，当连接到 servlet 时，它打印“StreamingServlet#doPost(): IN”，然后，对于每个传入的数据包，它应该打印数据字符串，当关闭连接时它应该打印"StreamingServlet#doPost(): OUT"最后从方法返回。

但我想我错过了一些东西，这是在 Java EE 中以另一种方式完成的。我不知道。

Answer 1

最后我自己解决了这个问题:

使用 BufferedReader，收集(缓冲)所有数据包，并在连接关闭时将其作为一个包读取和打印。所以我不得不使用 ServletInputStream [通过 HttpServletRequest#getInputStream() 获得] 并使用 read() 方法将数据包读入字节数组。现在一切如我所料。

但我仍然想知道，使用阻塞操作是否是或多或少的典型场景，因此在 doPost() 方法中保持很长时间(比如几分钟或几小时)，或者是否期望服务器以某种方式响应时间短得多。