检测通量数据V.S的末端。错误

Question

目前正在使用Angular 5和Spring 5 WebFlux研究SSE。基本应用程序工作正常，但在研究错误处理时，我们注意到angular应用程序中的EventSource在由于到达数据流的末尾而关闭连接和发生错误（例如，在传输过程中终止应用程序）之间没有任何区别。

我们的调查所依据的例子如下。

https://thepracticaldeveloper.com/2017/11/04/Full-Reactive-Stack-II-The-AngularJS-Client/

http://javasampleade.com/reactive-programming/angular-4-spring-webflux-spring-data-reactive-mongodb-example-full-reactive-angular-4-http-client-spring-boot-restapi-server#25_service

当spring成功发送数据并到达流的末尾从而关闭连接时，或者当应用程序在流中间Ctrl+C时，或者当我们在发送数据中间随机抛出异常时，EventSource中的onerror和完成函数都会被调用。

EventSourcehtml" target="_blank">参数在所有三种情况下都只包含{type:'error'}。

Answer 1

据我理解，SSE流主要讲无限流；该规范似乎没有提供一种标准的方式向客户机发送流结束的信号（默认情况下，客户机将尝试重新连接）。

您可以通过返回通量 并使用自定义事件终止该通量，在控制器中实现该功能：

return Flux.concat(
    fetchUserEvents(),
    Flux.just(ServerSentEvent.builder().event("disconnect").build()
);

在客户端,完成后可以正确地关闭连接,将所有其他用例作为错误,并让浏览器自动重新连接：

evtSource.addEventListener("disconnect", function(e) {
    evtSource.close();
}, false);