ApsaraMQ for RabbitMQ:接続とチャネル

永続的な接続の使用

アプリケーションの起動時に接続を開き、アプリケーションのライフサイクル全体にわたって維持してください。パブリッシュまたはコンシュームの操作ごとに接続を開閉しないでください。

ワークロードでチャネルの作成が頻繁に必要な場合は、安定した接続セットを再利用し、その中で複数のチャネルを作成してください。接続およびチャネルのオープンレートの制限については、制限事項をご参照ください。

プロデューサーとコンシューマーの接続の分離

メッセージのプロデュース用に少なくとも 1 つの接続を使用し、コンシューム用には別の接続を使用してください。ApsaraMQ for RabbitMQ は、インスタンスが処理できる速度を超えてパブリッシュする接続に対してフロー制御 (バックプレッシャー) を適用します。プロデューサーとコンシューマーが接続を共有すると、パブリッシュ側のフロー制御によってコンシューマー確認応答が遅延し、コンシュームのスループットが低下する可能性があります。

スレッドごとに 1 つのチャネルの使用

複数のスレッドで接続を共有できます。ただし、ほとんどのクライアントライブラリではチャネルはスレッドセーフではありません。スレッド間でチャネルを共有するのではなく、各スレッドに専用のチャネルを割り当ててください。

// アンチパターン：スレッド間でチャネルを共有する
Channel shared = connection.createChannel(); // スレッドセーフではありません

// 推奨：スレッドごとに 1 つのチャネル
ExecutorService executor = Executors.newFixedThreadPool(4);
for (int i = 0; i < 4; i++) {
    executor.submit(() -> {
        Channel ch = connection.createChannel();
        // このスレッドのパブリッシュ/コンシューム操作に ch を使用します
    });
}

複数のプロセスで接続を共有する場合は、接続を頻繁に開閉しないでください。そうしないと、ChannelNotFound エラーが発生する可能性があります。

消費の偏りの防止

少数の接続だけで大量のメッセージを処理すると、コンシューマー間で消費が不均等になる場合があります。これを防ぐには、次の対策を実施してください：

• コンシューマーあたりの接続数を増やすか、コンシューマーを追加してください。

• 各コンシューマーが同じ数の接続を確立するようにしてください。

• 目安として、コンシューマー接続の合計を少なくとも 30 に維持してください。