java - 是否可以流式传输嵌套的 Json 列表？

Question

API 响应以下 "application/json"体型构造:

{
  "transactions": [
    {
      "transaction": "1",
    },
    {
      "transaction": "2",
    },
        {
      "transaction": "3",
    }
  ]

}

基本上我将它映射到..

    public class Transactions {
     private List<Transaction> transactions;
       ...
    }

目前我将其检索为 Mono<Transactions> ，但它有缺点 - 它在内存中缓冲整个列表。

与 Spring Reactive API , 是否可以将事务列表作为 Flux 处理，而不会作为一个整体缓冲在内存中？

非常感谢!

Answer 1

在评论中收到更多信息后，这就是问题的答案。

如果 webflux 应用程序正在对非 webflux api 进行阻塞调用，则应采取措施将调用包装在 Mono#fromCallable 中。并放置在它自己的线程上，这样它就不会干扰其余的非阻塞线程。所有这些都记录在 react 堆文档中的 faq 下。

阻塞调用将始终返回单个响应，即 Mono所以在上面的情况下它会返回一个 List<Transaction> .

因为在阻塞调用之后我们已经有了完整的列表，所以大多数时候没有实际目的将它放在一个flux中，然后将它们一个一个地推送给客户端。

所以返回一个 Mono<List<Transaction>>调用客户端可能是要走的路。