此版本仍在开发中,尚不被认为是稳定的。对于最新的稳定版本,请使用 Spring Integration 6.5.1! |
集成端点
本节介绍 Spring Integration 提供的各种通道适配器和消息传递网关,以支持与外部系统进行基于消息的通信。
从 AMQP 到 Zookeeper,每个系统都有自己的集成要求,本节介绍了这些要求。
端点快速参考表
如前几节所述,Spring Integration 提供了许多用于与外部系统、文件系统等交互的端点。
为了实现透明的依赖管理,Spring Integration 提供了一个要导入到 Maven 配置中的物料清单 POM:
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-bom</artifactId>
<version>6.5.2-SNAPSHOT</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>
回顾一下:
-
入站通道适配器用于单向集成,以将数据引入消息传递应用程序。
-
出站通道适配器用于单向集成,以将数据发送出消息传递应用程序。
-
入站网关用于双向集成流,其中其他系统调用消息传递应用程序并接收回复。
-
出站网关用于双向集成流,其中消息传递应用程序调用某些外部服务或实体并期望结果。
下表总结了各种端点,并提供了指向相应章节的快速链接。
模块 | 入站适配器 | 出站适配器 | 入站网关 | 出站网关 |
---|---|---|---|---|
AMQP |
||||
阿帕奇骆驼 |
N |
N |
||
Apache Cassandra |
N |
N |
||
德贝齐姆 |
N |
N |
N |
|
事件 |
N |
N |
||
饲料 |
N |
N |
N |
|
文件 |
N |
|||
FTP(S) |
N |
|||
图形QL |
N |
N |
N |
|
榛铸 |
N |
N |
||
HTTP |
||||
JDBC 公司 |
N |
|||
JMS系统 |
||||
JMX公司 |
N |
|||
JPA的 |
N |
|||
阿帕奇卡夫卡 |
||||
邮件 |
N |
N |
||
Mongo数据库 |
N |
N |
||
MQTT的 |
N |
N |
||
R2DBC |
N |
N |
||
Redis |
Redis 入站通道适配器、Redis 队列入站通道适配器、Redis Store 入站通道适配器、Redis Stream 入站通道适配器 |
Redis 出站通道适配器、Redis 队列出站通道适配器、RedisStore 出站通道适配器、Redis 流出站通道适配器 |
||
资源 |
N |
N |
N |
|
RS袜子 |
N |
N |
||
SFTP |
N |
|||
中小型企业 |
N |
|||
STOMP |
N |
N |
||
流 |
N |
N |
||
系统日志 |
N |
N |
N |
|
TCP的 |
||||
UDP的 |
N |
N |
||
WebFlux (网络通量) |
||||
Web 服务 |
N |
N |
||
Web 套接字 |
N |
N |
||
XMPP的 |
N |
N |
||
零MQ |
N |
N |
此外,正如 Core Messaging 中所讨论的,Spring Integration 提供了用于与普通旧 Java 对象 (POJO) 交互的端点。
如 Channel Adapter 中所述,<int:inbound-channel-adapter>
元素允许您轮询 Java 方法以获取数据。
这<int:outbound-channel-adapter>
元素允许您将数据发送到void
方法。
如消息网关中所述,该<int:gateway>
元素允许任何 Java 程序调用消息传递流。
其中每一个都不需要对 Spring Integration 进行任何源级依赖。
在此上下文中,出站网关的等效方法是使用服务激活器(请参阅服务激活器)调用返回Object
某种。
从版本开始5.2.2
,则所有入站网关都可以配置errorOnTimeout
布尔标志来抛出一个MessageTimeoutException
当下游流在回复超时期间未返回回复时。
计时器直到线程将控制权返回给网关后才会启动,因此通常它仅在下游流异步或由于null
从某个处理程序返回,例如 filter。
此类异常可以在errorChannel
流程,例如为请求的客户提供补偿回复。