ApsaraMQ for RocketMQ:消費リトライ

メッセージリトライのトリガー条件

• 消費が失敗した場合。これには、コンシューマーが失敗ステータス識別子を返すか、予期しない例外をスローすることが含まれます。

• メッセージ処理がタイムアウトした場合。これには、PushConsumer でのキューイングタイムアウトが含まれます。

メッセージリトライの主な動作

• リトライプロセス状態機械: リトライフローにおけるメッセージのステータスと変更ロジックを制御します。

• 再試行間隔: 消費の失敗またはタイムアウトから、メッセージが再び消費可能になるまでの時間。

• 最大リトライ回数: メッセージをリトライできる最大回数。

メッセージリトライポリシーの違い

特定のリトライポリシーについては、「PushConsumer のリトライポリシー」および「SimpleConsumer のリトライポリシー」をご参照ください。

リトライ状態機械

たとえば、メッセージの消費リトライフローは上の図に示されています。メッセージが Ready 状態で 5 秒間あり、処理時間が 6 秒であると仮定します。

メッセージがリトライされるたびに、そのステータスは Ready から Inflight に、そして WaitingRetry に変わります。メッセージの再試行間隔は、消費の失敗またはタイムアウトから、メッセージが再び消費可能になるまでの時間です。メッセージの 2 回の消費間の実際の間隔には、処理時間と Ready 状態の期間も含まれます。例:

• メッセージは、最初の消費のために 0 秒で Ready 状態になります。

• コンシューマーの処理速度のため、5 秒でメッセージのプルと消費を開始します。6 秒後、メッセージ処理が異常になり、クライアントは消費失敗を返します。

• この時点では、消費をすぐにリトライすることはできません。システムは、メッセージが再び消費される前に再試行間隔が経過するのを待つ必要があります。

• 21 秒で、メッセージは再び Ready になります。

• クライアントは、さらに 5 秒後にメッセージの再消費を開始します。

したがって、メッセージの 2 回の消費間の実際の間隔は、処理時間 + 再試行間隔 + Ready 状態の期間 = 21 秒です。

再試行間隔

• 通常メッセージ (順序なしメッセージ): 再試行間隔は段階的な時間です。具体的な時間は次のとおりです。

  リトライ回数	再試行間隔	リトライ回数	再試行間隔
  1	10 秒	9	7 分
  2	30 秒	10	8 分
  3	1 分	11	9 分
  4	2 分	12	10 分
  5	3 分	13	20 分
  6	4 分	14	30 分
  7	5 分	15	1 時間
  8	6 分	16	2 時間

  説明

  リトライ回数が 16 回を超えた場合、それ以降のすべてのリトライの間隔は 2 時間になります。

• 順序付きメッセージ: 再試行間隔は固定時間です。具体的な値については、「パラメーターの制限」をご参照ください。

最大リトライ回数

• デフォルト値: 16。

• 最大制限: 1,000。

PushConsumer の最大リトライ回数は、コンシューマーグループのメタデータによって制御されます。この値を変更するには、「最大リトライ回数の変更」をご参照ください。

たとえば、最大リトライ回数が 3 の場合、メッセージは最大 4 回配信できます (元の配信 1 回とリトライ 3 回)。

使用例

PushConsumer のメッセージリトライをトリガーするには、消費失敗ステータスコードを返すだけです。SDK は予期しない例外もキャッチします。

SimpleConsumer simpleConsumer = null;
        // 使用例: PushConsumer を使用して通常のメッセージを消費します。消費が失敗した場合、エラーを返してリトライをトリガーします。
        MessageListener messageListener = new MessageListener() {
            @Override
            public ConsumeResult consume(MessageView messageView) {
                System.out.println(messageView);
                // ConsumeResult.FAILURE を返して、最大リトライ回数に達するまで自動的にリトライします。
                return ConsumeResult.FAILURE;
            }
        };
            

消費リトライログの表示

PushConsumer による順序付き消費のリトライは、コンシューマークライアントで発生します。サーバーは、消費リトライの詳細なログを取得できません。メッセージトレース内の順序付きメッセージの配信結果が 'failed' の場合、コンシューマークライアントのログで最大リトライ回数やコンシューマークライアントなどの情報を確認できます。

