此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring Integration 6.3.1！

此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring Integration 6.3.1！

上一节中讨论的网关是同步的，因为发送线程将挂起，直到 收到回复（或发生超时）。 Spring Integration 版本 4.3 添加了一个异步网关，该网关使用 from Spring AMQP。 发送消息时，线程会在发送操作完成后立即返回，并且在收到消息后，将在模板的侦听器容器线程上发送回复。 在轮询器线程上调用网关时，这可能很有用。 线程已释放，可用于框架中的其他任务。AsyncRabbitTemplate

以下清单显示了 AMQP 异步出站网关的可能配置选项：

  • Java DSL

  • Java

  • XML

@Configuration
public class AmqpAsyncApplication {

    @Bean
    public IntegrationFlow asyncAmqpOutbound(AsyncRabbitTemplate asyncRabbitTemplate) {
        return f -> f
                .handle(Amqp.asyncOutboundGateway(asyncRabbitTemplate)
                        .routingKey("queue1")); // default exchange - route to queue 'queue1'
    }

    @MessagingGateway(defaultRequestChannel = "asyncAmqpOutbound.input")
    public interface MyGateway {

        String sendToRabbit(String data);

    }

}
@Configuration
public class AmqpAsyncConfig {

    @Bean
    @ServiceActivator(inputChannel = "amqpOutboundChannel")
    public AsyncAmqpOutboundGateway amqpOutbound(AsyncRabbitTemplate asyncTemplate) {
        AsyncAmqpOutboundGateway outbound = new AsyncAmqpOutboundGateway(asyncTemplate);
        outbound.setRoutingKey("foo"); // default exchange - route to queue 'foo'
        return outbound;
    }

    @Bean
    public AsyncRabbitTemplate asyncTemplate(RabbitTemplate rabbitTemplate,
                     SimpleMessageListenerContainer replyContainer) {

        return new AsyncRabbitTemplate(rabbitTemplate, replyContainer);
    }

    @Bean
    public SimpleMessageListenerContainer replyContainer() {
        SimpleMessageListenerContainer container = new SimpleMessageListenerContainer(ccf);
        container.setQueueNames("asyncRQ1");
        return container;
    }

    @Bean
    public MessageChannel amqpOutboundChannel() {
        return new DirectChannel();
    }

}
<int-amqp:outbound-async-gateway id="asyncOutboundGateway"    (1)
                           request-channel="myRequestChannel" (2)
                           async-template=""                  (3)
                           exchange-name=""                   (4)
                           exchange-name-expression=""        (5)
                           order="1"                          (6)
                           reply-channel=""                   (7)
                           reply-timeout=""                   (8)
                           requires-reply=""                  (9)
                           routing-key=""                     (10)
                           routing-key-expression=""          (11)
                           default-delivery-mode""            (12)
                           confirm-correlation-expression=""  (13)
                           confirm-ack-channel=""             (14)
                           confirm-nack-channel=""            (15)
                           confirm-timeout=""                 (16)
                           return-channel=""                  (17)
                           lazy-connect="true" />             (18)
