集成端点
本节介绍 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.3.5</version>
<type>pom</type>
<scope>import</scope>
</dependency>
</dependencies>
</dependencyManagement>回顾一下
-
入站通道适配器用于单向集成，将数据引入消息应用程序。
-
出站通道适配器用于单向集成，将数据发送出消息应用程序。
-
入站网关用于双向集成流，其中其他一些系统调用消息应用程序并接收回复。
-
出站网关用于双向集成流，其中消息应用程序调用某些外部服务或实体并期望获得结果。
下表总结了各种端点，并提供了指向相应章节的快速链接。
| 模块 | 入站适配器 | 出站适配器 | 入站网关 | 出站网关 |
|---|---|---|---|---|
AMQP |
||||
Apache Camel |
N |
N |
||
Apache Cassandra |
N |
N |
||
Debezium |
N |
N |
N |
|
事件 |
N |
N |
||
Feed |
N |
N |
N |
|
文件 |
N |
|||
FTP(S) |
N |
|||
GraphQL |
N |
N |
N |
|
Hazelcast |
N |
N |
||
HTTP |
||||
JDBC |
N |
|||
JMS |
||||
JMX |
N |
|||
JPA |
N |
|||
Apache Kafka |
||||
邮件 |
N |
N |
||
MongoDB |
N |
N |
||
MQTT |
N |
N |
||
R2DBC |
N |
N |
||
Redis |
Redis 入站通道适配器、Redis 队列入站通道适配器、Redis 存储入站通道适配器、Redis 流入站通道适配器 |
Redis 出站通道适配器、Redis 队列出站通道适配器、RedisStore 出站通道适配器、Redis 流出站通道适配器 |
||
资源 |
N |
N |
N |
|
RSocket |
N |
N |
||
SFTP |
N |
|||
SMB |
N |
|||
STOMP |
N |
N |
||
流 |
N |
N |
||
Syslog |
N |
N |
N |
|
TCP |
||||
UDP |
N |
N |
||
WebFlux |
||||
Web 服务 |
N |
N |
||
Web 套接字 |
N |
N |
||
XMPP |
N |
N |
||
ZeroMQ |
N |
N |
此外，如核心消息传递中所述，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而停止，例如过滤器。此类异常可以在errorChannel流中处理，例如，为请求客户端生成补偿回复。
