Spring集成-imap邮件接收器

Question

我使用的是spring Boot2.2.4-Release和spring integration 5.2.3，我使用的是IntegrationFlow和DSL，因为我需要配置几个IMAP服务器。

所以我写了这段代码：

String flowId = MAIL_IN_FLOW_ID_PREFIX+cpd.getIndirizzoMail();
if( flowContext.getRegistrationById(flowId) != null ) {
    flowContext.remove(flowId);
}
ImapIdleChannelAdapterSpec imapIdleChannelAdapterSpec = Mail.imapIdleAdapter(connectionUrl.toString())
    .javaMailProperties(javaMailProperties)
    .shouldDeleteMessages(deleteMessages)
    .shouldMarkMessagesAsRead(markMessagesRead)
    .autoStartup(true)
    .autoCloseFolder(false)
    .id(confMailIn.getHost()+"_adapter")
    .selector(selectFunction);
IntegrationFlow flowIdle = IntegrationFlows.from(imapIdleChannelAdapterSpec)
    .handle(msgHandler)
    .get();
flowContext.registration(flowIdle).id(flowId).register();

其中msghandler是

@Component
public class MailMessageHandler implements MessageHandler {
    private static final Logger logger = LoggerFactory.getLogger(MailMessageHandler.class.getName());
    @Autowired
    private IConfigCasPostaleSvc ccps;
    @Autowired
    private IGestioneMailSvc gestioneMailSvc;
    @Override
    public void handleMessage(Message<?> message) throws MessagingException {
        MimeMessage mimeMessage = (MimeMessage) message.getPayload();
        if( logger.isDebugEnabled() ) {

            try {
                mimeMessage.getAllHeaders().asIterator().forEachRemaining(header->{
                    logger.debug("Header name {} header value {}", header.getName(), header.getValue());
                });
            } catch (javax.mail.MessagingException e) {
                logger.error("Errore nella lettura degli header", e);
            }
        }
        try {
            //Recupero i dati del messaggio
            MimeMessageParser parser = new MimeMessageParser(mimeMessage);
            parser = parser.parse();
            String mailId = mimeMessage.getMessageID();
            String oggettoMail = parser.getSubject();
            Date receivedDate = mimeMessage.getReceivedDate();
            List<DataSource> allegatiMail = parser.getAttachmentList();

            String corpoMail = parser.getHtmlContent();
            if( !StringUtils.hasText(corpoMail) ) {
                if( logger.isDebugEnabled() ) {
                    logger.debug("Nessun contenuto HTML nella mail; recupero il contenuto plain/text");
                }
                corpoMail = parser.getPlainContent();
            }
            MailInDto datiMail = new MailInDto();
            datiMail.setAllegatiMail(allegatiMail);
            datiMail.setIdMail(mailId);
            datiMail.setOggettoMail(oggettoMail);
            datiMail.setDataRicezioneMail(receivedDate);
            datiMail.setAllegatiMail(allegatiMail);
            datiMail.setCorpoMail(corpoMail);
            List<Address> destinatari = parser.getTo();
            for (Address to:destinatari) {

                String destinatario = to.toString();
                if( to instanceof InternetAddress ){
                    destinatario = ((InternetAddress)to).getAddress();
                }
                //Considero solo i destinatari che sono censiti nelle nostre tabelle
                Optional<ConfigurazioneCasellaPostaleDto> configurazioneCasellaPostale = ccps.getConfigurazioneCasellaPostale(destinatario);
                if( configurazioneCasellaPostale.isPresent() ) {
                    ConfigurazioneCasellaPostaleDto ccpd = configurazioneCasellaPostale.get();
                    //Indico l'UUID del documentale che contiene tutti i messaggi mail della casella postale
                    datiMail.setParentIdFolder(ccpd.getCasellaPostale().getIdFolderDocumentale());
                    //Posso salvare
                    datiMail.setIdCasellaPostale(ccpd.getCasellaPostale().getPk());
                    this.gestioneMailSvc.storeReceivedMail(datiMail, parser);
                }else {
                    if( logger.isDebugEnabled() ) {
                        logger.debug("Nessuna configurazione casella postale trovata per il destinatario {}", destinatario);
                    }
                }
            }
        }catch (Exception e) {

            throw new MessagingException("Errore nella gestione del messaggio "+message, e); 
        }
    }
}

通过设置.AutoCloseFolder(false)，我可以在处理程序组件中处理MimeMessage，但我有一些问题。

null

我不知道是否应该做什么来告诉框架关闭文件夹

谁能给我提点建议吗？

谢谢你

Answer 1

我认为调用FlowContext.Remove（flowId）；时会得到“文件夹关闭异常”，但MailMessageHandler中仍有一些进程试图读取MimeMessage。

若要手动关闭文件夹，您需要访问StaticMessageHeaderAccessor.GetCloseableResource(message)并调用其close()。