WSO2 APIM 2.1.0：HTTP POST参数获取及自定义认证用户识别问题

Hey，针对你在WSO2 API Manager透传场景下遇到的两个问题，我整理了实际项目里用过的解决方案，应该能帮到你：

看起来你的自定义认证逻辑已经在路由层面生效了，但WSO2的流量控制和分析模块没拿到用户信息对吧？这是因为自定义认证后，没有把用户标识注入到WSO2的上下文里，导致后续模块无法识别用户。

解决步骤很简单，在你的自定义认证处理器中，当通过X-Auth-Token验证用户身份后，添加以下代码把用户信息绑定到Message Context：

// 假设你已经从X-Auth-Token解析出了用户名和用户ID
String username = "解析后的用户名";
String userId = "解析后的用户ID";

MessageContext mc = getMessageContext();
// 设置用户名，这是WSO2流量控制/分析模块识别用户的核心属性
mc.setProperty("api.ut.userName", username);
// 可选：设置用户ID，如果你需要更精准的用户标识
mc.setProperty("api.ut.userId", userId);
// 确保处理器返回CONTINUE，让请求继续流转
return SynapseConstants.CONTINUE;

另外，记得在API的配置里做两件事：

• 把API的认证类型设置为Custom，避免WSO2强制校验OAuth令牌
• 如果不需要默认的APIAuthenticationHandler，可以在API的序列里移除它，或者调整处理器的执行顺序，确保你的自定义处理器先执行

获取POST参数要看请求的Content-Type，分三种常见场景处理：

1. Content-Type: application/x-www-form-urlencoded #

这种表单格式可以用WSO2自带的工具类解析：

import org.apache.synapse.transport.http.HttpTransportUtils;
import java.util.Map;
import java.io.InputStream;

MessageContext mc = getMessageContext();
// 获取请求体输入流
InputStream inputStream = mc.getEnvelope().getBody().getFirstElement().getTextAsStream();
// 解析表单参数（指定编码，比如UTF-8）
Map<String, String> formParams = HttpTransportUtils.parseFormParameters(inputStream, "UTF-8");
// 获取单个参数
String yourParam = formParams.get("your_param_name");

// 注意：如果后续还要用到请求流，记得重置
mc.setProperty("TRANSPORT_INPUT_STREAM", inputStream);

2. Content-Type: application/json #

对于JSON请求体，用WSO2的JsonUtil工具类解析最方便：

import org.apache.synapse.commons.json.JsonUtil;
import org.json.JSONObject;

MessageContext mc = getMessageContext();
// 获取JSON payload
JSONObject jsonPayload = JsonUtil.getJsonPayload(mc);
// 获取单个参数
String yourParam = jsonPayload.getString("your_param_name");

3. Content-Type: multipart/form-data（含文件上传） #

这种场景需要用Apache FileUpload来解析，代码示例：

import org.apache.commons.fileupload.FileItem;
import org.apache.commons.fileupload.FileUploadException;
import org.apache.commons.fileupload.disk.DiskFileItemFactory;
import org.apache.commons.fileupload.servlet.ServletFileUpload;
import javax.servlet.http.HttpServletRequest;
import java.util.List;

MessageContext mc = getMessageContext();
// 获取HTTP请求对象
HttpServletRequest request = (HttpServletRequest) mc.getProperty("transport.http.servletRequest");

// 初始化文件上传处理器
ServletFileUpload upload = new ServletFileUpload(new DiskFileItemFactory());
try {
    List<FileItem> items = upload.parseRequest(request);
    for (FileItem item : items) {
        if (item.isFormField()) {
            // 处理普通表单参数
            String paramName = item.getFieldName();
            String paramValue = item.getString("UTF-8");
            // 这里可以做参数逻辑处理
        } else {
            // 处理文件参数（比如获取文件名、文件流）
            String fileName = item.getName();
            InputStream fileStream = item.getInputStream();
            // 处理文件逻辑
        }
    }
} catch (FileUploadException e) {
    // 处理解析异常，比如返回错误响应
    e.printStackTrace();
}

注意：如果请求流被多次读取，可能会导致后续处理失败，建议用org.apache.synapse.commons.util.StreamUtils复制流后再操作，避免影响原请求的流转。

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