4. Spring 集成-参考

参考文档的这一部分提供了 Spring Integration 项目中对 AMQP 支持的快速介绍。

4.1 Spring Integration AMQP 支持

4.1.1 Introduction

Spring Integration项目包括基于 Spring AMQP 项目构建的 AMQP 通道适配器和网关。这些适配器是在 Spring Integration 项目中开发和发布的。在 Spring Integration 中,“通道适配器”是单向的(单向),而“网关”是双向的(请求-应答)。我们提供了入站通道适配器,出站通道适配器,入站网关和出站网关。

由于 AMQP 适配器是 Spring Integration 版本的一部分,因此该文档将作为 Spring Integration 发行版的一部分提供。作为品尝者,我们仅在此处简要概述主要功能。

4.1.2 入站通道适配器

要从队列接收 AMQP 消息,请配置\

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

4.1.3 出站通道适配器

要将 AMQP 邮件发送到 Exchange,请配置\ 。除交换名称外,还可以选择提供路由键

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

4.1.4 入站网关

要从队列接收 AMQP 消息并响应其回复地址,请配置\ 。

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

4.1.5 出站网关

要将 AMQP 邮件发送到 Exchange 并接收来自远程 Client 端的响应,请配置\ 。除交换名称外,还可以选择提供路由键

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