跳到主要内容

出站网关

QWen Plus 中英对照 Outbound Gateway

以下列表显示了 AMQP 外发网关的可能属性：

@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);

}
java

  • 适配器的唯一 ID。可选。

  • 消息通道，消息将通过此通道发送以进行转换并发布到 AMQP 交换。必需。

  • 配置的 AMQP 模板的 Bean 引用。可选（默认为 amqpTemplate）。

  • 消息应发送到的 AMQP 交换的名称。如果未提供，消息将发送到默认的无名交换。与 'exchange-name-expression' 互斥。可选。

  • 用于确定消息应发送到的 AMQP 交换名称的 SpEL 表达式，消息作为根对象。如果未提供，消息将发送到默认的无名交换。与 'exchange-name' 互斥。可选。

  • 当注册多个消费者时，此消费者的顺序，从而实现负载均衡和故障转移。可选（默认为 Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]）。

  • 回复应在此接收来自 AMQP 队列的消息并进行转换后发送到的消息通道。可选。

  • 网关在向 reply-channel 发送回复消息时等待的时间。这仅适用于 reply-channel 可能阻塞的情况——例如容量已满的 QueueChannel。默认为无穷大。

  • 当设置为 true 时，如果在 AmqpTemplate 的 replyTimeout 属性内没有收到回复消息，网关会抛出异常。默认为 true。

  • 发送消息时使用的 routing-key。默认情况下，这是一个空的 String。与 'routing-key-expression' 互斥。可选。

  • 用于确定发送消息时使用的 routing-key 的 SpEL 表达式，消息作为根对象（例如 'payload.key'）。默认情况下，这是一个空的 String。与 'routing-key' 互斥。可选。

  • 消息的默认传递模式：PERSISTENT 或 NON_PERSISTENT。如果 header-mapper 设置了传递模式，则会覆盖该值。如果存在 Spring Integration 消息头 amqp_deliveryMode，DefaultHeaderMapper 会设置该值。如果未提供此属性且头映射器未设置它，则默认取决于底层 Spring AMQP MessagePropertiesConverter 使用的 RabbitTemplate。如果没有完全自定义，默认是 PERSISTENT。可选。

  • 自版本 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 通道上发出的消息基于该消息，并添加了额外的头。以前，无论类型如何，都会创建一个新消息，其有效载荷是相关数据。另请参阅 发布确认和返回的替代机制。可选。

  • 正面 (ack) 发布确认发送到的通道。有效载荷是由 confirm-correlation-expression 定义的相关数据。如果表达式是 #root 或 #this，则消息是从原始消息构建的，并设置了 amqp_publishConfirm 头为 true。另请参阅 发布确认和返回的替代机制。可选（默认是 nullChannel）。

  • 负面 (nack) 发布确认发送到的通道。有效载荷是由 confirm-correlation-expression 定义的相关数据（如果没有配置 ErrorMessageStrategy）。如果表达式是 #root 或 #this，则消息是从原始消息构建的，并设置了 amqp_publishConfirm 头为 false。当有 ErrorMessageStrategy 时，消息是一个带有 NackedAmqpMessageException 有效载荷的 ErrorMessage。另请参阅 发布确认和返回的替代机制。可选（默认是 nullChannel）。

  • 设置后，如果在指定毫秒内未收到发布确认，网关将合成一个负面确认 (nack)。每 50% 的这个值检查一次待确认的消息，因此实际发送 nack 的时间会在 1x 到 1.5x 这个值之间。默认无（不会生成 nacks）。

  • 返回消息发送到的通道。当提供时，底层 AMQP 模板被配置为将无法投递的消息返回给适配器。当没有配置 ErrorMessageStrategy 时，消息由从 AMQP 接收到的数据构建，并具有以下附加头：amqp_returnReplyCode、amqp_returnReplyText、amqp_returnExchange 和 amqp_returnRoutingKey。当有 ErrorMessageStrategy 时，消息是一个带有 ReturnedAmqpMessageException 有效载荷的 ErrorMessage。另请参阅 发布确认和返回的替代机制。可选。

  • 用于构建 ErrorMessage 实例的 ErrorMessageStrategy 实现的引用，当发送返回或负面确认的消息时使用。

  • 设置为 false 时，端点尝试在应用程序上下文初始化期间连接到代理。这允许通过在代理不可用时记录错误消息来快速检测不良配置。当设置为 true（默认值）时，在发送第一条消息时建立连接（如果由于其他组件已经建立了连接而不存在，则不会重新建立）。

important

返回通道

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

important

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

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