Camel：带命名空间的XML拆分后如何基于文本值提取XML？

我之前也踩过带命名空间的大型XML在Apache Camel里拆分+提取的坑，结合你的场景，给你一套可行的解决方案：

因为你的XML用了tns命名空间（绑定到http://deutsche-boerse.com/DBRegHub），Camel的XPath、Splitter等组件必须能识别这个命名空间，否则会找不到目标节点。

你可以在路由里设置全局命名空间上下文，这样所有用到XML处理的地方都能自动识别tns前缀，不用重复配置。

处理大型XML一定要用流式拆分，避免把整个文件加载到内存导致OOM。Camel的tokenizeXML专门针对这个场景设计，配合streaming=true就能实现边读文件边拆分节点。

拆分出来的每个片段都是独立的<tns:tradeStatusDetails>节点，你可以用XPath指定命名空间前缀，精准提取里面的文本值（比如<tns:statusCode>或<tns:tradeId>这类子元素的内容）。

Java DSL版 #

import javax.xml.XMLConstants;
import javax.xml.namespace.NamespaceContext;
import org.apache.camel.builder.RouteBuilder;
import java.util.Iterator;

public class TradeStatusProcessingRoute extends RouteBuilder {
    @Override
    public void configure() throws Exception {
        from("file:src/main/resources/input?fileName=customerResponse.xml")
            // 设置全局命名空间上下文
            .setNamespaceContext(new NamespaceContext() {
                @Override
                public String getNamespaceURI(String prefix) {
                    if ("tns".equals(prefix)) {
                        return "http://deutsche-boerse.com/DBRegHub";
                    }
                    return XMLConstants.NULL_NS_URI;
                }

                @Override
                public String getPrefix(String namespaceURI) { return null; }
                @Override
                public Iterator<String> getPrefixes(String namespaceURI) { return null; }
            })
            // 流式拆分tns:tradeStatusDetails节点
            .split().tokenizeXML("tns:tradeStatusDetails").streaming()
                .log("Processing single trade status detail: ${body}")
                // 提取tns:statusCode的文本值到Header
                .setHeader("Trade-Status", xpath("tns:statusCode/text()", String.class))
                // 提取tns:tradeId的文本值到Header
                .setHeader("Trade-ID", xpath("tns:tradeId/text()", String.class))
                // 这里可以添加后续处理逻辑，比如存库、发MQ等
                .to("log:com.example.trade?showHeaders=true&showBody=false")
            .end();
    }
}

XML DSL版 #

如果你用Spring XML配置路由：

<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:camel="http://camel.apache.org/schema/spring"
       xsi:schemaLocation="
       http://www.springframework.org/schema/beans https://www.springframework.org/schema/beans/spring-beans.xsd
       http://camel.apache.org/schema/spring https://camel.apache.org/schema/spring/camel-spring.xsd">

    <camelContext id="tradeProcessingContext" xmlns="http://camel.apache.org/schema/spring">
        <route>
            <from uri="file:src/main/resources/input?fileName=customerResponse.xml"/>
            <!-- 配置命名空间映射 -->
            <setNamespaceContext>
                <namespace prefix="tns" uri="http://deutsche-boerse.com/DBRegHub"/>
            </setNamespaceContext>
            <!-- 流式拆分目标节点 -->
            <split streaming="true">
                <tokenizeXML token="tns:tradeStatusDetails"/>
                <log message="Processing single trade status detail: ${body}"/>
                <!-- 提取状态码到Header -->
                <setHeader headerName="Trade-Status">
                    <xpath resultType="java.lang.String">tns:statusCode/text()</xpath>
                </setHeader>
                <!-- 提取交易ID到Header -->
                <setHeader headerName="Trade-ID">
                    <xpath resultType="java.lang.String">tns:tradeId/text()</xpath>
                </setHeader>
                <to uri="log:com.example.trade?showHeaders=true&showBody=false"/>
            </split>
        </route>
    </camelContext>
</beans>

• 依赖要到位：确保项目里引入了camel-xml-jaxp组件（Maven/Gradle都需添加），否则XML处理相关功能会报错。
• 命名空间完全匹配：tns对应的URL必须和XML里的xmlns:tns="http://deutsche-boerse.com/DBRegHub"完全一致，哪怕多一个空格都会导致节点找不到。
• 超大型文件优化：如果文件特别大（几十上百MB），可以配合Camel的seda组件做异步拆分，避免主线程阻塞：.split().tokenizeXML(...).streaming().to("seda:processTradeStatus")，再单独写路由处理seda:processTradeStatus的消息。

内容的提问来源于stack exchange，提问作者Mikael Andersson Wigander