使用Spring WebClient时没有从endpoint接收数据，但我可以使用curl来获取数据

Question

$ curl "my/end/point"
data: {"message": "event1"}

data: {"message": "event2"}

data: {"message": "event3"}

data: {"message": "event4"}

...

final WebClient webClient = WebClient.create("my/end/point");
final String result = webClient.get()
                               .retrieve()
                               .bodyToFlux(String.class)
                               .blockFirst();
System.out.println(result);

null

final StringBuilder result = new StringBuilder();
final URL url = new URL("my/end/point");
final URLConnection conn = url.openConnection();
final BufferedReader rd = new BufferedReader(new InputStreamReader(conn.getInputStream()));
String line;
while ((line = rd.readLine()) != null) {
    result.append(line);
}
rd.close();
System.out.println(result.toString());

运行30秒后是否显示预期结果

data: {"message": "event1"}

data: {"message": "event2"}

...

有人知道为什么WebClient的结果是空的，而从endpoint获取数据的其他方法不是空的吗？我使用的是Java11和spring-webflux版本5.1.5。

Answer 1

我解决了问题，而不是做

final WebClient webClient = WebClient.create("my/end/point");

做

final WebClient webClient = WebClient.builder()
                                     .clientConnector(new ReactorClientHttpConnector(HttpClient.create()))
                                     .baseUrl(this.legalThingsSocketSettings.getUrl())
                                     .build();

工作，但我有点困惑，因为ReactorClientHTtpConnector应该是WebClient的默认客户端连接器。