Java11无Spring环境下Serverless应用处理MultipartFile并上传S3咨询

针对你的需求（Java11、无Spring、Serverless架构，基于API Gateway+S3），可以按以下步骤实现：

一、配置API Gateway支持multipart请求 #

在API Gateway中需要做以下配置，确保能正确传递multipart请求到后端：

• 在API的二进制媒体类型中添加multipart/form-data。
• 在集成请求的Content Handling选项中选择Convert to binary，这样请求体将以Base64编码的形式传递给Lambda（假设后端用AWS Lambda）。

二、解析multipart/form-data请求（无Spring） #

由于没有Spring的MultipartFile，可以使用Apache Commons FileUpload库来解析请求体，这是Java生态中处理multipart请求的成熟方案。

1. 添加依赖（Maven） #

<dependency>
    <groupId>commons-fileupload</groupId>
    <artifactId>commons-fileupload</artifactId>
    <version>1.5</version>
</dependency>
<dependency>
    <groupId>commons-io</groupId>
    <artifactId>commons-io</artifactId>
    <version>2.11.0</version>
</dependency>

2. 解析请求体代码示例 #

如果后端是AWS Lambda，可基于APIGatewayProxyRequestEvent获取请求数据，解码后用FileUpload解析：

import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.RequestContext;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;
import java.util.Base64;
import java.util.List;

public class MultipartParser {

    public void parseRequest(String base64Body, String contentType) throws Exception {
        // 解码Base64格式的请求体
        byte[] decodedBytes = Base64.getDecoder().decode(base64Body);
        ByteArrayInputStream inputStream = new ByteArrayInputStream(decodedBytes);

        // 配置FileUpload工厂
        DiskFileItemFactory factory = new DiskFileItemFactory();
        ServletFileUpload upload = new ServletFileUpload(factory);

        // 实现RequestContext接口，提供请求元数据
        RequestContext requestContext = new RequestContext() {
            @Override
            public String getCharacterEncoding() {
                return StandardCharsets.UTF_8.name();
            }

            @Override
            public String getContentType() {
                return contentType;
            }

            @Override
            public int getContentLength() {
                return decodedBytes.length;
            }

            @Override
            public InputStream getInputStream() throws IOException {
                return inputStream;
            }
        };

        // 解析所有表单项
        List<FileItem> items = upload.parseRequest(requestContext);
        for (FileItem item : items) {
            if (!item.isFormField()) {
                // 处理文件类型字段
                String fileName = item.getName();
                InputStream fileStream = item.getInputStream();
                String fileContentType = item.getContentType();

                // 调用S3上传方法
                new S3Uploader().uploadToS3(fileName, fileStream, fileContentType);
            } else {
                // 处理普通文本字段（可选）
                String fieldName = item.getFieldName();
                String fieldValue = item.getString(StandardCharsets.UTF_8.name());
                // 按需处理文本字段逻辑
            }
        }
    }
}

三、上传文件到Amazon S3 #

使用AWS SDK for Java 2.x（推荐Java11使用）实现S3上传，无需手动处理签名，Lambda可通过IAM角色获取权限。

1. 添加SDK依赖（Maven） #

<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>s3</artifactId>
    <version>2.20.100</version>
</dependency>

2. S3上传代码示例 #

import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.s3.S3Client;
import software.amazon.awssdk.services.s3.model.PutObjectRequest;
import java.io.InputStream;

public class S3Uploader {
    private final S3Client s3Client;
    private final String targetBucket = "your-s3-bucket-name"; // 替换为你的S3桶名
    private final Region region = Region.US_EAST_1; // 替换为你的桶所在区域

    public S3Uploader() {
        // 初始化S3客户端，自动读取Lambda的IAM角色权限
        this.s3Client = S3Client.builder()
                .region(region)
                .credentialsProvider(DefaultCredentialsProvider.create())
                .build();
    }

    public void uploadToS3(String fileName, InputStream fileStream, String contentType) {
        // 构建上传请求
        PutObjectRequest uploadRequest = PutObjectRequest.builder()
                .bucket(targetBucket)
                .key(fileName) // 可自定义S3对象键，比如添加前缀："uploads/" + fileName
                .contentType(contentType)
                .build();

        // 执行上传
        s3Client.putObject(uploadRequest, software.amazon.awssdk.core.sync.RequestBody.fromInputStream(fileStream, fileStream.available()));
    }
}

四、权限配置 #

确保Lambda的IAM角色拥有以下权限：

• s3:PutObject：针对目标S3桶的写入权限
• 必要的日志权限（可选，用于排查问题）

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