此版本仍在开发中，尚不被认为是稳定的。对于最新的稳定版本，请使用 Spring Integration 6.5.1！spring-doc.cadn.net.cn

异步出站网关

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

以下列表显示了 AMQP 异步出站网关的可能配置选项：spring-doc.cadn.net.cn

@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 对已配置的`AsyncRabbitTemplate`. 可选（默认为`asyncRabbitTemplate`).
4	应将消息发送到的 AMQP 交换的名称。如果未提供，则消息将发送到默认的无名交换。与“exchange-name-expression”互斥。自选。
5	一种 SpEL 表达式，用于确定将消息发送到的 AMQP 交换的名称，并将消息作为根对象。如果未提供，则消息将发送到默认的无名交换。与“交易所名称”互斥。自选。
6	注册多个使用者时此使用者的顺序，从而启用负载平衡和故障转移。可选（默认为`Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]`).
7	从 AMQP 队列接收并转换后应将回复发送到的消息通道。自选。
8	网关在将回复消息发送到`reply-channel`. 这仅适用于`reply-channel`可以阻止 — 例如`QueueChannel`当前容量限制已满。默认值为无大。
9	当AsyncRabbitTemplate’s `receiveTimeout属性，并且此设置为`true`，网关会向入站消息的`errorChannel`页眉。当AsyncRabbitTemplate’s `receiveTimeout属性，并且此设置为`false`，则网关向默认`errorChannel`（如果有）。它默认为`true`.
10	发送消息时要使用的路由键。默认情况下，这是一个空的`String`. 与 'routing-key-expression' 互斥。自选。
11	一个 SpEL 表达式，用于确定发送消息时要使用的路由键，将消息作为根对象（例如，'payload.key'）。默认情况下，这是一个空的`String`. 与“路由键”互斥。自选。
12	消息的默认传递模式：`PERSISTENT`或`NON_PERSISTENT`. 如果`header-mapper`设置投放模式。如果 Spring Integration 消息头（`amqp_deliveryMode`）存在，则`DefaultHeaderMapper`设置值。如果未提供此属性并且标头映射器未设置它，则默认值取决于底层 Spring AMQP`MessagePropertiesConverter`由`RabbitTemplate`. 如果未自定义，则默认值为`PERSISTENT`. 自选。
13	定义相关数据的表达式。提供后，这会将基础 AMQP 模板配置为接收发布者确认。需要专用的`RabbitTemplate`和`CachingConnectionFactory`与其`publisherConfirms`属性设置为`true`. 收到发布者确认并提供相关数据时，确认将写入`confirm-ack-channel`或`confirm-nack-channel`，具体取决于确认类型。确认的有效负载是此表达式定义的相关数据，消息的“amqp_publishConfirm”标头设置为`true` (`ack`）或`false` (`nack`). 为`nack`实例，附加标头（`amqp_publishConfirmNackCause`）提供。例子：`headers['myCorrelationData']`,`payload`. 如果表达式解析为`Message<?>`实例（例如“#this”），则在`ack`/`nack`channel 基于该消息，并添加了其他标头。另请参阅发布者确认和返回的替代机制。自选。
14	正（`ack`）发布者确认。有效负载是由`confirm-correlation-expression`. 需要基础`AsyncRabbitTemplate`拥有其`enableConfirms`属性设置为`true`. 另请参阅发布者确认和返回的替代机制。可选（默认值为`nullChannel`).
15	从 4.2 版本开始。负（`nack`）发布者确认。有效负载是由`confirm-correlation-expression`. 需要基础`AsyncRabbitTemplate`拥有其`enableConfirms`属性设置为`true`. 另请参阅发布者确认和返回的替代机制。可选（默认值为`nullChannel`).
16	设置后，如果在此时间内未收到发布者确认，网关将合成否定确认（nack）（以毫秒为单位）。每 50% 检查一次待处理的确认，因此发送 nack 的实际时间将介于该值的 1 倍到 1.5 倍之间。另请参阅发布者确认和返回的替代机制。默认为无（不会生成 nacks）。
17	将返回的消息发送到的通道。提供后，基础 AMQP 模板配置为将无法传递的消息返回到网关。该消息是根据从 AMQP 接收的数据构造的，并带有以下附加标头：`amqp_returnReplyCode`,`amqp_returnReplyText`,`amqp_returnExchange`和`amqp_returnRoutingKey`. 需要基础`AsyncRabbitTemplate`拥有其`mandatory`属性设置为`true`. 另请参阅发布者确认和返回的替代机制。自选。
18	当设置为`false`，则端点在应用程序上下文初始化期间尝试连接到代理。这样做允许在代理关闭时记录错误消息，从而“快速失败”检测错误配置。什么时候`true`（默认值），则建立连接（如果由于建立了其他组件而尚未存在 it）发送第一条消息时。

另请参阅异步服务激活器以获取更多信息。spring-doc.cadn.net.cn

兔子模板

当您使用确认和退货时，我们建议将RabbitTemplate连接到AsyncRabbitTemplate敬业。否则，可能会遇到意想不到的副作用。spring-doc.cadn.net.cn