能否从AWS发布订阅示例Java代码及自定义Java代码调用AWS Lambda？

当然没问题！这两个场景都完全可行，我来给你详细拆解下怎么实现：

1. 能不能从AWS发布订阅示例Java代码中调用Lambda？ #

完全可以！比如你用SNS（Simple Notification Service）做发布订阅的场景，不管是在发布消息的代码里，还是在订阅消息的处理逻辑（比如SNS订阅的Java应用）里，都能主动调用Lambda函数。甚至SNS本身支持直接触发Lambda作为订阅端点，但如果是需要在你的Java示例代码里主动发起调用，只要引入AWS Lambda SDK并配置好权限就行。

2. 能不能从自定义Java代码中调用Lambda？ #

必须可以！不管是你本地运行的Java程序、自建的Spring Boot服务，还是部署在AWS上的Java应用，只要能访问AWS服务（配置好凭证和网络），都能调用Lambda函数。

3. 基于AWS Java SDK调用Lambda的具体实现 #

现在AWS推荐使用AWS SDK for Java 2.x（比1.x更轻量、异步支持更好），下面是完整的实现步骤和代码示例：

步骤1：添加Maven依赖 #

在你的pom.xml中加入Lambda SDK的依赖：

<dependency>
    <groupId>software.amazon.awssdk</groupId>
    <artifactId>lambda</artifactId>
    <version>2.25.0</version> <!-- 可以替换为最新稳定版 -->
</dependency>
<!-- 如果需要处理JSON请求/响应，推荐加入Jackson依赖 -->
<dependency>
    <groupId>com.fasterxml.jackson.core</groupId>
    <artifactId>jackson-databind</artifactId>
    <version>2.15.2</version>
</dependency>

步骤2：配置AWS凭证 #

根据你的运行环境选择凭证配置方式：

• 本地开发/外部服务：可以通过~/.aws/credentials文件、环境变量（AWS_ACCESS_KEY_ID和AWS_SECRET_ACCESS_KEY）配置，代码中尽量避免硬编码凭证（不推荐生产环境使用）。
• AWS内部服务（如EC2、ECS、Lambda）：给服务关联IAM角色，角色需要包含lambda:InvokeFunction权限，SDK会自动从环境中获取凭证，无需手动配置。

步骤3：编写调用代码 #

下面是一个同步调用Lambda的示例：

import software.amazon.awssdk.auth.credentials.DefaultCredentialsProvider;
import software.amazon.awssdk.regions.Region;
import software.amazon.awssdk.services.lambda.LambdaClient;
import software.amazon.awssdk.services.lambda.model.InvokeRequest;
import software.amazon.awssdk.services.lambda.model.InvokeResponse;
import java.nio.charset.StandardCharsets;

public class LambdaInvoker {
    public static void main(String[] args) {
        // 1. 创建Lambda客户端，指定你的Lambda所在区域
        Region region = Region.US_EAST_1;
        LambdaClient lambdaClient = LambdaClient.builder()
                .region(region)
                .credentialsProvider(DefaultCredentialsProvider.create())
                .build();

        // 2. 准备请求参数：替换为你的Lambda函数名和请求数据
        String functionName = "YourLambdaFunctionName";
        String payload = "{\"key1\": \"value1\", \"key2\": \"value2\"}"; // 自定义请求体（JSON格式）

        InvokeRequest invokeRequest = InvokeRequest.builder()
                .functionName(functionName)
                .payload(payload.getBytes(StandardCharsets.UTF_8))
                .build();

        // 3. 调用Lambda并处理响应
        try {
            InvokeResponse response = lambdaClient.invoke(invokeRequest);
            String responsePayload = new String(response.payload().asByteArray(), StandardCharsets.UTF_8);
            System.out.println("Lambda响应内容: " + responsePayload);
            System.out.println("调用状态码: " + response.statusCode());
        } catch (Exception e) {
            System.err.println("调用Lambda失败: " + e.getMessage());
            e.printStackTrace();
        } finally {
            // 关闭客户端（也可以用try-with-resources语法自动关闭）
            lambdaClient.close();
        }
    }
}

异步调用（可选） #

如果不需要等待Lambda执行完成，可以用异步调用方式：

InvokeAsyncRequest asyncRequest = InvokeAsyncRequest.builder()
        .functionName(functionName)
        .payload(payload.getBytes(StandardCharsets.UTF_8))
        .build();
lambdaClient.invokeAsync(asyncRequest);

权限注意事项 #

确保执行Java代码的身份（IAM用户/角色）拥有lambda:InvokeFunction权限，示例IAM策略如下：

{
    "Version": "2012-10-17",
    "Statement": [
        {
            "Effect": "Allow",
            "Action": "lambda:InvokeFunction",
            "Resource": "arn:aws:lambda:us-east-1:123456789012:function:YourLambdaFunctionName"
        }
    ]
}

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