如何使用 CXF 拦截器和 org.w3c.dom.Node 修改 Web 服务请求

Question

使用 CXF 拦截器，我想将一些节点附加到发送到服务器的 xml 中。我创建了一个拦截器（见下文），它以 DOM 节点的形式获取消息，修改它并将其写回消息对象。

不幸的是，代码无法按预期工作 - 发送到服务器的 XML 不包含“magicWord”。恕我直言，我为此使用了错误的阶段。

所以问题是：如何使用 org.w3c.dom.Node 语法修改传出的 Web 服务请求？

package dummy;

import org.apache.cxf.message.Message;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.w3c.dom.Document;
import org.w3c.dom.Node;
import org.w3c.dom.NodeList;

class DummyInterceptor extends AbstractPhaseInterceptor {

    String magicWord = "abc";

    public DummyInterceptor() {
        super(Phase.PRE_PROTOCOL);
    }

    public void handleMessage(Message message) {
        Document document = (Document) message.getContent(Node.class);
        NodeList nodes = document.getElementsByTagName("wsse:Security");
        if (nodes.getLength() == 1) {
            Node wsseSecurityNode = nodes.item(0);
            wsseSecurityNode.appendChild(document.createTextNode(magicWord));
        }
        message.setContent(Node.class, document);
    }
}

Answer 1

最后我自己发现了如何做到这一点。

• 拦截器必须使用 'Phase.PRE_PROTOCOL'
• 拦截器必须使用 addAfter(SaajOutInterceptor) - SaajOutInterceptor 提供的 Message 拦截器类中的 Node
• 应派生自 AbstractSoapInterceptor
• 拦截器的 handleMessage 不会做修改 DOM 本身的肮脏工作，而是添加一个新的使用 message.getInterceptorChain().add(...) 拦截消息。
• 新添加的拦截器应该修改 DOM

Answer 2

如果您想在 cxf 拦截器中使用 DOM api 修改请求的正文，正确的阶段是 USER_PROTOCOL

SAAJOutInterceptor 创建 DOM 结构，因此您的拦截器必须在此之后运行，这意味着您可能必须将其添加到拦截器链，因为出于性能原因它并不总是由 cxf 添加。

import org.apache.cxf.binding.soap.SoapMessage;
import org.apache.cxf.binding.soap.interceptor.AbstractSoapInterceptor;
import org.apache.cxf.interceptor.Fault;
import org.apache.cxf.phase.Phase;
import org.w3c.dom.Node;

import javax.xml.soap.SOAPException;
import javax.xml.soap.SOAPMessage;

abstract public class SoapNodeModifierInterceptor extends AbstractSoapInterceptor {
    SoapNodeModifierInterceptor() { super(Phase.USER_PROTOCOL); }

    @Override public void handleMessage(SoapMessage message) throws Fault {
        try {
            if (message == null) {
                return;
            }
            SOAPMessage sm = message.getContent(SOAPMessage.class);
            if (sm == null) {
                throw new RuntimeException("You must add the SAAJOutInterceptor to the chain");
            }

            modifyNodes(sm.getSOAPBody());

        } catch (SOAPException e) {
            throw new RuntimeException(e);
        }
    }

    abstract void modifyNodes(Node node);
}

添加拦截器：

import org.apache.cxf.binding.soap.saaj.SAAJOutInterceptor;
import org.apache.cxf.endpoint.Client;

/*[...]*/
client.getOutInterceptors().add(new SAAJOutInterceptor())
client.getOutInterceptors().add(new MySoapNodeModifierInterceptor())