ApsaraMQ for RocketMQ は、Apache RocketMQ 上に構築された分散メッセージングプラットフォームです。メッセージ、イベント、ストリーム処理を、低レイテンシー、高い同時実行性、高可用性、高い信頼性で統合します。主な機能には、非同期デカップリング、ストリームデータ処理、分散アプリケーション向けのイベント駆動処理などがあります。
ApsaraMQ for RocketMQ を選ぶ理由
ApsaraMQ for RocketMQ は、Alibaba Cloud の クラウドネイティブインフラストラクチャ上に構築されており、Apache RocketMQ のコア API および機能と互換性があります。
ApsaraMQ for RocketMQ は、セルフマネージドクラスターと比較して、次の利点があります。
高度なアーキテクチャ
ApsaraMQ for RocketMQ は、コンピューティングとストレージを分離します。ストレージとコンピューティングは水平方向かつ独立してスケールするため、弾力的な運用保守 (O&M) と大規模で高性能なメッセージングが可能になります。
高いパフォーマンス
単一インスタンスのクラスターで、メッセージの送受信で最大 100 万トランザクション/秒 (TPS) を維持し、大規模なプロモーションなどのピークトラフィック時にも安定性を確保します。
セキュリティと信頼性
-
ゾーン冗長ストレージ：複数のゾーンにデプロイされ、データは 3 重に冗長化して保存されます。あるゾーンが利用できなくなっても、サービスは引き続きアクセス可能です。
-
データレプリケーション：クロスリージョンおよびリージョン内のデータレプリケーションをサポートしています。ルーティングルールにより、ソースインスタンスと宛先インスタンス間でデータが同期されます。
安定性に関する SLA
マルチゾーンデプロイメントにより、業界をリードする SLA を提供します。マルチレプリカストレージを通じて、99.99% のサービス可用性と 99.99999999% のデータの信頼性を実現します。
弾力性とコスト効率
メッセージコンピューティングは予約容量とバースト容量を組み合わせており、トラフィックスパイクのために大きなバッファを予約する必要がなくなり、マシンリソースを最大で半分節約できます。ストレージはサーバーレスかつ従量課金制であり、アタッチされたクラウドディスクよりも高い弾力性と低いコストを提供します。
運用保守 (O&M) とオブザーバビリティ
運用保守 (O&M) とオブザーバビリティ機能を提供します。具体的には、OpenTelemetry および Prometheus とのワンクリック統合、エンドツーエンドトレーシング、セルフサービスの運用保守 (O&M) 統合のための OpenAPI サポートなどが含まれます。
金融グレードの災害対策
グローバルなクロスリージョンメッセージルーティングとレプリケーションを、ミリ秒レベルのレイテンシーとトピックレベルのデータバックアップおよび同期でサポートします。
ユースケース
統一されたメッセージストレージと軽量なコンピューティングレイヤー上に構築された ApsaraMQ for RocketMQ は、非同期デカップリング、ストリームデータ処理、イベント駆動処理という 3 つの主要なシナリオをサポートしています。
ビジネスメッセージ
-
ApsaraMQ for RocketMQ は、元々 Alibaba の Double 11 (独身の日) セールのために構築されたもので、物流、ショッピングカート、クレジットポイントなどのマイクロサービスシステムで広く使用されています。ApsaraMQ for RocketMQ には、次の利点があります。
-
非同期デカップリングによる処理リンクの短縮
ApsaraMQ for RocketMQ は、アップストリームサービスとダウンストリームサービスを分離し、呼び出しチェーンを短縮します。これにより、応答時間の短縮、疎結合化、開発者効率の向上が実現します。
-
ピーク負荷の平準化による安定性の向上
非同期操作のみを提供する従来のミドルウェアとは異なり、ApsaraMQ for RocketMQ はオンライントランザクションシナリオ向けに構築されており、ピーク負荷の平準化をコア機能として含んでいるため、安定性が向上し、コストが削減されます。
ApsaraMQ for RocketMQ は数億のメッセージを蓄積し、ホットトラフィックモデルとコールドトラフィックモデルが混在する状況に対応します。大規模なプロモーションなどのピークシナリオでトラフィックの急増を吸収し、ダウンストリームサービスを安全な運用範囲内に維持します。
-
-
ApsaraMQ for RocketMQ の 分散トランザクションメッセージソリューションには、次の利点があります。
-
高性能なシステム
結果整合性に基づき、トランザクションメッセージは従来の XA トランザクションよりも高いスループットと優れたスケーラビリティを提供します。
-
開発コストの削減
2 フェーズのインターフェイスが複数のトランザクションブランチを調整するため、ビジネス補償ロジックが不要になります。
次の図は、従来のトランザクションと ApsaraMQ for RocketMQ のトランザクションメッセージソリューションを比較したものです。
-
-
ApsaraMQ for RocketMQ は、秒単位の精度を持つ分散 スケジュールメッセージを提供し、注文のタイムアウト処理や分散遅延スケジューリングに広く使用されています。
ApsaraMQ for RocketMQ のスケジュールメッセージには、次の利点があります。
-
高いスケジューリング精度と低い開発オーバーヘッド
スケジューリング時間に段階的な間隔はありません。ビジネス側での重複排除を行うことなく、任意の精度でイベントをトリガーできます。
-
高いパフォーマンスとスケーラビリティ
従来のスケジューリングソリューションでは、パフォーマンスボトルネックとなるデータベーススキャンが必要でした。ApsaraMQ for RocketMQ はイベント駆動処理を使用することで、数百万 TPS を達成します。
-
ストリーム処理
ApsaraMQ for RocketMQ は、ログ収集、データ統合、分析システムを接続する高スループットのストリームストレージを提供します。ApsaraMQ for RocketMQ を使用して、アップストリームのデータをリアルタイムコンピューティングやオフラインストレージなどのダウンストリームシステムに配信します。
イベント駆動処理
ApsaraMQ for RocketMQ を EventBridge と組み合わせることで、イベント駆動アーキテクチャを実装できます。EventBridge のビジュアルイベントルールは、メッセージデータを処理し、Function Compute、HTTP エンドポイント、サードパーティサービスなどのダウンストリームターゲットをトリガーします。
移行ガイド
利用開始
ApsaraMQ for RocketMQ インスタンスの作成：