集成端点
本节介绍了 Spring Integration 提供的各种通道适配器和消息网关,以支持与外部系统基于消息的通信。
每个系统,从 AMQP 到 Zookeeper,都有其自身的集成要求,本节将介绍这些要求。
终端快速参考表
如前所述部分所述,Spring Integration 提供了许多端点,用于与外部系统、文件系统等进行接口。
为了透明的依赖管理,Spring Integration 提供了一个物料清单 POM,可以导入到 Maven 配置中:
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-bom</artifactId>
<version>6.4.2</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
总结:
-
入站通道适配器用于单向集成,将数据引入消息应用程序。
-
出站通道适配器用于单向集成,将数据发送出消息应用程序。
-
入站网关用于双向集成流程,其中其他系统调用消息应用程序并接收回复。
-
出站网关用于双向集成流程,其中消息应用程序调用某些外部服务或实体并期望获得结果。
下表总结了各个端点,并提供了指向适当章节的快速链接。
表 1. 终端快速参考
此外,如 核心消息传递 中所述,Spring Integration 提供了与普通 Java 对象(POJO)接口的端点。如 通道适配器 中所述,<int:inbound-channel-adapter>
元素允许您轮询 Java 方法以获取数据。<int:outbound-channel-adapter>
元素允许您将数据发送到 void
方法。如 消息网关 中所述,<int:gateway>
元素允许任何 Java 程序调用消息流。所有这些都不需要在源代码级别依赖 Spring Integration。在此上下文中,出站网关的等效方法是使用服务激活器(参见 服务激活器)来调用返回某种类型的 Object
的方法。
从版本 5.2.2
开始,所有入站网关都可以配置一个 errorOnTimeout
布尔标志,在下游流在回复超时时间内没有返回回复时抛出一个 MessageTimeoutException
异常。计时器只有在线程将控制权返回给网关时才会启动,因此通常只在下游流是异步的,或者因为某些处理器返回 null
而停止时才有用,例如 filter。此类异常可以在 errorChannel
流中处理,例如为请求客户端生成补偿回复。