ApsaraMQ for RocketMQ は、Alibaba Cloud が提供するメッセージ、イベント、ストリーム処理を統合した分散型プラットフォームです。Apache RocketMQ をベースに構築されており、低遅延、高い同時実行性、高可用性、高信頼性を実現しています。Apache RocketMQ 5.0 のリリースを受けて、ApsaraMQ for RocketMQ ではより安定性と信頼性に優れたサーバー側 5.x バージョンが提供されるようになりました。本トピックでは、ApsaraMQ for RocketMQ のサーバー側 5.x バージョンと 4.x バージョンの相違点および互換性について説明します。
5.x バージョンのメリット
従来のサーバー側バージョンと比較して、ApsaraMQ for RocketMQ 5.x には以下のメリットがあります。
より高度なアーキテクチャ
ストレージとコンピューティングを分離したメッセージアーキテクチャを完全に採用しています。ストレージおよびコンピューティングリソースは、必要に応じて個別に水平方向にスケーリング可能です。このアーキテクチャにより、効率的なエラスティックな運用管理 (O&M) が可能となり、高性能かつ大規模な処理能力を提供します。
開発しきい値の低下
Apache RocketMQ と完全に一致するクライアント SDK の使用を推奨しています。また、以前のすべての SDK および API オペレーションバージョンとの下位互換性も備えています。
VPC 内での安全な識別をサポートしており、クラウドへの移行時にはアクセスポイントを変更するだけで済み、その他のコード変更は不要です。
O&M しきい値の低下
自動回転やエラスティック対応、軽量なステージング環境などのソリューションを提供しています。これにより、オンライン容量評価、ビジネスピーク/オフピーク時のエラスティック対応、日常的なグレースケール環境といった一般的な課題に対応し、全体的な O&M しきい値を下げ、リスクを軽減します。
より柔軟なコスト構造
クラウドインフラストラクチャ技術の最適化により、メッセージ送受信のコンピューティング能力が予約トラフィックとバーストトラフィックの組み合わせをサポートしています。そのため、バーストトラフィックのために大きなバッファーを確保する必要がなくなります。
メッセージストレージは従量課金モデルを採用しており、スケールインが不可能なクラウドディスクをアタッチする方式と比べて、大幅なエラスティックメリットを提供します。
より包括的な販売モデル
より包括的な階層型プランを提供し、月額および時間単位の両方の課金モデルをサポートしています。
新しい LiteTopic モデル により、AI アプリケーション向けの非同期通信をより強力にサポート
AI ビジネスタスクの長時間処理、コンピューティング能力リソースの希少性と高コスト、コンピューティング能力利用率とビジネストラフィック変動の競合といった一般的な課題に対応します。軽量トピック機能および関連ソリューションを提供することで、開発者は堅牢で効率的かつスケーラブルな非同期通信システムを簡単に構築できます。これにより、リクエストのピーク/オフピークが平準化され、バックエンド処理負荷が軽減され、リソース利用率が向上し、コスト削減につながります。
各バージョンの SDK 説明
次の表は、ApsaraMQ for RocketMQ の各バージョンにおける SDK および機能サポート状況を示しています。表中の ✔ は機能がサポートされていることを、✘ はサポートされていないことを示します。
次の表では、✔ は機能がサポートされていることを、✘ はサポートされていないことを示します。
比較項目 | ||||||
プロトコル | gRPC プロトコル v2 | Remoting プロトコル | Remoting プロトコル | Remoting プロトコル | gRPC プロトコル v1 | HTTP プロトコル |
アクセス可能なインスタンス | 5.x シリーズインスタンス |
|
|
| 4.x シリーズインスタンス | 4.x シリーズインスタンス |
使用推奨 | 5.x gRPC SDK を使用してください。
|
|
| |||
通常、順序、トランザクション、スケジュールされたメッセージの送信 | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔ | ✔ |
並列消費 | ✔#10004; | ✔#10004; | ✔#10004; | ✔ | ✔#10004; | ✔#10004; |
メッセージの順序消費 | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; | ✔#10004; |
メッセージの順序消費 同時実行数最適化 | ✔#10004; | ✘#10008; | ✘#10008; | ✘ | ✘#10008; | ✘#10008; |
ブロードキャスト消費 | ✘ | ✔#10004; | ✔ | ✔#10004; | ✘ | ✘#10008; |
ストリーム消費 (Flink への接続など) | ✘#10008; | ✔ | ✔#10004; | ✘#10008; | ✘#10008; | ✘#10008; |
メッセージトレース | ✔#10004; | ✔#10004; | バージョン 4.5.2 以降でサポート | ✔#10004; | ✔#10004; | ✘#10008; |
✔#10004; | ✘#10008; | ✘ | ✘#10008; | ✘ | ✘ | |
✔#10004; | 5.x シリーズインスタンスのみサポート | ✘ | ✘#10008; | ✘#10008; | ✘#10008; | |
4.x および 5.x バージョン間の機能互換性
ApsaraMQ for RocketMQ 5.x インスタンスは、大手エンタープライズ顧客の本番環境での運用経験に基づいて構築されており、メッセージ送受信に関する機能および動作が最適化されています。そのため、一部のシナリオではパラメータ設定および機能動作が異なる場合があります。これらの変更は通常、主要なメッセージフローに影響しません。既存の 4.x インスタンスを 5.x にアップグレードする場合は、ビジネス要件に基づいてリスクを評価する必要があります。
次の表は、機能および動作の相違点を示しています。
機能の相違点 | バージョン 4.x | バージョン 5.x | 説明 |
スケジュールされたメッセージの最大持続時間 | 40 日 |
詳細については、「クォータと制限事項」をご参照ください。 | 長時間のスケジューリングはシステムの安定性リスクとなる可能性があるため、持続時間を過度に長く設定しないでください。ビジネスシナリオを短い持続時間でシミュレートすることを推奨します。詳細については、「スケジュールおよび遅延メッセージ」をご参照ください。 既存の 4.x インスタンスを移行中で、最大持続時間が要件を満たさない場合は、チケットを送信してサポートを依頼してください。 |
HTTP プロトコルのサポート | ✔ | ✘ | バージョン 5.x は HTTP プロトコルをサポートしていません。既存の 4.x インスタンスで HTTP プロトコルを使用している場合は、アップグレードを延期してください。 |
RAM 権限付与ポリシー | データリンク + コントロールリンク | コントロールリンクをサポートしますが、権限付与ポリシーはバージョン 4.x とは異なります。 |
|
グローバルメッセージルーティング | ✔ | グローバルメッセージレプリケーション 機能を使用します。 | グローバルメッセージレプリケーション は、オープンソース、Alibaba Cloud 4.x、Alibaba Cloud 5.x の各インスタンスタイプをサポートしており、メッセージおよび消費進捗のクロスリージョン・クロスインスタンス同期を提供します。 |
メッセージタイプ制限 | 制限なし | 厳格に制限 | バージョン 5.x では、メッセージタイプごとにトピックを分離して個別に運用管理および処理を行います。システムは送信されたメッセージタイプとトピックに定義されたメッセージタイプを厳密に検証し、検証に失敗した場合は送信リクエストを拒否し、タイプ不一致例外を返します。詳細については、「トピック動作制約」をご参照ください。 |
購入制限事項
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 番目のステップではトピックおよびグループのインポート/エクスポート機能を使用してメタデータを迅速に作成できます。詳細については、「トピックのインポート/エクスポート」および「グループのインポート/エクスポート」をご参照ください。
ビジネス移行時には、デュアルリードおよびデュアルライト操作と段階的リリースを組み合わせた以下のソリューションを使用できます。
