消息处理程序链

这是一个实现，可以配置为单个消息端点，同时实际上委托给其他处理程序链，例如过滤器、转换器、拆分器等。 当需要以固定的线性进度连接多个处理程序时，这可能会导致更简单的配置。 例如，在其他组件之前提供 transformer 是相当常见的。 同样，当您在链中的其他组件之前提供过滤器时，您实际上是创建了一个选择性使用者。 无论哪种情况，链都只需要 single 和 single ，无需为每个单独的组件定义通道。MessageHandlerChainMessageHandlerinput-channeloutput-channelspring-doc.cn

这主要是为 XML 配置设计的。 对于 Java DSL，可以将定义视为链组件，但它与下面本章中描述的概念和原则无关。 有关更多信息，请参阅 Java DSL。MessageHandlerChainIntegrationFlow
Spring 集成提供了一个布尔属性： 。 当您在具有不同接受条件的同一点对点通道上提供多个选择性使用者时，应将此值设置为“true”（默认值为 ），以便调度程序知道消息已被拒绝，并因此尝试将消息传递给其他订阅者。 如果未引发异常，则调度程序会认为消息已成功传递，即使筛选器已删除消息以防止进一步处理。 如果您确实想要 “drop” 消息，过滤器的 'discard-channel' 可能很有用，因为它确实让您有机会对丢弃的消息执行某些操作（例如将其发送到 JMS 队列或将其写入日志）。FilterthrowExceptionOnRejectionfalse

处理程序链简化了配置，同时在内部保持组件之间相同程度的松散耦合，如果在某些时候需要非线性排列，修改配置是很简单的。spring-doc.cn

在内部，该链被扩展为列出的端点的线性设置，由匿名通道分隔。 在链中不考虑 reply channel headers。 只有在调用最后一个处理程序后，生成的消息才会转发到回复通道或链的输出通道。 由于这种设置，除了最后一个处理程序之外，所有处理程序都必须实现接口（它提供了一个 'setOutputChannel（）' 方法）。 如果 on the 已设置，则最后一个处理程序只需要一个 output channel。MessageProduceroutputChannelMessageHandlerChainspring-doc.cn

与其他终端节点一样，该是可选的。 如果链的末尾有回复消息，则 output-channel 优先。 但是，如果它不可用，则链处理程序将检查入站消息上的回复通道头作为回退。output-channel

在大多数情况下，您无需自行实施。 下一节重点介绍 chain 元素的命名空间支持。 大多数 Spring 集成端点（例如服务激活器和转换器）都适合在 .MessageHandlerMessageHandlerChainspring-doc.cn

配置链

该元素提供了一个属性。 如果链中的最后一个元素能够生成回复消息（可选），则它还支持属性。 然后，子元素是 filters、transformers、splitter 和 service-activator。 最后一个元素也可以是 router 或 outbound channel adapter。 以下示例显示了链定义：<chain>input-channeloutput-channelspring-doc.cn

<int:chain input-channel="input" output-channel="output">
    <int:filter ref="someSelector" throw-exception-on-rejection="true"/>
    <int:header-enricher>
        <int:header name="thing1" value="thing2"/>
    </int:header-enricher>
    <int:service-activator ref="someService" method="someMethod"/>
</int:chain>

前面示例中使用的元素设置一个消息标头，该消息的值为 。 Header Enricher 是仅涉及 Headers 值的专用化。 你可以通过实现一个进行 Headers 修改并将其连接为 bean 来获得相同的结果，但是 header-enricher 是一个更简单的选项。<header-enricher>thing1thing2TransformerMessageHandlerspring-doc.cn

可以配置为消息流的最后一个 “closed-box” 使用者。 对于此解决方案，您可以将其放在 <链的末尾>一些 <outbound-channel-adapter>，如下例所示：<chain>spring-doc.cn

<int:chain input-channel="input">
    <int-xml:marshalling-transformer marshaller="marshaller" result-type="StringResult" />
    <int:service-activator ref="someService" method="someMethod"/>
    <int:header-enricher>
        <int:header name="thing1" value="thing2"/>
    </int:header-enricher>
    <int:logging-channel-adapter level="INFO" log-full-message="true"/>
</int:chain>
不允许的属性和元素

某些属性 （如 和 不允许在链中使用的组件上指定）。 poller 子元素也是如此。orderinput-channelspring-doc.cn

