SDK を使用してメッセージを送受信する前に、必要な ApsaraMQ for RocketMQ リソース (インスタンス、トピック、コンシューマーグループ) を作成する必要があります。また、インスタンスのエンドポイントも必要です。これらのリソースは SDK コードで指定する必要があります。
前提条件
背景情報
リソースはコンソールで作成するか、API 操作を呼び出して作成できます。以下の手順ではコンソールを使用します。
OpenAPI を使用してリソースを作成するには、次のトピックをご参照ください:
制限事項
-
リージョンの制限
作成するインスタンスが、前提条件で準備した VPC および vSwitch と同じリージョンにあることを確認してください。
-
命名規則
インスタンス、トピック、コンシューマーグループの命名規則については、「クォータと制限」をご参照ください。
-
トピックタイプの制限
トピックのメッセージタイプは、送受信するメッセージのタイプと一致している必要があります。たとえば、通常メッセージのトピックを作成した場合、そのトピックは通常メッセージの送受信にのみ使用でき、順序メッセージには使用できません。詳細については、「トピックの使用に関する推奨事項」をご参照ください。
インスタンスの作成
ApsaraMQ for RocketMQ コンソールにログインします。左側のナビゲーションウィンドウで、[インスタンス] をクリックします。
-
上部メニューで、リージョン (例:中国 (杭州)) を選択します。
-
インスタンス数 ページで、インスタンスの作成 をクリックします。Message Queue for Apache RocketMQ インスタンスの作成 パネルで、インスタンスのバージョン を 5.0 シリーズ に設定し、プロダクトタイプ を選択して、OK をクリックします。
ApsaraMQ for RocketMQ は、次の製品タイプをサポートしています:
-
サブスクリプション:インスタンスのコンピューティング仕様に基づいて月単位で請求される前払いモデルです。
-
従量課金:インスタンスのコンピューティング仕様に基づいて時間単位で請求される後払いモデルです。
-
サーバーレス:メッセージリクエストの合計数に基づいて請求される従量課金モデルです。
説明サーバーレスインスタンスは、[中国 (杭州)]、[中国 (張家口)]、[中国 (北京)]、[中国 (深圳)]、[シンガポール (シンガポール)]、[ドイツ (フランクフルト)]、[米国 (バージニア)]、[米国 (シリコンバレー)] の各リージョンで利用できます。対応リージョンは順次追加されます。現在の対応状況については、「サポートされているリージョン」をご参照ください。
課金項目と適用シナリオの詳細については、「課金の概要」をご参照ください。
-
-
購入ページでインスタンスの仕様を選択し、[今すぐ購入] をクリックして支払いを完了します。
インスタンスを作成する際は、次の表をご参照ください。各パラメーターの詳細については、「インスタンスエディションの選択」をご参照ください。
サーバーレス
パラメーター
値の例
[Primary Edition]
Standard
課金モード
デフォルトは [Pay-by-request] です。
メッセージストレージ仕様
ストレージ容量を選択する必要はありません。実際に使用したストレージ領域に対して課金されます。
VPC ID
vpc-bp1cg09dua6sgh0******
前提条件で作成した VPC の ID です。
重要インスタンスの作成後、選択した VPC は変更できません。関連付けられた VPC を変更するには、まず購入したインスタンスをリリースしてから、新しいインスタンスを購入する必要があります。
[vSwitch ID]
vsw-bp1vqb0p9nz3irz******
前提条件で作成した vSwitch の ID です。
サーバーレスインスタンスでは、2 つの vSwitch ID を選択する必要があります。
重要インスタンスの作成後、選択した vSwitch は変更できません。関連付けられた vSwitch を変更するには、まず購入したインスタンスをリリースしてから、新しいインスタンスを購入する必要があります。
[[インターネットアクセス]]
オフ
説明-
この手順では VPC アクセスを例として使用するため、インターネットアクセスはデフォルトで無効になっています。
イントラネットアクセスタイプ
デフォルトは トラフィック課金 です。
サーバーレスインスタンスは VPC アクセスのみをサポートしており、インターネットアクセスには対応していません。
[リソースグループ]
デフォルトのリソースグループを選択します。
[セキュリティグループ]
前提条件で作成したセキュリティグループを選択します。
サブスクリプションまたは従量課金
パラメーター
値の例
[Primary Edition]
Standard
サブカテゴリ エディション
Cluster High-availability Edition (本番環境に推奨)
メッセージ送受信コンピューティング仕様
rmq.s2.2xlarge
VPC ID
vpc-bp1cg09dua6sgh0******
前提条件で作成した VPC の ID です。
重要インスタンスの作成後、選択した VPC は変更できません。関連付けられた VPC を変更するには、まず購入したインスタンスをリリースしてから、新しいインスタンスを購入する必要があります。
[vSwitch ID]
vsw-bp1vqb0p9nz3irz******
前提条件で作成した vSwitch の ID です。
重要インスタンスの作成後、選択した vSwitch は変更できません。関連付けられた vSwitch を変更するには、まず購入したインスタンスをリリースしてから、新しいインスタンスを購入する必要があります。
パブリックアクセスタイプ
オフ
説明この手順では VPC アクセスを例として使用するため、インターネットアクセスはデフォルトで無効になっています。インターネット経由でサービスにアクセスするには、[パブリックアクセスタイプ] を [有効] に設定します。
[リソースグループ]
デフォルトのリソースグループを選択します。
[ディスク暗号化]
オフ
説明ディスク暗号化は、Platinum Edition インスタンスでのみサポートされています。
[データディスク暗号化キー]
key-hzz66c8207****
説明同じリージョンでディスク暗号化に使用されるキーの ID です。このパラメーターは、ディスク暗号化 が 有効化 に設定されている場合にのみ必須です。
-
インスタンスエンドポイントの取得
-
インスタンス数 ページで、対象インスタンスの名前をクリックします。
-
インスタンスの詳細 ページの TCP プロトコルエンドポイント セクションで、エンドポイント情報を確認します。
-
VPC エンドポイント:VPC から ApsaraMQ for RocketMQ にアクセスするために使用するエンドポイントです。このエンドポイントはデフォルトで提供されます。
-
パブリックエンドポイント:インターネット経由でサービスにアクセスするために使用するエンドポイントです。このエンドポイントは、パブリックアクセスが有効な場合にのみ表示されます。
-
インスタンスのユーザー名とパスワードの取得
以下の手順では、デフォルトのアクセス制御方法であるインテリジェント認証を使用して、システムのユーザー名とパスワードを取得する方法を説明します。
代わりにアクセス制御リスト (ACL) 認証を使用するには、ACL ユーザーを作成して権限を設定し、ACL のユーザー名とパスワードを使用します。詳細については、「ユーザー認証」をご参照ください。
クライアントが ApsaraMQ for RocketMQ サーバーに接続する際は、アクセス方法に基づいてユーザー名とパスワードを設定します。
-
インターネット経由でサーバーにアクセスする場合:インスタンスのユーザー名とパスワードを設定する必要があります。
-
VPC からサーバーにアクセスする場合:サーバーレスインスタンスの場合、認証不要のアクセスが有効であれば認証情報は不要です。他のインスタンスタイプでは、認証は自動で行われ、認証情報は必要ありません。
-
インスタンス数 ページで、対象インスタンスの名前をクリックします。
-
左側のナビゲーションウィンドウで、アクセス制御 をクリックします。
-
スマート認証 タブをクリックして、インスタンスの ユーザー名 と パスワード を表示します。
トピックの作成
-
インスタンス数 ページで、対象インスタンスの名前をクリックします。
-
左側のナビゲーションウィンドウで トピック をクリックします。次に、トピック ページで トピックの作成 をクリックします。
-
トピックの作成 パネルで、トピック名と説明を入力し、メッセージのタイプ を 通常メッセージ に設定して、OK をクリックします。
コンシューマーグループの作成
-
インスタンス数 ページで、対象インスタンスの名前をクリックします。
-
左側のナビゲーションウィンドウで グループ をクリックします。次に、グループ ページで グループの作成 をクリックします。
-
グループの作成 パネルで Group ID を入力し、他のパラメーターはデフォルト設定のままにして、確定 をクリックします。