使用 Spring WebFlux 和 EventSource 的 Server Sent Events

Question

我正在处理服务器发送的事件。

参考链接:http://sinhamohit.com/writing/spring-boot-reactive-sse

上面的例子包括Spring Boot和WebFlux的SSE。

Spring WebFlux和HTML5 EventSource有任何可用的示例吗？

Answer 1

用WebFlux创建简单的项目。下面是服务器发送事件的控制器方法:

@GetMapping(value = "/notifyonEvent", produces = 
MediaType.TEXT_EVENT_STREAM_VALUE)  
public Flux<String> getData() {
Random r = new Random();
int low = 0;
int high = 50;
return Flux.fromStream(Stream.generate(() -> r.nextInt(high - low) + low)
    .map(s -> String.valueOf(s))
    .peek((msg) -> {
        LOGGER.info(msg);
    }))
    .map(s -> s)
    .delayElements(Duration.ofSeconds(1));
}

客户端

var source = new EventSource("YOURAPP_URL/notifyonEvent");
source.onmessage = function(event) {
  console.log(event.data);
};