基于Spring Boot 3与aws-serverless-java-container-springboot3的SQS触发Lambda问题

你完全不需要创建API Gateway风格的控制器，就能在SQS触发的Lambda处理器中获取Spring Bean。核心是利用SpringBootLambdaContainerHandler初始化Spring上下文，然后直接从上下文中提取Bean。

修改代码的关键步骤： #

1. 调整SpringBootLambdaContainerHandler的初始化方式：
   原来的getAwsProxyHandler是为API Gateway场景设计的，我们可以改用通用的初始化方法，直接关联你的Spring Boot主类，让容器正确初始化完整的Spring上下文。

2. 从上下文获取Bean：
   通过lambdaContainerHandler.getApplicationContext()方法拿到Spring的ApplicationContext，再调用getBean()就能获取你需要的自定义业务Bean。

修改后的完整代码示例： #

package aus.gov.mkt.function.handler;

import com.amazonaws.serverless.exceptions.ContainerInitializationException;
import com.amazonaws.serverless.proxy.spring.SpringBootLambdaContainerHandler;
import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import com.amazonaws.services.lambda.runtime.events.SQSEvent;
import org.springframework.context.ApplicationContext;

// 替换为你实际的业务Bean类
import aus.gov.mkt.service.SqsMessageProcessor;

public class Handler implements RequestHandler<SQSEvent, Void> {

    private static final SpringBootLambdaContainerHandler lambdaContainerHandler;
    private static final SqsMessageProcessor messageProcessor;

    static {
        try {
            // 传入你的Spring Boot主类（带@SpringBootApplication注解的类）
            lambdaContainerHandler = SpringBootLambdaContainerHandler.getHandler(YourSpringBootApp.class);
            // 获取Spring应用上下文
            ApplicationContext context = lambdaContainerHandler.getApplicationContext();
            // 从上下文中提取自定义Bean
            messageProcessor = context.getBean(SqsMessageProcessor.class);
        } catch (ContainerInitializationException e) {
            e.printStackTrace();
            throw new RuntimeException("Spring上下文初始化失败", e);
        }
    }

    @Override
    public Void handleRequest(SQSEvent sqsEvent, Context context) {
        // 使用Bean处理SQS消息
        messageProcessor.process(sqsEvent.getRecords());
        return null;
    }
}

关键说明： #

• 把YourSpringBootApp.class替换成你项目中实际的Spring Boot主类。
• 你的业务Bean（比如示例中的SqsMessageProcessor）需要被Spring管理，记得给它添加@Service、@Component之类的注解。
• 不要使用AwsProxyRequest/AwsProxyResponse相关的处理器，这类模型是API Gateway场景专属的，SQS触发完全不需要。

替代方案：直接初始化Spring上下文 #

如果不想依赖SpringBootLambdaContainerHandler的封装，也可以用Spring Boot原生方式初始化上下文：

static {
    ApplicationContext context = new SpringApplication(YourSpringBootApp.class).run();
    messageProcessor = context.getBean(SqsMessageProcessor.class);
}

不过更推荐用SpringBootLambdaContainerHandler，它会适配Lambda环境的Spring生命周期，避免潜在的资源泄漏问题。

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