【发布时间】:2018-04-06 18:18:55
【问题描述】:
用例:我们有一个现有的生产 API。我们打算使用 API Manager 作为传递中介,以便在我们现有的 API 上利用限制和分析。
我们编写了一个自定义身份验证处理程序,该处理程序加载到默认 APIAuthenticationHandler 的上游。这允许我们通过自定义标头 X-Auth-Token 而不是 WSO2 OAuth 令牌来识别我们的用户 - 这部分适用于经过身份验证的路由。
不幸的是,这不允许我们识别访问我们的身份验证路径的用户,结果是我们的分析数据与大量“未知”用户存在偏差。
我一直在尝试找出如何在我们的自定义身份验证处理程序中访问用户登录的 HTTP POST 参数,但我无法确定 Synapse 将其存储在类树中的什么位置。
网上各种建议,比如通过
访问HttpServletRequestHttpServletRequest servletRequest = (HttpServletRequest) messageContext.getProperty(HTTPConstants.MC_HTTP_SERVLETREQUEST);
不工作。
这些参数不能作为 MessageContext 或 Axis2MessageContext 对象中的属性使用。
log_in_message.xml 中介记录一个包含我想要的参数的 SOAP 信封:
Envelope: <?xml version='1.0' encoding='utf-8'?>
<soapenv:Envelope xmlns:soapenv="http://www.w3.org/2003/05/soap-envelope">
<soapenv:Body>
<xformValues>
<api_key>*expunged*</api_key>
<login_id>testy.user</login_id>
</xformValues>
</soapenv:Body>
</soapenv:Envelope> {org.apache.synapse.mediators.builtin.LogMediator}
但在我的自定义处理程序中,消息上下文中只有一个空的 SoapEnvelope:
[PassThru] <?xml version='1.0' encoding='utf-8'?><soapenv:Envelope xmlns:soapenv="http://www.w3.org/2003/05/soap-envelope"><soapenv:Body/></soapenv:Envelope>
我还没有找到一个明显的中介模式来添加到我们的 API 的突触序列中,以便将此 REST 参数注入到消息上下文中的属性中。我在网上找到的所有内容都涉及向 URI 动态添加参数。
有问题的请求是 HTTP 1.1 POST(内容类型为 x-www-form-encoded),并且已由下游服务成功处理,因此肯定包含参数。
谁能建议一种方法,我可以从中介树或自定义处理程序中的 java 类中获取 HTTP POST 正文或正文参数?
谢谢
编辑:对于那些在未来某个时间来的人来说,事实证明它就像在我的处理程序中调用调解器一样简单:
public boolean handleRequest(MessageContext messageContext) {
...
// mediate
// In order to avoid a remote registry call occurring on each invocation, we
// directly get the extension sequences from the local registry.
Map localRegistry = messageContext.getConfiguration().getLocalRegistry();
// run inbound mediations
String apiName = (String) messageContext.getProperty(RESTConstants.SYNAPSE_REST_API);
Object sequence = localRegistry.get(apiName + "--In");
if (sequence instanceof Mediator) {
((Mediator) sequence).mediate(messageContext);
}
编辑 2:Bee 建议的更好的解决方案如下:
private String getLoginIdFromSoapEnvelope(org.apache.axis2.context.MessageContext axis2MessageContext) {
String loginId = null;
try {
RelayUtils.buildMessage(axis2MessageContext);
SOAPEnvelope envelope = axis2MessageContext.getEnvelope();
OMElement root = envelope.getBody().getFirstElement();
OMElement loginElement = root.getFirstChildWithName(new QName("login_id"));
loginId = loginElement != null ? loginElement.getText() : null;
}catch (Exception exc) {
log.error("Unable to unmarshal via RelayUtils.buildMessage", exc);
}
return loginId;
}
【问题讨论】: