异步处理电子邮件中的附件（Spring Mail Integration）

Question

如果我有一个带有邮件服务器入站通道的 Spring 应用程序，那么处理每封电子邮件中的每个文件的最佳方法是什么（我大约每 1 分钟轮询一次，并获取 1 封带有多个附件的电子邮件）。

虽然我可以在接收通道（SimpleAsyncTaskExecutor 或 ThreadPoolTask​​Executor）应用多线程，但这并没有多大帮助，因为如果我在一封电子邮件中附加了 10 个文件，它们的处理几乎绑定到一个线程。

到目前为止，我一直保持同步，因为我想为每封电子邮件聚合一些数据，并在处理所有文件后发送响应。我相信这也可以通过更好的方式来完成。

一般来说，如何异步处理每封电子邮件中的每个文件，然后再次异步构建电子邮件回复？

Answer 1

看起来您正在要求 java.lang. util.concurrent.Future。这是一个java核心概念，阻塞直到计算出（方法）结果。 （有关示例，请参阅 JavaDoc）

Spring @Async 也支持 Future 概念。

因此，您唯一需要做的就是拥有一种使用 @Async 的方法，将邮件的一个附件作为参数，并返回将来计算的结果。
您需要为所有附件调用所有这些方法（异步）并将立即返回的 future 存储在列表中。调用完所有方法后。您尝试在新循环中获取功能结果。此循环完成后，所有附件都将异步进行。

 processOneMail(List<Attachement> attachments) {
      List<Future<AttachmentResult>> futures = new ArrayList...

      for(Attachment attachment : attachments) {
        futures.add(processOneAttachment(attachment)); //async
      }

      List<AttachmentResult> attachmentResults = new ArrayList...
      for(Future<AttachmentResult>> future : futures) {
         attachmentResults.add(future.get()); //eventually blocks
      }
      //now all attachments are calculated and stored in the list.      
      ...
    }
@Async
Future<AttachmentResult> processOneAttachment(Attachment attachment) {
   ...
}

另请参阅：http://blog.espenberntsen.net/2010/03 /08/spring-asynchronous-support/