Flux.create（）不生成事件

Question

我试图使用Flux.create生成异步服务器发送事件。当我的客户端连接时，请求最终超时，并且没有收到任何事件。我硬编码了一个由Flux发送的事件。创建只是为了查看数据流，但客户端仍然没有收到任何数据。

@GetMapping(path = "/stream", headers = "Accept=*/*", consumes = MediaType.ALL_VALUE, produces = MediaType.TEXT_EVENT_STREAM_VALUE)
public Flux<ServerSentEvent<PricingDTO>> getEventStream() {

  final Flux<ServerSentEvent<PricingDTO>> flux = Flux.<ServerSentEvent<PricingDTO>>create(emitter -> {
    final PricingDTO pricing = new PricingDTO();
    pricing.setId(99L);
    emitter.next(ServerSentEvent.builder(pricing).build());
  });

  return flux;
}

客户端（Angular）代码：

const eventSource = new EventSource(url);
eventSource.onmessage = (event) => {
  console.debug('Received event: ' + event);
  const json = JSON.parse(event.data);
  // Should be PricingDTO record here
};

eventSource.onerror = (error) => {
  if (eventSource.readyState === EventSource.CLOSED) {
    console.log('The stream has been closed by the server.');
    eventSource.close();
  } else {
    console.log('Error here: ' + error);
  }
};

我从来没有看到一个事件来自事件源。最终请求超时，我看到错误:< code > net::ERR _ EMPTY _ RESPONSE

我是使用WebFlux的新手，我怀疑在返回Flux结果之前，我在FluxStream上缺少一些初始化。我已经调试并确实看到我的Web服务正在接收请求并返回Flux对象。任何想法为什么我没有收到我的活动？

Answer 1

您的webflux代码似乎很好。我用下面的简化示例测试了这一点（没有自定义类）。

@SpringBootApplication
@RestController
public class App {

    public static void main(String[] args) {
        SpringApplication.run(App.class, args);
    }

    @GetMapping(path = "/stream", produces = MediaType.TEXT_EVENT_STREAM_VALUE)
    public Flux<String> getEventStream() {
        return Flux.create(emitter -> emitter.next("hi").next("hi2"));
    }
}

当连接到chrome中的蒸汽时，您可以看到事件来得正好：

data:hi

data:hi2

问题要么在于接受头过滤器，要么在于客户端。当然，您可以通过在浏览器中连接到流（或者更好的是，通过测试）来验证这一点