Spring Web Flux Web客户端无法逐个接收值

Question

@GetMapping("/test")
fun fluxTest(): Flux<Int> {
        return Flux.create {em ->
            Thread{
                (0..10).forEach{
                    em.next(it)
                    Thread.sleep(1000)
                }
                em.complete()
            }.run()
        }
    }

因此，上面的代码是一个Spring MVC控制器方法，以1秒的间隔发出0~10个数字。

这是我的客户代码。

val client = WebClient.builder().baseUrl("http://localhost:8083/api/v1")
    .build()
val disposable = client.get()
    .uri("/test")
    .retrieve()
    .bodyToFlux(Int::class.java)
    .subscribe ({
        System.out.println("Value arrived : $it")
    }, {err ->
        err.printStackTrace()
    })

问题是，客户端程序一次打印出0~10个，而不是以1秒的间隔逐个打印。

所以，它不会逐个打印来自服务器的值，而是在流完成时打印所有接收到的值。

有人能帮我解决这个问题吗？

谢啦

Answer 1

看起来你应该启用服务器发送事件，简单的方法只需将生产者添加到enpoint如下：

@GetMapping(path = "/test", produces=MediaType.TEXT_EVENT_STREAM_VALUE)