1 此适配器的唯一 ID。 自选。
2 应将消息发送到的消息通道，以便将消息转换并发布到 AMQP 交换。 必填。
3 Bean 引用配置的 . 可选（默认为 ）。AsyncRabbitTemplateasyncRabbitTemplate
4 应将消息发送到的 AMQP 交换的名称。 如果未提供，则将消息发送到默认的无名交换。 与“exchange-name-expression”互斥。 自选。
5 一个 SpEL 表达式，该表达式经过计算以确定将消息发送到的 AMQP 交换的名称，并将该消息作为根对象。 如果未提供，则将消息发送到默认的无名交换。 与“交换名称”互斥。 自选。
6 注册多个使用者时此使用者的顺序，从而启用负载平衡和故障转移。 可选（默认为 ）。Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]
7 从 AMQP 队列接收回复并转换后应将回复发送到的消息通道。 自选。
8 网关在向 . 这仅适用于 can 阻塞的情况，例如容量限制当前已满。 默认值为无穷大。reply-channelreply-channelQueueChannel
9 如果在属性中未收到任何回复消息，并且此设置为 ，网关将向入站消息的标头发送错误消息。 如果在属性中未收到回复消息，并且此设置为 ，网关将向默认值（如果可用）发送错误消息。 它默认为 。AsyncRabbitTemplate’s `receiveTimeouttrueerrorChannelAsyncRabbitTemplate’s `receiveTimeoutfalseerrorChanneltrue
10 发送消息时使用的路由键。 默认情况下，这是一个空的 . 与“routing-key-expression”互斥。 自选。String
11 一个 SpEL 表达式，该表达式经过计算以确定发送消息时要使用的路由键， 将消息作为根对象（例如，“payload.key”）。 默认情况下，这是一个空的 . 与“routing-key”互斥。 自选。String
12 消息的默认传递模式：或 . 如果设置了交付模式，则被覆盖。 如果存在 Spring Integration 消息头 （），则设置值。 如果未提供此属性，并且标头映射器未设置此属性，则默认值取决于 . 如果未自定义，则默认值为 。 自选。PERSISTENTNON_PERSISTENTheader-mapperamqp_deliveryModeDefaultHeaderMapperMessagePropertiesConverterRabbitTemplatePERSISTENT
13 定义相关数据的表达式。 提供后，这会将基础 AMQP 模板配置为接收发布者确认。 需要专用的 和 a，其属性设置为 。 当收到发布者确认并提供相关数据时，确认将写入 或 ，具体取决于确认类型。 确认的有效负载是此表达式定义的关联数据，消息的“amqp_publishConfirm”标头设置为 （） 或 （）。 例如，提供了一个额外的标头 （）。 例子：。 如果表达式解析为实例（如“#this”），则在 / 通道上发出的消息基于该消息，并添加了其他标头。 另请参阅发布者确认和退货的替代机制。 自选。RabbitTemplateCachingConnectionFactorypublisherConfirmstrueconfirm-ack-channelconfirm-nack-channeltrueackfalsenacknackamqp_publishConfirmNackCauseheaders['myCorrelationData']payloadMessage<?>acknack
14 向其发送正面 （） 发布者确认的渠道。 有效负载是由 定义的关联数据。 要求基础将其属性设置为 。 另请参阅发布者确认和退货的替代机制。 可选（默认值为 ）。ackconfirm-correlation-expressionAsyncRabbitTemplateenableConfirmstruenullChannel
15 从 4.2 版开始。 向否定 （） 发布者确认发送的渠道。 有效负载是由 定义的关联数据。 要求基础将其属性设置为 。 另请参阅发布者确认和退货的替代机制。 可选（默认值为 ）。nackconfirm-correlation-expressionAsyncRabbitTemplateenableConfirmstruenullChannel
16 设置后，如果在此时间内未收到发布者确认（以毫秒为单位），网关将合成否定确认 （nack）。 每 50% 检查一次挂起的确认，因此发送 nack 的实际时间将介于此值的 1 倍到 1.5 倍之间。 另请参阅发布者确认和退货的替代机制。 默认值为 non（不会生成 nacks）。
17 将返回的消息发送到的通道。 提供后，基础 AMQP 模板配置为将无法送达的消息返回到网关。 该消息是根据从 AMQP 接收的数据构造的，并具有以下附加标头：、 、 和 。 要求基础将其属性设置为 。 另请参阅发布者确认和退货的替代机制。 自选。amqp_returnReplyCodeamqp_returnReplyTextamqp_returnExchangeamqp_returnRoutingKeyAsyncRabbitTemplatemandatorytrue
18 设置为 时，端点将在应用程序上下文初始化期间尝试连接到代理。 这样做可以“快速”检测错误配置，方法是在代理关闭时记录错误消息。 当（默认值）时，建立连接（如果由于建立了其他组件而尚不存在 it） 发送第一条消息时。falsetrue
1 此适配器的唯一 ID。 自选。
2 应将消息发送到的消息通道，以便将消息转换并发布到 AMQP 交换。 必填。
3 Bean 引用配置的 . 可选（默认为 ）。AsyncRabbitTemplateasyncRabbitTemplate
4 应将消息发送到的 AMQP 交换的名称。 如果未提供，则将消息发送到默认的无名交换。 与“exchange-name-expression”互斥。 自选。
5 一个 SpEL 表达式，该表达式经过计算以确定将消息发送到的 AMQP 交换的名称，并将该消息作为根对象。 如果未提供，则将消息发送到默认的无名交换。 与“交换名称”互斥。 自选。
6 注册多个使用者时此使用者的顺序，从而启用负载平衡和故障转移。 可选（默认为 ）。Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]
7 从 AMQP 队列接收回复并转换后应将回复发送到的消息通道。 自选。
8 网关在向 . 这仅适用于 can 阻塞的情况，例如容量限制当前已满。 默认值为无穷大。reply-channelreply-channelQueueChannel
9 如果在属性中未收到任何回复消息，并且此设置为 ，网关将向入站消息的标头发送错误消息。 如果在属性中未收到回复消息，并且此设置为 ，网关将向默认值（如果可用）发送错误消息。 它默认为 。AsyncRabbitTemplate’s `receiveTimeouttrueerrorChannelAsyncRabbitTemplate’s `receiveTimeoutfalseerrorChanneltrue
10 发送消息时使用的路由键。 默认情况下，这是一个空的 . 与“routing-key-expression”互斥。 自选。String
11 一个 SpEL 表达式，该表达式经过计算以确定发送消息时要使用的路由键， 将消息作为根对象（例如，“payload.key”）。 默认情况下，这是一个空的 . 与“routing-key”互斥。 自选。String
12 消息的默认传递模式：或 . 如果设置了交付模式，则被覆盖。 如果存在 Spring Integration 消息头 （），则设置值。 如果未提供此属性，并且标头映射器未设置此属性，则默认值取决于 . 如果未自定义，则默认值为 。 自选。PERSISTENTNON_PERSISTENTheader-mapperamqp_deliveryModeDefaultHeaderMapperMessagePropertiesConverterRabbitTemplatePERSISTENT
13 定义相关数据的表达式。 提供后，这会将基础 AMQP 模板配置为接收发布者确认。 需要专用的 和 a，其属性设置为 。 当收到发布者确认并提供相关数据时，确认将写入 或 ，具体取决于确认类型。 确认的有效负载是此表达式定义的关联数据，消息的“amqp_publishConfirm”标头设置为 （） 或 （）。 例如，提供了一个额外的标头 （）。 例子：。 如果表达式解析为实例（如“#this”），则在 / 通道上发出的消息基于该消息，并添加了其他标头。 另请参阅发布者确认和退货的替代机制。 自选。RabbitTemplateCachingConnectionFactorypublisherConfirmstrueconfirm-ack-channelconfirm-nack-channeltrueackfalsenacknackamqp_publishConfirmNackCauseheaders['myCorrelationData']payloadMessage<?>acknack
14 向其发送正面 （） 发布者确认的渠道。 有效负载是由 定义的关联数据。 要求基础将其属性设置为 。 另请参阅发布者确认和退货的替代机制。 可选（默认值为 ）。ackconfirm-correlation-expressionAsyncRabbitTemplateenableConfirmstruenullChannel
15 从 4.2 版开始。 向否定 （） 发布者确认发送的渠道。 有效负载是由 定义的关联数据。 要求基础将其属性设置为 。 另请参阅发布者确认和退货的替代机制。 可选（默认值为 ）。nackconfirm-correlation-expressionAsyncRabbitTemplateenableConfirmstruenullChannel
16 设置后，如果在此时间内未收到发布者确认（以毫秒为单位），网关将合成否定确认 （nack）。 每 50% 检查一次挂起的确认，因此发送 nack 的实际时间将介于此值的 1 倍到 1.5 倍之间。 另请参阅发布者确认和退货的替代机制。 默认值为 non（不会生成 nacks）。
17 将返回的消息发送到的通道。 提供后，基础 AMQP 模板配置为将无法送达的消息返回到网关。 该消息是根据从 AMQP 接收的数据构造的，并具有以下附加标头：、 、 和 。 要求基础将其属性设置为 。 另请参阅发布者确认和退货的替代机制。 自选。amqp_returnReplyCodeamqp_returnReplyTextamqp_returnExchangeamqp_returnRoutingKeyAsyncRabbitTemplatemandatorytrue
18 设置为 时，端点将在应用程序上下文初始化期间尝试连接到代理。 这样做可以“快速”检测错误配置，方法是在代理关闭时记录错误消息。 当（默认值）时，建立连接（如果由于建立了其他组件而尚不存在 it） 发送第一条消息时。falsetrue

有关详细信息，另请参阅异步服务激活器。

兔子模板

当您使用确认和退货时，我们建议将接线接入专用。 否则，可能会遇到意想不到的副作用。RabbitTemplateAsyncRabbitTemplate
兔子模板

当您使用确认和退货时，我们建议将接线接入专用。 否则，可能会遇到意想不到的副作用。RabbitTemplateAsyncRabbitTemplate