对于最新的稳定版本，请使用 Spring Integration 6.3.1！Spring中文文档

对于最新的稳定版本，请使用 Spring Integration 6.3.1！Spring中文文档

以下示例显示了 AMQP 出站通道适配器的可用属性：Spring中文文档

@Bean
public IntegrationFlow amqpOutbound(AmqpTemplate amqpTemplate,
        MessageChannel amqpOutboundChannel) {
    return IntegrationFlow.from(amqpOutboundChannel)
            .handle(Amqp.outboundAdapter(amqpTemplate)
                        .routingKey("queue1")) // default exchange - route to queue 'queue1'
            .get();
}
@Bean
@ServiceActivator(inputChannel = "amqpOutboundChannel")
public AmqpOutboundEndpoint amqpOutbound(AmqpTemplate amqpTemplate) {
    AmqpOutboundEndpoint outbound = new AmqpOutboundEndpoint(amqpTemplate);
    outbound.setRoutingKey("queue1"); // default exchange - route to queue 'queue1'
    return outbound;
}

@Bean
public MessageChannel amqpOutboundChannel() {
    return new DirectChannel();
}
<int-amqp:outbound-channel-adapter id="outboundAmqp"             (1)
                               channel="outboundChannel"         (2)
                               amqp-template="myAmqpTemplate"    (3)
                               exchange-name=""                  (4)
                               exchange-name-expression=""       (5)
                               order="1"                         (6)
                               routing-key=""                    (7)
                               routing-key-expression=""         (8)
                               default-delivery-mode""           (9)
                               confirm-correlation-expression="" (10)
                               confirm-ack-channel=""            (11)
                               confirm-nack-channel=""           (12)
                               confirm-timeout=""                (13)
                               wait-for-confirm=""               (14)
                               return-channel=""                 (15)
                               error-message-strategy=""         (16)
                               header-mapper=""                  (17)
                               mapped-request-headers=""         (18)
                               lazy-connect="true"               (19)
                               multi-send="false"/>              (20)