コンシューマークライアントのログパスについては、「ログ設定」をご参照ください。

クライアントログで次のキーワードを検索すると、消費の失敗に関連するコンテンツをすばやく見つけることができます。

Message listener raised an exception while consuming messages
Failed to consume fifo message finally, run out of attempt times

リトライ状態機械

PushConsumer のリトライポリシーとは異なり、SimpleConsumer の再試行間隔は事前に割り当てられます。メッセージを受信するたびに、コンシューマーは API を呼び出すときに不可視期間パラメーター InvisibleDuration を設定します。このパラメーターは、メッセージの最大処理時間を指定します。消費が失敗してリトライがトリガーされた場合、不可視期間パラメーターの値が再利用されるため、次の再試行間隔を設定する必要はありません。

事前に割り当てられた不可視期間は、ビジネスにおける実際のメッセージ処理時間と大幅に異なる場合があります。API 操作を使用して、不可視期間を変更できます。

たとえば、メッセージ処理時間を最大 20 ms に事前設定できます。ただし、実際のビジネスでは、メッセージは 20 ms 以内に処理できません。メッセージの不可視期間を変更して処理時間を延長し、メッセージがリトライメカニズムをトリガーするのを防ぐことができます。

次の図に示すように、メッセージの不可視期間への変更はすぐに有効になります。メッセージの不可視期間は、API が呼び出された瞬間から再計算されます。

メッセージの再試行間隔

再試行間隔 = 不可視期間 - 実際のメッセージ処理時間

SimpleConsumer の消費再試行間隔は、メッセージの不可視期間によって制御されます。たとえば、不可視期間が 30 ms で、実際のメッセージ処理に 10 ms かかってから失敗応答が返された場合、次のリトライは 20 ms 後に発生します。再試行間隔は 20 ms です。メッセージが処理されず、30 ms 後に結果が返されない場合、メッセージはタイムアウトし、すぐにリトライされます。この場合、再試行間隔は 0 ms です。

最大リトライ回数

• デフォルト値: 16。

• 最大制限: 1,000。

SimpleConsumer の最大リトライ回数は、コンシューマーグループ用に作成されたメタデータによって制御されます。この値を変更するには、「最大リトライ回数の変更」をご参照ください。

たとえば、最大リトライ回数が 3 の場合、メッセージは最大 4 回配信できます (元の配信 1 回とリトライ 3 回)。

使用例

SimpleConsumer のメッセージリトライをトリガーするには、タイムアウトを待つだけです。

 // 使用例: SimpleConsumer を使用して通常のメッセージを消費します。リトライしたい場合は、タイムアウトを待つだけです。サーバーは自動的にリトライします。
        List<MessageView> messageViewList = null;
        try {
            messageViewList = simpleConsumer.receive(10, Duration.ofSeconds(30));
            messageViewList.forEach(messageView -> {
                System.out.println(messageView);
                // 処理が失敗し、サーバーにリトライさせたい場合は、メッセージを無視するだけです。表示されるようになったら、再度受信を試みることができます。
            });
        } catch (ClientException e) {
            // システムのスロットリングなどの理由でプルが失敗した場合は、メッセージを再度受信するリクエストを開始する必要があります。
            e.printStackTrace();
        }

合理的なリトライとスロットリング目的での消費リトライのトリガー回避

「シナリオ」で述べたように、メッセージリトライは、ビジネス処理が失敗し、現在の消費失敗がまれなイベントであるシナリオに適しています。消費スロットリングなどの永続的な失敗のシナリオには適していません。

• 不適切な例:

  現在の消費速度が速すぎてスロットリングがトリガーされた場合、消費失敗を返して次の再消費を待つことができます。

• 適切な例:

  現在の消費速度が速すぎてスロットリングがトリガーされた場合、メッセージの受信を遅らせて後で消費することができます。

メッセージ消費タイムアウトの設定方法

消費タイムアウトはコンシューマークライアントで設定されます。具体的なパラメーター設定は次のとおりです。

consumer.setConsumeTimeout(15); // 単位: 分。最小値: 1。最大値: 180。