ApsaraMQ for RocketMQ は、Apache RocketMQ をベースにした Alibaba Cloud の分散プラットフォームです。低レイテンシー、高い同時実行性、高可用性、高信頼性を備えたメッセージ、イベント、ストリームを処理するための統一ソリューションを提供します。Apache RocketMQ 5.0 のリリース後、Alibaba Cloud ApsaraMQ for RocketMQ は、より安定して信頼性の高いサーバーバージョン 5.x を提供するようになりました。このトピックでは、ApsaraMQ for RocketMQ のサーバーバージョン 5.x と 4.x の違いと互換性について説明します。
バージョン 5.x の利点
以前のサーバーバージョンと比較して、ApsaraMQ for RocketMQ 5.x には次の利点があります。
高度なアーキテクチャ
バージョン 5.x は、ストレージとコンピューティングを分離する分離アーキテクチャを使用します。この設計により、ストレージリソースと計算リソースを必要に応じて水平かつ独立してスケーリングできます。このアーキテクチャは、効率的な弾力性のある運用保守 (O&M) をサポートし、パフォーマンス専有型の大規模な容量を提供します。
簡素化された開発
バージョン 5.x は、Apache RocketMQ と完全に互換性のあるクライアント SDK を介したアクセスをサポートします。また、以前のすべての SDK バージョンおよび API 操作との互換性も維持します。
VPC 内でのセキュリティ認証をサポートします。クラウドに移行するには、コードを変更せずにエンドポイントを変更するだけで済みます。
簡素化された O&M
バージョン 5.x は、自動弾力性や軽量テスト環境などのソリューションを提供し、一般的な課題に対処します。これらの課題には、オンライン容量評価、サービストラフィックの変動への対応、日常的なグレースケール環境の管理などがあります。これにより、全体的な O&M が簡素化され、リスクが軽減されます。
より柔軟なコスト
クラウドネイティブ技術で最適化されたバージョン 5.x は、メッセージ処理のための予約トラフィックとバーストトラフィックの弾力性の組み合わせをサポートします。つまり、バーストトラフィックのために大きなバッファーを予約する必要はありません。
メッセージストレージは従量課金です。スケールダウンできないアタッチドディスクと比較して、このモデルは弾力性において大きな利点を提供します。
より幅広い製品
バージョン 5.x は、完全なサブスクリプションおよび従量課金の価格モデルを備えた、より包括的な範囲のインスタンスタイプを提供します。
AI アプリケーションにおける非同期通信を改善するための新しい LiteTopic モデル
このモデルは、長いタスク処理時間、希少で高価な計算能力、計算能力の利用率と変動するサービストラフィックのバランスをとるという課題など、AI サービスにおける一般的な問題点に対処します。軽量な Topic 機能と対応するソリューションを提供します。開発者はこのモデルを使用して、堅牢で効率的、かつスケーラブルな非同期通信システムを簡単に構築できます。このシステムは、リクエストのピークを管理し、バックエンドの処理圧力を軽減することで、リソース利用率を向上させ、コストを削減します。
SDK バージョン
次の表は、ApsaraMQ for RocketMQ のさまざまな SDK バージョンでサポートされている機能について説明しています。
表では、✅ は機能がサポートされていることを示し、❌ は機能がサポートされていないことを示します。
項目 | ||||||
プロトコル | gRPC プロトコル v2 | Remoting プロトコル | Remoting プロトコル | Remoting プロトコル | gRPC プロトコル v1 | HTTP プロトコル |
アクセス可能なインスタンス | 5.x シリーズのインスタンス |
|
|
| 4.x シリーズのインスタンス | 4.x シリーズのインスタンス |
推奨 | 5.x gRPC SDK を使用してください。
|
|
| |||
通常、順序、トランザクション、およびスケジュールメッセージの送信 | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
同時消費 | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
順序消費 | ✅ | ✅ | ✅ | ✅ | ✅ | ✅ |
最適化された同時実行性による順序消費 | ✅ | ❌ | ❌ | ❌ | ❌ | ❌ |
ブロードキャスト消費 | ❌ | ✅ | ✅ | ✅ | ❌ | ❌ |
ストリーム消費 (Flink などへの接続) | ❌ | ✅ | ✅ | ❌ | ❌ | ❌ |
メッセージトレース | ✅ | ✅ | バージョン 4.5.2 以降でサポート | ✅ | ✅ | ❌ |
✅ | ❌ | ❌ | ❌ | ❌ | ❌ | |
✅ | 5.x シリーズのインスタンスでのみサポート | ❌ | ❌ | ❌ | ❌ | |
バージョン 4.x と 5.x の機能の互換性
ApsaraMQ for RocketMQ 5.x のインスタンスは、大規模なエンタープライズ顧客の本番環境での実践に基づいて最適化されています。メッセージの送受信プロセスにおける一部の機能の動作が調整されています。そのため、一部のシナリオでは、パラメーター構成と機能の動作が異なる場合があります。これらの違いは、通常、主要なメッセージ処理フローには影響しません。既存の 4.x インスタンスを 5.x にアップグレードする場合は、必要に応じてリスクを評価する必要があります。
機能の動作の具体的な違いは次のとおりです。
機能の違い | バージョン 4.x | バージョン 5.x | 説明 |
スケジュールメッセージの最大遅延 | 40 日 |
| 長い遅延パラメーターは、システムの安定性にリスクをもたらす可能性があります。過度に長い遅延を設定しないでください。より短い遅延を使用して、ビジネスシナリオをシミュレートしてください。詳細については、「スケジュールメッセージと遅延メッセージ」をご参照ください。 既存の 4.x インスタンスを移行していて、最大遅延が要件を満たさない場合は、submit a ticketしてご相談ください。 |
HTTP プロトコルのサポート | サポート | 非サポート | バージョン 5.x は HTTP プロトコルをサポートしていません。既存の 4.x インスタンスが HTTP プロトコルを使用している場合は、アップグレードを延期してください。 |
RAM 権限付与ポリシー | データリンク + コントロールリンク | コントロールリンクをサポートしますが、権限付与ポリシーはバージョン 4.x とは異なります |
|
グローバルメッセージルーティング | サポート | 非サポート | バージョン 5.x は、グローバルメッセージルーティングタスクの構成をサポートしていません。インスタンス間でメッセージを同期するには、メッセージ統合機能を使用する必要があります。詳細については、「メッセージ統合」をご参照ください。 |
メッセージタイプの制限 | 制限なし | 厳格な制限 | バージョン 5.x では、メッセージタイプは独立した O&M と処理のために Topic に分離されます。システムは、送信されたメッセージのタイプが Topic に定義されたメッセージタイプと一致することを厳密に検証します。検証が失敗した場合、メッセージ送信リクエストは拒否され、タイプ不一致の例外が返されます。詳細については、「Topic の動作の制約」をご参照ください。 |
購入制限
ApsaraMQ for RocketMQ 5.x のインスタンスは、すべてのユーザーが購入できます。
ApsaraMQ for RocketMQ 4.x のインスタンスは、既存のユーザーのみが購入できます。インスタンスをバージョン 5.x にアップグレードすることをお勧めします。アップグレードするには、チケットを送信してください。
バージョン 4.x から 5.x へのアップグレード
アップグレードツールを使用したバージョン 4.x から 5.x へのインプレースアップグレードは、現在サポートされていません。既存のインスタンスをバージョン 5.x にアップグレードするには、5.x インスタンスを購入し、次の図に示すように、サービストラフィックを徐々に新しいインスタンスに移行する必要があります。
前の図に示すように、2 番目のステップで Topic とグループのインポートおよびエクスポート機能を使用して、メタデータをすばやく作成できます。詳細については、「Topic のインポートとエクスポート」および「グループのインポートとエクスポート」をご参照ください。
サービスを移行する際には、次の図に示すデュアルリード、デュアルライト、および段階的リリースソリューションを使用できます。
