出站网关

以下列表显示了 AMQP 出站网关的可能属性

Java DSL
Java
XML

@Bean
public IntegrationFlow amqpOutbound(AmqpTemplate amqpTemplate) {
    return f -> f.handle(Amqp.outboundGateway(amqpTemplate)
                    .routingKey("foo")) // default exchange - route to queue 'foo'
            .get();
}

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

    String sendToRabbit(String data);

}

@Bean
@ServiceActivator(inputChannel = "amqpOutboundChannel")
public AmqpOutboundEndpoint amqpOutbound(AmqpTemplate amqpTemplate) {
    AmqpOutboundEndpoint outbound = new AmqpOutboundEndpoint(amqpTemplate);
    outbound.setExpectReply(true);
    outbound.setRoutingKey("foo"); // default exchange - route to queue 'foo'
    return outbound;
}

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

@MessagingGateway(defaultRequestChannel = "amqpOutboundChannel")
public interface MyGateway {

    String sendToRabbit(String data);

}

<int-amqp:outbound-gateway id="outboundGateway"               (1)
                           request-channel="myRequestChannel" (2)
                           amqp-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)
                           error-message-strategy=""          (18)
                           lazy-connect="true" />             (19)

1	此适配器的唯一 ID。可选。
2	消息通道，将消息发送到该通道以将其转换为 AMQP 交换机并发布到该交换机。必需。
3	对已配置的 AMQP 模板的 Bean 引用。可选（默认为 `amqpTemplate`）。
4	要将消息发送到的 AMQP 交换机的名称。如果未提供，则消息将发送到默认的无名交换机。与 'exchange-name-expression' 互斥。可选。
5	一个 SpEL 表达式，用于评估要将消息发送到的 AMQP 交换机的名称，其中消息作为根对象。如果未提供，则消息将发送到默认的无名交换机。与 'exchange-name' 互斥。可选。
6	当注册多个使用者时，此使用者的顺序，从而启用负载均衡和故障转移。可选（默认为 `Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]`）。
7	消息通道，在从 AMQP 队列接收消息并转换后，应将回复发送到该通道。可选。
8	网关在将回复消息发送到 `reply-channel` 时等待的时间。这仅适用于 `reply-channel` 可以阻塞的情况，例如，具有容量限制且当前已满的 `QueueChannel`。默认为无穷大。
9	当为 `true` 时，如果在 `AmqpTemplate` 的 `replyTimeout` 属性内未收到回复消息，则网关将抛出异常。默认为 `true`。
10	发送消息时要使用的 `routing-key`。默认情况下，这是一个空 `String`。与 'routing-key-expression' 互斥。可选。
11	一个 SpEL 表达式，用于评估发送消息时要使用的 `routing-key`，其中消息作为根对象（例如，'payload.key'）。默认情况下，这是一个空 `String`。与 'routing-key' 互斥。可选。
12	消息的默认传递模式：`PERSISTENT` 或 `NON_PERSISTENT`。如果 `header-mapper` 设置了传递模式，则会被覆盖。如果存在 Spring Integration 消息头 `amqp_deliveryMode`，则 `DefaultHeaderMapper` 会设置该值。如果未提供此属性并且头映射器未设置它，则默认值取决于 `RabbitTemplate` 使用的底层 Spring AMQP `MessagePropertiesConverter`。如果根本没有自定义它，则默认值为 `PERSISTENT`。可选。
13	从 4.2 版本开始。一个定义相关数据的表达式。当提供时，此配置将配置底层 AMQP 模板以接收发布者确认。需要一个专用的 `RabbitTemplate` 和一个 `CachingConnectionFactory`，其 `publisherConfirms` 属性设置为 `true`。当收到发布者确认并提供相关数据时，它将写入 `confirm-ack-channel` 或 `confirm-nack-channel`，具体取决于确认类型。确认的有效负载是相关数据，由此表达式定义。消息有一个标题“amqp_publishConfirm”设置为 `true`（`ack`）或 `false`（`nack`）。对于 `nack` 确认，Spring Integration 提供了额外的标题 `amqp_publishConfirmNackCause`。示例：`headers['myCorrelationData']` 和 `payload`。如果表达式解析为 `Message<?>` 实例（例如 `#this`），则在 `ack`/`nack` 通道上发出的消息基于该消息，并添加了额外的标题。以前，会创建一个新消息，其有效负载为相关数据，与类型无关。另请参阅发布者确认和返回的替代机制。可选。
14	发送正向（`ack`）发布者确认的通道。有效负载是 `confirm-correlation-expression` 定义的相关数据。如果表达式为 `#root` 或 `#this`，则消息将从原始消息构建，并设置 `amqp_publishConfirm` 标题为 `true`。另请参阅发布者确认和返回的替代机制。可选（默认值为 `nullChannel`）。
15	发送负向（`nack`）发布者确认的通道。有效负载是 `confirm-correlation-expression` 定义的相关数据（如果未配置 `ErrorMessageStrategy`）。如果表达式为 `#root` 或 `#this`，则消息将从原始消息构建，并设置 `amqp_publishConfirm` 标题为 `false`。当存在 `ErrorMessageStrategy` 时，消息是一个 `ErrorMessage`，其 `NackedAmqpMessageException` 有效负载。另请参阅发布者确认和返回的替代机制。可选（默认值为 `nullChannel`）。
16	如果在指定毫秒数内未收到发布者确认，则网关将合成一个负确认（nack）。挂起的确认每隔此值的 50% 检查一次，因此实际发送 nack 的时间将在此值的 1 倍到 1.5 倍之间。默认情况下为 none（不会生成 nack）。
17	返回消息发送到的通道。提供此通道时，底层 AMQP 模板配置为将无法投递的消息返回到适配器。如果没有配置 `ErrorMessageStrategy`，则消息将从 AMQP 收到的数据构建，并包含以下附加标头：`amqp_returnReplyCode`、`amqp_returnReplyText`、`amqp_returnExchange` 和 `amqp_returnRoutingKey`。如果存在 `ErrorMessageStrategy`，则消息为 `ErrorMessage`，其有效负载为 `ReturnedAmqpMessageException`。另请参见发布者确认和返回的替代机制。可选。
18	对用于构建 `ErrorMessage` 实例的 `ErrorMessageStrategy` 实现的引用，用于发送返回或负确认的消息。
19	如果设置为 `false`，则端点会在应用程序上下文初始化期间尝试连接到代理。这允许通过在代理关闭时记录错误消息来快速检测错误配置。如果设置为 `true`（默认值），则在发送第一条消息时建立连接（如果由于其他组件建立了连接而尚未存在）。

return-channel

使用 return-channel 需要一个 RabbitTemplate，其 mandatory 属性设置为 true，以及一个 CachingConnectionFactory，其 publisherReturns 属性设置为 true。当使用具有返回的多个出站端点时，每个端点都需要一个单独的 RabbitTemplate。

底层 AmqpTemplate 的默认 replyTimeout 为五秒。如果需要更长的超时时间，则必须在 template 上配置它。

请注意，出站适配器和出站网关配置之间的唯一区别是 expectReply 属性的设置。