SDK を使用してメッセージを送受信する前に、ApsaraMQ for RocketMQ で次のリソースを作成する必要があります。
インスタンス -- 選択した課金方法とネットワーク構成を持つマネージドメッセージングサービスです。
Topic -- メッセージを送受信するためのチャネルです。
使用者グループ -- Topic をサブスクライブするコンシューマーの論理的なグループです。
これらのリソースを作成した後、SDK コードで使用するインスタンスのエンドポイントと認証情報を取得します。
前提条件
開始する前に、次のタスクを完了してください。
制限事項
リージョン:ApsaraMQ for RocketMQ インスタンスは、「前提条件」セクションで作成した VPC および vSwitch と同じリージョンに存在する必要があります。
命名規則:ApsaraMQ for RocketMQ のインスタンス、Topic、および使用者グループの命名規則については、「クォータと制限」をご参照ください。
Topic のメッセージタイプ:Topic のメッセージタイプは、その Topic が送受信するメッセージのタイプと一致している必要があります。たとえば、通常メッセージの送受信に使用される Topic を作成した場合、その Topic は通常メッセージの送受信にのみ使用できます。詳細については、「注意事項」をご参照ください。
背景情報
ApsaraMQ for RocketMQ では、ApsaraMQ for RocketMQ コンソールでリソースを作成するか、API 操作を呼び出してリソースを作成できます。このトピックでは、ApsaraMQ for RocketMQ コンソールでリソースを作成する方法について説明します。
API 操作を呼び出してリソースを作成する場合は、次のトピックをご参照ください。
インスタンスの作成
ApsaraMQ for RocketMQ コンソールにログインします。左側のナビゲーションウィンドウで、[インスタンス] をクリックします。
上部のナビゲーションバーで、中国 (杭州) などのリージョンを選択します。
[インスタンス] ページで、[インスタンスの作成] をクリックします。[Create Message Queue for Apache RocketMQ Instance] パネルで、[インスタンスバージョン] パラメーターを [V5.0] に設定し、[課金方法] パラメーターを設定します。その後、[OK] をクリックします。ApsaraMQ for RocketMQ は、次の課金方法をサポートしています。さまざまな課金方法の課金項目とシナリオについては、「課金の概要」をご参照ください。
サーバーレスの ApsaraMQ for RocketMQ インスタンスは、中国 (杭州)、中国 (上海)、中国 (北京)、中国 (張家口)、中国 (深セン)、中国 (成都)、シンガポール、ドイツ (フランクフルト)、米国 (バージニア) のリージョンでのみ利用可能です。
課金方法 課金方法 サブスクリプション インスタンスに対して選択したコンピューティング仕様とサブスクリプション期間 (月単位) に基づいて、前払いが必要です。 従量課金 インスタンスに対して選択したコンピューティング仕様と実際の使用期間 (時間単位) に基づいて、料金が後払いされます。 サーバーレス メッセージの受信と配信のために開始された API 呼び出しの総数に基づいて課金されます。 購入ページで、インスタンスの仕様を選択し、[今すぐ購入] をクリックします。その後、画面の指示に従って支払いを完了します。次の表は、購入ページでパラメーターを設定する方法の例を示しています。購入ページに表示される仕様については、「インスタンスの選択」をご参照ください。
重要ApsaraMQ for RocketMQ インスタンスを作成した後、インスタンスがデプロイされている VPC または vSwitch を変更することはできません。VPC または vSwitch を変更する場合は、インスタンスをリリースして新しいインスタンスを購入する必要があります。
サーバーレスインスタンスのパラメーター設定
| パラメーター | 例 | 説明 |
|---|---|---|
| プライマリエディション | Standard Edition | -- |
| 課金方法 | リクエスト課金 | 自動的に指定されます。 |
| メッセージストレージ容量 | -- | ストレージ容量を指定する必要はありません。実際の使用量に基づいてストレージスペースが課金されます。 |
| VPC ID | *vpc-bp1cg09dua6sgh0\*\*\*\*\*\** | このトピックの「前提条件」セクションで作成した VPC の ID。 |
| VSwitch ID | *vsw-bp1vqb0p9nz3irz\*\*\*\*\*\** | このトピックの「前提条件」セクションで作成した vSwitch の ID。サーバーレスの ApsaraMQ for RocketMQ インスタンスには、2 つの vSwitch ID を選択する必要があります。 |
| インターネットアクセス | 無効化 | この例では、クライアントは VPC 内の ApsaraMQ for RocketMQ ブローカーに接続されます。デフォルトでは、インターネットアクセスは無効になっています。インターネット経由で ApsaraMQ for RocketMQ にアクセスする場合は、このパラメーターを [有効化] に設定します。 |
| 内部ネットワークの測定方法 | トラフィック量による支払い | 自動的に指定されます。サーバーレスの ApsaraMQ for RocketMQ インスタンスには、VPC 内でのみアクセスできます。 |
| リソースグループ | デフォルトのリソースグループ | サーバーレスの ApsaraMQ for RocketMQ インスタンスが属するリソースグループ。 |
| セキュリティグループ | -- | このトピックの「前提条件」セクションで作成したセキュリティグループ。 |
サブスクリプションまたは従量課金インスタンスのパラメーター設定
| パラメーター | 例 | 説明 |
|---|---|---|
| プライマリエディション | Standard Edition | -- |
| サブカテゴリ エディション | 高可用性クラスター版 (本番環境に推奨) | -- |
| コンピューティング仕様 | rmq.s2.2xlarge | -- |
| VPC ID | *vpc-bp1cg09dua6sgh0\*\*\*\*\*\** | このトピックの「前提条件」セクションで作成した VPC の ID。 |
| VSwitch ID | *vsw-bp1vqb0p9nz3irz\*\*\*\*\*\** | このトピックの「前提条件」セクションで作成した vSwitch の ID。 |
| インターネットアクセス | 無効化 | この例では、クライアントは VPC 内の ApsaraMQ for RocketMQ ブローカーに接続されます。デフォルトでは、インターネットアクセスは無効になっています。インターネット経由で ApsaraMQ for RocketMQ にアクセスする場合は、このパラメーターを [有効化] に設定します。 |
| リソースグループ | デフォルトのリソースグループ | ApsaraMQ for RocketMQ インスタンスが属するリソースグループ。 |
| ディスク暗号化 | 無効化 | ディスク暗号化機能は、ApsaraMQ for RocketMQ 5.x Enterprise Platinum Edition インスタンスでのみサポートされています。 |
| ディスク暗号化キー | key-hzz66c8207\*\*\*\* | インスタンスがデプロイされているリージョンでディスク暗号化に使用されるキーの ID。このパラメーターは、[ディスク暗号化] パラメーターを [有効化] に設定した場合にのみ必要です。 |
インスタンスが作成された後、[インスタンス] ページに表示され、そのステータスが [実行中] であることを確認します。
Topic の作成
[インスタンス] ページで、管理するインスタンスの名前をクリックします。
左側のナビゲーションウィンドウで、[Topics] をクリックします。表示される [Topics] ページで、[Topic の作成] をクリックします。
[Topic の作成] パネルで、Topic 名と説明を入力し、[メッセージタイプ] パラメーターを [通常メッセージ] に設定してから、[OK] をクリックします。
Topic が作成された後、Topic リストに表示されていることを確認します。
使用者グループの作成
[インスタンス] ページで、管理するインスタンスの名前をクリックします。
左側のナビゲーションウィンドウで、[グループ] をクリックします。表示される [グループ] ページで、[グループの作成] をクリックします。
[グループの作成] パネルで、[グループ ID] パラメーターを設定し、[OK] をクリックします。パネル内の他のパラメーターには、デフォルト値を使用できます。
使用者グループが作成された後、グループリストに表示されていることを確認します。
インスタンスのエンドポイントの取得
クライアントを接続するには、インスタンスのエンドポイントが必要です。取得方法は次のとおりです。
[インスタンス] ページで、管理するインスタンスの名前をクリックします。
「TCP エンドポイント」セクションの「インスタンスの詳細」ページで、インスタンスのエンドポイントを表示します。
VPC エンドポイント:VPC 内で ApsaraMQ for RocketMQ インスタンスにアクセスするために使用されるエンドポイントです。これは ApsaraMQ for RocketMQ が提供するデフォルトのエンドポイントです。
パブリックエンドポイント:インターネット経由で ApsaraMQ for RocketMQ にアクセスするために使用されるエンドポイントです。パブリックエンドポイントは、インターネットアクセスを有効にした場合にのみ表示されます。
インスタンスのユーザー名とパスワードの取得
この例では、インテリジェント認証を使用して ApsaraMQ for RocketMQ インスタンスのユーザー名とパスワードを取得する方法について説明します。アクセス制御リスト (ACL) ベースのアクセス認証を使用する場合は、ACL ユーザーを作成し、その ACL ユーザーに必要な権限を付与してから、ACL ユーザーのユーザー名とパスワードを取得する必要があります。詳細については、「ユーザー認証」をご参照ください。
クライアントを ApsaraMQ for RocketMQ ブローカーに接続する際に、インスタンスのユーザー名とパスワードを指定するかどうかは、アクセス方法によって異なります。
インターネット経由で ApsaraMQ for RocketMQ ブローカーにアクセスする場合は、インスタンスのユーザー名とパスワードを指定する必要があります。
VPC 内で ApsaraMQ for RocketMQ ブローカーにアクセスする場合、ユーザー名とパスワードの指定が必要なのは、インスタンスがサーバーレスインスタンスであり、かつ VPC での認証不要機能が無効になっている場合のみです。その他の場合、システムはクライアントが使用する VPC エンドポイントに基づいてクライアントを自動的に識別します。
認証情報を取得するには:
[インスタンス] ページで、管理するインスタンスの名前をクリックします。
表示されたページの左側のナビゲーションウィンドウで、[アクセス制御] をクリックします。
[Intelligent Authentication] タブをクリックすると、インスタンスのユーザー名とパスワードを表示できます。
次のステップ
メッセージの送受信に必要なすべてのリソースが作成されました。次のステップに進んでください。