Apache Camel：将CXF消费者端点请求体存入Header遇XML解析异常

嘿，我太懂你这个坑了！把XML请求存到Header里想复用，结果触发了START_ELEMENT/END_ELEMENT相关的XML解析异常对吧？这问题我之前帮好几个开发者排查过，核心原因其实很简单——XML输入流是一次性的：当你第一次读取这个流（比如路由初始消费请求、第一次XSLT转换）后，流的指针就走到了末尾，后续再尝试从这个流读取XML，自然会因为没有可解析的元素而报错。

下面给你两个靠谱的解决方案，按需选择：

方案1：将XML转换为可复用的DOM对象 #

最直接的思路是把一次性的流转换成内存中的DOM树形结构，这样不管读取多少次都不会有耗尽问题。你只需要在路由最开头添加convertBodyTo处理器，把请求体转成org.w3c.dom.Document，再存入Header备用即可。

示例路由配置：

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
  <route id="reuseXmlPayloadRoute">
    <!-- 从你的Web服务端点接收请求 -->
    <from uri="your-web-service-endpoint"/>
    <!-- 把原始XML流转换为DOM Document，实现多次复用 -->
    <convertBodyTo type="org.w3c.dom.Document"/>
    <!-- 将DOM对象存入Header，命名为OriginalPayload -->
    <setHeader headerName="OriginalPayload">
      <simple>${body}</simple>
    </setHeader>
    
    <!-- 第一次XSLT转换，直接使用当前Body（已经是DOM对象） -->
    <to uri="xslt:classpath:/first-transform.xsl"/>
    <!-- 这里可以添加第一次转换后的业务逻辑处理 -->
    
    <!-- 取出Header中的原始DOM对象，设置为Body用于第二次转换 -->
    <setBody>
      <simple>${header.OriginalPayload}</simple>
    </setBody>
    <!-- 第二次XSLT转换 -->
    <to uri="xslt:classpath:/second-transform.xsl"/>
    <!-- 这里添加第二次转换后的业务逻辑处理 -->
  </route>
</camelContext>

方案2：使用Camel Cache组件缓存载荷 #

如果你不想手动处理DOM转换，也可以用Camel的Cache组件把原始请求体缓存起来，后续直接从缓存中读取。这种方式不仅适用于XML，其他类型的载荷也能复用。

示例路由配置：

<camelContext id="camel" xmlns="http://camel.apache.org/schema/spring">
  <route id="cachedPayloadRoute">
    <from uri="your-web-service-endpoint"/>
    <!-- 将原始请求体存入缓存，用Exchange ID作为唯一标识 -->
    <cache:put cacheName="requestPayloadCache" key="${exchangeId}">
      <simple>${body}</simple>
    </cache:put>
    
    <!-- 第一次XSLT转换 -->
    <to uri="xslt:classpath:/first-transform.xsl"/>
    <!-- 处理第一次转换结果 -->
    
    <!-- 从缓存中取出原始载荷，设置为Body -->
    <setBody>
      <cache:get cacheName="requestPayloadCache" key="${exchangeId}"/>
    </setBody>
    <!-- 第二次XSLT转换 -->
    <to uri="xslt:classpath:/second-transform.xsl"/>
    <!-- 处理第二次转换结果 -->
    
    <!-- 可选：处理完后清理缓存，避免内存泄漏 -->
    <cache:remove cacheName="requestPayloadCache" key="${exchangeId}"/>
  </route>
</camelContext>

额外注意事项 #

• 如果你的请求体是String类型（而非Stream），其实可以直接存入Header复用，但Web服务端点通常会将请求封装成Stream，所以必须先做转换。
• 用DOM对象的话，要注意大XML的内存占用问题，如果你的请求体特别大，可能需要考虑用SAX或者StAX的方式处理，但大部分场景下DOM已经足够好用。

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