该版本仍在开发中,尚未被视为稳定。请使用最新的稳定版本,使用 Spring AMQP 4.0.0!spring-doc.cadn.net.cn

Spring集成 - 参考文献

参考文档的这一部分简要介绍了 Spring 集成项目中的 AMQP 支持。spring-doc.cadn.net.cn

介绍

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

由于AMQP适配器是Spring Integration版本的一部分,相关文档作为Spring Integration发行版的一部分提供。 我们在这里简要介绍了主要功能。 更多细节请参见 Spring Integration 参考指南spring-doc.cadn.net.cn

入站通道适配器

要从队列接收AMQP消息,可以配置<入站通道适配器>. 以下示例展示了如何配置入站通道适配器:spring-doc.cadn.net.cn

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

出站通道适配器

要向交换机发送AMQP消息,可以配置<出站通道适配器>. 你可以选择在交换机名称外提供一个“路由密钥”。 以下示例展示了如何定义出站通道适配器:spring-doc.cadn.net.cn

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

入站网关

要从队列接收AMQP消息并回复其回复地址,您可以配置<入站网关>. 以下示例展示了如何定义入站网关:spring-doc.cadn.net.cn

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

出站网关

要将AMQP消息发送到交换机并接收来自远程客户端的回应,您可以配置<出站网关>. 你可以选择在交换机名称外提供一个“路由密钥”。 以下示例展示了如何定义出站网关:spring-doc.cadn.net.cn

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