拆分 XML 消息
XPathMessageSplitter
支持带有String
或Document
负载。
拆分器使用提供的 XPath 表达式将负载拆分为多个节点。
默认情况下,这会导致每个Node
实例成为新消息的有效负载。
当每条消息都应该是一个Document
中,您可以设置createDocuments
旗。
其中 aString
payload 传入,则 payload 会被转换,然后被拆分,然后再转换回String
消息。
XPath 拆分器实现MessageHandler
因此,应与相应的端点一起配置(有关更简单的配置替代方案,请参阅以下示例后面的命名空间支持示例)。
以下示例配置一个 Bean,该 Bean 使用XPathMessageSplitter
:
<bean id="splittingEndpoint"
class="org.springframework.integration.endpoint.EventDrivenConsumer">
<constructor-arg ref="orderChannel" />
<constructor-arg>
<bean class="org.springframework.integration.xml.splitter.XPathMessageSplitter">
<constructor-arg value="/order/items" />
<property name="documentBuilder" ref="customisedDocumentBuilder" />
<property name="outputChannel" ref="orderItemsChannel" />
</bean>
</constructor-arg>
</bean>
XPath splitter 命名空间支持允许您创建具有 input 通道和 output 通道的消息端点,如下例所示:
<!-- Split the order into items and create a new message for each item node -->
<int-xml:xpath-splitter id="orderItemSplitter"
input-channel="orderChannel"
output-channel="orderItemsChannel">
<int-xml:xpath-expression expression="/order/items"/>
</int-xml:xpath-splitter>
<!-- Split the order into items, create a new document for each item-->
<int-xml:xpath-splitter id="orderItemDocumentSplitter"
input-channel="orderChannel"
output-channel="orderItemsChannel"
create-documents="true">
<int-xml:xpath-expression expression="/order/items"/>
<int:poller fixed-rate="2000"/>
</int-xml:xpath-splitter>
从版本 4.2 开始,XPathMessageSplitter
公开outputProperties
(例如OutputKeys.OMIT_XML_DECLARATION
) 属性的javax.xml.transform.Transformer
实例时,请求payload
不是类型org.w3c.dom.Node
.
以下示例定义了一个属性,并将其与output-properties
财产:
<util:properties id="outputProperties">
<beans:prop key="#{T (javax.xml.transform.OutputKeys).OMIT_XML_DECLARATION}">yes</beans:prop>
</util:properties>
<xpath-splitter input-channel="input"
output-properties="outputProperties">
<xpath-expression expression="/orders/order"/>
</xpath-splitter>
起始version 4.2
这XPathMessageSplitter
暴露一个iterator
选项作为boolean
flag(默认为true
).
这允许在下游流中 “流式处理” 拆分节点。
使用iterator
mode 设置为true
,则每个节点在迭代时都会进行转换。
什么时候false
,在开始将拆分节点发送到输出通道之前,首先转换所有条目。
(您可以将差异视为“转换、发送、转换、发送”与“转换、转换、发送、发送”。
有关更多信息,请参阅 Splitter 。