如何解决使用 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
。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。