全部產品
Search
文件中心

ApsaraMQ for RocketMQ:參數說明

更新時間:Jul 01, 2024

本文介紹您在使用社區版Java SDK接入阿里雲雲訊息佇列 RocketMQ 版時,需要配置的參數。

通用參數

參數名

參數說明

NAMESRV_ADDR

設定TCP協議存取點,從雲訊息佇列 RocketMQ 版控制台執行個體詳情頁面擷取。

AccessKey

AccessKey ID,阿里雲身分識別驗證標識。擷取方式,請參見建立AccessKey

SecretKey

AccessKey Secret,阿里雲身分識別驗證密鑰。擷取方式,請參見建立AccessKey

AccessChannel

用於指定使用雲上訊息軌跡,上雲設定為:AccessChannel:CLOUD。

訊息發送參數

參數名

參數說明

producerGroup

Producer組名,多個Producer如果屬於一個應用,發送同樣的訊息,則應該將它們歸為同一組,即您在阿里雲RocketMQ控制台上建立的Group ID,更多資訊,請參見基本概念

sendMsgTimeout

發送訊息逾時時間,單位:毫秒。

compressMsgBodyOverHowmuch

訊息Body超過多大開始壓縮(Consumer收到訊息會自動解壓縮),預設值:4,單位:KB。

retryTimesWhenSendFailed

如果訊息發送失敗,最大重試次數,該參數只對同步發送模式起作用。

maxMessageSize

用戶端限制的訊息大小,超過報錯,同時服務端也會限制,所以需要跟服務端配合使用,預設值:4,單位:MB。

訊息訂閱參數

參數名

參數說明

consumerGroup

Consumer組名,多個Consumer如果屬於一個應用,訂閱同樣的訊息,且消費邏輯一致,則應該將它們歸為同一組,即您在阿里雲RocketMQ控制台上建立的Group ID,詳情請參見基本概念

consumeFromWhere

新的Consumer Group啟動後,用於確定從何處開始拉取,預設從最新位點拉取。

consumeThreadMin

消費線程池最小線程數,預設值:20。

consumeThreadMax

消費線程池最大線程數,預設值:20。請與最小線程數保持一致。

consumeConcurrentlyMaxSpan

單隊列並行消費位點允許的最大跨度,預設值:2000,允許區間為[1,65535]。

pullThresholdForQueue

拉訊息本地隊列緩衝訊息最大數量,預設值:1000,單位:條,允許區間為[1,65535]。

pullThresholdSizeForQueue

拉訊息本地隊列緩衝訊息總大小,預設值:100,單位:MB,允許區間為[1,1024]。

maxReconsumeTimes

最大重試次數,預設值:16,單位:次。

suspendCurrentQueueTimeMillis

順序訊息最小稍候再試,預設值:1000,單位:毫秒,允許區間為[10,30000]。

更多資訊