本文介紹您在使用社區版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]。 |