头聚合期间，错误通道和回复通道消失

Question

我有以下工作流程。

>

入站通道

分流器

分割通道的任务执行器-所有线程执行相同的工作流。

3.a .构建请求

3.b .网关消息endpoint的服务激活器包装。

3 . c . http-outbound-gateway上带有错误通道配置的网关包装器(用于在调用http-outbound-gateway时处理异常)

超文本传输协议-出站-网关

聚合器

spring集成工作流的响应。

如果在 3.d 中发生异常，则控制将转到为网关错误通道配置的服务激活器。我只将失败消息中的以下内容复制到新标头，然后复制到传递到错误通道的标头。

a. 相关性 Id b. 序列编号 c. 序列大小

但是在聚合拆分器响应时，DefaultAggregatingMessageGroupProcessor.java删除冲突的标头，并在向聚合器提供控制之前删除错误通道和回复通道。

因此，一旦聚合器完成其操作，它就无法找到回复或错误通道，并导致异常。

我使用的是SpringIntegrationCore版本2.2.1，我不确定为什么在头聚合期间删除了回复通道和错误通道。

任何关于解决这个问题的意见都会有很大的帮助。

谢谢你：）

编辑1：非常感谢加里帮助我解决这种情况。我正在共享我的当前配置

<!-- SPLITTER -->
<int:splitter id="dentalSplitter" ref="dentalServiceSplitter"
    method="getDentalServiceList" input-channel="dentalServiceSplitterChannel"
    output-channel="dentalSplitterTaskChannel" />

<int:channel id="dentalSplitterTaskChannel">
    <int:dispatcher task-executor="dentalTaskExecutor" />
</int:channel>

<int:chain input-channel="dentalSplitterTaskChannel" output-channel="dentalGatewayChannel">
    <int:header-enricher>
        <int:header name="CHAIN_START_TIME" expression="T(System).currentTimeMillis()" overwrite="true" />
    <int:object-to-json-transformer content-type="application/json"/>               
</int:chain>

<int:service-activator input-channel="dentalGatewayChannel" ref="dentalGatewayWrapper" output-channel="dentalReplyChannel" />
<int:gateway id="dentalGatewayWrapper" default-request-channel="dentalCostEstimateRequestChannel" error-channel="dentalErrorChannel"/>

<int-http:outbound-gateway id="dentalGateway"
    url-expression="@urlBuilder.build('${service.endpoint}')"  
    http-method="POST" request-factory="clientHttpRequestFactory"  
    request-channel="dentalCostEstimateRequestChannel" extract-request-payload="true" 
    expected-response-type="com.dental.test.DentalResponse">
    <int-http:request-handler-advice-chain> 
         <ref bean="logChainTimeInterceptor" /> 
    </int-http:request-handler-advice-chain>
</int-http:outbound-gateway>

<!-- EXCEPTION -->
<int:chain input-channel="dentalErrorChannel" output-channel="dentalAggregatorChannel">
    <int:transformer ref="commonErrorTransformer" method="dentalGracefulReturn"/>
</int:chain>

<!-- SUCCESS -->
<int:chain input-channel="dentalReplyChannel" output-channel="dentalAggregatorChannel">
        <int:filter discard-channel="dentalErrorChannel"
        expression="T(com.dental.util.InvocationOutcomeHelper).isOutcomeSuccess(payload?.metadata?.outcome?.code,payload?.metadata?.outcome?.message)" />
</int:chain>

<!-- AGGREGATION -->

<int:chain input-channel="dentalAggregatorChannel" output-channel="wsDentalServiceOutputChannel" >
    <int:aggregator ref="dentalServiceAggregator" />
    <int:service-activator ref="dentalResponseServiceActivator" />
</int:chain>

我注意到的是，每个分离通道在通过网关时都会为错误和回复创建一个新的临时通道，在从网关获得响应后，它会保留保留的(原始入站)错误和回复通道头。正如您所提到的，在控制到达错误转换器后，保留保留头的流程被中断，聚合消息组处理器接收临时通道的三个不同实例，并因此删除它们。我计划有一个定制的消息组处理器，并修改聚合消息头的冲突解决策略，并提出了这个配置。

<bean id="channelPreservingAggregatingMessageHandler" class="org.springframework.integration.aggregator.AggregatingMessageHandler">
    <constructor-arg name="processor" ref="channelPreservingMessageGroupProcessor"/>
</bean>

不过，我还没有测试过这一点。但基于这种讨论，这似乎不是一个可行的解决方案。

看起来我在网关中的错误处理配置不正确。但是，我对您的这种说法感到困惑“不直接转发消息，而只是处理您的错误流上的错误，并正常地将结果返回给网关“包装器”。如果我移除了错误通道，当异常发生时，我如何取回控制权？也许我没明白这里的一些事情。你能详细说明一下吗？

Answer 1

当询问此类场景时，您通常需要显示您的配置。但是，我怀疑您正在将错误流中的消息直接转发到聚合器。

这就像在代码中执行< code>GOTO并破坏作用域。

它不起作用，因为错误消息中的< code>replyChannel头是用于网关“包装器”的，而不是原始的上游入站网关。当聚合器得到冲突的头时，它别无选择，只能丢弃这些头(您将看到一条调试日志消息)。

与其直接转发消息，不如简单地处理错误流上的错误并将结果正常返回到网关“包装器”（只需省略错误流最后一个元素上的错误通道）。

然后，网关将修改回复，使其与其他消息(好的和坏的)保持一致，并将其转发给聚合器。

您不需要弄乱错误流中的标题，只需返回您希望与好结果一起聚合的值。

您应该更新到当前版本，或者至少是2.2.x系列中的最新版本(2.2.6)。