AWS SDK或Spring Cloud AWS是否有S3转SQS事件的现成Java类？

开发者阿泽

2026-6-25

处理S3 SQS事件的Java类说明

AWS SDK中的现成类

AWS SDK for Java（v2）提供了直接映射S3事件的官方类，无需自行创建。核心类是software.amazon.awssdk.services.s3.model.S3EventNotification，它完全匹配你提供的JSON事件结构：

根对象S3EventNotification包含Records列表
每条记录对应S3EventNotification.S3EventNotificationRecord类，封装了eventVersion、eventSource、eventName等所有顶层字段
嵌套的s3字段对应S3EventNotification.S3Entity，进一步包含bucket（S3BucketEntity）和object（S3ObjectEntity）等子对象

直接用SDK的JSON工具即可完成反序列化，示例代码：

import software.amazon.awssdk.services.s3.model.S3EventNotification;

// sqsMessageBody为从SQS获取的事件JSON字符串
String sqsMessageBody = "你的事件JSON内容";
S3EventNotification event = S3EventNotification.parseJson(sqsMessageBody);

// 遍历并访问事件详情
for (S3EventNotification.S3EventNotificationRecord record : event.records()) {
    System.out.println("事件类型: " + record.eventName());
    System.out.println("Bucket名称: " + record.s3().bucket().name());
    System.out.println("对象Key: " + record.s3().object().key());
}

Spring Cloud AWS中的支持

Spring Cloud AWS 3.x及以上版本直接集成了上述SDK类，在Spring应用中处理SQS消息时更便捷：

监听方法可直接将参数声明为S3EventNotification，Spring会自动完成反序列化
示例代码：

import org.springframework.cloud.aws.messaging.listener.annotation.SqsListener;
import software.amazon.awssdk.services.s3.model.S3EventNotification;

@SqsListener("你的SQS队列名称")
public void handleS3UploadEvent(S3EventNotification event) {
    event.records().forEach(record -> {
        String bucket = record.s3().bucket().name();
        String objectKey = record.s3().object().key();
        // 执行业务处理逻辑
    });
}