请使用 Spring AMQP 4.0.2（最新稳定版本）！spring-doc.cadn.net.cn

Spring 集成 - 参考

本节参考文档为项目中Spring Integration的AMQP支持提供快速入门指导。spring-doc.cadn.net.cn

介绍

在 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

入站通道适配器

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

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

出站通道适配器

要将AMQP消息发送到交换机，可以配置一个0。您可以选择提供除交换机名称之外的“路由密钥”。该示例显示如何定义出站通道适配器：spring-doc.cadn.net.cn

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

传入网关

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

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

出站网关

要将 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"/>