ApsaraMQ for RocketMQ は、複数のプログラミング言語に対応した TCP および HTTP クライアント SDK を提供します。本ガイドでは、サービスの有効化、リソースの作成、および最初の通常メッセージの送信手順を説明します。
プロトコルの選択
ApsaraMQ for RocketMQ の各インスタンスには、TCP エンドポイントと HTTP エンドポイントの両方が公開されています。ワークロードに適したプロトコルを選択し、対応する SDK とエンドポイントを使用してください。
| プロトコル | SDK |
|---|---|
| TCP | TCP クライアント SDK |
| HTTP | HTTP クライアント SDK |
SDK は必ず対応するエンドポイントと組み合わせて使用してください。TCP クライアント SDK は TCP エンドポイントにのみ接続可能であり、HTTP クライアント SDK は HTTP エンドポイントにのみ接続可能です。
前提条件
開始する前に、以下の条件を満たしていることを確認してください。
ApsaraMQ for RocketMQ が有効化された Alibaba Cloud アカウント (root ユーザー)
ApsaraMQ for RocketMQ リソースの作成および管理に必要な RAM 権限
ご利用のプログラミング言語に対応した SDK がインストール済みのクライアント環境
通常メッセージの送信および受信
ApsaraMQ for RocketMQ は、4 種類のメッセージタイプをサポートしています。以下では、通常メッセージを例として手順を説明します。順序付きメッセージ、トランザクションメッセージ、またはスケジュールされたメッセージを利用する場合は、それぞれのドキュメントをご参照ください。
ステップ 1:サービスの有効化と権限付与
Alibaba Cloud コンソールで ApsaraMQ for RocketMQ を有効化し、ご利用のアカウントに対して RAM 権限を設定します。
ステップ 2:リソースの作成
ApsaraMQ for RocketMQ コンソールで、インスタンス、トピック、およびグループを作成します。
トピックを作成する際は、通常メッセージ をメッセージタイプとして選択してください。各トピックは 1 種類のメッセージタイプのみをサポートするため、通常メッセージ用トピックでは他のメッセージタイプの送信・受信はできません。
TCP および HTTP のコンシューマー向けに、別々のグループを作成することを推奨します。異なるプロトコルでは異なるクライアント SDK を使用する必要があります。グループの制限事項および構成詳細については、「グループの管理」をご参照ください。
ステップ 3:エンドポイントの取得
ご利用のインスタンスに対応する TCP または HTTP エンドポイントを特定し、選択したプロトコルと一致するエンドポイントを使用してください。
すべてのリージョンで、TCP および HTTP のパブリックエンドポイントおよびプライベートエンドポイントが利用可能です。
| エンドポイントタイプ | 使用タイミング |
|---|---|
| VPC エンドポイント(推奨) | 本番ワークロード向け。インターネットトラフィック料金は発生しません。 |
| パブリックエンドポイント | クロスリージョンアクセス、オンプレミスデータセンター、または Cloud Enterprise Network(CEN)が利用できない場合のインターネット経由アクセス向け。アウトバウンドトラフィック料金が適用されます。詳細については、「インターネットトラフィックの課金」をご参照ください。 |
ステップ 4:メッセージの送信および受信
ご利用のプログラミング言語に対応した SDK を使用して、エンドポイントに接続し、トピックへメッセージを送信、およびトピックからのメッセージをサブスクライブします。
TCP の場合:「TCP クライアント SDK を使用したメッセージの送信およびサブスクライブ」をご参照ください。
HTTP の場合:「HTTP クライアント SDK を使用したメッセージの送信およびサブスクライブ」をご参照ください。
以下のフローチャートは、エンドツーエンドの処理フローを示しています。
