http - 通过 HTTP 传输纯文本

Question

我希望通过 HTTP 传输一组日志消息。我想一次发送一行消息，可能在行与行之间有延迟，我希望每一行在服务器发送后尽快显示在浏览器中。

我目前的做法是将Content-Type设置为text/plain； charset=UTF-8 在响应中，并根据需要从服务器开始流式传输行，它们之间有延迟。我确保在每次写入后刷新所有相关的输出流。

我在 Chrome 中观察到的行为是它会等到响应完全完成后再显示任何内容。但我想要的行为是在发送时查看每一行。这可能吗？

我已经提出了很多关于这个主题的 stackoverflow 问题，但没有一个能完全回答我的问题。我认为 Transfer-Encoding 与我无关，因为那似乎是为了下载大文件(如果我错了请纠正我)。

这不是关于下载文件的问题，因为我希望这些行直接在浏览器中呈现。

Answer 1

由于 question and answer 中提到的问题，我认为您无法在这里完成“最正确”的解决方案由 Ivan 链接.至少我的 Chrome 和 Firefox 可以毫不费力地逐行呈现他们收到的最新内容，但是，正如上面所说，它需要 hack 或更改要求以使其更加透明。

这里要做的第一件事是获取但抑制第一个前导 n 字节以触发浏览器呈现。

如果你选择 text/plain ，您只能依赖特定浏览器如何呈现输出文本。要抑制第一个虚拟 block 输出，您可以只渲染空格，因为它们既不打算由人也不打算由浏览器解析(至少我是这么认为的，因为您想要浏览器内输出，因此可能不会使其成为机器-可解析)。这里的一个技巧是编写 Unicode \u200B ( zero width space ) 希望目标浏览器将使用它在输出窗口中呈现任何内容。不幸的是，我的 Firefox 实例无法识别该字符并呈现默认的未知字符占位符。然而，Chrome 完全忽略了这些字符，在视觉上它们看起来什么都不是!这似乎是你所需要的。所以，这里的通用算法是:

• 检测用户代理以确定 header block 长度(您需要知道这些预定义值)。
• 编写 UTF-8 BOM(0xEF、0xBB、0xBF)以确保 Chrome won't start the download the remote output to a file .
• 写\u200B字符 n 次，其中 n 在前一项中确定并刷新输出。
• 生成一些带有暂停的虚拟内容，以每 n 秒获取新的内容行，并在每行之后立即刷新。

但是，如果您希望 \u200B 没有像 Firefox 那样的输出渲染问题。性格，你可能想切换到text/html . HTML 支持标记注释，因此我们可以排除某些内容不被呈现。这允许完全依赖 HTML，而不是特定的浏览器细节。知道了这一点，算法就变得有些不同了:

• 检测用户代理以确定 header block 长度。
• 用<!--渲染 block 的开始，然后是一些 n 空格(但据我所知至少有一个；或任何 HTML 注释)，然后是 --> . n 应该是上面 block 的长度减去注释开始/结束标记的长度。
• 生成一些虚拟输出，其中每一行都是 HTML 转义的，以 <br/> 结尾或 <br> , 然后立即冲洗。

这种方法对我来说在 Chrome 和 Firefox 中都很好用。如果您对某些 Java 没问题，这里有一些实现上述内容的代码:

@RestController
@RequestMapping("/messages")
public final class MessagesController {

    private static final List<String> lines = asList(
            "Lorem ipsum dolor sit amet,",
            "consectetur adipiscing elit,",
            "sed do eiusmod tempor incididunt ut labore et dolore magna aliqua."
    );

    @RequestMapping(value = "html", method = GET, produces = "text/html")
    public void getHtml(final HttpServletRequest request, final ServletResponse response)
            throws IOException, InterruptedException {
        render(Renderers.HTML, request, response);
    }

    @RequestMapping(value = "text", method = GET, produces = "text/plain")
    public void getText(final HttpServletRequest request, final ServletResponse response)
            throws IOException, InterruptedException {
        render(Renderers.PLAIN, request, response);
    }

    private static void render(final IRenderer renderer, final HttpServletRequest request, final ServletResponse response)
            throws IOException, InterruptedException {
        final int stubLength = getStubLength(request);
        final ServletOutputStream outputStream = response.getOutputStream();
        renderer.renderStub(stubLength, outputStream);
        renderInfiniteContent(renderer, outputStream);
    }

    private static int getStubLength(final HttpServletRequest request) {
        final String userAgent = request.getHeader("User-Agent");
        if ( userAgent == null ) {
            return 0;
        }
        if ( userAgent.contains("Chrome") ) {
            return 1024;
        }
        if ( userAgent.contains("Firefox") ) {
            return 1024;
        }
        return 0;
    }

    private static void renderInfiniteContent(final IRenderer renderer, final ServletOutputStream outputStream)
            throws IOException, InterruptedException {
        for ( ; ; ) {
            for ( final String line : lines ) {
                renderer.renderLine(line, outputStream);
                sleep(5000);
            }
        }
    }

    private interface IRenderer {

        void renderStub(int length, ServletOutputStream outputStream)
                throws IOException;

        void renderLine(String line, ServletOutputStream outputStream)
                throws IOException;

    }

    private enum Renderers
            implements IRenderer {

        HTML {
            private static final String HTML_PREFIX = "<!-- ";
            private static final String HTML_SUFFIX = " -->";
            private final int HTML_PREFIX_SUFFIX_LENGTH = HTML_PREFIX.length() + HTML_SUFFIX.length();

            @Override
            public void renderStub(final int length, final ServletOutputStream outputStream)
                    throws IOException {
                outputStream.print(HTML_PREFIX);
                for ( int i = 0; i < length - HTML_PREFIX_SUFFIX_LENGTH; i++ ) {
                    outputStream.write('\u0020');
                }
                outputStream.print(HTML_SUFFIX);
                outputStream.flush();
            }

            @Override
            public void renderLine(final String line, final ServletOutputStream outputStream)
                    throws IOException {
                outputStream.print(htmlEscape(line, "UTF-8"));
                outputStream.print("<br/>");
            }
        },

        PLAIN {
            private static final char ZERO_WIDTH_CHAR = '\u200B';
            private final byte[] bom = { (byte) 0xEF, (byte) 0xBB, (byte) 0xBF };

            @Override
            public void renderStub(final int length, final ServletOutputStream outputStream)
                    throws IOException {
                outputStream.write(bom);
                for ( int i = 0; i < length; i++ ) {
                    outputStream.write(ZERO_WIDTH_CHAR);
                }
                outputStream.flush();
            }

            @Override
            public void renderLine(final String line, final ServletOutputStream outputStream)
                    throws IOException {
                outputStream.println(line);
                outputStream.flush();
            }
        }

    }

}

此外，您要实现的方法不会向下滚动浏览器窗口。您可能想在 Chrome 中使用用户脚本自动向下滚动特定的 URL 页面，但据我所知，它不适用于 text/plain。虽然输出。