Spring Integration Gateway 退出“由于异常”并且在处理错误后未收到回复

Question

嘿，我正在将消息发送到 http 端点，因为我必须在选择性失败时触发错误流，所以我通过网关发送消息，然后最终通过 http 出站网关路由它。

@MessagingGateway(errorChannel="invocationFailureChannel")
public interface Invocator {
    @Gateway(requestChannel="invocationChannel")
    public Boolean invokeService(Message<String> invocation);
}

@Bean
public IntegrationFlow errorHandlingFlow() {
    return IntegrationFlows
            .from("invocationFailureChannel")
            .transform("payload.getFailedMessage()")
            .handle(new GenericHandler<Object>() {
                @Override
                public Object handle(Object payload, Map<String, Object> headers) {
                    //Do Stuff
                    return false;
                }
            })
            .get();
}

错误通道的回复应该会反馈给实际调用网关的 bean，对吧？但我得到了这个奇怪的例外：

o.s.m.c.GenericMessagingTemplate$TemporaryReplyChannel - 收到回复消息，但接收线程在发送请求消息时因异常退出

我尝试为请求和回复设置超时，但这并没有真正帮助。我尝试在调用网关的代码上放置一个 try-catch，但我也没有收到错误。

我什至尝试了一个与以下所示相同的示例：

https://www.youtube.com/watch?v=mF2uq4DnVCg

我不知道为什么它不适合我。即使在示例示例中，我也会遇到相同的错误。

Answer 1

当网关将错误发送到错误通道时，它有一个新的“replyChannel”标头；旧的已“用完” - 网关收到错误时使用。

这一行...

.transform("payload.getFailedMessage()")

搞砸了，因为返回消息的转换器会覆盖标头，因此新的回复通道会被用过的通道替换。

你可以使用

.transform("payload.failedMessage.payload")

框架将负责维护标头。如果您需要访问 failedMessage 标头，您将需要一个自定义转换器，并且您需要确保保留“新”replyChannel 标头。

或者，您可以使用标头丰富器从失败的消息中复制单个标头 - .enrichHeaders(s -> s.headerExpression("foo", "payload.failedMessage.headers['foo']")) 在 .transform() 之前。