SpringCloud Rabbit生產(chǎn)者Properties

2023-11-29 16:04 更新

以下屬性僅適用于Rabbit生產(chǎn)者,并且必須以spring.cloud.stream.rabbit.bindings.<channelName>.producer.為前綴。

autoBindDlq

是否自動聲明DLQ并將其綁定到綁定器DLX。

默認(rèn)值:false。

batchingEnabled

是否啟用生產(chǎn)者的郵件批處理。根據(jù)以下屬性(在此列表的后三個條目中進(jìn)行了描述),將消息批處理為一條消息:'batchSize',batchBufferLimitbatchTimeout。有關(guān)更多信息,請參見批處理。

默認(rèn)值:false。

batchSize

啟用批處理時要緩沖的消息數(shù)。

默認(rèn)值:100。

batchBufferLimit

啟用批處理時的最大緩沖區(qū)大小。

默認(rèn)值:10000。

batchTimeout

啟用批處理時的批處理超時。

默認(rèn)值:5000。

bindingRoutingKey

用于將隊(duì)列綁定到交換機(jī)的路由密鑰(如果bindQueuetrue)。僅適用于未分區(qū)的目的地。僅在提供requiredGroups的情況下適用,然后僅對那些組有效。

默認(rèn)值:#。

bindQueue

是否將隊(duì)列綁定到目標(biāo)交換機(jī)。如果您已經(jīng)設(shè)置了自己的基礎(chǔ)結(jié)構(gòu)并且先前已創(chuàng)建并綁定了隊(duì)列,則將其設(shè)置為false。僅在提供requiredGroups的情況下適用,然后僅對那些組有效。

默認(rèn)值:true

壓縮

發(fā)送時是否應(yīng)壓縮數(shù)據(jù)。

默認(rèn)值:false

deadLetterQueueName

DLQ的名稱僅在提供了requiredGroups之后才適用,然后僅適用于那些組。

默認(rèn)值:prefix+destination.dlq

deadLetterExchange

分配給隊(duì)列的DLX。僅當(dāng)autoBindDlqtrue時相關(guān)。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:“ prefix + DLX”

deadLetterExchangeType

分配給隊(duì)列的DLX的類型。僅當(dāng)autoBindDlqtrue時才相關(guān)。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:“直接”

deadLetterRoutingKey

分配給隊(duì)列的死信路由鍵。僅當(dāng)autoBindDlqtrue時相關(guān)。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:destination

聲明Dlx

是否聲明目的地交換死信。僅當(dāng)autoBindDlqtrue時才相關(guān)。如果您有預(yù)配置的DLX,請?jiān)O(shè)置為false僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:true。

聲明交換

是否聲明目的地交換。

默認(rèn)值:true。

delayExpression

一個SpEL表達(dá)式,用于評估應(yīng)用于消息的延遲(x-delay標(biāo)頭)。如果交換不是延遲的消息交換,則無效。

默認(rèn)值:未設(shè)置x-delay頭。

延遲交易

是否將交換聲明為Delayed Message Exchange。需要代理上的延遲消息交換插件。x-delayed-type參數(shù)設(shè)置為exchangeType。

默認(rèn)值:false。

deliveryMode

交付方式。

默認(rèn)值:PERSISTENT。

dlqDeadLetterExchange

聲明DLQ后,將分配給該隊(duì)列的DLX。僅在提供了requiredGroups之后才適用,然后僅對那些組適用。

默認(rèn)值:none

dlqDeadLetterRoutingKey

聲明DLQ后,將分配一個死信路由密鑰給該隊(duì)列。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:none

dlqExpires

刪除未使用的死信隊(duì)列之前的時間(以毫秒為單位)。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:no expiration

dlqLazy
x-queue-mode=lazy參數(shù)聲明死信隊(duì)列。請參閱惰性隊(duì)列。考慮使用策略而不是此設(shè)置,因?yàn)槭褂貌呗栽试S更改設(shè)置而不刪除隊(duì)列。僅在提供requiredGroups時適用,然后僅適用于那些組。
dlqMaxLength

死信隊(duì)列中的最大消息數(shù)。僅在提供了requiredGroups之后才適用,然后僅對那些組適用。

默認(rèn)值:no limit

dlqMaxLengthBytes

所有消息中的死信隊(duì)列中的最大總字節(jié)數(shù)。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:no limit

dlqMaxPriority

死信隊(duì)列中郵件的最大優(yōu)先級(0-255)僅在提供requiredGroups時才適用,然后僅適用于那些組。

默認(rèn)值:none

dlqTtl

聲明時應(yīng)用于死信隊(duì)列的默認(rèn)生存時間(以毫秒為單位)。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:no limit

exchangeAutoDelete

如果declareExchangetrue,則是否應(yīng)自動刪除交換(在刪除最后一個隊(duì)列之后將其刪除)。

默認(rèn)值:true。

耐用

如果declareExchangetrue,則交換是否應(yīng)該持久(在代理重新啟動后生存)。

默認(rèn)值:true。

exchangeType

交換類型:direct,fanouttopic用于未分區(qū)的目的地,directtopic用于分區(qū)的目的地。

默認(rèn)值:topic

過期

刪除未使用的隊(duì)列之前的時間(以毫秒為單位)。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:no expiration

headerPatterns

標(biāo)頭要映射到出站郵件的模式。

默認(rèn)值:['*'](所有標(biāo)題)。

使用x-queue-mode=lazy參數(shù)聲明隊(duì)列。請參閱惰性隊(duì)列考慮使用策略而不是此設(shè)置,因?yàn)槭褂貌呗栽试S更改設(shè)置而不刪除隊(duì)列。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:false。

最長長度

隊(duì)列中的最大消息數(shù)。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:no limit

maxLengthBytes

來自所有消息的隊(duì)列中的最大總字節(jié)數(shù)。僅在提供requiredGroups的情況下適用,然后僅對那些組有效。

默認(rèn)值:no limit

maxPriority

隊(duì)列中消息的最大優(yōu)先級(0-255)。僅在提供requiredGroups的情況下適用,然后僅對那些組有效。

默認(rèn)值:none

字首

要添加到destination交換名稱的前綴。

默認(rèn)值:“”。

queueNameGroupOnly

當(dāng)true時,從名稱等于group的隊(duì)列中使用。否則,隊(duì)列名稱為destination.group。例如,在使用Spring Cloud Stream從現(xiàn)有RabbitMQ隊(duì)列中消費(fèi)時,這很有用。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:false。

routingKeyExpression

一個SpEL表達(dá)式,用于確定發(fā)布消息時要使用的路由密鑰。對于固定的路由鍵,請使用文字表達(dá)式,例如屬性文件中的routingKeyExpression='my.routingKey'或YAML文件中的routingKeyExpression: '''my.routingKey'''。

默認(rèn)值:destinationdestination-<partition>(用于分區(qū)目標(biāo))。

交易的

是否使用交易渠道。

默認(rèn)值:false。

ttl

聲明時適用于隊(duì)列的默認(rèn)生存時間(以毫秒為單位)。僅在提供requiredGroups時適用,然后僅適用于那些組。

默認(rèn)值:no limit

對于RabbitMQ,可以由外部應(yīng)用程序設(shè)置內(nèi)容類型標(biāo)頭。Spring Cloud Stream支持它們作為用于任何類型的傳輸?shù)臄U(kuò)展內(nèi)部協(xié)議的一部分—包括Kafka(0.11之前的版本)之類的傳輸,其本身不支持標(biāo)頭。
以上內(nèi)容是否對您有幫助:
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號
微信公眾號

編程獅公眾號