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