端到端响应式流RESTful服务

Question

问题很简单：假设我有一个完全可响应的后端，如何将其流式传输到浏览器（例如大文本），并在每个块来自服务器时立即将它们打印给用户？

可能我缺少一些重要的概念性要点，但是我所需要知道的是：是否可以通过一个HTTP
GET（或否）请求发送少量数据（从服务器到浏览器）？关键是：在发送全部数据之前，我可以写那些小的部分吗？

谢谢你的帮助。我以前确实尝试过google，但是我总是会得到其他概念（例如websockets，long-
polling，react.js）的信息，我认为并非如此。

编辑：我不要求特定的API ou库。我只是想了解这个概念，例如：“您不能使用HTTP协议来做到这一点！”
或“这与反应式编程无关，您对流的真正含义感到困惑。请参阅’something_else.js’”。

EDIT2：我通过以下方法使用spring-mvc（spring-boot）做了一个小的rest控制器：

@RequestMapping(value = "/flush", method = RequestMethod.GET)
public void flushTest(HttpServletResponse response) {

    response.setContentType("text/html");
    response.setStatus(SC_OK);

    try (ServletOutputStream outputStream = response.getOutputStream()) {
        for (int i = 0; i < 3; i++) {
            String chunk = "chunk_" + i;
            outputStream.print(chunk);
            outputStream.flush();
            response.flushBuffer();
        }
    } catch (IOException e) {
        e.printStackTrace();
    }

}

在浏览器中，即使使用flushBuffer，也只有整个响应到达。经过一些研究，这可能是TOMCAT问题，我更改了pom.xml并包括了underwow：

<dependency>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-undertow</artifactId>
</dependency>

使用默认配置：

server.undertow.accesslog.enabled=true
server.undertow.accesslog.dir=target/logs
server.undertow.accesslog.pattern=combined
server.compression.enabled=true
server.compression.min-response-size=1l

这时，在我的IDE中使用调试，每个块都在flushBuffer之后写入。

因此，我相信这可能是TOMCAT配置。长话短说，我知道“流式解决方案”上有很多东西可以帮助我，感谢所有评论，但是我的问题有点概念性。

Answer 1

HTTP之上有一个协议，该协议允许使用HTTP传输以较小的，易于使用的块形式将服务器响应传递给浏览器。它称为 SSE （服务器发送事件）或
EventSource ，这里是有关该主题的相当完整的文章。

还有其他使用HTTP协议流数据的方法。一种这样的替代方法是JSON流传输，其中您可以从服务器在线路上编写部分响应，并在到达JSON块时使用它们。在消费方面，一个流行的库称为Oboe.js，在服务器端，您基本上需要在要发送或可用时在响应线路上写入部分数据。

对于这两种html" target="_blank">方法，Rx对于处理服务器端的流逻辑都是有用的。您将片段建模为流（处理错误等），最终在订户中将单个发射写在导线上，在Observable完成时关闭响应。

在客户端，可以将EventSource事件包装在新的Observable中（通过Rx.Observable.create()），并作为流进行进一步处理。Oboe.js事件也可以转换为Observables（通过Rx.Observable.fromEvent()。