集成端点
本节介绍 Spring Integration 提供的各种通道适配器和消息网关，用于支持与外部系统的基于消息的通信。
从 AMQP 到 Zookeeper 的每个系统都有自己的集成要求，本节将介绍这些要求。
端点快速参考表
如前面章节所述，Spring Integration 提供了许多端点，用于与外部系统、文件系统等进行接口。
为了透明的依赖管理，Spring Integration 提供了一个 bill-of-materials POM，可以将其导入 Maven 配置中
<dependencyManagement>
<dependencies>
<dependency>
<groupId>org.springframework.integration</groupId>
<artifactId>spring-integration-bom</artifactId>
<version>6.4.4</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 Store 入站通道适配器, Redis Stream 入站通道适配器 |
Redis 出站通道适配器, Redis 队列出站通道适配器, RedisStore 出站通道适配器, Redis Stream 出站通道适配器 |
||
资源 |
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 Services |
N |
N |
||
Web Sockets |
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 流上处理，例如为请求客户端生成补偿回复。
