すべてのプロダクト
Search

このプロダクト

    ApsaraMQ for RabbitMQ:[Queues]

    ドキュメントセンター

    ApsaraMQ for RabbitMQ:[Queues]

    最終更新日:Aug 01, 2026

    キューは、コンシューマーがメッセージを取得するまでメッセージをバッファリングします。ApsaraMQ for RabbitMQ コンソールでキューを作成、監視、バインド、削除します。

    前提条件

    以下を確認してください。

    • ApsaraMQ for RabbitMQ インスタンスがあること

    • キューを作成するインスタンスに vhost があること

    • (オプション) RAM ユーザーの場合： 権限の付与 (オプション)。

    キューの作成

    1. ApsaraMQ for RabbitMQ コンソールにログインします。 左側のナビゲーションペインで、[インスタンス]をクリックします。

    2. 上部メニューで、インスタンスのリージョンを選択し、インスタンス名をクリックします。

    3. 左側のナビゲーションペインで、[キュー] をクリックします。

    4. キューリスト ページで、この vHost の横にある 切り替え をクリックし、キューの作成先となる vhost を選択します。 次に、キューの作成 をクリックします。

    5. キューの作成 パネルで、次のパラメーターを設定し、[OK] をクリックします。

      パラメータ

      説明

      [キュー名]

      キュー名。命名規則：

      1. [1. Queue 名には、英字、数字、ハイフン (-)、アンダースコア (_)、ピリオド (.)、ハッシュ (#)、スラッシュ (/)、アットマーク (@)、コロン (:)、カンマ (,)、スペース ( )、大なり記号 (>) のみ使用できます。長さは 1～255 文字です。]

      2. [2. キューを作成すると、名前は変更できません。名前を変更するには、既存のキューを削除し、新しいキューを作成する必要があります。]

      3. amq. は予約済みのプレフィックスであり、使用できません。

      [自動削除]

      最後のコンシューマーがサブスクライブを解除した後にキューを削除します。[はい]: 有効。[いいえ]: 無効。

      [リトライポリシー]

      オプションのリトライパラメータ。

      [デッドレターポリシー]

      オプションのデッドレターパラメータ。クリックして展開します。

    リトライポリシー

    パラメータ

    説明

    [インスタンス設定の継承]

    インスタンスレベルのリトライポリシーを使用するかどうか。

    [最大配信回数]

    メッセージの最大配信試行回数。

    [消費タイムアウト期間]

    コンシューマーがメッセージを処理するための最大時間。

    デッドレターポリシー

    パラメータ

    説明

    [DeadLetterExchange]

    デッドレターメッセージを受信するエクスチェンジ。

    [DeadLetterRoutingKey]

    デッドレターメッセージをターゲットキューにルーティングするために使用されるルーティングキー。

    [MessageTTL]

    Time-to-Live (ミリ秒単位)。未消費のメッセージは、この期間後にデッドレターとなり、デッドレターエクスチェンジにルーティングされます。詳細については、「メッセージ TTL」をご参照ください。

    よくある質問

    Q: どのクライアントがメッセージを消費するかを指定できますか？

    いいえ。ApsaraMQ for RabbitMQ では、特定のコンシューマークライアントを指定することはできません。メッセージの配信は、標準的な RabbitMQ のラウンドロビンまたは優先度ベースのディスパッチメカニズムに従います。

    Q: コードを使用して順次キュー (x-single-active-consumer) を作成するにはどうすればよいですか？

    ApsaraMQ for RabbitMQ コンソールでは、x-single-active-consumer パラメータの設定はできません。順次キューを作成するには、SDK を使用してください。channel.queueDeclare メソッドを呼び出し、arguments パラメータに "x-single-active-consumer": true を設定します。

    例：

    Map<String, Object> arguments = new HashMap<>();
arguments.put("x-single-active-consumer", true);
channel.queueDeclare("my-queue", true, false, false, arguments);

    最大キュー数

    インスタンスのクォータ数が上限に達した場合：

    • エンタープライズ、プロフェッショナル、およびプラチナエディション インスタンスの場合は、[アップグレード] をクリックしてアップグレードします。

    • (Shared) Pay-by-Messaging-Request、(Shared) Pay-by-Provisioned-Capacity-and-Elastic-Traffic、(Exclusive) Pay-by-Provisioned-Capacity-and-Elastic-Traffic インスタンスの場合、[クォータの変更] をクリックしてキューの上限数を調整します。

    各インスタンスの数量制限については、制限 の [クラスター制限] にある [インスタンスあたりのキュー数] をご参照ください。

    キュー統計の表示

    メトリックはインスタンスエディションによって異なります。

    1. キューリスト ページで、目的のキューを見つけ、操作 列の詳細 をクリックします。

    2. キュー詳細 ページで、指示板 タブをクリックします。

      インスタンスエディション

      監視ソース

      リファレンス

      Enterprise Edition、Platinum Edition

      Managed Service for Prometheus および Managed Service for Grafana

      ダッシュボード

      Standard Edition、Professional Edition

      Cloud Monitor

      監視

    説明

    Standard Edition は購入できなくなりました。既存のインスタンスは引き続き使用できます。

    エクスチェンジをキューにバインド

    1. キューリスト ページで、対象のキューを見つけ、操作 列の 詳細 をクリックします。

    2. キュー詳細 ページで、ターゲットとしてバインド タブをクリックします。次に、バインドの追加 をクリックします。

    3. バインドの追加 パネルで、ソース Exchange と [ルーティングキー] を設定し、[OK] をクリックします。

    説明

    x-consistent-hash エクスチェンジの場合、ルーティングキーはキューの重み (1〜20 の整数) を指定します。

    キューへのメッセージ送信

    バインドされたエクスチェンジからキューにメッセージを送信します。

    1. キューリスト ページで、目的のキューを見つけ、操作 列の 詳細 をクリックします。

    2. キュー詳細 ページで、ターゲットとしてバインド タブをクリックします。

    3. バインディング一覧で、対象のバインディングを見つけ、操作 列の メッセージ送信 をクリックします。

    4. メッセージ送信 パネルで、[必須] オプションを選択し、メッセージID と メッセージ本文 を入力し、OK をクリックします。

    説明

    デフォルトエクスチェンジ (エクスチェンジ名が空) を使用してメッセージを送信する場合、ルーティングキーは既存のキュー名と正確に一致する必要があります。また、クライアントアカウントはターゲットキューに対する書き込み権限を持っている必要があります。キューが存在しないか、権限が不足している場合、メッセージは通知なく破棄され、コンソールに送信記録は残りません。メッセージを送信する前に、キューが正しく宣言されており、クライアントアカウントが必要な書き込み権限を持っていることを確認してください。

    コンシューマータグの表示

    コンシューマータグは、コンシューマークライアントを一意に識別します。クライアントが指定しない場合、ブローカーが自動的に生成します。カスタムタグではなく、自動生成されたタグを使用してください。

    重要

    各コンシューマータグは、クライアントごとに一意である必要があります。SDK は、コンシューマータグをキーとする Map<String, Consumer> を使用して、接続上のコンシューマーを追跡します。同じ接続上のコンシューマーがタグを共有している場合、自動再接続後に再開されるのは 1 つだけです。他のコンシューマーは復元されません。

    コンシューマータグを表示するには、コンシューマークライアントがブローカーに接続されている必要があります。キューリスト ページで対象のキューを見つけ、操作 列の consumerTag リスト をクリックします。

    キューのクリア

    キューリスト ページで、目的のキューを見つけ、操作 列で さらに表示 > メッセージのクリア を選択します。

    キューの削除

    警告

    キューを削除すると、未消費のメッセージがすべて完全に削除されます。この操作は元に戻せません。

    1. キューリスト ページで、以下のいずれかの方法でキューを削除します。

      • 単一キュー: キューを見つけ、操作 列で さらに表示 > 削除 を選択します。 または、キュー名をクリックするか、詳細 をクリックし、キュー詳細 ページの右上隅にある 削除 をクリックします。

      • 複数のキュー：キューを選択し、キューリストの下にある一括削除をクリックします。

    2. 削除を確定します。