ApsaraMQ for RocketMQのリソースクォータ、インスタンス仕様、および特定のパラメーターに制限が課されます。 アプリケーションの例外を防ぐには、ApsaraMQ for RocketMQを使用するときに制限を超えないようにしてください。
パラメータの制限
制限を変更できないパラメーターを次の表に示します。 特殊文字または制限を超えることによって引き起こされるシステム例外を防ぐには、規則に基づいてパラメーターを設定する必要があります。
パラメーター | 制限事項 | 説明 |
インスタンス名 |
| なし。 |
トピック名 |
トピック名には、システム用に予約されている次の文字列、または特別なプレフィックスを含む文字列を含めることはできません。 | トピックの名前を指定するときは、共通文字の短い文字列を使用する必要があります。 特殊文字を使用しないでください。 トピック名に特殊文字を使用すると、システム解析中に例外が発生する可能性があります。 トピック名が長すぎる場合、システムはメッセージの送受信を拒否する可能性があります。 |
消費者グループ名 |
コンシューマーグループ名には、システム用に予約されている次の文字列、または特別なプレフィックスを含む文字列を含めることはできません。 | なし。 |
インスタンスの説明 |
| なし。 |
トピックの説明 | ||
グループの説明 | ||
ACLクレデンシャル |
| なし。 |
リクエストのタイムアウト期間 |
| リクエストタイムアウト期間は、クライアントがAPI操作を同期的に呼び出す前にクライアントが待機する期間です。 スレッドが長期間ブロックされないように、このパラメーターに適切な値を指定します。 |
メッセージサイズ | メッセージのサイズは4 MBを超えることはできません。 メッセージ本文のサイズのみが計算されます。 | メッセージを送信するときは、過負荷のファイル送信を防ぐために、負荷のサイズを圧縮する必要があります。 メッセージのサイズが上限を超える場合は、メッセージを分割するか、メッセージをObject Storage Service (OSS) に保存します。 メッセージをOSSに保存する場合、プロデューサーは、メッセージが保存されているURLを使用してメッセージを送信できます。 |
カスタムメッセージ属性 |
システム用に予約されている属性名を属性キーとして使用することはできません。 | なし。 |
メッセージグループ |
| メッセージグループは、順序付けられたメッセージのグループを識別するために使用される。 このパラメーターを共有プロパティに設定すると、注文IDやユーザーIDなど、メッセージを順番に送信または受信します。 |
メッセージ送信の再試行 |
| メッセージ送信の再試行機能はクライアントSDKに組み込まれた機能であり、アプリケーションでは表示できません。 スレッドがブロックされないようにするには、このパラメーターに大きな値を指定しないことをお勧めします。 再試行の最大数に達した後にメッセージが送信されない場合は、メッセージの可用性を確保するためにビジネス側で対策を講じることを推奨します。 |
メッセージ消費の再試行 |
| このパラメーターは、メッセージが何度も再試行されないように、ビジネス要件に基づいて設定する必要があります。 消費の再試行の回数が多いと、システムが過負荷になる可能性があります。 |
トランザクション例外チェックの間隔 |
| システムの再起動または例外が原因でハーフメッセージのコミットが失敗した場合、プロデューサーはこのパラメーターで指定された間隔に基づいてトランザクションのステータスをチェックします。 トランザクションステータスに対して実行される頻繁なチェックは、システムパフォーマンスを低下させる可能性があります。 システムのパフォーマンスを確保するために、このパラメーターに小さな値を指定しないことをお勧めします。 |
半メッセージの最初のチェックの期間 |
| 応答パラメーター。 |
半分のメッセージの最大タイムアウト期間 |
| システムの再起動または例外が原因でハーフメッセージのコミットが失敗した場合、プロデューサーはトランザクション例外チェックパラメーターの間隔で指定された間隔に基づいてトランザクションのステータスをチェックします。 ハーフメッセージに指定された最大タイムアウト時間が経過しても結果が返されない場合、ハーフメッセージは強制的にロールバックされます。 このパラメーターを監視して、異常なトランザクションを防止できます。 |
スケジュールされたメッセージを送信する最大間隔 |
| 間隔が長くなりすぎないように、スケジュールされたメッセージの送信間隔を時間単位で指定することをお勧めします。 |
プッシュコンシューマの消費タイムアウト期間 |
| プッシュコンシューマーのタイムアウト期間は、ApsaraMQ for RocketMQブローカーによって一元管理されます。 消費タイムアウト期間が経過してもメッセージが消費されない場合、システムはメッセージの消費が失敗したと判断し、メッセージを再試行します。 この場合、少数のメッセージが複製され得る。 |
プッシュコンシューマ向けのローカルキャッシング |
| コンシューマーがプッシュコンシューマーの場合、特定のメッセージはSDKクライアントのローカルストレージにキャッシュされ、コンシューマーのスループットとパフォーマンスが向上します。 キャッシュされたメッセージの最大数およびキャッシュされたメッセージの最大サイズを指定する場合、値がシステムで許可されている範囲内にあることを確認する必要があります。 |
プッシュ消費者の再試行間隔 |
| なし。 |
プッシュコンシューマ向けの同時スレッド |
| なし。 |
一度にプルできるメッセージの最大数 |
| このパラメーターには、コンシューマーがメッセージを消費するときにクライアントから取得できるメッセージの最大数を指定します。 ビジネス要件に基づいてパラメーターの値を指定することを推奨します。 パラメータの値が過度に大きい場合、消費が失敗した場合、多数のメッセージが複製される可能性がある。 |
シンプルな消費者のための最大不可視期間 |
| 消費インビジブル期間は、以下の式を使用することによって計算される。消費インビジブル期間=メッセージを処理するための期間 + 再試行間隔。 このパラメーターには、必要な実際の期間よりも大きな値を指定することを推奨します。 |
消費者の長いポーリングタイムアウト | 有効範囲: 5〜20。 単位は秒です。 有効な範囲内でカスタム値を指定できます。 | このパラメーターを設定した後、ApsaraMQ for RocketMQブローカーでレディメッセージが利用できない場合、ブローカーが新しいメッセージを受信するか、タイムアウト期間に達するまで、クライアントからのリクエストはブロックされます。 ApsaraMQ for RocketMQのロングポーリング機能は、メッセージ量が少ないときに空のリクエストの数とクライアントとブローカーのワークロードを減らすことができます。 |
リソースクォータの制限
ApsaraMQ for RocketMQは、運用環境での安定性を確保するために、特定の操作のメトリック (QPS (queries per second) や同時実行など) のクォータをO&Mプラクティスに基づいて制限します。 ほとんどの場合、クォータはビジネス要件を満たすことができます。 特別なシナリオでクォータを増やしたい場合は、ApsaraMQ for RocketMQテクニカルサポートにお問い合わせください。
項目 | 制限事項 | 説明 | |
サブスクリプションおよび従量課金インスタンス | Serverless インスタンス | ||
単一リージョンのインスタンス | すべてのタイプの作成されたインスタンスの総数は、リージョン内の1,000を超えることはできません。 | なし。 | |
単一インスタンスのメッセージングTPS | 1つのインスタンスの1秒あたりのメッセージングトランザクション (TPS) は、購入する仕様によって異なります。 詳細については、「インスタンス仕様の制限」をご参照ください。 | 適応弾性がサポートされています。 | メッセージングTPSは、インスタンスのパフォーマンスを示します。 実際のTPS使用量が仕様の制限を超えた場合、インスタンスは抑制されます。 この場合、できるだけ早い機会に仕様をアップグレードすることをお勧めします。 |
単一インスタンスのトピック | 1つのインスタンスに作成できるトピックの数は、購入した仕様によって異なります。 詳細については、「インスタンス仕様の制限」をご参照ください。 | 作成したトピックの数に基づいて課金されます。 詳細については、「トピック料金」をご参照ください。 | ビジネスのセキュリティと安定性を確保するために、異なるインスタンスを使用して異なるワークロードを処理することを推奨します。 |
単一インスタンスのグループ | 1つのインスタンスに作成できるグループの数は、購入する仕様によって異なります。 詳細については、「インスタンス仕様の制限」をご参照ください。 | 5,000 | ビジネスのセキュリティと安定性を確保するために、異なるインスタンスを使用して異なるワークロードを処理することを推奨します。 |
メッセージ保存期間 |
|
| ストレージ資金が十分な場合は、より長い保持期間を指定することを推奨します。 保持期間が長くなると、システムはより長い時間ウィンドウ内で問題のトラブルシューティングとメッセージのバックトラックを実行できます。 |
単一のコンシューマーグループ内のInflightメッセージ | 最大値: 2500。 | 最大値: 2500。 | 消費者グループ内の消費者からの遅い応答は、多数の機内メッセージを引き起こす可能性がある。 通常のビジネスを確実に実行するには、できるだけ早い機会に問題に対処してください。 |
操作の制限
ApsaraMQ for RocketMQは、オープンソースのApache RocketMQに基づく、フルマネージド型でO&Mフリーのサービスとしてのプラットフォーム (PaaS) サービスです。 特定の高リスクのO&M運用および機能には制限があります。 操作と機能の上限を引き上げたい場合は、ApsaraMQ for RocketMQテクニカルサポートにお問い合わせください。
項目 | 制限事項 |
Apache RocketMQ管理ツールとの互換性 | ApsaraMQ for RocketMQは、Apache RocketMQ Admin APIの呼び出し、またはApache RocketMQ CLI管理ツールの使用によるインスタンス、トピック、およびグループの管理をサポートしていません。 API操作を呼び出してApsaraMQ for RocketMQリソースを管理する場合は、Alibaba Cloudが提供するOpenAPI Explorerを使用することを推奨します。 OpenAPI Explorerは、複数のプログラミング言語とCLIコマンドのSDKを使用してリソースの管理をサポートします。 |
Apache RocketMQリクエスト-返信メッセージ | ApsaraMQ for RocketMQは、Apache RocketMQ Request-Replyメッセージの送信をサポートしていません。 |
Apache RocketMQストリーミング | ApsaraMQ for RocketMQは、ホストされているApache RocketMQストリーミングをサポートしていません。 Alibaba Cloud環境に基づいてストリーミングコンポーネントをデプロイできます。 ApsaraMQ for RocketMQが提供するメッセージ統合機能を使用して、軽量のデータ統合と計算を設定することもできます。 |
Apache RocketMQ MQTT | ApsaraMQ for RocketMQは、ホストされているApache RocketMQ MQTTをサポートしていません。 Alibaba Cloudが提供するApsaraMQ for MQTTの使用を推奨します。 ApsaraMQ for MQTTは、Apache RocketMQ MQTTと比較して、より多くの機能を提供します。 |
Apache RocketMQ EventBridge | ApsaraMQ for RocketMQは、ホストされているApache RocketMQ EventBridgeをサポートしていません。 Alibaba Cloudが提供するEventBridgeを使用することを推奨します。 Apache RocketMQ EventBridgeと比較して、Alibaba Cloud EventBridgeはより多くの機能を提供します。 |
Apache RocketMQコネクタ | ApsaraMQ for RocketMQは、ホストされているApache RocketMQコネクタをサポートしていません。 ApsaraMQ for RocketMQが提供するメッセージ統合機能を使用して、メッセージ流入およびメッセージ流出機能を実装できます。 |
インスタンス仕様の制限
Standard EditionインスタンスおよびProfessional Editionスタンドアロンインスタンスは、コンピューティングリソースのスケーリングをサポートしていません。 仕様制限を超えるトラフィックによって引き起こされるインスタンススロットリングを防ぐために、リソース使用量を計画することを推奨します。
インスタンスのトピックおよびコンシューマーグループクォータは、大規模な本番環境での実際のユースケースに基づいて計算されます。 ほとんどの場合、これらのクォータはビジネス要件を満たすことができます。 部門やアプリケーションごとに異なるトピックや消費者グループを使用することを推奨します。 すべてのビジネスを1つのインスタンスで実行しないでください。
メッセージングTPSは、メッセージを送受信できる合計回数です。 メッセージングTPSは、サイズが4 KBの通常のメッセージに基づいて計算されます。 注目メッセージと大きなメッセージのTPSを計算するときは、乗数を使用する必要があります。 計算方法については、「コンピューティング仕様」をご参照ください。
以下の項目では、実際のメッセージング TPS が仕様の制限を超えた場合の動作について説明します。
インスタンスのエラスティック TPS 機能が有効化され、使用された超過 TPS がエラスティック TPS 機能で指定された上限を超えていない場合、インスタンスは正常に実行されます。 超過 TPS の料金は従量課金方式で課金されます。 使用された超過 TPS がエラスティック TPS 機能で指定された上限を超えた場合、インスタンスでスロットリングが行われます。
エラスティック TPS 機能の課金ルールについては、「エラスティック TPS 料金」をご参照ください。
エラスティック TPS 機能が ApsaraMQ for RocketMQ インスタンスでサポートされていないか、または有効化されていない場合、インスタンスでスロットリングが行われます。
多数のクライアントがApsaraMQ for RocketMQインスタンスに接続されている場合、ブローカーは接続を維持するために多数のリソースを消費します。 これはブローカーの安定性を損なう。 ApsaraMQ for RocketMQインスタンスへの接続数が仕様の制限を超えないようにすることを推奨します。
サブスクリプションおよび従量課金インスタンス
Standard Edition
サブカテゴリ版 | コンピューティング仕様 | 最大メッセージングTPS | 最大弾性TPS | 最大接続数 | 送信インターネット帯域幅 (Mbit/s) | インスタンスあたりの最大トピック数 | インスタンスあたりの最大コンシューマーグループ |
スタンドアロン版 | rmq.s1.micro | 500 | 非該当 Elastic TPSはサポートされていません。 | 2,000 | 1から1,000 カスタム設定がサポートされています。 | 100 | 1,000 |
クラスター高可用性エディション | rmq.s2.2xlarge | 2,000 | 4,000 | 50 | 500 | ||
rmq.s2.4xlarge | 4,000 | 4,000 | 75 | 750 | |||
rmq.s2.6xlarge | 6,000 | 6,000 | 100 | 1,000 |
最大仕様 (rmq.s2.6xlarge) で提供されるトピックとコンシューマーグループのクォータが要件を満たしていない場合は、インスタンスをProfessional Editionにアップグレードし、ビジネス要件を満たす仕様を選択することを推奨します。
プロフェッショナル版
サブカテゴリ版 | コンピューティング仕様 | 最大メッセージングTPS | 最大弾性TPS | 最大接続数 | 送信インターネット帯域幅 (Mbit/s) | インスタンスあたりの最大トピック数 | インスタンスあたりの最大コンシューマーグループ |
スタンドアロン版 | rmq.p1.micro | 500 | 非該当 Elastic TPSはサポートされていません。 | 2,000 | 1から1,000 カスタム設定がサポートされています。 | 150 | 1,500 |
クラスター高可用性エディション | rmq.p2.4xlarge | 4,000 | 2,000 | 4,000 | 100 | 1,000 | |
rmq.p2.6xlarge | 6,000 | 3,000 | 6,000 | ||||
rmq.p2.10xlarge | 10,000 | 5,000 | 10,000 | 150 | 1,500 | ||
rmq.p2.20xlarge | 20,000 | 10,000 | 10,000 | ||||
rmq.p2.50xlarge | 50,000 | 20,000 | 14,000 | ||||
rmq.p2.100xlarge | 100,000 | 30,000 | 26,000 | ||||
rmq.p2.150xlarge | 150,000 | 50,000 | 38,000 |
最大の仕様 (rmq.p2.10xlarge以上) で提供されるトピックとコンシューマーグループのクォータが要件を満たしていない場合、 チケットを起票します。
Enterprise Platinum Edition
サブカテゴリ版 | コンピューティング仕様 | 最大メッセージングTPS | 最大弾性TPS | 最大接続数 | 送信インターネット帯域幅 (Mbit/s) | インスタンスあたりの最大トピック数 | インスタンスあたりの最大コンシューマーグループ |
クラスター高可用性エディション | rmq.u2.10xlarge | 10,000 | 5,000 | 10,000 | 1から1,000 カスタム設定がサポートされています。 | 150 | 1,500 |
rmq.u2.20xlarge | 20,000 | 10,000 | 10,000 | ||||
rmq.u2.40xlarge | 40,000 | 20,000 | 10,000 | ||||
rmq.u2.100xlarge | 100,000 | 30,000 | 26,000 | ||||
rmq.u2.150xlarge | 150,000 | 50,000 | 38,000 | ||||
rmq.u2.200xlarge | 200,000 | 60,000 | 50,000 | ||||
rmq.u2.400xlarge | 400,000 | 100,000 | 54,000 | ||||
rmq.u2.600xlarge | 600,000 | 200,000 | 80,000 | ||||
rmq.u2.1000xlarge | 1,000,000 | 300,000 | 134,000 |
Enterprise Platinum Editionインスタンスが提供するトピックとコンシューマーグループのクォータが要件を満たしていない場合、 チケットを起票します。
Serverless インスタンス
プライマリインスタンスのエディション | コンピューティング仕様 | ピークメッセージングTPS | 最大接続数 | インターネットトラフィック | インスタンスあたりの最大トピック数 | インスタンスあたりの最大コンシューマーグループ |
Standard Edition | rmq.s3.nxlarge | 50,000 | 10,000 | 制限は課されない。 実際の使用量に基づいて課金されます。 | 5,000 | 5,000 |
Professional Edition | rmq.p3.nxlarge | 50,000 メッセージングTPSが50,000を超える場合、数分以内の自動スケーリングがサポートされます。 | 30,000 | 制限は課されない。 実際の使用量に基づいて課金されます。 | 5,000 | 5,000 |