Red Hat Summit Red Hat Summitサポートコンソール開発者トライアルの開始お問い合わせ

第8章 フロー制御

フロー制御は、プロデューサーとコンシューマーの間のデータの流れを制限することで、プロデューサーとコンシューマーの負荷が大きくなるのを防ぎます。AMQ Core Protocol JMS を使用すると、コンシューマーとプロデューサー両方のフロー制御を設定できます。

コンシューマーフローの制御

コンシューマーフローの制御は、クライアントがブローカーからのメッセージを消費する際に、ブローカーとクライアントの間のデータフローを制御します。AMQ Core Protocol JMSは、デフォルトでメッセージをバッファーしてからコンシューマーに配信します。バッファーがない場合は、クライアントはメッセージを消費する前に、最初にブローカーから各メッセージを要求する必要があります。このタイプの「ラウンドトリップ」の通信はコストがかかります。メモリー不足の問題によりコンシューマーがメッセージをすぐに処理できず、バッファーが受信メッセージでオーバーフローすることがあるため、クライアント側のデータのフローを制限することが重要になります。

プロデューサーフロー制御

コンシューマーウィンドウベースのフロー制御と同様に、クライアントはプロデューサーからブローカーに送信されるデータ量をブローカーに制限し、ブローカーが大量のデータで過負荷にならないようにすることができます。プロデューサーの場合、ウィンドウサイズは 1 度にインフライトにできるバイト数を決定します。

8.1. コンシューマーウィンドウサイズの設定

クライアント側のバッファーに保持されるメッセージの最大サイズは、その ウィンドウサイズ によって決定されます。AMQ Core Protocol JMS のウインドウのデフォルトサイズは 1 MiB または 1024 * 1024 バイトです。ほとんどのユースケースでは、デフォルトのままで問題ありません。その他のケースでは、ウィンドウサイズの最適な値を見つけるために、システムのベンチマークが必要な場合があります。AMQ Core Protocol JMS を使用すると、デフォルトを変更する必要がある場合にバッファーウインドウサイズを設定できます。

以下の例は、AMQ Core Protocol JMS を使用する場合にコンシューマーウインドウサイズパラメーターを設定する方法を示しています。それぞれの例で、コンシューマーウィンドウサイズを 300,000 バイトに設定します。

手順

  • クライアントが JNDI を使用して接続ファクトリーをインスタンス化する場合は、接続文字列 URL の一部として consumerWindowSize パラメーターを含めます。JNDI コンテキスト環境内に URL を格納します。以下の例では、jndi.properties ファイルを使用して URL を格納します。 

    java.naming.factory.initial=org.apache.activemq.artemis.jndi.ActiveMQInitialContextFactory
connectionFactory.myConnectionFactory=tcp://localhost:61616?consumerWindowSize=300000
    Copy to Clipboard

  • クライアントが JNDI を使用して接続ファクトリーをインスタンス化しない場合は、値を ActiveMQConnectionFactory.setConsumerWindowSize() に渡します。 

    ConnectionFactory cf =  ActiveMQJMSClient.createConnectionFactory(...)
cf.setConsumerWindowSize(300000);
    Copy to Clipboard
トップに戻る
Red Hat logoGithubredditYoutubeTwitter

詳細情報

試用、購入および販売

コミュニティー

Red Hat ドキュメントについて

Red Hat をお使いのお客様が、信頼できるコンテンツが含まれている製品やサービスを活用することで、イノベーションを行い、目標を達成できるようにします。 最新の更新を見る.

多様性を受け入れるオープンソースの強化

Red Hat では、コード、ドキュメント、Web プロパティーにおける配慮に欠ける用語の置き換えに取り組んでいます。このような変更は、段階的に実施される予定です。詳細情報: Red Hat ブログ.

会社概要

Red Hat は、企業がコアとなるデータセンターからネットワークエッジに至るまで、各種プラットフォームや環境全体で作業を簡素化できるように、強化されたソリューションを提供しています。

Theme

© 2025 Red Hat