Spring集成Java DSL：在出现拆分和聚合方法的错误情况后，如何继续？

Question

我的程序在高层执行以下操作

Task 1
  get the data from the System X
  the Java DSL split
    post the data to the System Y
    post the reply data to the X
  the Java DSL aggregate
Task 2
  get the data from the System X
  the Java DSL split
    post the data to the System Y
    post the reply data to the X
  the Java DSL aggregate
...

问题是，当一个将数据发布到System Y子任务失败时，错误消息会正确发送回System X，但在此之后，任何其他子任务或任务都不会执行。

我的错误处理程序这样做：

...
Message<String> newMessage = MessageBuilder.withPayload("error occurred")
                .copyHeadersIfAbsent(message.getPayload().getFailedMessage().getHeaders()).build();
...
Set some extra headers etc. 
...
return newMessage;

有什么问题吗？

编辑：

我调试了Spring集成。在错误情况下，只有第一条错误消息到达方法AbstractCorrelationMessageHandler。handleMessageInternal。其他成功消息和失败消息未到达该方法。

如果没有错误，则所有消息都会发送到该方法，最后释放该组。

我的程序可能有什么问题？

编辑2：

这起作用了：

为Http添加了建议。outboundGateway：

.handle(Http.outboundGateway(...,
                    c -> c.advice(myAdvice()))

还有myAdvice bean

@Bean
private Advice myAdvice() {
    return new MyAdvice();
}

和MyAdvie类

public class MyAdvice<T> extends AbstractRequestHandlerAdvice {
@SuppressWarnings("unchecked")
@Override
protected Object doInvoke(final ExecutionCallback callback, final Object target, final Message<?> message)
        throws Exception {
    ...

    try {
        result = (MessageBuilder<T>) callback.execute();
    } catch (final MessageHandlingException e) {
        take the exception cause for the new payload
    }

    return new message with the old headers and replyChannel header and result.payload or the exception cause as a payload
}

}

Answer 1

你的程序没有问题。这正是正则循环在Java中的工作方式。要捕获每个迭代的异常并继续处理其他剩余项，您肯定需要进行一次尝试。。捕获Java循环中的。因此，类似的东西需要在这里应用于拆分器。它可以通过表达式EvaluationRequestHandlerAdvice、作为拆分器输出的ExecutorChannel或通过拆分器输出通道上的service activator进行网关调用来实现。

由于故事是关于一个聚合器的，因此您仍然需要以某种方式完成一个组，这只能通过从错误处理中发出一些错误补偿消息以返回聚合器的输入通道来完成。在这种情况下，您需要确保从抛出到错误流的MessagingException的失败消息中复制请求标头。聚合组后，您需要将带有错误的消息与正常消息分开。这只能通过特殊的有效负载来完成，或者您可能只是将异常作为有效负载，以便在聚合器的最终结果中正确区分错误与正常消息。