Vaadin 和异步接收电子邮件

问题描述

我的 Vaadin 14 应用程序应该会在后台接收电子邮件。如果已收到具有特定主题的电子邮件，则应通过 UI 上的 PUSH 消息通知用户。 对于整个电子邮件处理，我从 Spring 集成中实现了电子邮件/消息处理，这也有效。两个 bean（IntegrationFlow 和一个 ServiceActivator）是通过 Spring 应用程序上下文中的 @Configuration 和 @Bean 注释生成的，如下所示：

@Configuration
public class EmailReceiver {

    @Bean
    public HeaderMapper<MimeMessage> mailHeaderMapper() {
        return new DefaultMailHeaderMapper();
    }

    @Bean
    public IntegrationFlow imapMailFlow() {    
        IntegrationFlow flow =  IntegrationFlows
                .from(Mail.imapInboundAdapter("imaps://user:[e-mail]/INBox")
                                .userFlag("testSIUserFlag")
                                .javaMailProperties(new Properties()),e -> e.autoStartup(true)
                                .poller(p -> p.fixedDelay(5000)))
                .transform(Mail.toStringTransformer())
                .channel(MessageChannels.queue("imapChannel"))
                .get();
        return flow;
     }

    @Bean(name = PollerMetadata.DEFAULT_POLLER)
    public PollerMetadata defaultPoller() {
        PollerMetadata pollerMetadata = new PollerMetadata();
        pollerMetadata.setTrigger(new PeriodicTrigger(1000));
        return pollerMetadata;
    }
    
    @Bean
    @ServiceActivator(inputChannel = "imapChannel")
    public MessageHandler processNewEmail() {
        MessageHandler messageHandler = new MessageHandler() {

            @Override
            public void handleMessage(org.springframework.messaging.Message<?> message) throws MessagingException {
                System.out.println("new email received");
            }
        };
        return messageHandler;
    }
}

另见此处：https://docs.spring.io/spring-integration/docs/current/reference/html/mail.html#mail-java-dsl-configuration

使用这样一个@Configuration 注释类，电子邮件是在 Vaadin 应用程序的后台接收的。检查。

但是如何在方法 EmailReceiver.processNewEmail 中将回调集成到 Vaadin 视图中？

    @Bean
    @ServiceActivator(inputChannel = "imapChannel")
    public MessageHandler processNewEmail(UI ui) {

这总是在应用程序启动时抛出错误：Scope vaadin-ui is not active for the current thread; consider defining a scoped proxy for this bean。

有一个使用 Vaadin https://vaadin.com/docs/v14/flow/advanced/tutorial-push-access 进行异步更新的示例。 与此相反，我必须为@ServiceActivator 处理创建一个@Bean。一旦出现这种情况，总是会出现错误 There is no UI available. The UI scope is not active。

如果我将方法 processNewEmail() 移到一个单独的类中，我仍然无法引用 Vaadin UI：

    @MessageEndpoint
    class EmailMessageHandler  {

        private UI ui;
        
        public EmailMessageHandler(UI ui) {
            this.ui = ui;
        }
        
        @Bean
        @ServiceActivator(inputChannel = "imapChannel")
        public MessageHandler processNewEmail() {
            MessageHandler messageHandler = new MessageHandler() {

            @Override
            public void handleMessage(org.springframework.messaging.Message<?> message) throws MessagingException {
                System.out.println("new email received" + message);
            }
        };
        return messageHandler;
        }
    }

如何将 Vaadin 异步处理和 Spring-Integration Email/ServiceActivator 处理结合起来？

解决方法

关键是您的邮件接收功能是每个应用程序的单例。另一方面，您将拥有与向您的应用程序发出 HTTP 请求的用户数量一样多的 UI。因此，您需要考虑一些中介来转储电子邮件并在 UI 请求发生时从那里获取它们。

您已经将那个 imapChannel 作为 QueueChannel。因此，您可以从 UI 范围的代码中获取它并调用其 receive() API 以提取下一条消息。唯一的问题是它是一个队列：只要一个调用 receive()，另一个就不会看到相同的消息。到目前为止，这对您来说可能没问题，但最好考虑一下可以在消息传递方面被视为主题的内容。 Reactor 的Sinks.Many：https://projectreactor.io/docs/core/release/reference/#sinks

是一个易于使用的好候选者