このトピックでは、SDK for JavaのCommunity Editionを使用してApsaraMQ for RocketMQに接続するときに設定する必要があるパラメーターについて説明します。
共通パラメーター
パラメーター | 説明 |
NAMESRV_ADDR | TCPエンドポイント。 エンドポイントは、ApsaraMQ for RocketMQコンソールの [インスタンスの詳細] ページで取得できます。 |
アクセスキー(AccessKey) | 認証に使用されるAccessKey ID。 AccessKey IDの取得方法については、「AccessKeyペアの作成」をご参照ください。 |
SecretKey | 認証に使用されるAccessKeyシークレット。 AccessKeyシークレットの取得方法については、「AccessKeyペアの作成」をご参照ください。 |
AccessChannel | クラウドでメッセージトレース機能を使用するかどうかを指定します。 クラウドでメッセージトレース機能を使用する場合は、このパラメーターをcloudに設定します。 |
メッセージ送信用のパラメータ
パラメーター | 説明 |
producerGroup | プロデューサーグループのID。 複数のプロデューサが同じアプリケーションに属し、同じメッセージを送信する場合、プロデューサは同じグループに属すると見なされます。 ApsaraMQ for RocketMQコンソールでプロデューサーグループのIDを取得できます。 詳細については、「Terms」をご参照ください。 |
sendMsgTimeout | メッセージを送信するためのタイムアウト期間。 単位:ミリ秒。 |
compressMsgBodyOverHowmuch | 圧縮するメッセージのボディサイズのしきい値を指定します。 メッセージの本体サイズがしきい値を超える場合、メッセージは圧縮され、消費者による受信時に解凍される。 デフォルト値: 4。 (単位:KB) |
retryTimesWhenSendFailed | メッセージの送信に失敗した場合にメッセージに対して実行できる再試行の最大数。 このパラメーターは、同期モードで送信されたメッセージに対してのみ有効です。 |
maxMessageSize | クライアントによって指定された最大メッセージサイズ。 メッセージのサイズがこのパラメーターで指定された値を超えると、エラーが報告されます。 ブローカはまた、メッセージサイズに制限を課す。 このパラメーターは、ブローカーの対応するパラメーターと一緒に使用する必要があります。 デフォルト値: 4。 単位:MB。 |
メッセージサブスクリプションのパラメータ
パラメーター | 説明 |
consumerGroup | コンシューマーグループの ID です。 複数のコンシューマが同じアプリケーションに属し、同じメッセージにサブスクライブし、同じメッセージ消費ロジックを使用する場合、これらのコンシューマは同じグループに属していると見なされます。 ApsaraMQ for RocketMQコンソールでコンシューマーグループのIDを取得できます。 詳細については、「Terms」をご参照ください。 |
consumeFromWhere | コンシューマーグループの開始後にメッセージが消費されるオフセット。 デフォルトでは、メッセージは最新のオフセットから消費されます。 |
consumeThreadMin | コンシューマースレッドプール内のスレッドの最小数。 デフォルト値は 20 です。 |
consumeThreadMax | コンシューマースレッドプール内のスレッドの最大数。 デフォルト値は 20 です。 スレッドの最大数は、スレッドの最小数と一致している必要があります。 |
consumeConcurrentlyMaxSpan | メッセージがキューで同時に消費されるときに許可される最大オフセットスパン。 有効な値: -1 から 65535 デフォルト値: 2000。 |
pullThresholdForQueue | メッセージがプルされたときにローカルキューにキャッシュできるメッセージの最大数。 有効な値: -1 から 65535 デフォルト値は 1000 です。 |
pullThresholdSizeForQueue | メッセージがプルされたときにローカルキューにキャッシュできるメッセージの合計サイズ。 有効な値: 1 ~ 1024 デフォルト値:100 単位:MB。 |
maxReconsumeTimes | リトライの最大回数は 10 回です。 デフォルト値: 16。 |
suspendCurrentQueueTimeMillis | 順序付けられたメッセージの2回の連続した再試行間の最小時間間隔。 有効な値: 10 ~ 30000 デフォルト値は 1000 です。 単位:ミリ秒。 |