Spring Integration - 參考文件

參考文件的這個部分簡要介紹了 Spring Integration 專案中的 AMQP 支援。

簡介

Spring Integration 專案包含 AMQP 通道适配器和閘道器，它們建立在 Spring AMQP 專案之上。這些适配器在 Spring Integration 專案中開發和發布。在 Spring Integration 中，「通道适配器」是單向的（單向），而「閘道器」是雙向的（請求-回覆）。我們提供了一個輸入通道适配器、一個輸出通道适配器、一個輸入閘道器和一個輸出閘道器。

由於 AMQP 适配器是 Spring Integration 發行版的一部分，因此文件作為 Spring Integration 發行版的一部分提供。我們在此處快速概述主要功能。有關更多詳細資訊，請參閱 Spring Integration 參考指南。

輸入通道适配器

若要從佇列接收 AMQP 訊息，您可以設定 <inbound-channel-adapter>。以下範例顯示如何設定輸入通道适配器

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

輸出通道适配器

若要將 AMQP 訊息發送到交換器，您可以設定 <outbound-channel-adapter>。除了交換器名稱之外，您還可以選擇性地提供 'routing-key'。以下範例顯示如何定義輸出通道适配器

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

輸入閘道器

若要從佇列接收 AMQP 訊息並回覆其 reply-to 位址，您可以設定 <inbound-gateway>。以下範例顯示如何定義輸入閘道器

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

輸出閘道器

若要將 AMQP 訊息發送到交換器並從遠端用戶端接收回覆應，您可以設定 <outbound-gateway>。除了交換器名稱之外，您還可以選擇性地提供 'routing-key'。以下範例顯示如何定義輸出閘道器

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