Jackson反序列化数组的Flux

Question

我正在尝试反序列化列表通量

我已经研究了这个问题，它涉及一系列对象。事实上，我已经能够使用他们的Mono解决方案方法来检索Mono

当我尝试使用Flux而不是Mono时会发生什么：我已经尝试过使用WebClient和Mign-两者的效果相同。单步执行Jackson代码，在处理Flux世界时它永远不会拉回TokenBuffers。这似乎与Codecs和Jackson JSON的Spring留档中的内容一致——“当解码到多值发布者（例如Flux）时，一旦接收到足够的字节用于完全形成的对象，每个TokenBuffer就会传递给ObjectMapper”

想法？更好的例子？

Answer 1

确实尝试了发布的x-ndjson解决方案，但最终出现了另一个问题：Flux Jackson将不会保留列表的边界。例如，我真的需要知道[e1， e2， e3]属于一起。相反，我进入了包含单个元素的Next列表。

我的最终解决方案很简单：我们创建了一个带有单个字段的对象类型，然后包含自定义对象列表。例如，{序列：[e1， e2， e3]}。然后让我通过Flux接收我的ListWrapperObject，同时保持每个序列的边界。由于我们不拥有API，我们需要与我们调用的团队协商，但谢天谢地他们能够调整。我将该解决方案提供给下一位寻求此类路径的读者。我还承认，如果您无法修改API，可能还没有一种方法可以通过Jackson解决它。

Answer 2

在流式传输mimetype（例如Application/x-ndjson）的情况下，WebFlux将序列化为JSON并在网络中刷新Flux的每个项目。

@GetMapping(path = "/customObjects", produces = MediaType.APPLICATION_NDJSON_VALUE)
public Flux<Response> streamCustomObjects() {
return Flux.interval(Duration.ofSeconds(1))
                .map(e -> new Response(List.of(new CustomObject("George", 20), new CustomObject("Lefteris", 28))));
}

下面的WebClient调用生成一个响应的流量：

Flux<Response> responses = webClient.get()
      .uri("/customObjects")
      .retrieve()
      .bodyToFlux(Response.class);

responses.subscribe(System.out::println);

示例输出：

(after 1 sec)
    Response(customObjects=[CustomObject(name=George, age=20), CustomObject(name=Lefteris, age=28)])
(after 2 sec)
    Response(customObjects=[CustomObject(name=George, age=20), CustomObject(name=Lefteris, age=28)])
(after 3 sec)
    Response(customObjects=[CustomObject(name=George, age=20), CustomObject(name=Lefteris, age=28)])