java - 没有 CXF/Spring-ws 的 Camel 返回简单的 SoapFault

Question

我创建了一个代理 Camel ，它接受 SOAP(通过 HTTP)和 RESTful 请求并将它们转发到正确的 Web 服务。 Camel 不知道消息结构，它不知道 WSDL 或任何东西，它只根据 http header 知道它是否是 SOAP。没有 CXF 端点。

进一步它做一些处理。那里可能会发生异常，例如当找不到服务或 url 无效时。 有没有一种简单的方法可以直接从这只 Camel 返回有效的 SOAPFault？ 我尝试编写一个简单的处理器，称为 onException。它看起来像这样:

.choice().when().header("SOAP").processRef(ExceptionToSoapProcessor())

应该将任何异常转换为 SOAPFault 的处理器看起来像这样

@Override
public void process(Exchange exchange) throws Exception {
    Exception exception = (Exception) exchange.getProperty(Exchange.EXCEPTION_CAUGHT);
    Integer responseCode = (Integer) exchange.getOut().getHeader(Exchange.HTTP_RESPONSE_CODE);

    QName qName = SoapFault.FAULT_CODE_SERVER;
    if (responseCode != null && responseCode < 500) {
        qName = SoapFault.FAULT_CODE_CLIENT;
    }

    SoapFault fault = new SoapFault(exception.getMessage(), qName);
    Message outMessage = exchange.getOut();
    outMessage.setHeader(Message.RESPONSE_CODE, 500);
    outMessage.setFault(true);
    outMessage.setBody(fault);

    exchange.setException(null);
    exchange.removeProperty(Exchange.EXCEPTION_CAUGHT);
    exchange.setProperty(Exchange.EXCEPTION_HANDLED, true);
}

但现在我不明白我将如何编码它，响应看起来像这样:

org.apache.cxf.binding.soap.SoapFault: Unauthorized

(“未经授权”是实际消息)

PS:我用了dataformat SOAP之前，但如前所述，我在这个 Camel 中没有任何 ServiceInterface。

Answer 1

我会将错误场景的处理移至 onException()堵塞。这样你就可以“声明”一些行为，比如将异常标记为已处理。恕我直言，让它更干净一些。

仅仅返回 SOAP 错误不会产生有效的 SOAP 响应。您必须构建完整的消息结构。我认为没有用于将 SOAP 消息转换为文本流的类型转换器，因此您必须自己编码 SOAP 响应。

这是我用来完成这项工作的代码:

<onException>
    <exception>java.lang.Exception</exception>
    <handled>
        <constant>true</constant>
    </handled>
    <bean beanType="some.package.WSHelper" method="createSOAPFaultServerError" />
</onException>


public static String createSOAPFaultServerError(final Exception cause) {
    String result = null;
    LOG.error("Creating SOAP fault, hiding original cause from client:", cause);
    try {
        SOAPMessage message = MessageFactory.newInstance().createMessage();
        SOAPEnvelope envelope = message.getSOAPPart().getEnvelope();
        SOAPBody body = message.getSOAPBody();
        SOAPFault fault = body.addFault();
        fault.setFaultCode("Server");
        fault.setFaultString("Unexpected server error.");
        Detail detail = fault.addDetail();
        Name entryName = envelope.createName("message");
        DetailEntry entry = detail.addDetailEntry(entryName);
        entry.addTextNode("The server is not able to complete the request. Internal error.");

        result = soapMessage2String(message);
    } catch (Exception e) {
        LOG.error("Error creating SOAP Fault message", e);
    }

    return result;
}

private static String soapMessage2String(final SOAPMessage message) throws SOAPException, IOException {
    String result = null;

    ByteArrayOutputStream outStream = new ByteArrayOutputStream();
    message.writeTo(outStream);
    result = new String(outStream.toByteArray(), StandardCharsets.UTF_8);

    return result;
}

HTH