使用 Spring App 中的期货处理并行异步操作

问题描述

我有一个包含 +1M 条目的数据库，我正在以块的形式查询数据库（假设 chunkSize = 1000）。

迭代这个 1000 块，我想为每个实体向rabbitMQ 发布一条消息，将这个块的所有期货收集到一个数组/列表中。

等待这个futures数组，直到所有futures都完成/失败，然后把这个1000的数组过滤成两个新的list（successList，failureList），然后为mongoDB准备两个bulkupdate操作，执行两个ops。

我必须逐块等待，否则，下一次迭代（用于获取数据库实体）将重新读取已经在进行中的实体。

PS：我最初的假设是在列表中使用 CompletableFutures（我会在 Javascript 中做同样的事情，不确定 java 是否有其他方法）

解决方法

如 this answer 中所述，Spring AMQP 允许您等待 Future 中的 CorrelationData 以获取发布消息的结果。您无需发明自己的机制。

如果您想存储有关发送的更多信息，您始终可以子类化 CorrelationData。