基于Spring Boot与AWS的邮件微服务：SQS收发附件及S3使用疑问

一、SQS消息收发实现步骤 #

1. 消息封装与发送 #

首先需要把接口接收的邮件信息（收件人、主题、正文、附件信息）封装成可序列化的消息对象，注意直接把MultipartFile的二进制内容放进SQS消息会有问题——SQS单条消息最大仅支持256KB，大附件会直接触发容量限制。

示例消息DTO代码：

public class EmailMessageDto implements Serializable {
    private String recipient;
    private String subject;
    private String body;
    // 存储附件元数据，而非二进制内容
    private List<AttachmentMeta> attachments;

    public static class AttachmentMeta implements Serializable {
        private String fileName;
        private String contentType;
        // 用S3时存储对象键
        private String s3ObjectKey;
        // 仅小文件可临时存base64，不推荐大文件使用
        private String base64Content;
    }
    // getter、setter 省略
}

用AWS SDK发送消息到SQS的示例代码：

@Service
public class SqsEmailProducer {
    private final SqsClient sqsClient;
    private final String queueUrl;

    public SqsEmailProducer(SqsClient sqsClient, @Value("${aws.sqs.email-queue-url}") String queueUrl) {
        this.sqsClient = sqsClient;
        this.queueUrl = queueUrl;
    }

    public void sendEmailMessage(EmailMessageDto message) {
        try {
            String messageBody = new ObjectMapper().writeValueAsString(message);
            SendMessageRequest request = SendMessageRequest.builder()
                    .queueUrl(queueUrl)
                    .messageBody(messageBody)
                    .build();
            sqsClient.sendMessage(request);
        } catch (JsonProcessingException e) {
            throw new RuntimeException("序列化邮件消息失败", e);
        }
    }
}

2. 消息消费处理 #

可以用Spring Cloud AWS的@SqsListener注解简化消费逻辑，消费时根据附件的存储方式获取内容：

@Service
public class SqsEmailConsumer {
    private final AmazonS3 s3Client;
    private final JavaMailSender mailSender;

    public SqsEmailConsumer(AmazonS3 s3Client, JavaMailSender mailSender) {
        this.s3Client = s3Client;
        this.mailSender = mailSender;
    }

    @SqsListener("${aws.sqs.email-queue-name}")
    public void handleEmailMessage(String messageBody) {
        try {
            EmailMessageDto message = new ObjectMapper().readValue(messageBody, EmailMessageDto.class);
            MimeMessage mimeMessage = mailSender.createMimeMessage();
            MimeMessageHelper helper = new MimeMessageHelper(mimeMessage, true);
            helper.setTo(message.getRecipient());
            helper.setSubject(message.getSubject());
            helper.setText(message.getBody());

            // 处理附件
            for (EmailMessageDto.AttachmentMeta meta : message.getAttachments()) {
                InputStream attachmentStream;
                if (meta.getS3ObjectKey() != null) {
                    // 从S3读取附件
                    S3Object s3Object = s3Client.getObject("你的存储桶名称", meta.getS3ObjectKey());
                    attachmentStream = s3Object.getObjectContent();
                } else {
                    // 从base64解码小文件
                    byte[] content = Base64.getDecoder().decode(meta.getBase64Content());
                    attachmentStream = new ByteArrayInputStream(content);
                }
                helper.addAttachment(meta.getFileName(), attachmentStream, meta.getContentType());
            }

            mailSender.send(mimeMessage);
        } catch (Exception e) {
            // 异常处理：重试、转入死信队列等
            throw new RuntimeException("处理邮件消息失败", e);
        }
    }
}

二、是否必须使用S3存储附件？ #

不是必须，但强烈推荐使用S3存储附件，核心原因：

• SQS单条消息最大256KB的限制，超过该大小的附件无法直接嵌入消息；
• 用base64编码存储二进制内容会额外增加30%左右的体积，进一步压缩可用空间；
• S3支持几乎无限的存储容量，与AWS生态集成流畅，存取效率稳定；
• 避免消息体过大导致的SQS性能下降、传输延迟问题。

如果你的业务场景中所有附件都远小于256KB（如几KB的配置文件），可以临时用base64编码嵌入消息，但从可扩展性和可靠性角度，S3是更优选择。

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