Spring集成邮件轮询器

Question

我想为我的邮件适配器配置一个轮询器，只运行一次或以编程方式运行。

这是一个独立的应用程序(java -jar xxxx.jar)，所以我想也许一种选择是将fixed-rate 属性配置为任意最大值然后退出应用程序，即：System.exit(0)。

对于这种情况，是否有更多替代方案或某种“正确方法”？

这是我的integration-context.xml：

<int-mail:inbound-channel-adapter id="imapAdapter"
                                  store-uri="imaps://${imap.user}:${imap.password}@${imap.server.ip}:${imap.server.port}/inbox"
                                  channel="receiveChannel"
                                  auto-startup="true"
                                  should-delete-messages="false"
                                  should-mark-messages-as-read="false"                                      
                                  java-mail-properties="javaMailProperties" 
                                  mail-filter-expression="subject matches '(?i)*UNSUSCRIBE*'">
    <int:poller max-messages-per-poll="1" fixed-rate="5000"/>
</int-mail:inbound-channel-adapter>

PS：不幸的是，imap-idle-channel-adapter 不是一个选项。

Answer 1

我可以建议你OnlyOnceTrigger:

@Bean
public Trigger onlyOnceTrigger() {
       return new Trigger() {
              private final AtomicBoolean invoked = new AtomicBoolean();
              @Override
              public Date nextExecutionTime(TriggerContext triggerContext) {
                    return this.invoked.getAndSet(true) ? null : new Date();
              }
       };
}

应该将其注入该适配器的<int:poller>。

但是，如果您说它是独立的应用程序，您应该注意整个应用程序的一些barrier，并且在您决定关闭应用程序之前您真的不应该丢失进程。

其中一个不错的选择是 CountDownLatch 和 1 算作一个 bean。您应该在System.exit(0) 之前从您的main 等待它，或者在进程结束时使用最后一个：

<outbound-channel-adapter expression="T(System).exit(0)"/>

但是，如果它真的适合您只运行一次适配器并且max-messages-per-poll="1" 确实是一个不错的选择，那么您应该考虑更多。

邮箱中可能没有消息，因此onlyOnceTrigger 可能会在没有为您带来良好结果的情况下完成，并且您的应用已陷入空白......