1 此适配器的唯一 ID。 自选。
2 应将消息发送到的消息通道，以便将消息转换并发布到 AMQP 交换。 必填。
3 对已配置的 AMQP 模板的 Bean 引用。 可选（默认为 ）。amqpTemplate
4 将消息发送到的 AMQP 交换的名称。 如果未提供，则将消息发送到默认的无名交换。 与“exchange-name-expression”互斥。 自选。
5 一个 SpEL 表达式，该表达式经过计算以确定将消息发送到的 AMQP 交换的名称，并将该消息作为根对象。 如果未提供，则将消息发送到默认的无名交换。 与“交换名称”互斥。 自选。
6 注册多个使用者时此使用者的顺序，从而启用负载平衡和故障转移。 可选（默认为 ）。Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]
7 发送消息时使用的固定路由键。 默认情况下，这是一个空的 . 与“routing-key-expression”互斥。 自选。String
8 一个 SpEL 表达式，该表达式经过计算以确定发送消息时要使用的路由键，并将消息作为根对象（例如，“payload.key”）。 默认情况下，这是一个空的 . 与“routing-key”互斥。 自选。String
9 消息的默认传递模式：或 . 如果设置了交付模式，则被覆盖。 如果存在 Spring Integration 消息标头，则设置值。 如果未提供此属性，并且标头映射器未设置此属性，则默认值取决于 . 如果根本不自定义，则默认值为 。 自选。PERSISTENTNON_PERSISTENTheader-mapperamqp_deliveryModeDefaultHeaderMapperMessagePropertiesConverterRabbitTemplatePERSISTENT
10 定义相关数据的表达式。 提供后，这会将基础 AMQP 模板配置为接收发布者确认。 需要 专用 和 属性设置为 的 。 收到发布者确认并提供关联数据后，会根据确认类型将其写入 或 。 确认的有效负载是相关数据，由此表达式定义。 邮件的“amqp_publishConfirm”标头设置为 （） 或 （）。 示例：和 。 版本 4.1 引入了消息标头。 它包含用于发布者确认的“nack”。 从版本 4.2 开始，如果表达式解析为实例（如 ），则在 / 通道上发出的消息将基于该消息，并添加了额外的标头。 以前，无论类型如何，都会使用关联数据作为其有效负载创建新消息。 另请参阅发布者确认和退货的替代机制。 自选。RabbitTemplateCachingConnectionFactorypublisherConfirmstrueconfirm-ack-channelconfirm-nack-channeltrueackfalsenackheaders['myCorrelationData']payloadamqp_publishConfirmNackCausecauseMessage<?>#thisacknack
11 正 （） 发布者确认发送到的频道。 有效负载是由 定义的关联数据。 如果表达式为 或 ，则从原始消息生成消息，标头设置为 。 另请参阅发布者确认和退货的替代机制。 可选（默认值为 ）。ackconfirm-correlation-expression#root#thisamqp_publishConfirmtruenullChannel
12 向否定 （） 发布者确认发送的渠道。 有效负载是由 定义的关联数据（如果未配置）。 如果表达式为 或 ，则从原始消息生成消息，标头设置为 。 当存在 时，消息是带有有效负载的。 另请参阅发布者确认和退货的替代机制。 可选（默认值为 ）。nackconfirm-correlation-expressionErrorMessageStrategy#root#thisamqp_publishConfirmfalseErrorMessageStrategyErrorMessageNackedAmqpMessageExceptionnullChannel
13 设置后，如果在此时间内未收到发布者确认（以毫秒为单位），适配器将合成否定确认 （nack）。 每 50% 检查一次挂起的确认，因此发送 nack 的实际时间将介于此值的 1 倍到 1.5 倍之间。 另请参阅发布者确认和退货的替代机制。 默认值为 non（不会生成 nacks）。
14 设置为 true 时，调用线程将阻塞，等待发布者确认。 这需要配置一个 for confirming，以及一个 . 线程最多会阻塞（默认为 5 秒）。 如果发生超时，将抛出 a。 如果启用了返回并返回了一条消息，或者在等待确认时发生任何其他异常，则将抛出一个，并附上相应的消息。RabbitTemplateconfirm-correlation-expressionconfirm-timeoutMessageTimeoutExceptionMessageHandlingException
15 将返回的消息发送到的通道。 提供后，基础 AMQP 模板配置为向适配器返回无法传递的消息。 如果未配置，则根据从 AMQP 接收的数据构造消息，并具有以下附加标头：、、、。 当存在 时，消息是带有有效负载的。 另请参阅发布者确认和退货的替代机制。 自选。ErrorMessageStrategyamqp_returnReplyCodeamqp_returnReplyTextamqp_returnExchangeamqp_returnRoutingKeyErrorMessageStrategyErrorMessageReturnedAmqpMessageException
16 对用于在发送返回或否定确认消息时构建实例的实现的引用。ErrorMessageStrategyErrorMessage
17 对发送 AMQP 消息时使用的引用。 默认情况下，只有标准的 AMQP 属性（例如 ）被复制到 Spring Integration 。 默认的“DefaultAmqpHeaderMapper”不会将任何用户定义的标头复制到消息中。 如果提供了“request-header-names”，则不允许。 自选。AmqpHeaderMappercontentTypeMessageHeaders
18 要从 映射到 AMQP 消息的 AMQP 标头的名称的逗号分隔列表。 如果提供了“header-mapper”引用，则不允许。 此列表中的值也可以是与标头名称匹配的简单模式（例如 或或）。MessageHeaders"*""thing1*, thing2""*thing1"
19 设置为 时，端点将在应用程序上下文初始化期间尝试连接到代理。 这允许对错误配置进行“快速故障”检测，但如果代理关闭，也会导致初始化失败。 当（默认值）时，在发送第一条消息时建立连接（如果由于其他组件建立连接而不存在）。falsetrue
20 当设置为 时，类型的有效负载将作为离散消息在单个调用范围内的同一通道上发送。 需要 . 如果为 true，则在发送消息后调用。 使用事务模板时，将在新事务或已启动的事务（如果存在）中执行发送。trueIterable<Message<?>>RabbitTemplateRabbitTemplatewait-for-confirmsRabbitTemplate.waitForConfirmsOrDie()
1 此适配器的唯一 ID。 自选。
2 应将消息发送到的消息通道，以便将消息转换并发布到 AMQP 交换。 必填。
3 对已配置的 AMQP 模板的 Bean 引用。 可选（默认为 ）。amqpTemplate
4 将消息发送到的 AMQP 交换的名称。 如果未提供，则将消息发送到默认的无名交换。 与“exchange-name-expression”互斥。 自选。
5 一个 SpEL 表达式，该表达式经过计算以确定将消息发送到的 AMQP 交换的名称，并将该消息作为根对象。 如果未提供，则将消息发送到默认的无名交换。 与“交换名称”互斥。 自选。
6 注册多个使用者时此使用者的顺序，从而启用负载平衡和故障转移。 可选（默认为 ）。Ordered.LOWEST_PRECEDENCE [=Integer.MAX_VALUE]
7 发送消息时使用的固定路由键。 默认情况下，这是一个空的 . 与“routing-key-expression”互斥。 自选。String
8 一个 SpEL 表达式，该表达式经过计算以确定发送消息时要使用的路由键，并将消息作为根对象（例如，“payload.key”）。 默认情况下，这是一个空的 . 与“routing-key”互斥。 自选。String
9 消息的默认传递模式：或 . 如果设置了交付模式，则被覆盖。 如果存在 Spring Integration 消息标头，则设置值。 如果未提供此属性，并且标头映射器未设置此属性，则默认值取决于 . 如果根本不自定义，则默认值为 。 自选。PERSISTENTNON_PERSISTENTheader-mapperamqp_deliveryModeDefaultHeaderMapperMessagePropertiesConverterRabbitTemplatePERSISTENT
10 定义相关数据的表达式。 提供后，这会将基础 AMQP 模板配置为接收发布者确认。 需要 专用 和 属性设置为 的 。 收到发布者确认并提供关联数据后，会根据确认类型将其写入 或 。 确认的有效负载是相关数据，由此表达式定义。 邮件的“amqp_publishConfirm”标头设置为 （） 或 （）。 示例：和 。 版本 4.1 引入了消息标头。 它包含用于发布者确认的“nack”。 从版本 4.2 开始，如果表达式解析为实例（如 ），则在 / 通道上发出的消息将基于该消息，并添加了额外的标头。 以前，无论类型如何，都会使用关联数据作为其有效负载创建新消息。 另请参阅发布者确认和退货的替代机制。 自选。RabbitTemplateCachingConnectionFactorypublisherConfirmstrueconfirm-ack-channelconfirm-nack-channeltrueackfalsenackheaders['myCorrelationData']payloadamqp_publishConfirmNackCausecauseMessage<?>#thisacknack
11 正 （） 发布者确认发送到的频道。 有效负载是由 定义的关联数据。 如果表达式为 或 ，则从原始消息生成消息，标头设置为 。 另请参阅发布者确认和退货的替代机制。 可选（默认值为 ）。ackconfirm-correlation-expression#root#thisamqp_publishConfirmtruenullChannel
12 向否定 （） 发布者确认发送的渠道。 有效负载是由 定义的关联数据（如果未配置）。 如果表达式为 或 ，则从原始消息生成消息，标头设置为 。 当存在 时，消息是带有有效负载的。 另请参阅发布者确认和退货的替代机制。 可选（默认值为 ）。nackconfirm-correlation-expressionErrorMessageStrategy#root#thisamqp_publishConfirmfalseErrorMessageStrategyErrorMessageNackedAmqpMessageExceptionnullChannel
13 设置后，如果在此时间内未收到发布者确认（以毫秒为单位），适配器将合成否定确认 （nack）。 每 50% 检查一次挂起的确认，因此发送 nack 的实际时间将介于此值的 1 倍到 1.5 倍之间。 另请参阅发布者确认和退货的替代机制。 默认值为 non（不会生成 nacks）。
14 设置为 true 时，调用线程将阻塞，等待发布者确认。 这需要配置一个 for confirming，以及一个 . 线程最多会阻塞（默认为 5 秒）。 如果发生超时，将抛出 a。 如果启用了返回并返回了一条消息，或者在等待确认时发生任何其他异常，则将抛出一个，并附上相应的消息。RabbitTemplateconfirm-correlation-expressionconfirm-timeoutMessageTimeoutExceptionMessageHandlingException
15 将返回的消息发送到的通道。 提供后，基础 AMQP 模板配置为向适配器返回无法传递的消息。 如果未配置，则根据从 AMQP 接收的数据构造消息，并具有以下附加标头：、、、。 当存在 时，消息是带有有效负载的。 另请参阅发布者确认和退货的替代机制。 自选。ErrorMessageStrategyamqp_returnReplyCodeamqp_returnReplyTextamqp_returnExchangeamqp_returnRoutingKeyErrorMessageStrategyErrorMessageReturnedAmqpMessageException
16 对用于在发送返回或否定确认消息时构建实例的实现的引用。ErrorMessageStrategyErrorMessage
17 对发送 AMQP 消息时使用的引用。 默认情况下，只有标准的 AMQP 属性（例如 ）被复制到 Spring Integration 。 默认的“DefaultAmqpHeaderMapper”不会将任何用户定义的标头复制到消息中。 如果提供了“request-header-names”，则不允许。 自选。AmqpHeaderMappercontentTypeMessageHeaders
18 要从 映射到 AMQP 消息的 AMQP 标头的名称的逗号分隔列表。 如果提供了“header-mapper”引用，则不允许。 此列表中的值也可以是与标头名称匹配的简单模式（例如 或或）。MessageHeaders"*""thing1*, thing2""*thing1"
19 设置为 时，端点将在应用程序上下文初始化期间尝试连接到代理。 这允许对错误配置进行“快速故障”检测，但如果代理关闭，也会导致初始化失败。 当（默认值）时，在发送第一条消息时建立连接（如果由于其他组件建立连接而不存在）。falsetrue
20 当设置为 时，类型的有效负载将作为离散消息在单个调用范围内的同一通道上发送。 需要 . 如果为 true，则在发送消息后调用。 使用事务模板时，将在新事务或已启动的事务（如果存在）中执行发送。trueIterable<Message<?>>RabbitTemplateRabbitTemplatewait-for-confirmsRabbitTemplate.waitForConfirmsOrDie()
返回通道

使用 a 需要 a 的属性设置为 和 a 的属性设置为 。 使用多个返回的出站终结点时，每个终结点都需要一个单独的终结点。return-channelRabbitTemplatemandatorytrueCachingConnectionFactorypublisherReturnstrueRabbitTemplateSpring中文文档
返回通道

使用 a 需要 a 的属性设置为 和 a 的属性设置为 。 使用多个返回的出站终结点时，每个终结点都需要一个单独的终结点。return-channelRabbitTemplatemandatorytrueCachingConnectionFactorypublisherReturnstrueRabbitTemplateSpring中文文档