服务器从rest控制器发送了事件Spring Webflux返回事件名作为响应

Question

我使用带有reactor Flux的SSE来捕获linux系统指标并发布到浏览器(javascript eventsource)。

目前，问题是无法将特定数据发送到特定客户端。经过多个SO帖子后，它被告知在事件源中使用事件侦听器，来自服务器的响应应该在响应中使用事件作为键。

因为，我从服务器返回一个对象，所以将事件作为响应json中的键之一就足够了，它将由事件源标识。

在客户端设置一个唯一的数字，该数字将在json响应中的事件键中返回。

谢谢你的帮助！

Javascript：

jsonStreamObjectHeap.addEventListener("197e08e-f9a4-4e6e-9a04-220ade08a8f4",function(e){
        $.each(message, function(index, value) {
           /*some operation*/
        });
        }

来自Rest控制器的响应：

{
   "event":"197e08e-f9a4-4e6e-9a04-220ade08a8f4",
   "data":"2048"
}

Rest控制器代码:

 Flux<Long> interval = Flux.interval(Duration.ofSeconds(1));
        interval.subscribe((i) -> testStreamList.forEach(testStream -> {
            try {
                generateTestStream(testStream, UUID);
            } catch (JsonProcessingException e) {
                e.printStackTrace();
            }
        }));
 Flux<List<TestStream>> transactionFlux = Flux.fromStream(Stream.generate(() -> testStreamList));
 return Flux.zip(interval, transactionFlux).map(Tuple2::getT2);

Answer 1

我发现 org.springframework.http.codec.ServerSentEvent 可以从 rest 控制器插入到您的 Flux 响应中。

  Flux<Long> interval = Flux.interval(Duration.ofSeconds(1));    
  Flux<HeapStat> transactionFlux = Flux.fromStream(Stream.generate(() -> heapStat));

  /*Bulding ServerSentEvent to from the tuple*/

  return Flux.zip(interval, transactionFlux).map(tuple->
           ServerSentEvent.<HeapStat>builder().event(jsessionId).data(tuple.getT2()).build()
                );

您可以准备与SSEEmmiter完全相同的响应，具有自定义事件名称Last-Event-ID