|
| |
| Sun Java System Message Queue 3.5 SP1 管理ガイド | |
第 6 章
ブローカとアプリケーションの管理この章では、ブローカとブローカが提供するサービスの管理に関するタスクを実行する方法について説明します。これらのタスクの中には、特定のクライアントアプリケーションに依存していないものがあります。次の項目が含まれます。
その他のブローカのタスクは、特定のアプリケーションのために実行されます。これらのタスクには、物理的な送信先、永続サブスクリプション、トランザクションなどの管理が含まれます。
- Message Queue のメッセージは、ブローカの送信先を経由して、受信側またはサブスクライバにルートされる。管理者は、ブローカ上でこれらの送信先を作成する必要がある
- 永続サブスクリプションを保持するクライアントが、アクティブでない場合でも、Message Queue によって、永続サブスクライバのリソースの割り当ておよび管理が行われる。Message Queue のリソースを節約するために、Message Queue のコマンドツールを使用して、永続サブスクリプションに関する情報を入手し、永続サブスクリプションを破棄、あるいはそれらのメッセージをパージすることができる
- Message Queue のトランザクションおよび分散トランザクションは、ブローカによって記録される。障害が発生した場合、トランザクションを手動でコミット、またはロールバックする必要がある
この章では、コマンドユーティリティ (imqcmd) を使用して、これらのすべてのタスクを実行する方法について説明します。Message Queue メッセージサーバのグラフィカルインタフェースである管理コンソールを使用して、これらと同じタスクの多くを実行することができます。詳細は、第 4 章「管理コンソールのチュートリアル」を参照してください。
コマンドユーティリティコマンドユーティリティを使用すると、ブローカおよびブローカが提供するサービスを管理することができます。この節では、imqcmd コマンドの基本構文、サブコマンドのリスト、imqcmd オプションの概要について説明します。後続の節では、これらのコマンドを使用して、特定のタスクを実行する方法について説明します。
imqcmd コマンドの構文
imqcmd コマンドの一般的な構文は、次のとおりです。
-v、-h、および -H オプションを指定した場合、そのコマンド行で指定するサブコマンドは実行されません。たとえば、次のコマンドを入力すると、バージョン情報が表示されますが、restart サブコマンドは実行されません。
imqcmd のサブコマンド
コマンドユーティリティ (imqcmd) には、次の表 6-1 に示すようなサブコマンドが含まれています。サブコマンドについては、この章のタスクに関する節で詳しく説明します。
imqcmd のオプションの概要
表 6-2 に、imqcmd コマンドのオプションを一覧表示します。これらの使用方法については、後続のタスクごとの節を参照してください。
表 6-2 imqcmd のオプション
オプション
説明
-b hostName:port
ブローカのホスト名とポート番号を指定する。デフォルト値は localhost:7676
ポートだけを指定する場合 : -b :7878
名前だけを指定する場合 : -b somehost-c clientID
トピックの永続サブスクライバの ID を指定する。「永続サブスクリプションの管理」を参照
-d destinationName
トピック名を指定する。list dur サブコマンドや destroy dur サブコマンドと一緒に使用する。「永続サブスクリプションの管理」を参照
-f
ユーザーの確認なしで、アクションを実行する
-h
使用方法に関するヘルプを表示する。コマンド行ではそれ以外のことは実行されない
-H
使用方法に関するヘルプ、属性リスト、および例を表示する コマンド行ではそれ以外のことは実行されない
-int interval
metrics bkr、metrics dst、および metrics svc サブコマンドがメトリックス出力を表示する間隔を秒単位で指定する
-javahome path
使用する代替の Java 2 互換のランタイムを指定する。デフォルトではシステム上のランタイムまたは Message Queue にバンドルされたランタイムを使用する
-m metricType
表示するメトリックス情報のタイプを指定する。このオプションは、metrics dst、metrics svc、または metrics bkr サブコマンドと同時に使用する。metricType の値は、メトリックスが送信先、サービス、ブローカのどれに対して生成されたかによって異なる
-msp numSamples
metrics bkr、metrics dst、および metrics svc サブコマンドがメトリックス出力で表示するメトリックスのサンプル数を指定する
-n argumentName
サブコマンドの引数の名前を指定する。これはサブコマンドに応じて、物理的な送信先、永続サブスクリプション、コネクション ID、またはトランザクション ID の名前になる
-o attribute=value
属性の値を指定する。これはサブコマンドの引数に応じて、ブローカの属性 (「ブローカの管理」を参照)、サービス (「コネクションサービスの管理」を参照)、または送信先 (「送信先の管理」を参照) になる
-p password
管理者パスワードを指定する。この値を省略すると、管理者名の入力を要求される
-pst pauseType
送信先を停止したときに、プロデューサ、コンシューマ、または両方を停止させるどうかを指定する。「送信先の管理」を参照
-rtm timeout
imqcmd のサブコマンドの初期 (再試行) タイムアウト期間を秒単位で指定する。タイムアウトとは、imqcmd のサブコマンドがブローカへの要求を作成した後、待機している時間の長さ。それ以降、サブコマンドが再試行されるたびに、タイムアウト値として初期タイムアウト値の倍数が使用される。デフォルト値: 10
-rtr numRetries
imqcmd のサブコマンドが最初にタイムアウトになった後の再試行回数を指定する。デフォルト値: 5
-s
サイレントモード。出力が表示されない
-secure
ssladmin コネクションサービス (「手順 4: SSL ベースのクライアントを設定および実行する」を参照) を使用して、セキュリティ保護されたブローカへの管理コネクションを指定する
-svn serviceName
どのコネクションのサービスを一覧表示するかを指定する。「コネクション情報の取得」を参照
-t destType
送信先のタイプを指定する。t (トピック)、または q (キュー) のどちらかとなる。「送信先の管理」を参照
-tmp
一時送信先を表示する 表 6-9 を参照
-u userName
管理者名を指定する。この値を省略すると、管理者名の入力を要求される
-v
バージョン情報を表示する。コマンド行ではそれ以外のことは実行されない
imqcmd のサブコマンドを実行するたびに、ホスト名とポート番号 (-b)、ユーザー名 (-u)、パスワード (-p)、および安全なコネクション (-secure) のオプションを指定する必要があります。ホスト名とポート番号を指定しない場合、デフォルト値が使用されます。ユーザー名とパスワードの情報を指定しないと、これらの情報の入力を要求されます。-secure オプションを指定しない場合は、コネクションがセキュリティ保護されません。
注
-secure オプションを使用するには、「TCP/IP を介した SSL ベースのサービスの設定」に記載されているとおり、ターゲットブローカインスタンスに ssladmin サービスを設定し有効にする必要があります。
imqcmd コマンドの使用
imqcmd コマンドを使用してブローカを管理する場合、次のタスクを実行する必要があります。
「ブローカの起動」を参照コマンドユーティリティは、すでに起動しているブローカを管理する場合にのみ使用できる。コマンドユーティリティでは、ブローカを起動することはできない。
- ブローカをローカルホストのポート 7676 で実行していない場合、-b オプションを使用して、ターゲットブローカを指定する
- 適切な管理者名とパスワードを指定する。この値を指定しないと、値の入力を要求される。imqcmd を使用する操作はすべてユーザーリポジトリに照らし合わされて認証される。詳細は、「ユーザーの認証」を参照
Message Queue をインストールすると、デフォルトの単層ファイルのユーザーリポジトリがインストールされます。リポジトリは 2 つのエントリと一緒に出荷されます。1 つは管理ユーザー用、もう 1 つはゲストユーザー用です。これらのエントリを使用すれば、追加作業を行わずにブローカインスタンスに接続できます。たとえば、Message Queue をテストするだけなら、デフォルトのユーザー名とパスワード (admin/admin) を使用して、imqcmd ユーティリティを実行できます。
運用システムをセットアップする場合は、管理ユーザーを認証および認可するための追加作業を行う必要があります (第 8 章「セキュリティの管理」を参照)。特に、Message Queue のユーザーリポジトリ内にエントリを作成する必要があります (「単層型ファイルユーザーリポジトリを使用する」を参照)。また、ユーザーリポジトリについて、LDAP ディレクトリサーバを使用するオプションも用意されています (「ユーザーリポジトリに LDAP サーバを使用する」を参照)。
imqcmd の使用例
次の例は、imqcmd コマンドの使用方法を示しています。
ブローカの管理コマンドユーティリティには、次のブローカ管理タスクを実行するために使用できるサブコマンドが含まれています。
ブローカのコネクションサービスを管理する方法については、「コネクションサービスの管理」を参照してください。ブローカの送信先を管理する方法については、「送信先の管理」を参照してください。
表 6-3 は、ブローカを管理するのに使用する imqcmd のサブコマンドについてまとめたものです。ホスト名、またはポートを指定しない場合は、デフォルトの localhost:7676 が使用されます。
表 6-3 ブローカを管理する imqcmd のサブコマンド
サブコマンドの構文
説明
metrics bkr [-b hostName:port]
[-m metricType]
[-int interval]
[-msp numSamples]デフォルトのブローカ、または指定したホストとポートのブローカに対して、ブローカのメトリックスを表示する。
表示するメトリックスのタイプを指定するには、-m オプションを使用する
ttl ブローカとの間のメッセージとパケットのフローに関するメトリックスを表示する (デフォルトのメトリックスタイプ)
rts ブローカとの間のメッセージとパケットのフローレートに関するメトリックスを表示する (秒単位)
cxn コネクション、仮想メモリーヒープ、およびスレッドを表示する
メトリックスを表示する間隔を秒単位で指定するには、-int オプションを使用する。デフォルトは 5 秒
出力で表示するサンプル数を指定するには、-msp オプションを使用する。デフォルトは無制限 (無限)
pause bkr [-b hostName:port]
デフォルトのブローカ、または指定したホストとポートのブローカを停止する。「ブローカの停止および再開」を参照
query bkr -b hostName:port
デフォルトのブローカ、または指定したホストとポートのブローカの現在のプロパティの設定を一覧表示する。また、特定のブローカに接続している実行中のブローカ (マルチブローカクラスタ内の) のリストも表示される
reload cls
ブローカクラスタに対してのみ適用。クラスタ内のすべてのブローカで、imq.cluster.brokerlist プロパティの再読み込みとクラスタ情報の更新を実行する。詳細は、「クラスタへのブローカの追加」を参照
restart bkr [-b hostName:port]
デフォルトのブローカ、または指定したホストとポートのブローカをシャットダウンして、再起動する
このコマンドは、ブローカを最初に起動したときに指定したオプションを使用して、ブローカを再起動する。別のオプションを有効にする必要がある場合、ブローカをシャットダウンしてから、必要なオプションを指定して、ブローカを起動し直す必要がある
resume bkr [-b hostName:port]
デフォルトのブローカ、または指定したホストとポートのブローカを再開する
shutdown bkr [-b hostName:port]
デフォルトのブローカ、または指定したホストとポートのブローカをシャットダウンする
update bkr [-b hostName:port]
-o attribute=value
[-o attribute=value1]��デフォルトのブローカ、または指定したホストとポートのブローカに対して、指定した属性を変更する
localhost のポート 7676 で実行するブローカを対象にしない場合、表 6-3 に示されるサブコマンドを使用するときに、ブローカのホスト名とポート番号を指定する必要があります。
ブローカ情報の表示
シングルブローカに関する情報のクエリーと表示を行うには、query bkr サブコマンドを使用します。たとえば、次のように指定します。
このコマンドでは、次のような情報が出力されます。
ブローカのプロパティの更新
表 6-4 に示すブローカのプロパティを更新するには、update bkr サブコマンドを使用します。ブローカの更新情報は、ブローカのインスタンス設定ファイルに自動的に書き込まれます。
表 6-4 imqcmd によって更新されるブローカプロパティ
プロパティ
参照先
imq.autocreate.queue
imq.autocreate.topic
imq.autocreate.queue.maxNumActiveConsumers
imq.autocreate.queue.maxNumBackupConsumers
imq.cluster.url
imq.log.level
imq.log.file.rolloversecs
imq.log.file.rolloverbytes
imq.system.max_count
imq.system.max_size
imq.message.max_size
imq.portmapper.port
たとえば、次のコマンドはキュー送信先の自動作成を無効にします。
ブローカの状態の制御
ブローカの起動後に、次の imqcmd のサブコマンドを使用して、ブローカの状態を制御できます。
ブローカの停止および再開
ただし、ブローカを停止しても管理コネクションサービスは中断されないため、ブローカへのメッセージを制限するために必要な管理タスクは実行できます。たとえば、特定の送信先にメッセージが集中した場合には、ブローカを停止し、問題の修復に役立つ次のいずれかを実行できます。これらは、メッセージの送信元の追跡、送信先のサイズの制限、または送信先の破棄のいずれかです。
ブローカを停止しても、クラスタコネクションサービスは継続されます。ただし、クラスタ内のメッセージ配信は、クラスタ内のブローカによって実行される配信機能によって異なります。
次のコマンドでは、myhost のポート 1588 の で実行しているブローカが停止されます。
また、個々のコネクションサービスを停止することもできます。「コネクションサービスの停止および再開」を参照してください。個々の送信先の停止については、「送信先の停止と再開」を参照してください。
ブローカのシャットダウンと再起動
ブローカのメトリックスの表示
ブローカに関するメトリックス情報を表示するには、metrics bkr サブコマンドを使用します。たとえば、ブローカに入力するメッセージフローとブローカから出力されるメッセージのフローレートを10 秒間隔で取得するには、次のコマンドを使用します。
このコマンドでは、次のような情報が出力されます。
--------------------------------------------------------
Msgs/sec Msg Bytes/sec Pkts/sec Pkt Bytes/sec
In Out In Out In Out In Out
--------------------------------------------------------
0 0 27 56 0 0 38 66
10 0 7365 56 10 10 7457 1132
0 0 27 56 0 0 38 73
0 10 27 7402 10 20 1400 8459
0 0 27 56 0 0 38 73
imqcmd を使用してブローカのメトリックスをレポートする方法の詳細は、「監視ツール」を参照してください。
コネクションサービスの管理コマンドユーティリティには、次のコネクションサービス管理タスクを実行するために使用できるサブコマンドが含まれています。
Message Queue のコネクションサービスの概要については、「コネクションサービス」を参照してください。
表 6-5 は、コネクションサービスを管理するのに使用する imqcmd のサブコマンドについてまとめたものです。ホスト名、またはポートを指定しない場合は、デフォルトの localhost:7676 が使用されます。
表 6-5 コネクションサービスを管理する imqcmd のサブコマンド
サブコマンドの構文
説明
list svc [-b hostName:port]
デフォルトのブローカ、または指定したホストとポートのブローカのすべてのコネクションサービスを一覧表示する
metrics svc -n serviceName
[-b hostName:port]
[-m metricType]
[-int interval]
[-msp numSamples]デフォルトのブローカ、または指定したホストとポートのブローカで実行している特定のサービスのメトリックスを表示する
表示するメトリックスのタイプを指定するには、-m オプションを使用する
ttl 指定したサービスを使ってブローカとの間で入出力されているメッセージとパケットのフローに関するメトリックスを表示する (デフォルトのメトリックスタイプ)
rts 指定したサービスを使ってブローカとの間で入出力されているメッセージとパケットのフローレートに関するメトリックスを表示する (秒単位)
cxn コネクション、仮想メモリーヒープ、およびスレッドを表示する
メトリックスを表示する間隔を秒単位で指定するには、-int オプションを使用する。デフォルトは 5 秒
出力で表示するサンプル数を指定するには、-msp オプションを使用する。デフォルトは無制限 (無限)
pause svc -n serviceName
[-b hostName:port]デフォルトのブローカ、または指定したホストとポートのブローカで実行している特定のサービスを停止する。admin サービスは停止できない
query svc -n serviceName
[-b hostName:port]デフォルトのブローカ、または指定したホストとポートのブローカで実行している特定のサービスに関する情報を一覧表示する
resume svc -n serviceName
[-b hostName:port]デフォルトのブローカ、または指定したホストとポートのブローカで実行していた特定のサービスを再開する
update svc -n serviceName
[-b hostName:port]
-o attribute=value
[-o attribute=value1]...デフォルトのブローカ、または指定したホストとポートのブローカで実行している特定のサービスの特定の属性を更新する。サービスの属性については、表 6-7 を参照
ブローカは、アプリケーションクライアントと管理クライアントの両方からの通信をサポートしています。Message Queue ブローカで現在使用できるコネクションサービスを、表 6-6 に示します。「サービス名」列の値は、-n オプションでサービス名を指定するのに使用する値になります。表が示すように、各サービスは使用するサービスタイプ (アプリケーションクライアントの場合は NORMAL、管理クライアントの場合は ADMIN) と基礎となるトランスポートレイヤーによって指定されます。
表 6-6 ブローカでサポートされているコネクションサービス
サービス名
サービスタイプ
プロトコルタイプ
jms
NORMAL
tcp
ssljms (Enterprise Edition)
NORMAL
tls (SSL ベースセキュリティ)
httpjms (Enterprise Edition)
NORMAL
http
httpsjms (Enterprise Edition)
NORMAL
https (SSL ベースセキュリティ)
admin
ADMIN
tcp
ssladmin (Enterprise Edition)
ADMIN
tls (SSL ベースセキュリティ)
コネクションサービスの一覧表示
ブローカの使用可能なコネクションサービスを一覧表示するには、次のようなコマンドを使用します。
たとえば、次のコマンドでは、myServer ホストのポート 6565 で実行しているブローカで使用可能なサービスが一覧表示されます。
次のコマンドでは、localhost のポート 7676 で実行しているブローカのすべてのサービスが一覧表示されます。
このコマンドでは、次のような情報が出力されます。
------------------------------------------------
Service Name Port Number Service State
------------------------------------------------
admin 41844 (dynamic) RUNNING
httpjms - UNKNOWN
httpsjms - UNKNOWN
jms 41843 (dynamic) RUNNING
ssladmin dynamic UNKNOWN
ssljms dynamic UNKNOWN
コネクションサービス情報の表示
シングルサービスに関する情報のクエリーと表示を行うには、query サブコマンドを使用します。たとえば、次のように指定します。
このコマンドでは、次のような情報が出力されます。
Service Name jms
Service State RUNNING
Port Number 60920 (dynamic)
Current Number of Allocated Threads 0
Current Number of Connections 0
Min Number of Threads 10
Max Number of Threads 1000
コネクションサービスのプロパティの更新
表 6-7 に示す 1 つ以上のサービスのプロパティを変更するには、update サブコマンドを使用します。
表 6-7 imqcmd によって更新されるコネクションサービスプロパティ
プロパティ
説明
port
更新するサービスに割り当てられるポート (httpjms または httpsjms には適用しない)。値 0 は、ポートマッパーによって動的に割り当てられるポートを示している
minThreads
サービスに割り当てられるスレッドの最小数
maxThreads
サービスに割り当てられるスレッドの最大数
次のコマンドでは、jms サービスに割り当てられたスレッドの最小数が 20 に変更されます。
コネクションサービスのメトリックスの表示
シングルサービスに関するメトリックス情報を表示するには、metrics サブコマンドを使用します。たとえば、jms コネクションサービスによって処理されたメッセージとパケットの累計数を取得するには、次のコマンドを使用します。
このコマンドでは、次のような情報が出力されます。
-------------------------------------------------
Msgs Msg Bytes Pkts Pkt Bytes
In Out In Out In Out In Out
-------------------------------------------------
164 100 120704 73600 282 383 135967 102127
657 100 483552 73600 775 876 498815 149948
imqcmd を使用してコネクションサービスのメトリックスをレポートする方法の詳細は、「監視ツール」を参照してください。
コネクションサービスの停止および再開
admin サービス (停止できない) 以外のサービスを停止するには、次のようなコマンドを使用します。
サービスを停止すると、次のような結果になります。
- ブローカは、停止したサービスでの新たなクライアントコネクションの受け入れをやめる。Message Queue クライアントが新しいコネクションを開こうとすると、例外が発生する
- 停止したサービスの既存のコネクションはすべて維持されるが、ブローカはサービスが再開されるまでこれらのコネクションのすべてのメッセージ処理を中断する。たとえば、クライアントがメッセージを送信しようとしても、サービスが再開されるまでは、send() メソッドがそれを阻止する
- すでにブローカが受信済みのメッセージのメッセージ配信状態は維持される。たとえば、トランザクションは中断されず、サービスが再開された時点でメッセージ配信も再開される
サービスを再開するには、次のようなコマンドを使用します。
コネクション情報の取得コマンドユーティリティには、コネクションに関する情報を一覧表示し取得するために使用できるサブコマンドが含まれています。
表 6-8 に、コネクションに適用する imqcmd のサブコマンドを一覧表示します。ホスト名、またはポートを指定しない場合は、localhost、7676 を使用するものと仮定します。
表 6-8 コネクションサービスを管理する imqcmd のサブコマンド
サブコマンドの構文
説明
list cxn [-svn serviceName]
[-b hostName:port]デフォルトのブローカ、または指定したホストとポートのブローカで実行している指定したサービス名のコネクションをすべて一覧表示する。サービス名が指定しない場合は、すべてのコネクションが一覧表示される
query cxn -n connectionID
[-b hostName:port]デフォルトのブローカ、または指定したホストとポートのブローカで実行している指定したコネクションに関する情報を表示する
シングルコネクションサービスに関する情報のクエリーと表示を行うには、query サブコマンドを使用します。たとえば、次のように指定します。
このコマンドでは、次のような情報が出力されます。
Connection ID 421085509902214374
User guest
Service jms
Producers 0
Consumers 1
Host 111.22.333.444
Port 60953
Client ID
Client Platform
送信先の管理Message Queue のメッセージはすべて、特定のブローカで作成されたキューとトピック送信先を経由して、コンシューマクライアントにルートされます。
コマンドユーティリティには、次の送信先管理タスクを実行するために使用できるサブコマンドが含まれています。
送信先の概要については、「物理的な送信先」を参照してください。
表 6-9 は、imqcmd の送信先のサブコマンドについてまとめたものです。デフォルトのブローカ (localhost:7676) を使用しない場合、ブローカのホスト名とポート番号を指定する必要があります。
表 6-9 送信先の管理に使用される imqcmd のサブコマンド
サブコマンドの構文
説明
compact dst [-t destType
-n destName]特定のタイプと名前の送信先に対応する組み込みのファイルベースのデータストアを圧縮する。送信先のタイプと名前が指定されていない場合は、すべての送信先が圧縮される。圧縮する前に送信先を停止する必要がある
create dst -t destType
-n destName
[-o attribute=value]
[-o attribute=value1]...特定のタイプの送信先を指定した名前と属性で作成する。送信先名には、英数字 (空白文字は含まない) だけを使用する必要がある。送信先名は、英字や "_" および "$" で開始できる。文字列「mq.」で開始することはできない
destroy dst -t destType
-n destName特定のタイプと名前の送信先を破棄する
list dst [-t destType] [-tmp]
指定したタイプのすべての送信先を一覧表示する。同様に、一時送信先についても一覧表示するオプションがある (「一時送信先」を参照)
type 引数には次の 2 つの値がある
destType = q (キュー)
destType = t (トピック)タイプが指定されない場合は、すべてのタイプの送信先すべてが一覧表示される
metrics dst -t destType
-n destName
[-m metricType]
[-int interval]
[-msp numSamples]特定のタイプと名前の送信先に関するメトリックス情報を表示する
表示するメトリックスのタイプを指定するには、-m オプションを使用する
ttl 送信先との間でやり取りされメモリーに常駐しているメッセージとパケットに関するメトリックスを表示する (デフォルトのメトリックスタイプ)
rts 送信先との間のメッセージとパケットのフローレート (秒単位) に関するメトリックスと、その他のレート情報を表示する
con コンシューマ関連のメトリックスを表示する
dsk ディスク使用量のメトリックスを表示する
メトリックスを表示する間隔を秒単位で指定するには、-int オプションを使用する。デフォルトは 5 秒
出力で表示するサンプル数を指定するには、-msp オプションを使用する。デフォルトは無制限 (無限)
pause dst [-t destType
-n destName]
[-pst pauseType]特定のタイプと名前の送信先について、コンシューマへのメッセージ (-pst CONSUMERS)、プロデューサからのメッセージ (-pst PRODUCERS)、またはその両方 (-pst ALL) を停止する。送信先のタイプと名前が指定されていない場合は、すべての送信先が停止される。デフォルト値は ALL
purge dst -t destType
-n destName特定のタイプと名前の送信先のメッセージをパージする
query dst -t destType
-n destName特定のタイプと名前の送信先に関する情報を一覧表示する
resume dst [-t destType
-n destName]特定のタイプと名前の停止された送信先についてメッセージの配信を再開する。送信先のタイプと名前が指定されていない場合は、すべての送信先が再開される
update dst -t destType
-n destName
-o attribute=value
[-o attribute=value1]...特定の送信先で特定の属性値を更新する
属性名は、表 6-10 に示す属性のどれかになる
送信先の作成
送信先を作成するときには、次の情報を指定する必要があります。
送信先の属性の多くは、ブローカメモリーリソースとメッセージフローを管理するために使用されます。たとえば、送信先で許容されるプロデューサの最大数、または送信先で許容されるメッセージの最大数 (または、サイズ) を指定できます。これらの制限は、ブローカ設定プロパティを使用してブローカ全体に設定できる制限に似ています (「メモリーリソースとメッセージフローの管理」を参照)。また、これらの制限に達したときの、ブローカの応答方法も指定できます。
キュー送信先だけに適用される送信先属性もあります。これらの属性は、複数のコンシューマにロードバランスされたメッセージ配信で使用されるアクティブコンシューマ数とバックアップコンシューマ数を指定するために使用されます (「キューの送信先」を参照)。
表 6-10 で、各タイプの送信先に適用される属性を説明します。送信先の作成または更新時に属性値を設定できます。自動作成される送信先の場合は、ブローカのインスタンス設定ファイルにデフォルトのプロパティ値を設定します (「設定ファイル」を参照)。
表 6-10 送信先の属性
送信先タイプ
属性
デフォルト値
説明
キューとトピック
maxNumMsgs1
-1
(無制限)送信先で許容されるコンシュームされないメッセージの最大数を指定する
キューとトピック
maxTotalMsgBytes1
-1
(無制限)送信先でコンシュームされないメッセージ用として許容されるメモリーの最大量をバイト単位で指定する
キューとトピック
limitBehavior
REJECT_
NEWESTメモリー制限のしきい値に達したときのブローカの応答方法を指定する。値は、次のどれかになる
FLOW_CONTROL - プロデューサの低速化
REMOVE_OLDEST - もっとも古いメッセージの破棄
REMOVE_LOW_PRIORITY - メッセージの有効期間に従い優先度のもっとも低いメッセージを破棄する (生成元のクライアントはメッセージの削除に関する通知は受信しない)
REJECT_NEWEST - 最新のメッセージを拒否する (プロデューシングクライアントは、持続メッセージの場合は拒否に関する例外を受け取るが、持続メッセージ以外の場合は通知を受信しない)
キューとトピック
maxBytesPerMsg
-1
(無制限)送信先で許容されるシングルメッセージの最大サイズをバイト単位で指定する。プロデューシングクライアントは持続メッセージの場合は拒否に関する例外を受け取るが、持続メッセージ以外の場合は通知を受信しない
キューとトピック
maxNumProducers1
-1
(無制限)送信先で許容されるプロデューサの最大数を指定する。この制限に達すると、新しいプロデューサを作成できない
キューのみ
maxNumActiveConsumers
1
ロードバランスされたキュー送信先からの配信でアクティブにできるコンシューマの最大数を指定する。値を -1 に設定した場合、無制限になる (Platform Edition では、この値は 2 に制限される)
キューのみ
maxNumBackupConsumers
0
キュー送信先からのロードバランスされた配信で障害が生じた場合に、アクティブコンシューマに代わることができるバックアップコンシューマの最大数を指定する。値を -1 に設定した場合、無制限になる
キューとトピック
consumerFlowLimit
トピック: 1000
キュー : 1000
シングルバッチでコンシューマに配信されるメッセージの最大数を指定する。ロードバランスされたキュー配信では、ロードバランスされる前に、最初にキューに入ることができるアクティブコンシューマにルートされるメッセージの数となる (「複数のコンシューマへのキュー配信」を参照)。この制限は、各コネクションの送信先のコンシューマに対して小さい値を指定することでオーバーライドできる (『Message Queue Java Client Developer's Guide』のコネクションファクトリ属性の説明を参照)。値を -1 に設定した場合、無制限になる
キューのみ
localDeliveryPreferred
false
ブローカクラスタ内のロードバランスされたキュー配信にだけ適用される。ローカルブローカ上にコンシューマが存在しない場合にだけ、メッセージがリモートコンシューマに配信されるように指定する。送信先をローカルだけの配信に制限してはならない (isLocalOnly = false)
キューとトピック
isLocalOnly
false
ブローカクラスタに対してのみ適用。送信先がそのほかのブローカに複製されないように指定する。さらに、メッセージの配信をローカルコンシューマ (送信先の作成元にあるブローカに接続されたコンシューマ) だけに制限する。いったん送信先が作成されると、この属性は更新できない
1. クラスタ環境では、このプロパティはクラスタ内のすべてのインスタンスに一括して適用されるのではなく、クラスタ内の送信先の各インスタンスに適用されます。
imqcmd create dst -n myQueue -t q -o "maxNumActiveConsumers=5"
送信先名は、英数字 (空白文字は含まない) だけを使用でき、英字、または記号「_」と「$」で開始できます。文字列「mq.」はメトリックストピック送信先用に予約されているため、この文字列で開始することはできません (表 2-8 を参照)。
定義の一覧表示
送信先の現在の属性値、送信先に関連付けられているプロデューサまたはコンシューマの数、送信先内のメッセージの数とサイズなどのメッセージングメトリックスに関する情報を取得できます。
情報を取得したい送信先を検索するために、最初に list dst サブコマンドを使用して特定のブローカ上のすべての送信先を一覧表示できます。たとえば、myHost のポート 4545 上で実行しているブローカ上の送信先すべてのリストを取得するには次のコマンドを入力します。
list dst サブコマンドを使用すると、任意で、一覧表示する送信先のタイプを指定したり、一次送信先を含めたりすることができます (-tmp オプションを使用)。一次送信先はクライアントによって作成され、通常は、そのほかのクライアントへ送信されたメッセージへの返信を受信することを目的としています (「一時送信先」を参照)。
送信先情報の表示
送信先の現在の属性値に関する情報を取得するには、次に示すように、query dst サブコマンドを使用します。
このコマンドでは、次のような情報が出力されます。
------------------------------------
Destination Name Destination Type
------------------------------------
XQueue Queue
On the broker specified by:
-------------------------
Host Primary Port
-------------------------
localhost 7676
Destination Name XQueue
Destination Type Queue
Destination State RUNNING
Created Administratively true
Current Number of Messages 0
Current Total Message Bytes 0
Current Number of Producers 0
Current Number of Active Consumers 0
Current Number of Backup Consumers 0
Max Number of Messages unlimited (-1)
Max Total Message Bytes unlimited (-1)
Max Bytes per Message unlimited (-1)
Max Number of Producers 100
Max Number of Active Consumers 1
Max Number of Backup Consumers 0
Limit Behavior REJECT_NEWEST
Consumer Flow Limit 100
Is Local Destination false
Local Delivery is Preferred false
また、出力は送信先に関連付けられたプロデューサとコンシューマの数を示しています。キュー送信先に関しては、アクティブコンシューマとバックアップコンシューマの両方が含まれています。
update dst サブコマンドを使用すると、1 つ以上の属性の値を変更できます (「送信先の属性の更新」を参照)。
送信先の属性の更新
送信先の属性を変更するには、update dst サブコマンドと -o オプションを使用して、更新する属性を指定します。複数の属性を更新する必要がある場合、-o オプションを使用できます。たとえば、次のコマンドでは maxBytesPerMsg 属性が 1000 に、MaxNumMsgs 属性が 2000 にそれぞれ変更されます。
更新が可能な属性については、表 6-10 を参照してください。
送信先の type や isLocalOnly 属性を更新する場合、update dst サブコマンドは使用できません。
送信先のメトリックスの表示
送信先に関するメッセージメトリックス情報を取得するには、次に示すように、metrics dst サブコマンドを使用します。
このコマンドでは、次のような情報が出力されます。
-----------------------------------------------------------------------------
Msgs Msg Bytes Msg Count Total Msg Bytes (k) Largest
In Out In Out Current Peak Avg Current Peak Avg Msg (k)
-----------------------------------------------------------------------------
200 200 147200 147200 0 200 0 0 143 71 0
300 200 220800 147200 100 200 10 71 143 64 0
300 300 220800 220800 0 200 0 0 143 59 0
imqcmd を使用して送信先のメトリックスをレポートする方法の詳細は、「監視ツール」を参照してください。
送信先の停止と再開
プロデューサから送信先、送信先からコンシューマ、またはその両方のメッセージの配信を制御するために、送信先を停止できます。特に、メッセージのプロデュースがコンシュームよりかなり高速な場合に、送信先がメッセージによって過負荷にならないように、送信先へのメッセージフローを停止できます。
送信先へ、または送信先からのメッセージの配信を停止するには、次に示すように、pause dst サブコマンドを使用します。
送信先を停止しており、配信を再開したい場合は、次のコマンドを入力します。
マルチブローカ クラスタでは、送信先のインスタンスはクラスタ内の各ブローカに常駐します。これらの送信先はそれぞれ個別に停止する必要があります。
送信先のパージ
送信先のキューに現在入っているメッセージは、すべてパージすることが可能です。送信先をパージすると、物理的な送信先のキューに入っているすべてのメッセージが削除されます。送信先に累積されたメッセージによって、システムのリソースが大幅に消費される場合に、これらのメッセージをパージすることができます。これは、登録済みのコンシューマクライアントがキューに入っていない場合やキューが多数のメッセージを受信する場合に発生する可能性があります。また、トピックの永続サブスクライバが、アクティブにならない場合にも発生する可能性があります。どちらの場合も、メッセージが必要以上に保持されます。
送信先でメッセージをパージするには、次に示すように、purge dst サブコマンドを使用します。
ブローカをシャットダウンした後、再起動するときに、古いメッセージを配信する必要がない場合は、-reset messges オプションを使用して、古いメッセージをパージします。たとえば、次のとおりです。
これで、ブローカを再起動すると、送信先のパージに関する問題が解消されます。
マルチブローカ クラスタでは、送信先のインスタンスはクラスタ内の各ブローカに常駐します。これらの送信先はそれぞれ個別にパージする必要があります。
送信先の破棄
送信先を破棄するには、次に示すように、destroy dst サブコマンドを使用します。
送信先を破棄すると、その送信先のすべてのメッセージがパージされ、ブローカからその送信先がなくなるため、操作を元に戻すことはできません。
送信先の圧縮
メッセージの持続ストアとして、プラグインされた JDBC 互換のデータストアではなく、組み込みのファイルベースのデータストアを使用している場合は、ディスク利用率を監視し、必要に応じてディスクを圧縮できます。
ファイルベースのメッセージストアは、保持される送信先に応じてメッセージがディレクトリに格納されるように構成されています。各送信先のディレクトリでは、大半のメッセージが可変長のレコードから成る 1 つのファイル、つまり可変長のレコードファイルに格納されます。断片化を減らすため、サイズが設定可能なしきい値を超えているメッセージは専用の個別のファイルに格納されます。可変サイズのメッセージが保持されていて、その後可変長のレコードファイルから削除された場合、空きレコードが再利用されていないファイルに空白ができることがあります。
未使用の空きレコードを管理するために、コマンドユーティリティには、送信先ごとにディスク利用率を監視したり、利用率の低下時に空きディスクスペースを再利用したりするためのサブコマンドが含まれています。
送信先のディスク利用率の監視
送信先のディスク利用率を監視するには、次の imqcmd のサブコマンドを使用します。
このコマンドでは、次のような情報が出力されます。
--------------------------------------
Reserved Used Utilization Ratio
--------------------------------------
806400 804096 99
1793024 1793024 100
2544640 2518272 98
サブコマンド出力の各列の意味は次のとおりです。
表 6-11 送信先ディスク利用率のメトリックス
メトリックス
説明
Reserved (予約済み)
すべてのレコードによって使用されるディスクスペース (バイト単位)。アクティブメッセージを保持するレコードと再利用可能な空きレコードが含まれる
Used (使用中)
アクティブメッセージを保持しているレコードによって使用されるディスクスペース (バイト単位)
Utilization Ratio (利用率)
使用されているディスクスペースを予約済みのディスクスペースで割ったときの商。割合が高いほど、アクティブメッセージを保持するためにより多くのディスクスペースが使用されている
未使用の送信先ディスクスペースの再利用
ディスク利用率のパターンは、特定の送信先を使用しているメッセージングアプリケーションの特性によって異なります。また、送信先との間でやり取りされる相対的なメッセージフローとメッセージの相対的なサイズに応じて、時間の経過とともに予約済みディスクスペースが拡大することがあります。
メッセージのプロデュースレートがメッセージのコンシュームレートを大きく上回る場合は、一般に、空きレコードが再利用され利用率が高くなります。ただし、メッセージのプロデュースレートがメッセージのコンシュームレートと同程度かそれより低い場合は、利用率は低いと予測できます。
一般に、予約済みディスクスペースは安定化させ、利用率は高いまま維持する必要があります。一般的に、システムが安定して、予約済みディスクスペースがほぼ一定になり利用率が高い (75% を超える) 状態に達した場合には、未使用のディスクスペースを再利用する必要はありません。システムが安定した状態になったが利用率が低い (50% を下回る) 場合は、ディスクを圧縮し、空きレコードが占有しているディスクスペースを再利用できます。
予約済みのディスクスペースが時間の経過とともに増え続けている場合は、送信先メモリーの制限プロパティと制限動作を設定して送信先のメモリー管理を設定し直す必要があります (表 6-10 を参照)。
未使用の送信先ディスクスペースを再利用するには
送信先のタイプと名前が指定されなかった場合、これらの操作はすべての送信先に対して実行されます。
永続サブスクリプションの管理ブローカの永続サブスクリプションを管理するには、imqcmd のサブコマンドを使用する必要があります。永続サブスクリプションとは、クライアントによって、永続的であると登録されたトピックのサブスクリプションのことです。このサブスクリプションには固有の識別情報があり、コンシューマがアクティブになっていないときでも、サブスクリプションのメッセージを保持するブローカが必要となります。通常、ブローカはメッセージの有効期限が切れたときだけ、保持していた永続サブスクライバのメッセージを削除します。
表 6-12 は、imqcmd の永続サブスクリプションのサブコマンドについてまとめたものです。デフォルトのブローカ (localhost:7676) を使用しない場合、ブローカのホスト名とポート番号を指定する必要があります。
表 6-12 永続サブスクリプションを管理する imqcmd のサブコマンド
サブコマンド
説明
list dur -d destName
特定の送信先の永続サブスクリプションをすべて一覧表示する
destroy dur -n subscrName
-c client_id特定のクライアント識別子を持つ特定の永続サブスクリプションを破棄する (「クライアント識別子」を参照)
purge dur -n subscrName
-c client_id特定のクライアント識別子を持つ特定の永続サブスクリプションのすべてのメッセージをパージする (「クライアント識別子」を参照)
たとえば、次のコマンドでは、トピック SPQuotes の永続サブスクリプションがすべて一覧表示されます。
list dur サブコマンドでは、トピックの永続サブスクリプションごとに、永続サブスクリプションの名前、ユーザーのクライアント ID、このトピックのキューに入っているメッセージの数、および永続サブスクリプションの状態 (アクティブまたは非アクティブ) を返します。たとえば、次のように表示されます。
Name Client ID Number of Durable Sub
Messages State
----------------------------------------------------------------
myDurable myClientID 1 INACTIVE
list dur サブコマンドから返される情報を使用して、破棄する必要がある永続サブスクリプションやメッセージをパージする必要がある永続サブスクリプションを識別することができます。サブスクリプションを識別するには、サブスクリプションの名前とクライアント ID を使用します。たとえば、次のように指定します。
トランザクションの管理クライアントアプリケーションによって開始されたトランザクションはすべてブローカによって記録されます。これらは、XA リソースマネージャによって管理される Message Queue の単純なトランザクション、または分散トランザクションです (「ローカルトランザクション」を参照)。各トランザクションには、Message Queue トランザクション ID が付けられています。これは、ブローカのトランザクションを一意に識別するための 64 ビットの数字です。また、分散トランザクションには、分散トランザクションマネージャによって割り当てられる最大 128 バイトの分散トランザクション ID (XID) が付けられます。Message Queue は、Message Queue トランザクション ID と XID の関連付けを保持します。
分散トランザクションの場合、障害が発生すると、トランザクションがコミットされずに PREPARED 状態のままになる可能性があります。このため、管理者は監視を行い、PREPARED 状態のトランザクションをロールバックするか、またはコミットする必要があります。
表 6-13 は、imqcmd のトランザクションのサブコマンドについてまとめたものです。デフォルトのブローカ (localhost:7676) を使用しない場合、ブローカのホスト名とポート番号を指定する必要があります。
表 6-13 トランザクションを管理する imqcmd のサブコマンド
サブコマンド
説明
list txn
ブローカによって記録されたトランザクションがすべて一覧表示される
query txn -n transaction_id
特定のトランザクションに関する情報が表示される
commit txn -n transaction_id
特定のトランザクションをコミットする
rollback txn -n transaction_id
特定のトランザクションをロールバックする
たとえば、次のコマンドでは、ブローカのすべてのトランザクションが一覧表示されます。
トランザクションごとに、list サブコマンドは、トランザクション ID、状態、ユーザー名、メッセージまたは通知の数、および作成時間を返します。たとえば、次のように表示されます。
---------------------------------------------------------------
Transaction ID State User name # Msgs/ Creation time
# Acks
---------------------------------------------------------------
64248349708800 PREPARED guest 4/0 1/30/02 10:08:31 AM
64248371287808 PREPARED guest 0/4 1/30/02 10:09:55 AM
このコマンドを使用すると、ブローカ内のローカルと分散の両方のトランザクションがすべて表示されます。PREPARED 状態のトランザクションだけをコミット、またはロールバックすることができます。これを実行するのは、障害の発生でトランザクションが PREPARED 状態になり、分散トランザクションマネージャによってコミットされるプロセスになっていないことがわかっている場合だけです。
たとえば、ブローカの自動ロールバックプロパティを false に設定した場合 (表 2-4 を参照)、ブローカの起動時に、PREPARED 状態のトランザクションを手動でコミット、またはロールバックする必要があります。
list サブコマンドは、トランザクションでプロデュースされたメッセージの数とトランザクションで通知されたメッセージの数 (#Msgs/#Acks) も表示します。トランザクションがコミットされるまで、これらのメッセージは配信されず、通知は処理されません。
query サブコマンドを使用すると、同じ情報のほかに、 クライアント ID、コネクション識別子、分散トランザクション ID (XID) などの多数の追加された値を確認できます。たとえば、次のように指定します。
次のような情報が出力されます。
Client ID
Connection guest@192.18.116.219:62209->jms:62195
Creation time 1/30/02 10:08:31 AM
Number of acknowledgements 0
Number of messages 4
State PREPARED
Transaction ID 64248349708800
User name guest
XID
6469706F6C7369646577696E6465723130313234313431313030373230
分散トランザクションをコミット、またはロールバックするには、commit サブコマンドと rollback サブコマンドを使用します。前述したように、PREPARED 状態のトランザクションだけをコミット、またはロールバックできます。たとえば、次のように指定します。
ブローカの起動時に、PREPARED 状態のトランザクションが自動的にロールバックされるように、ブローカを設定することも可能です。詳細は、表 2-4 の imq.transaction.autorollback プロパティを参照してください。