Spring Webflux-向endpoint发送数据流

Question

我有一个关于Spring WebFlux的问题。我想创建一个使用内容类型text/event-stream的反应endpoint。不是生产而是消费。我们的一个服务需要向另一个服务发送大量的小对象，我们认为这样流式传输可能是一个很好的解决方案。

@PostMapping(value = "/consumeStream", consumes = MediaType.TEXT_EVENT_STREAM_VALUE)
public Mono<Void> serve(@RequestBody Flux<String> data) {
    return data.doOnNext(s -> System.out.println("MessageReceived")).then();
}

WebClient.builder().baseUrl("http://localhost:8080")
            .clientConnector(new ReactorClientHttpConnector())
            .build()
            .post()
            .uri("/test/serve")
            .contentType(MediaType.TEXT_EVENT_STREAM)
            .body(BodyInserters.fromPublisher(flux, String.class))
            .exchange()
            .block();

流量是每1秒产生一个值的流。我遇到的问题是，WebClient完全读取发布服务器，然后将数据作为一个整体发送，而不是一个接一个地流式传输。我能用这个客户机或任何其他客户机做些什么吗？我不想走网络插座的方式。

Answer 1

SSE标准不允许POST。即使在浏览器API https://www.w3.org/tr/eventsource/中也无法指定方法

作为名称状态的服务器端事件是为将事件从服务器传递到客户端而设计的。