通过AWS API Gateway对接Slack slash-command时Java Lambda报错问题咨询

Python Lambda运行时为弱类型实现，会自动将API Gateway传入的完整事件JSON直接转换为字典结构，不需要提前声明入参类型，你只需要手动从字典的body字段取原始请求体自行处理即可，不存在运行时提前反序列化的逻辑。
Java Lambda运行时为强类型实现，会根据你handler方法定义的入参类型，尝试将入站的完整事件JSON反序列化为对应类型。如果你的handler入参声明为String类型，运行时会尝试把整个JSON对象（结构包含headers、body、requestContext等多个字段）反序列化为字符串，自然会触发JSON类型不匹配的报错。

方案1：使用官方预置的API Gateway事件类（推荐） #

这个方案适配性最高，不需要自己处理底层流解析：

1. 首先在项目的依赖管理中引入AWS Lambda Java Events库，以下为Maven示例：

<dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-lambda-java-events</artifactId>
    <version>3.11.1</version>
</dependency>
<dependency>
    <groupId>com.amazonaws</groupId>
    <artifactId>aws-lambda-java-core</artifactId>
    <version>1.2.21</version>
</dependency>

2. 修改handler方法的入参类型，如果你用的是HTTP API就用APIGatewayV2HTTPEvent，REST API就用APIGatewayProxyRequestEvent，示例代码：

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestHandler;
import com.amazonaws.services.lambda.runtime.events.APIGatewayV2HTTPEvent;
import com.amazonaws.services.lambda.runtime.events.APIGatewayV2HTTPResponse;
import java.net.URLDecoder;
import java.nio.charset.StandardCharsets;
import java.util.Base64;
import java.util.Map;
import java.util.HashMap;

public class SlackCommandHandler implements RequestHandler<APIGatewayV2HTTPEvent, APIGatewayV2HTTPResponse> {
    @Override
    public APIGatewayV2HTTPResponse handleRequest(APIGatewayV2HTTPEvent event, Context context) {
        String rawBody = event.getBody();
        // 如果API Gateway开启了base64编码，先解码
        if (Boolean.TRUE.equals(event.getIsBase64Encoded())) {
            rawBody = new String(Base64.getDecoder().decode(rawBody), StandardCharsets.UTF_8);
        }
        // 解析x-www-form-urlencoded格式的请求体
        Map<String, String> params = new HashMap<>();
        try {
            String[] pairs = rawBody.split("&");
            for (String pair : pairs) {
                int idx = pair.indexOf("=");
                String key = URLDecoder.decode(pair.substring(0, idx), StandardCharsets.UTF_8.name());
                String value = URLDecoder.decode(pair.substring(idx + 1), StandardCharsets.UTF_8.name());
                params.put(key, value);
            }
        } catch (Exception e) {
            context.getLogger().log("Failed to parse request body: " + e.getMessage());
            return APIGatewayV2HTTPResponse.builder()
                    .withStatusCode(400)
                    .withBody("参数解析失败")
                    .build();
        }
        
        // 你的业务逻辑，params里可直接获取Slack传的command、text、user_id等参数
        
        // 返回响应给Slack
        return APIGatewayV2HTTPResponse.builder()
                .withStatusCode(200)
                .withBody("请求处理成功")
                .build();
    }
}

3. 重新打包上传Lambda即可正常运行。

方案2：使用流类型入参手动解析 #

如果不想引入额外依赖，可以直接把handler的入参出参设为InputStream和OutputStream，自行解析所有内容：

import com.amazonaws.services.lambda.runtime.Context;
import com.amazonaws.services.lambda.runtime.RequestStreamHandler;
import java.io.InputStream;
import java.io.OutputStream;
import com.fasterxml.jackson.databind.ObjectMapper;
import java.util.Map;

public class SlackCommandHandler implements RequestStreamHandler {
    private static final ObjectMapper objectMapper = new ObjectMapper();
    @Override
    public void handleRequest(InputStream input, OutputStream output, Context context) {
        // 手动解析输入流为Map，拿到body字段后续处理
        Map<String, Object> event = objectMapper.readValue(input, Map.class);
        String body = (String) event.get("body");
        Boolean isBase64Encoded = (Boolean) event.get("isBase64Encoded");
        // 后续解码、解析查询字符串逻辑和方案1完全一致
    }
}

• 确认API Gateway的Lambda集成是代理集成模式，否则事件结构和上述示例不匹配
• 确认API Gateway的二进制媒体类型配置没有把application/x-www-form-urlencoded误配置为二进制类型，若配置了则按照逻辑正常解码即可

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