对于最新的稳定版本,请使用 spring-cloud-stream 4.3.0spring-doc.cadn.net.cn

RabbitMQ 生产者属性

以下属性仅适用于 Rabbit 生产者,并且必须以spring.cloud.stream.rabbit.bindings.<channelName>.producer..spring-doc.cadn.net.cn

但是,如果需要将同一组属性应用于大多数绑定,请将 避免重复,Spring Cloud Stream 支持为所有通道设置值, 以spring.cloud.stream.rabbit.default.<property>=<value>.spring-doc.cadn.net.cn

另外,请记住,绑定特定属性将覆盖其默认中的等效属性。spring-doc.cadn.net.cn

altermateExchange.binding.queue

如果交换尚不存在,并且name,则将此队列绑定到备用交换。 预配一个没有参数的简单持久队列;如果需要更复杂的配置,则必须自行配置和绑定队列。spring-doc.cadn.net.cn

违约:nullalternateExchange.binding.routingKey 如果交换尚不存在,并且namequeue,则使用此路由密钥将队列绑定到备用交换。spring-doc.cadn.net.cn

默认值:(对于默认值#topic替代交换)spring-doc.cadn.net.cn

alternateExchange.exists

备用交换是否存在,或者是否需要预配。spring-doc.cadn.net.cn

违约:falsespring-doc.cadn.net.cn

alternateExchange.类型

如果备用交换尚不存在,则要预配的交换类型。spring-doc.cadn.net.cn

违约:topicspring-doc.cadn.net.cn

alternateExchange.name

在目标交换机上配置备用交换机。spring-doc.cadn.net.cn

违约:nullspring-doc.cadn.net.cn

自动绑定Dlq

是否自动声明 DLQ 并将其绑定到绑定程序 DLX。spring-doc.cadn.net.cn

违约:false.spring-doc.cadn.net.cn

批处理已启用

是否由生产者启用消息批处理。 消息根据以下属性批处理为一条消息(在此列表中的接下来的三个条目中描述): 'batchSize',batchBufferLimitbatchTimeout. 有关详细信息,请参阅批处理。 另请参阅接收批处理消息spring-doc.cadn.net.cn

违约:false.spring-doc.cadn.net.cn

batch大小

启用批处理时要缓冲的消息数。spring-doc.cadn.net.cn

违约:100.spring-doc.cadn.net.cn

batch缓冲限制

启用批处理时的最大缓冲区大小。spring-doc.cadn.net.cn

违约:10000.spring-doc.cadn.net.cn

batchTimeout

启用批处理时的批处理超时。spring-doc.cadn.net.cn

违约:5000.spring-doc.cadn.net.cn

bindingRoutingKey

用于将队列绑定到交换的路由密钥(如果bindQueuetrue). 可以是多个键 - 请参阅bindingRoutingKeyDelimiter. 对于分区目标,-n附加到每个键。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:。#spring-doc.cadn.net.cn

bindingRoutingKeyDelimiter

当它不为空时,'bindingRoutingKey' 被视为由此值分隔的键列表;通常使用逗号。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:null.spring-doc.cadn.net.cn

绑定队列

是否声明队列并将其绑定到目标交换。 将其设置为false如果您已经设置了自己的基础设施,并且之前已经创建并绑定了队列。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:true.spring-doc.cadn.net.cn

压缩

发送时是否应压缩数据。spring-doc.cadn.net.cn

违约:false.spring-doc.cadn.net.cn

确认AckChannel

什么时候errorChannelEnabled为 true,则是向其发送正面投放确认(又称发布者确认)的通道。 如果通道不存在,则DirectChannel以此名称注册。 必须将连接工厂配置为启用发布者确认。 相互排斥useConfirmHeader.spring-doc.cadn.net.cn

违约:nullChannel(acks 被丢弃)。spring-doc.cadn.net.cn

deadLetter队列名称

DLQ 的名称 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:prefix+destination.dlqspring-doc.cadn.net.cn

死信交换

要分配给队列的 DLX。 仅在以下情况下相关autoBindDlqtrue. 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:“前缀+DLX”spring-doc.cadn.net.cn

deadLetter交换类型

要分配给队列的 DLX 类型。 仅当autoBindDlqtrue. 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:“直接”spring-doc.cadn.net.cn

deadLetterRouting键

要分配给队列的死信路由键。 仅在以下情况下相关autoBindDlqtrue. 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:destinationspring-doc.cadn.net.cn

声明Dlx

是否为目的地申报死信交换。 仅当autoBindDlqtrue. 设置为false如果您有预配置的 DLX。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:true.spring-doc.cadn.net.cn

声明交换

是否声明目标的交换。spring-doc.cadn.net.cn

违约:true.spring-doc.cadn.net.cn

延迟表达式

用于评估要应用于消息的延迟的 SpEL 表达式 (x-delay标头)。 如果交换不是延迟消息交换,则无效。spring-doc.cadn.net.cn

默认值:否x-delayheader 已设置。spring-doc.cadn.net.cn

延迟交换

是否将交易所声明为Delayed Message Exchange. 需要代理上的延迟消息交换插件。 这x-delayed-type参数设置为exchangeType.spring-doc.cadn.net.cn

违约:false.spring-doc.cadn.net.cn

交付模式

交付模式。spring-doc.cadn.net.cn

违约:PERSISTENT.spring-doc.cadn.net.cn

dlqBinding参数

将 dlq 绑定到死信交换时应用的参数;与headers deadLetterExchangeType以指定要匹配的标头。 例如…​dlqBindingArguments.x-match=any,…​dlqBindingArguments.someHeader=someValue. 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:空spring-doc.cadn.net.cn

dlq死信交换

声明 DLQ 时,要分配给该队列的 DLX。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:nonespring-doc.cadn.net.cn

dlqDeadLetterRoutingKey

声明 DLQ 时,要分配给该队列的死信路由密钥。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:nonespring-doc.cadn.net.cn

dlq过期

删除未使用的死信队列之前多长时间(以毫秒为单位)。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:no expirationspring-doc.cadn.net.cn

dlq懒惰

使用x-queue-mode=lazy论点。 请参阅“延迟队列”。 请考虑使用策略而不是此设置,因为使用策略允许在不删除队列的情况下更改设置。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

dlq最大长度

死信队列中的最大消息数。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:no limitspring-doc.cadn.net.cn

dlqMaxLength字节

所有消息的死信队列中的最大总字节数。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:no limitspring-doc.cadn.net.cn

dlqMax优先级

死信队列中消息的最大优先级 (0-255) 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:nonespring-doc.cadn.net.cn

dlqQuorum.deliveryLimit

什么时候quorum.enabled=true,设置传递限制,在此之后,邮件将被丢弃或死信。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:无 - 代理默认值将适用。spring-doc.cadn.net.cn

dlqQuorum.enabled

如果为 true,请创建仲裁死信队列,而不是经典队列。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:falsespring-doc.cadn.net.cn

dlqQuorum.initialGroupSize

什么时候quorum.enabled=true,设置初始仲裁大小。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:无 - 代理默认值将适用。spring-doc.cadn.net.cn

dlqSingleActiveConsumer

设置为 true 以设置x-single-active-consumerqueue 属性设置为 true。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:falsespring-doc.cadn.net.cn

dlqTtl

声明时应用于死信队列的默认生存时间(以毫秒为单位)。仅当以下情况适用requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:no limitspring-doc.cadn.net.cn

交易所自动删除

如果declareExchangetrue,交换是否应自动删除(在删除最后一个队列后将其删除)。spring-doc.cadn.net.cn

违约:true.spring-doc.cadn.net.cn

交换耐用

如果declareExchangetrue,交易所是否应该持久(在代理重启后幸存)。spring-doc.cadn.net.cn

违约:true.spring-doc.cadn.net.cn

交换类型

交易所类型:direct,fanout,headerstopic对于未分区的目标和direct,headerstopic用于分区目标。spring-doc.cadn.net.cn

违约:topic.spring-doc.cadn.net.cn

到期

删除未使用的队列之前多长时间(以毫秒为单位)。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:no expirationspring-doc.cadn.net.cn

headerPatterns

要映射到出站邮件的标头的模式。spring-doc.cadn.net.cn

默认值:(所有标头)。['*']spring-doc.cadn.net.cn

懒惰

使用x-queue-mode=lazy论点。 请参阅“延迟队列”。 请考虑使用策略而不是此设置,因为使用策略允许在不删除队列的情况下更改设置。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:false.spring-doc.cadn.net.cn

最大长度

队列中的最大消息数。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:no limitspring-doc.cadn.net.cn

maxLength字节

队列中所有消息的最大总字节数。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:no limitspring-doc.cadn.net.cn

最大优先级

队列中消息的最大优先级 (0-255)。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:nonespring-doc.cadn.net.cn

前缀

要添加到destination交换。spring-doc.cadn.net.cn

默认值:“”。spring-doc.cadn.net.cn

生产者类型

生产者的类型。spring-doc.cadn.net.cn

queueBindingArguments

将队列绑定到交换时应用的参数;与headers exchangeType以指定要匹配的标头。 例如…​queueBindingArguments.x-match=any,…​queueBindingArguments.someHeader=someValue. 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:空spring-doc.cadn.net.cn

队列名称仅组

什么时候true,从名称等于group. 否则队列名称为destination.group. 例如,当使用 Spring Cloud Stream 从现有 RabbitMQ 队列中消费时,这很有用。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:false。spring-doc.cadn.net.cn

quorum.deliveryLimit

什么时候quorum.enabled=true,设置传递限制,在此之后,邮件将被丢弃或死信。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:无 - 代理默认值将适用。spring-doc.cadn.net.cn

法定人数已启用

如果为 true,请创建仲裁队列而不是经典队列。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:falsespring-doc.cadn.net.cn

quorum.initialGroup大小

什么时候quorum.enabled=true,设置初始仲裁大小。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

默认值:无 - 代理默认值将适用。spring-doc.cadn.net.cn

路由键表达式

用于确定发布消息时要使用的路由键的 SpEL 表达式。 对于固定路由键,请使用routingKey.spring-doc.cadn.net.cn

违约:destinationdestination-<partition>用于分区目标。spring-doc.cadn.net.cn

路由键

定义发布邮件时要使用的固定路由键的字符串。spring-doc.cadn.net.cn

默认值:请参阅routingKeyExpressionspring-doc.cadn.net.cn

单主动消费者

设置为 true 以设置x-single-active-consumerqueue 属性设置为 true。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:falsespring-doc.cadn.net.cn

交易

是否使用交易通道。spring-doc.cadn.net.cn

违约:false.spring-doc.cadn.net.cn

TTL的

声明时应用于队列的默认生存时间(以毫秒为单位)。 仅适用于以下情况requiredGroups提供,然后仅提供给这些组。spring-doc.cadn.net.cn

违约:no limitspring-doc.cadn.net.cn

使用ConfirmHeader

请参阅发布者确认。 相互排斥confirmAckChannel.spring-doc.cadn.net.cn

对于 RabbitMQ,内容类型标头可以由外部应用程序设置。 Spring Cloud Stream 将它们作为用于任何类型传输的扩展内部协议的一部分,包括本机不支持标头的传输,例如 Kafka(0.11 之前)。