此版本仍在开发中,尚未被视为稳定版本。对于最新的稳定版本,请使用 Spring AMQP 3.2.0spring-doc.cn

Spring 集成 - 参考

参考文档的这一部分提供了对 Spring 集成项目中 AMQP 支持的快速介绍。spring-doc.cn

介绍

Spring 集成项目包括基于 Spring AMQP 项目构建的 AMQP 通道适配器和网关。 这些适配器是在 Spring Integration 项目中开发和发布的。 在 Spring 集成中,“通道适配器”是单向的(单向的),而“网关”是双向的(请求-回复)。 我们提供 inbound-channel-adapter、outbound-channel-adapter、inbound-gateway 和 outbound-gateway。spring-doc.cn

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

入站通道适配器

要从队列接收 AMQP 消息,您可以配置 . 以下示例说明如何配置入站通道适配器:<inbound-channel-adapter>spring-doc.cn

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

出站通道适配器

要将 AMQP 消息发送到交换,您可以配置 . 除了交换名称之外,您还可以选择提供 'routing-key'。 以下示例说明如何定义出站通道适配器:<outbound-channel-adapter>spring-doc.cn

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

入站网关

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

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

出站网关

要将 AMQP 消息发送到交换并接收来自远程客户端的响应,您可以配置一个 . 除了交换名称之外,您还可以选择提供 'routing-key'。 以下示例显示如何定义出站网关:<outbound-gateway>spring-doc.cn

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