对于 Spring 集成核心组件，XML 模式本身会强制执行其中一些约束。 但是，对于非核心组件或您自己的自定义组件，这些约束由 XML 名称空间解析器（而不是 XML 架构）强制执行。spring-doc.cn

这些 XML 名称空间解析器约束是在 Spring Integration 2.2 中添加的。 如果尝试使用不允许的属性和元素，则 XML 命名空间解析器会引发 .BeanDefinitionParsingExceptionspring-doc.cn

使用 'id' 属性

从 Spring Integration 3.0 开始，如果为链元素赋予了一个属性，则该元素的 bean 名称是链和元素本身的组合。 没有属性的元素不会注册为 bean，但每个元素都会被赋予一个包含 chain 的 bean 。 请考虑以下示例：ididididcomponentNameidspring-doc.cn

<int:chain id="somethingChain" input-channel="input">
    <int:service-activator id="somethingService" ref="someService" method="someMethod"/>
    <int:object-to-json-transformer/>
</int:chain>

在前面的示例中：spring-doc.cn

  • 根元素具有 'somethingChain'。 因此，实现（ 或 ，取决于类型）Bean 将此值作为其 Bean 名称。<chain>idAbstractEndpointPollingConsumerEventDrivenConsumerinput-channelspring-doc.cn

  • 该 Bean 获取一个 Bean 别名（'somethingChain.handler'），它允许从 .MessageHandlerChainBeanFactoryspring-doc.cn

  • 这不是一个完全成熟的消息收发端点（它不是 or ）。 它是 . 在这种情况下，注册到 的 bean 名称是 'somethingChain$child.somethingService.handler'。<service-activator>PollingConsumerEventDrivenConsumerMessageHandler<chain>BeanFactoryspring-doc.cn

  • this 的值相同，但没有 '.handler' 后缀。 它变为 'somethingChain$child.somethingService'。componentNameServiceActivatingHandlerspring-doc.cn

  • 最后一个子组件 没有属性。 它基于它在 中的位置。 在本例中，它是 'somethingChain$child#1'。 （名称的最后一个元素是链中的顺序，以 '#0' 开头）。 请注意，此转换器未在应用程序上下文中注册为 Bean，因此它不会获得 . 但是，它的值可用于日志记录和其他目的。<chain><object-to-json-transformer>idcomponentName<chain>beanNamecomponentNamespring-doc.cn

元素的属性使它们有资格进行 JMX 导出，并且可以在消息历史记录中跟踪它们。 如前所述，您可以使用适当的 bean 名称从 访问它们。id<chain>BeanFactoryspring-doc.cn

在元素上提供显式属性以简化日志中子组件的标识并提供从 etc 访问它们非常有用。id<chain>BeanFactory

从 Chain 中调用 Chain

有时，您需要从链中对另一个链进行嵌套调用，然后返回并继续在原始链中执行。 为此，您可以通过包含 <gateway> 元素来使用消息传送网关，如下例所示：spring-doc.cn

<int:chain id="main-chain" input-channel="in" output-channel="out">
    <int:header-enricher>
      <int:header name="name" value="Many" />
    </int:header-enricher>
    <int:service-activator>
      <bean class="org.foo.SampleService" />
    </int:service-activator>
    <int:gateway request-channel="inputA"/>
</int:chain>

<int:chain id="nested-chain-a" input-channel="inputA">
    <int:header-enricher>
        <int:header name="name" value="Moe" />
    </int:header-enricher>
    <int:gateway request-channel="inputB"/>
    <int:service-activator>
        <bean class="org.foo.SampleService" />
    </int:service-activator>
</int:chain>

<int:chain id="nested-chain-b" input-channel="inputB">
    <int:header-enricher>
        <int:header name="name" value="Jack" />
    </int:header-enricher>
    <int:service-activator>
        <bean class="org.foo.SampleService" />
    </int:service-activator>
</int:chain>

在前面的示例中，由此处配置的 'gateway' 元素在处理结束时调用。 在 中，在标头扩充后调用 a。 然后，流返回以完成 中的执行。 最后，流返回到 。 在链中定义元素的嵌套版本时，它不需要该属性。 相反，它采用当前状态的消息，并将其放置在属性中定义的通道上。 当该网关启动的下游流完成时，a 将返回到网关并继续其在当前链中的旅程。nested-chain-amain-chainnested-chain-anested-chain-bnested-chain-bmain-chain<gateway>service-interfacerequest-channelMessagespring-doc.cn