Spring Integration中如何优化错误处理机制？

本文共计1848个文字，预计阅读时间需要8分钟。

《手册开头概述中提到的，面向消息的框架（如Spring Integration）背后的主要动机之一是促进组件之间的松散耦合。消息通道起着重要作用，因为生产者和消费者不必相互了解。》

如本手册开头的概述中所述，面向消息的框架（如 Spring Integration）背后的主要动机之一是促进组件之间的松散耦合。 消息渠道起着重要作用，因为生产者和消费者不必相互了解。 但是，优点也有一些缺点。 在松散耦合的环境中，有些事情会变得更加复杂，一个例子是错误处理。

将消息发送到通道时，最终处理该消息的组件可能与发送方在同一线程中运行，也可能不在运行。 如果使用简单的默认值（当元素没有子元素和“task-executor”属性时），消息处理发生在发送初始消息的同一线程中。 在这种情况下，如果抛出 an，它可以被发送方捕获，或者如果它是未捕获的，它可能会传播到发送方之外。 这与普通 Java 调用堆栈中的异常引发操作的行为相同。​​DirectChannel​​​​<channel>​​​​<queue>​​​​Exception​​​​RuntimeException​​

在调用方线程上运行的消息流可以通过消息传递网关（请参阅消息传递网关）或 （请参阅消息传递模板）调用。 在任一情况下，默认行为都是向调用方引发任何异常。 对于消息网关，请参阅错误处理，了解有关如何引发异常以及如何配置网关以将错误路由到错误通道的详细信息。 使用 或直接发送到 a 时，总是会向调用方引发异常。​​MessagingTemplate​​​​MessagingTemplate​​​​MessageChannel​​

添加异步处理时，事情变得更加复杂。