Tomcat环境下如何通过Apache CXF拦截器捕获并修改SOAP出站请求的URI

你的需求完全可以实现，问题出在拦截器阶段选择和URI的获取方式上——PRE_STREAM阶段太晚了，此时请求已经接近发送状态，完整的端点URI信息已经被拆解成请求头和路径片段，自然拿不到完整值。我们需要更早的阶段来操作。

核心思路 #

选择Phase.PREPARE_SEND这个拦截阶段（在请求准备发送但还未构建HTTP请求之前），此时CXF已经组装好完整的出站端点URI，并且还允许我们修改它。同时要使用CXF提供的正确属性键来获取和更新端点地址。

完整拦截器实现 #

下面是调整后的拦截器代码，包含日志记录和URI修改逻辑：

import org.apache.cxf.message.Message;
import org.apache.cxf.phase.AbstractPhaseInterceptor;
import org.apache.cxf.phase.Phase;
import org.apache.cxf.transport.http.HttpConduit;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import java.net.URL;

public class EndpointInterceptor extends AbstractPhaseInterceptor<Message> {
    private static final Logger LOGGER = LoggerFactory.getLogger(EndpointInterceptor.class);

    public EndpointInterceptor() {
        // 关键：选择PREPARE_SEND阶段，此时端点地址已就绪且可修改
        super(Phase.PREPARE_SEND);
    }

    @Override
    public void handleMessage(Message message) throws Fault {
        // 1. 获取原始出站端点URI
        String originalEndpoint = (String) message.get(Message.ENDPOINT_ADDRESS);
        LOGGER.debug("Original outbound endpoint: {}", originalEndpoint);

        // 2. 这里添加你的业务逻辑：把之前移除的参数重新拼接回去
        // 示例：假设要添加的参数是"internalSwitch=enabled&debug=1"
        String modifiedEndpoint = appendParameters(originalEndpoint, "internalSwitch=enabled&debug=1");
        LOGGER.debug("Modified outbound endpoint: {}", modifiedEndpoint);

        // 3. 更新Message中的端点地址
        message.put(Message.ENDPOINT_ADDRESS, modifiedEndpoint);

        // 4. 同步更新HttpConduit的目标地址，确保后续连接使用修改后的URI
        HttpConduit conduit = (HttpConduit) message.getExchange().getConduit();
        if (conduit != null) {
            try {
                conduit.setTargetAddress(new URL(modifiedEndpoint));
            } catch (Exception e) {
                LOGGER.error("Failed to update conduit target address", e);
                throw new Fault(e);
            }
        }
    }

    // 工具方法：安全地给URL添加参数
    private String appendParameters(String originalUrl, String paramsToAdd) {
        if (originalUrl == null || paramsToAdd == null || paramsToAdd.isEmpty()) {
            return originalUrl;
        }
        return originalUrl.contains("?") 
                ? originalUrl + "&" + paramsToAdd 
                : originalUrl + "?" + paramsToAdd;
    }
}

如何注册拦截器 #

你需要把这个拦截器添加到CXF客户端的出站拦截器列表中，而不是入站拦截器：

代码方式注册

// 假设你的SOAP端口代理是yourSoapPort
YourServicePortType yourSoapPort = ...; // 从CXF客户端获取端口实例
org.apache.cxf.endpoint.Client client = org.apache.cxf.frontend.ClientProxy.getClient(yourSoapPort);
client.getOutInterceptors().add(new EndpointInterceptor());

Spring XML配置方式

<jaxws:client id="yourSoapClient" 
              serviceClass="com.your.package.YourServicePortType" 
              address="http://your-preprocessed-endpoint">
    <jaxws:outInterceptors>
        <bean class="com.your.package.EndpointInterceptor"/>
    </jaxws:outInterceptors>
</jaxws:client>

为什么之前的方法无效？ #

PRE_STREAM阶段是CXF拦截器链中非常靠后的阶段，此时HTTP请求的流已经准备完毕，端点URI已经被解析为Host头、请求路径等零散信息，无法再拿到完整的原始URI。而PREPARE_SEND阶段是在请求构建的早期，端点地址还以完整字符串的形式保存在Message.ENDPOINT_ADDRESS属性中，这是修改它的最佳时机。

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