在Spring Integration中获取包含原始标题和附件的电子邮件

<dependency>
    <groupId>org.springframework.integration</groupId>
    <artifactId>spring-integration-mail</artifactId>
    <version>5.5.0</version>
</dependency>

<int-mail:inbound-channel-adapter id="emailAdapter"
    store-uri="imap://username:password@imap.example.com/inbox"
    channel="emailChannel"
    should-delete-messages="false"
    should-mark-messages-as-read="true"
    auto-startup="true">
    <int:poller fixed-rate="5000"/>
</int-mail:inbound-channel-adapter>

<int:channel id="emailChannel"/>

<int-mail:header-enricher input-channel="emailChannel" output-channel="processedEmailChannel">
    <int-mail:header-mapper>
        <int-mail:header-mapper>
            <int-mail:header-name-mapper>
                <bean class="org.springframework.integration.mail.SimpleMailHeaderMapper">
                    <property name="includeAllHeaders" value="true"/>
                </bean>
            </int-mail:header-name-mapper>
        </int-mail:header-mapper>
    </int-mail:header-mapper>
</int-mail:header-enricher>

<int:channel id="processedEmailChannel"/>

<int:service-activator input-channel="processedEmailChannel" ref="emailProcessor" method="processEmail"/>

<bean id="emailProcessor" class="com.example.EmailProcessor"/>

package com.example;

import org.springframework.integration.annotation.ServiceActivator;
import org.springframework.messaging.Message;
import org.springframework.stereotype.Component;

@Component
public class EmailProcessor {
    
    @ServiceActivator
    public void processEmail(Message<?> message) {
        // 处理获取到的邮件
        String subject = (String) message.getHeaders().get("subject");
        Object content = message.getPayload();
        // 处理邮件的标题和内容
        
        // 处理附件
        if (message.getPayload() instanceof Multipart) {
            Multipart multipart = (Multipart) message.getPayload();
            for (int i = 0; i < multipart.getCount(); i++) {
                BodyPart bodyPart = multipart.getBodyPart(i);
                if (Part.ATTACHMENT.equalsIgnoreCase(bodyPart.getDisposition())) {
                    // 处理附件
                }
            }
        }
    }
}