如何从Microsoft Graph API返回的MIME邮件内容构建spring.messaging.Message对象？

1. 辅助工具类实现 #

创建工具类负责解析Graph API返回的MIME内容，转换为Spring Messaging的Message对象，同时提取邮件头信息到Message Headers中：

import org.springframework.messaging.Message;
import org.springframework.messaging.support.MessageBuilder;
import jakarta.mail.internet.MimeMessage;
import jakarta.mail.internet.MimeMultipart;
import jakarta.mail.Session;
import java.io.ByteArrayInputStream;
import java.util.Properties;

public class EmailMessageBuilder {

    // 从MIME字节数组构建Spring Message
    public static Message<?> buildFromMimeBytes(byte[] mimeContent) throws Exception {
        Properties props = new Properties();
        Session session = Session.getInstance(props);
        
        // 解析MIME内容为MimeMessage
        MimeMessage mimeMessage = new MimeMessage(session, new ByteArrayInputStream(mimeContent));
        
        // 初始化MessageBuilder并设置Payload
        MessageBuilder<?> messageBuilder = MessageBuilder.withPayload(extractPayload(mimeMessage));
        
        // 复制关键邮件头到Spring Message Headers
        mimeMessage.getAllHeaderLines().forEach(headerLine -> {
            String[] parts = headerLine.split(":", 2);
            if (parts.length == 2) {
                messageBuilder.setHeader(parts[0].trim(), parts[1].trim());
            }
        });
        
        return messageBuilder.build();
    }

    // 根据MIME类型提取对应Payload
    private static Object extractPayload(MimeMessage mimeMessage) throws Exception {
        Object content = mimeMessage.getContent();
        if (content instanceof MimeMultipart) {
            return content;
        } else if (mimeMessage.isMimeType("text/plain")) {
            return content.toString();
        } else {
            throw new IllegalArgumentException("不支持的MIME内容类型: " + mimeMessage.getContentType());
        }
    }
}

2. 调用Graph API并构建Message示例 #

通过RestTemplate调用Graph API获取MIME内容后，直接使用工具类构建Message：

import org.springframework.web.client.RestTemplate;
import org.springframework.messaging.Message;

public class GraphEmailFetcher {
    private final RestTemplate restTemplate;
    private static final String GRAPH_MIME_URL = "https://graph.microsoft.com/v1.0/users/{username}/messages/{messageId}/$value";

    public GraphEmailFetcher(RestTemplate restTemplate) {
        this.restTemplate = restTemplate;
    }

    public Message<?> fetchAndBuildMessage(String username, String messageId) throws Exception {
        // 调用Graph API获取MIME字节数组
        byte[] mimeContent = restTemplate.getForObject(GRAPH_MIME_URL, byte[].class, username, messageId);
        
        // 构建Spring Message并返回
        return EmailMessageBuilder.buildFromMimeBytes(mimeContent);
    }
}

3. 适配现有处理逻辑 #

构建完成的Message可以直接发送到emailMessageChannel，你的现有processMessage和processEmailMessage方法无需修改即可处理：

• 若邮件为多部分格式，Payload会是MimeMultipart，自动进入processMimeMultipartEmail分支
• 若为纯文本邮件，Payload会是String，自动进入processStringEmail分支

关键注意点 #

• 项目需引入JavaMail依赖（如com.sun.mail:jakarta.mail）和Spring Messaging依赖
• 可根据业务需求筛选需要复制到Spring Headers的邮件头字段，无需全量复制
• 可扩展异常处理逻辑，覆盖MIME解析失败、API调用失败等场景

内容的提问来源于stack exchange，提问作者Shrey Soni