5. Spring Integration - 参考

参考文档的这一部分快速介绍了 Spring Integration 项目中的 AMQP 支持。spring-doc.cadn.net.cn

5.1. Spring Integration AMQP 支持

本简短的章节介绍了 Spring Integration 和 Spring AMQP 项目之间的关系。spring-doc.cadn.net.cn

5.1.1. 简介

Spring Integration 项目包括基于 Spring AMQP 项目构建的 AMQP 通道适配器和网关。这些适配器是在 Spring Integration 项目中开发和发布的。在 Spring Integration 中，“通道适配器”是单向的（单向），而“网关”是双向的（请求-回复）。我们提供入站通道适配器、出站通道适配器、入站网关和出站网关。spring-doc.cadn.net.cn

由于 AMQP 适配器是 Spring Integration 版本的一部分，因此该文档可作为 Spring Integration 发行版的一部分提供。我们在此处提供了主要功能的快速概述。有关更多详细信息，请参阅 Spring Integration 参考指南。spring-doc.cadn.net.cn

5.1.2. 入站通道适配器

要从队列接收 AMQP 消息，您可以配置<inbound-channel-adapter>. 以下示例显示如何配置入站通道适配器：spring-doc.cadn.net.cn

<amqp:inbound-channel-adapter channel="fromAMQP"
                              queue-names="some.queue"
                              connection-factory="rabbitConnectionFactory"/>

5.1.3. 出站通道适配器

要将 AMQP 消息发送到交换，您可以配置<outbound-channel-adapter>. 除了交换名称之外，还可以选择提供“路由键”。以下示例演示如何定义出站通道适配器：spring-doc.cadn.net.cn

<amqp:outbound-channel-adapter channel="toAMQP"
                               exchange-name="some.exchange"
                               routing-key="foo"
                               amqp-template="rabbitTemplate"/>

5.1.4. 入站网关

要从队列接收 AMQP 消息并响应其回复地址，您可以配置<inbound-gateway>. 以下示例演示如何定义入站网关：spring-doc.cadn.net.cn

<amqp:inbound-gateway request-channel="fromAMQP"
                      reply-channel="toAMQP"
                      queue-names="some.queue"
                      connection-factory="rabbitConnectionFactory"/>

5.1.5. 出站网关

要将 AMQP 消息发送到交换并从远程客户端接收回响应，您可以配置<outbound-gateway>. 除了交换名称之外，还可以选择提供“路由密钥”。以下示例演示如何定义出站网关：spring-doc.cadn.net.cn

<amqp:outbound-gateway request-channel="toAMQP"
                       reply-channel="fromAMQP"
                       exchange-name="some.exchange"
                       routing-key="foo"
                       amqp-template="rabbitTemplate"/>