JPH1027168A - メッセージ動的負荷分散方式 - Google Patents

Abstract

(57)【要約】 【課題】 メッセージの処理における処理時間を短縮
し、分散トランザクションシステム全体としての処理効
率の向上を図る。 【解決手段】 メッセージ処理手段１０２または２０２
は、メッセージ格納手段１０３または２０３に格納され
ているメッセージに対する処理を実行し、最後に実行し
たメッセージに対する処理のために要した処理時間を格
納する。負荷測定手段１０４または２０４は、メッセー
ジ格納手段１０３または２０３に格納されているメッセ
ージの個数とメッセージ処理手段１０２または２０２に
格納されている処理時間とに基づき、計算機１０１また
は２０１の負荷を測定する。メッセージ分散手段３０２
は、計算機１０１および２０１から送信された負荷状況
情報に基づき、端末装置４０１，４０２，または４０３
からのメッセージの送信先を決定する。

Description

【発明の詳細な説明】

【０００１】

【発明の属する技術分野】本発明は、複数の計算機（分
散して接続された計算機群）でトランザクション処理を
実行する分散トランザクションシステムに関し、特に端
末装置から計算機に対して送信される処理要求のメッセ
ージに対する処理（トランザクション処理）の負荷を各
計算機に動的に振り分ける（分散させる）制御を行うメ
ッセージ動的負荷分散方式に関する。

【０００２】

【従来の技術】以下、従来の技術について説明する。

【０００３】従来、この種のメッセージ動的負荷分散方
式は、端末装置から処理要求のメッセージが発行された
場合に、各計算機の負荷状況に差が生じたとき（計算機
の処理能力に差が生じたとき）に、処理能力の低い計算
機にも処理能力の高い計算機と同じ量の処理要求のメッ
セージが送信されていた。

【０００４】なお、本発明に対する従来の技術について
は、特開平１−２４６６５７号公報（並列処理システ
ム）の第１頁第８行〜第１５行および第２頁第１７行〜
第４０行に記載がある。

【０００５】

【発明が解決しようとする課題】上述した従来の技術で
は、処理能力の低い計算機にも処理能力の高い計算機と
同じ量の処理要求のメッセージが送信されているので、
分散トランザクションシステム全体としての処理効率が
低下するという問題点があった。

【０００６】なお、上述の特許公報に係る従来技術で
は、処理を行うプロセッサ（本願発明の「計算機」に相
当する）への負荷（メッセージに対する処理の負荷）の
割当ては、プロセッサを用いて行われる処理の遊休時間
または実行時間により各プロセッサの負荷が測定され、
最小（最低）負荷のプロセッサに新たな負荷が割り当て
られて各プロセッサの負荷が均等にされ、分散トランザ
クションシステム全体としての処理効率の向上が図られ
ている。

【０００７】この従来技術では、プロセッサでの処理が
終了した時点で処理をプロセッサに割り当てているた
め、プロセッサが処理を終了した時点で即座に次の処理
を割り当てる必要がある。ここで、負荷分散手段からプ
ロセッサへの処理の割当てに関しては、処理要求の転送
時間だけプロセッサが処理を行わない時間がある。その
ために、処理を行うプロセッサと負荷分散手段との間が
高速の通信手段で結合されていないと、処理を行うプロ
セッサの有効利用を実現できない場合が生じるという問
題点がある。

【０００８】本発明の目的は、上述の点に鑑み、上述の
問題点を除去し、メッセージの処理における処理時間を
短縮し、分散トランザクションシステム全体としての処
理効率の向上を実現できるメッセージ動的負荷分散方式
を提供することにある。

【０００９】すなわち、本発明では、計算機（プロセッ
サ）へのメッセージの割当てを計算機の処理の終了を待
たずに行い、割当て後の処理要求のメッセージは割り当
てられた計算機で格納し、負荷状況の評価には計算機で
格納されているメッセージの個数と終了した処理の処理
時間とを乗じた値により予測することにより、上述の目
的を達成している。

【００１０】

【課題を解決するための手段】本発明のメッセージ動的
負荷分散方式は、複数の端末装置から処理要求のメッセ
ージが送信され、分散して接続された複数の計算機の中
から選択された計算機によって当該メッセージに対する
処理を行う分散トランザクションシステムにおいて、自
己が存在する処理実行計算機において処理待ちのメッセ
ージと当該処理待ちのメッセージの個数とを格納する処
理実行計算機内のメッセージ格納手段と、前記メッセー
ジ格納手段に格納されているメッセージに対する処理を
実行し、最後に実行したメッセージに対する処理のため
に要した処理時間を格納する処理実行計算機内のメッセ
ージ処理手段と、前記メッセージ格納手段に格納されて
いるメッセージの個数と前記メッセージ処理手段に格納
されている処理時間とに基づいて自己が存在する処理実
行計算機の負荷を測定する処理実行計算機内の負荷測定
手段と、前記負荷測定手段による測定結果に基づく負荷
状況情報を分散制御計算機に送信する処理実行計算機内
の負荷状況送信手段と、前記負荷状況送信手段から送信
された負荷状況情報を受信する分散制御計算機内の負荷
状況受信手段と、前記負荷状況受信手段によって受信さ
れた各処理実行計算機からの負荷状況情報に基づいて端
末装置からのメッセージの送信先の処理実行計算機を決
定する分散制御計算機内のメッセージ分散手段と、前記
メッセージ分散手段により決定された送信先の処理実行
計算機に端末装置からのメッセージを送信する分散制御
計算機内のメッセージ送信手段とを有する。

【００１１】

【発明の実施の形態】次に、本発明について図面を参照
して詳細に説明する。

【００１２】図１は、本発明のメッセージ動的負荷分散
方式の実施の形態の一例を示すブロック図である。

【００１３】このメッセージ動的負荷分散方式は、計算
機１０１（第１の処理実行計算機）と、計算機２０１
（第２の処理実行計算機）と、計算機３０１（分散制御
計算機）と、端末装置４０１，４０２，および４０３
（第１，第２，および第３の端末装置）とを含んで構成
されている。なお、本例では、実際にトランザクション
処理を実行する処理実行計算機の数は２台であるが、そ
の台数が２に限定されないことはいうまでもない（ちな
みに、端末装置の台数も限定されない）。また、処理要
求のメッセージに対する処理の負荷を分散する制御を行
う分散制御計算機（本例では、計算機３０１）が同時に
処理実行計算機として機能することも可能である（その
際には、例えば、計算機３０１内にも計算機１０１等と
同様の構成要素が存在することになる）。

【００１４】計算機１０１は、メッセージ処理手段１０
２と、メッセージ格納手段１０３と、負荷測定手段１０
４と、負荷状況送信手段１０５とを含んで構成されてい
る。

【００１５】計算機２０１は、メッセージ処理手段２０
２と、メッセージ格納手段２０３と、負荷測定手段２０
４と、負荷状況送信手段２０５とを含んで構成されてい
る。

【００１６】計算機３０１は、メッセージ分散手段３０
２と、メッセージ送信手段３０３と、負荷状況受信手段
３０４とを含んで構成されている。

【００１７】図２は、メッセージ分散手段３０２の処理
を示す流れ図である。この処理は、端末装置発行メッセ
ージ受信ステップ２１と、計算機負荷比較判定ステップ
２２と、メッセージ送信先決定ステップ２３と、メッセ
ージ送信先決定ステップ２４とからなる。

【００１８】図３は、計算機１０１の負荷状況送信手段
１０５または計算機２０１の負荷状況送信手段２０５か
ら計算機３０１の負荷状況受信手段３０４に送信される
負荷状況情報７０１の内容を示す図である。

【００１９】負荷状況情報７０１は、各処理実行計算機
（ここでは、計算機１０１または計算機２０１）の負荷
状況を示す情報で構成され、当該負荷状況情報７０１の
送出元の処理実行計算機の識別（ここでは、計算機１０
１であるか計算機２０１であるかの区別）のために用い
られる計算機ＩＤ（ＩＤｅｎｔｉｆｉｃａｔｉｏｎ）７
０２と、当該負荷状況情報７０１が示す負荷状況の対象
となるメッセージ処理手段の識別（ここでは、計算機１
０１のメッセージ処理手段１０２であるか計算機２０１
のメッセージ処理手段２０２であるかの区別）のために
用いられるメッセージ処理手段ＩＤ７０３と、メッセー
ジ処理手段ＩＤ７０３で示されるメッセージ処理手段
（ここでは、メッセージ処理手段１０２またはメッセー
ジ処理手段２０２）で１つのメッセージに対する処理を
実行するために必要であった時間を示すメッセージ処理
手段処理時間７０４と、計算機ＩＤ７０２で示される処
理実行計算機において格納されているメッセージ（ここ
では、計算機１０１のメッセージ格納手段１０３または
計算機２０１のメッセージ格納手段２０３に格納されて
いるメッセージ）の個数を示す格納メッセージ個数７０
５とから構成されている。

【００２０】図４は、処理実行計算機である計算機１０
１におけるメッセージ処理手段１０２およびメッセージ
格納手段１０３の詳細な構成および処理の態様を示すブ
ロック図である（計算機２０１もこの構成等と同様の構
成等を有している）。

【００２１】メッセージ格納手段１０３は、メッセージ
格納域５０１と、メッセージ数格納域５０２とを含んで
構成されている。

【００２２】メッセージ格納域５０１は、メッセージ処
理手段１０２が処理するまで待ち状態にあるメッセージ
群を格納する。

【００２３】メッセージ数格納域５０２は、メッセージ
格納域５０１に格納されているメッセージの個数を格納
する。

【００２４】メッセージ処理手段１０２は、時間計測手
段６０１と、処理時間格納域６０２と、メッセージ処理
ロジック６０３とを含んで構成されている。

【００２５】時間計測手段６０１は、メッセージ処理ロ
ジック６０３がメッセージ格納手段１０３のメッセージ
格納域５０１に格納されているメッセージ群の中のメッ
セージを１つ取り出しそのメッセージに対する処理を終
了するまでの時間を計測し、その時間を処理時間格納域
６０２に格納する。

【００２６】処理時間格納域６０２は、メッセージ処理
手段１０２がメッセージ格納手段１０３から最後に（最
も近い時点で）取り出した１つのメッセージに対する処
理を実行するために必要となった時間（処理時間）を格
納している。

【００２７】メッセージ処理ロジック６０３は、端末装
置４０１，４０２，または４０３から発行されたメッセ
ージに対する処理を実際に行う論理機構である。

【００２８】次に、このような実施の形態を有する本発
明のメッセージ動的負荷分散方式の動作について説明す
る。

【００２９】第１に、処理実行計算機である計算機１０
１または計算機２０１の動作について説明する。なお、
ここでは、計算機１０１における動作で代表させて説明
する。

【００３０】計算機１０１のメッセージ格納手段１０３
は、計算機３０１のメッセージ送信手段３０３から送信
されたメッセージ（端末装置４０１，端末装置４０２，
または端末装置４０３からの処理要求のメッセージ）を
格納する。

【００３１】メッセージ処理手段１０２は、メッセージ
格納手段１０３に格納されている処理要求のメッセージ
に対する処理を実行する。

【００３２】負荷測定手段１０４は、メッセージ格納手
段１０３のメッセージ格納域５０１に格納されているメ
ッセージの個数（メッセージ数格納域５０２に格納され
ている値）とメッセージ処理手段１０２が最後に実行し
た１つのメッセージに対する処理に要した時間（メッセ
ージ処理手段１０２の処理時間格納域６０２に格納され
ている値）とを調べることにより計算機１０１の負荷状
況を測定し、その測定結果を負荷状況送信手段１０５に
通知する。

【００３３】負荷状況送信手段１０５は、負荷測定手段
１０４で測定された負荷状況を負荷状況情報７０１（図
３参照）の形式に編集して、その負荷状況情報７０１を
分散制御計算機である計算機３０１の負荷状況受信手段
３０５に送信する。

【００３４】第２に、分散制御計算機である計算機３の
動作（端末装置４０１，端末装置４０２，および端末装
置４０３の動作を含む）について説明する。

【００３５】計算機３０１の負荷状況受信手段３０４
は、計算機１０１の負荷状況を示す負荷状況情報７０１
を計算機１０１の負荷状況送信手段１０５から受け取
り、計算機２０１の負荷状況を示す負荷状況情報７０１
を計算機２０１の負荷状況送信手段２０５から受け取
る。

【００３６】これらの負荷状況情報７０１は、メッセー
ジ分散手段３０２で、端末装置４０１，端末装置４０
２，または端末装置４０３からのメッセージを計算機１
０１で処理すべきか計算機２０１で処理すべきかを判断
する際に用いられる。

【００３７】すなわち、負荷状況受信手段３０４は、計
算機１０１の負荷状況送信手段１０５から送信された計
算機１０１の負荷状況情報７０１および計算機２０１の
負荷状況送信手段２０５から送信された計算機２０１の
負荷状況情報７０１をメッセージ分散手段３０２に通知
する。

【００３８】一方、端末装置４０１は、計算機１０１の
メッセージ処理手段１０２または計算機２０１のメッセ
ージ処理手段２０２の処理を要求するメッセージ（処理
要求のメッセージ）を計算機３０１に送信する。なお、
端末装置４０２または端末装置４０３も、端末装置４０
１と同様の処理を行う。

【００３９】メッセージ分散手段３０２は、以上のよう
な負荷状況情報７０１の存在および端末装置４０１〜４
０３からの処理要求のメッセージの存在を前提として、
以下に示すような処理を行う（図２参照）。

【００４０】端末装置４０１，端末装置４０２，または
端末装置４０３からの処理要求のメッセージを１つ受け
取り（受信し）（ステップ２１）、負荷状況受信手段３
０４によって受信された負荷状況情報７０１に基づいて
計算機１０１の負荷状況と計算機２０１の負荷状況とを
比較する（ステップ２２）。

【００４１】ステップ２２の比較で「計算機１０１の負
荷が計算機２０１の負荷よりも低い」と判断した場合に
は、「端末装置４０１，端末装置４０２，および端末装
置４０３のどれかから受け取ったメッセージを計算機１
０１に送信すること（そのメッセージを計算機１０１の
メッセージ格納手段１０３に格納すること）」を決定す
る（ステップ２３）。

【００４２】一方、ステップ２２の比較で「計算機１０
１の負荷が計算機２０１の負荷より高い」と判断した場
合には、「端末装置４０１，端末装置４０２，および端
末装置４０３のどれかから受け取ったメッセージを計算
機２０１に送信すること（そのメッセージを計算機２０
１のメッセージ格納手段２０３に格納すること）」を決
定する（ステップ２４）。なお、ここでは、両方の負荷
の大きさが等しい場合には、計算機２０１にそのメッセ
ージを送信するものとし、上記の「計算機１０１の負荷
が計算機２０１の負荷より高い」の中に両方の負荷の大
きさが等しい場合を含むものとする。

【００４３】ここで、メッセージ分散手段３０２は、負
荷状況受信手段３０４により受信された負荷状況情報７
０１に基づく「計算機１０１の負荷と計算機２０１の負
荷との高低の比較判定」を以下の〜に示す手順のよ
うにして行う。

【００４４】 計算機１０１のメッセージ格納手段１
０３に格納されているメッセージの個数（計算機１０１
からの負荷状況情報７０１中の格納メッセージ個数７０
５の値）を計算機１０１のメッセージ処理手段１０２が
最後に実行した１つのメッセージに対する処理に要した
時間（当該負荷状況情報７０１中のメッセージ処理手段
処理時間７０４の値）に乗じた計算値を求める。

【００４５】 計算機２０１のメッセージ格納手段２
０３に格納されているメッセージの個数（計算機２０１
からの負荷状況情報７０１中の格納メッセージ個数７０
５の値）を計算機２０１のメッセージ処理手段２０２が
最後に実行した１つのメッセージに対する処理に要した
時間（当該負荷状況情報７０１中のメッセージ処理手段
処理時間７０４の値）に乗じた計算値を求める。

【００４６】 の計算値がの計算値より小さけれ
ば計算機１０１の負荷が計算機２０１の負荷よりも低い
と判断し、の計算値がの計算値より大きければ計算
機１０１の負荷が計算機２０１の負荷よりも高いと判断
する。

【００４７】メッセージ送信手段３０３は、メッセージ
分散手段３０２によって「計算機１０１のメッセージ処
理手段１０２で処理すべきメッセージ」と判断されたメ
ッセージ（図２ステップ２３参照）を、計算機１０１の
メッセージ格納手段１０３に送信する。

【００４８】また、メッセージ送信手段３０３は、メッ
セージ分散手段３０２によって「計算機２０１のメッセ
ージ処理手段２０２で処理すべきメッセージ」と判断さ
れたメッセージ（図２ステップ２４参照）を、計算機２
０１のメッセージ格納手段２０３に送信する。

【００４９】なお、処理実行計算機が３台以上存在する
場合には、負荷が最低の処理実行計算機にメッセージが
送信される。

【００５０】

【実施例】次に、以上のような実施の形態を有する本発
明のメッセージ動的負荷分散方式の具体的な実施例につ
いて、図面を用いて説明する。

【００５１】図５〜図８は、本発明のメッセージ動的負
荷分散方式の一実施例の動作を説明するためのブロック
図である。

【００５２】図５は、本実施例のメッセージ動的負荷分
散方式におけるメッセージ処理手段１０２，メッセージ
格納手段１０３，メッセージ処理手段２０２，およびメ
ッセージ格納手段２０３の動作の態様を示すブロック図
である。

【００５３】なお、メッセージ処理手段１０２には、処
理時間格納域６０２が用意され、メッセージ処理手段１
０２で１つのメッセージの処理に必要であった時間が格
納されている。また、メッセージ格納手段１０３には、
メッセージ数格納域５０２が用意され、メッセージ格納
手段１０３に格納されているメッセージの個数が格納さ
れている。

【００５４】同様に、メッセージ処理手段２０２には、
処理時間格納域６１２が用意され、メッセージ処理手段
２０２で１つのメッセージの処理に必要であった時間が
格納されている。また、メッセージ格納手段２０３に
は、メッセージ数格納域５１２が用意され、メッセージ
格納手段２０３に格納されているメッセージの個数が格
納されている。

【００５５】図６は、計算機１０１から計算機３０１に
負荷状況情報７０１が送信される際の処理の態様を示す
ブロック図である。

【００５６】図７は、計算機２０１から計算機３０１に
負荷状況情報７０１が送信される際の処理の態様を示す
ブロック図である。

【００５７】図８は、計算機１０１および計算機２０１
から負荷状況情報７０１が計算機３０１に送信され、計
算機３０１のメッセージ分散手段３０２によって端末装
置４０３からのメッセージが計算機１０１に送信される
場合の一連の処理の態様を示す図である。

【００５８】なお、負荷計算領域８０１は計算機１０１
の負荷を計算するための領域であり、負荷計算領域８０
２は計算機２０１の負荷を計算するための領域である。
また、負荷比較手段８０３は、負荷計算領域８０１内の
計算値と負荷計算領域８０２内の計算値とを比較し、端
末装置４０３からのメッセージを計算機１０１に送信す
べきか計算機２０１に送信すべきかを決める手段であ
る。

【００５９】次に、本実施例のメッセージ動的負荷分散
方式の動作について、図５〜図８を用いて説明する。

【００６０】第１に、図５を参照して、本実施例の動作
の前提について説明する。本実施例では、以下の〜
に示す事項の存在を前提としている。

【００６１】 端末装置４０３から１つの処理要求の
メッセージが発行されている。

【００６２】 そのメッセージの発行の時点で、計算
機１０１または計算機２０１では、過去に端末装置４０
１〜４０３のどれかからメッセージ処理手段１０２また
はメッセージ処理手段２０２のどちらかで処理を行う旨
の要求のメッセージに対する処理を行っている。

【００６３】 計算機１０１のメッセージ処理手段１
０２の処理時間格納域６０２には、最後に（最も近い時
点で）実行したメッセージの処理に必要であった時間の
「５秒」が格納されている。

【００６４】 計算機１０１のメッセージ格納手段１
０３のメッセージ数格納域５０２には、現時点でメッセ
ージ処理手段１０２の処理を待っている状態のメッセー
ジの個数である「３個」が格納されている。

【００６５】 計算機２０１のメッセージ処理手段２
０２の処理時間格納域６１２には、最後に実行したメッ
セージの処理に必要であった時間の「３秒」が格納され
ている。

【００６６】 計算機２０１のメッセージ格納手段２
０３のメッセージ数格納域５１２には、現時点でメッセ
ージ処理手段２０２の処理を待っている状態のメッセー
ジの個数である「６個」が格納されている。

【００６７】第２に、図６を参照して、計算機１０１か
ら計算機３０１に負荷状況情報７０１が通知される過程
の動作を説明する。なお、計算機１０１の計算機ＩＤは
「１」であるものとし、メッセージ処理手段１０２のメ
ッセージ処理手段ＩＤは「１０」であるものとする。

【００６８】ここで、メッセージ格納手段１０３のメッ
セージ格納域５０１には、３個のメッセージが格納され
ている。また、メッセージ数格納域５０２には、メッセ
ージ格納域５０１に格納されているメッセージの個数で
ある「３個」が格納されている。

【００６９】この場合に、メッセージ処理手段１０２内
の時間計測手段６０１は、メッセージ処理ロジック６０
３がメッセージ格納手段１０３のメッセージ格納域５０
１から最後に取り出した１つのメッセージに対する処理
に要する時間を測定しており、メッセージ処理ロジック
６０３がそのメッセージに対する処理の実行を終了した
時点でメッセージ処理手段１０２の処理時間格納域６０
２にその処理に必要であった時間の「５秒」を設定して
いる。

【００７０】負荷測定手段１０４は、メッセージ処理手
段１０２の処理時間格納域６０２に格納されている処理
時間の「５秒」という値と、メッセージ格納手段１０３
のメッセージ数格納域５０２に格納されている「メッセ
ージ格納域５０１に格納されているメッセージの個数」
の「３個」という値とを負荷状況送信手段１０５に渡
す。

【００７１】負荷状況送信手段１０５は、負荷測定手段
１０４から受け取ったメッセージ処理処手段１０２の処
理時間である「５秒」とメッセージ格納手段１０３に格
納されているメッセージの個数の「３個」とを図３に示
した負荷状況情報７０１の形式に編集し、その負荷状況
情報７０１を計算機３０１に送信する。

【００７２】ここで、負荷状況送信手段１０５から計算
機３０１に送信される負荷状況情報７０１中の各項目に
は、次の〜に示すような値が格納されている（図６
参照）。

【００７３】 計算機ＩＤ７０２には、計算機１０１
の計算機ＩＤの「１」の値が格納されている。

【００７４】 メッセージ処理手段ＩＤ７０３には、
計算機１０１のメッセージ処理手段１０２のメッセージ
処理手段ＩＤの「１０」の値が格納されている。

【００７５】 メッセージ処理手段処理時間７０４に
は、負荷測定手段１０４がメッセージ処理手段１０２の
処理時間格納域６０２から取り出した「５秒」の値が格
納されている。

【００７６】 格納メッセージ個数７０５には、負荷
測定手段１０４がメッセージ格納手段１０３のメッセー
ジ数格納域５０２から取り出した「３個」の値が格納さ
れている。

【００７７】第３に、図７を参照して、計算機２０１か
ら計算機３０１に負荷状況情報７０１が通知される過程
の動作を説明する。なお、計算機２０１の計算機ＩＤは
「２」であるものとし、メッセージ処理手段２０２のメ
ッセージ処理手段ＩＤは「２０」であるものとする。

【００７８】ここで、メッセージ格納手段２０３のメッ
セージ格納域５１１には、６個のメッセージが格納され
ている。また、メッセージ数格納域５１２には、メッセ
ージ格納域５１１に格納されているメッセージの個数で
ある「６個」が格納されている。

【００７９】この場合に、メッセージ処理手段２０２内
の時間計測手段６１１は、メッセージ処理ロジック６１
３がメッセージ格納手段２０３のメッセージ格納域５１
１から最後に取り出した１つのメッセージに対する処理
に要する時間を測定しており、メッセージ処理ロジック
６１３がそのメッセージに対する処理の実行を終了した
時点でメッセージ処理手段２０２の処理時間格納域６１
２にその処理に必要であった時間の「３秒」を設定して
いる。

【００８０】負荷測定手段２０４は、メッセージ処理手
段２０２の処理時間格納域６１２に格納されている処理
時間の「３秒」という値と、メッセージ格納手段２０３
のメッセージ数格納域５１２に格納されている「メッセ
ージ格納域５１１に格納されているメッセージの個数」
の「６個」という値とを負荷状況送信手段２０５に渡
す。

【００８１】負荷状況送信手段２０５は、負荷測定手段
２０４から受け取ったメッセージ処理処手段２０２の処
理時間である「３秒」とメッセージ格納手段２０３に格
納されているメッセージの個数の「６個」とを図３に示
した負荷状況情報７０１の形式に編集し、その負荷状況
情報７０１を計算機３０１に送信する。

【００８２】ここで、負荷状況送信手段２０５から計算
機３０１に送信される負荷状況情報７０１中の各項目に
は、次の〜に示すような値が格納されている（図７
参照）。

【００８３】 計算機ＩＤ７０２には、計算機２０１
の計算機ＩＤの「２」の値が格納されている。

【００８４】 メッセージ処理手段ＩＤ７０３には、
計算機２０１のメッセージ処理手段２０２のメッセージ
処理手段ＩＤの「２０」の値が格納されている。

【００８５】 メッセージ処理手段処理時間７０４に
は、負荷測定手段２０４がメッセージ処理手段２０２の
処理時間格納域６１２から取り出した「３秒」の値が格
納されている。

【００８６】 格納メッセージ個数７０５には、負荷
測定手段２０４がメッセージ格納手段２０３のメッセー
ジ数格納域５１２から取り出した「６個」の値が格納さ
れている。

【００８７】第４に、図８を参照して、端末装置４０３
からの処理要求のメッセージと計算機１０１および計算
機２０１からの負荷状況情報７０１とを以上のようにし
て受信した場合の計算機３０１における動作について説
明する。

【００８８】計算機３０１の負荷状況受信手段３０４
は、計算機１０１からの負荷状況情報７０１を受け取
り、その内容の計算機ＩＤ７０２が計算機１０１を示す
「１」であることを確認し、メッセージ処理手段ＩＤ７
０３が計算機１０１のメッセージ処理手段１０２を示す
「１０」であることを確認し、その負荷状況情報７０１
をメッセージ分散手段３０２に渡す。

【００８９】同様に、負荷状況受信手段３０４は、計算
機２０１からの負荷状況情報７０１を受け取り、その内
容の計算機ＩＤ７０２が計算機２０１を示す「２」であ
ることを確認し、メッセージ処理手段ＩＤ７０３が計算
機２０１のメッセージ処理手段２０２を示す「２０」で
あることを確認し、その負荷状況情報７０１をメッセー
ジ分散手段３０２に渡す。

【００９０】メッセージ分散手段３０２は、負荷状況受
信手段３０５から受け取った負荷状況情報７０１中のメ
ッセージ処理手段処理時間７０４の「５秒」の値と当該
負荷状況情報７０１中の格納メッセージ個数７０５の
「３個」の値とを掛け合わせた「５＊３＝１５」の計算
値を計算機１０１の負荷の値として負荷計算領域８０１
に格納する。

【００９１】同様に、メッセージ分散手段３０２は、負
荷状況受信手段３０６から受け取った負荷状況情報７０
１中のメッセージ処理手段処理時間７０４の「３秒」の
値と当該負荷状況情報７０１中の格納メッセージ個数７
０５の「６個」の値とを掛け合わせた「３＊６＝１８」
の計算値を計算機２０１の負荷の値として負荷計算領域
８０２に格納する。

【００９２】さらに、メッセージ分散手段３０２の負荷
比較手段８０３は、負荷計算領域８０１内の計算機１０
１の負荷の計算値が「１５」であり、負荷計算領域８０
２内の計算機２０１の負荷の計算値が「１８」であるこ
とに基づき、計算機１０１の負荷が計算機２０１の負荷
よりも低いことを認識する。

【００９３】これによって、メッセージ分散手段３０２
は、端末装置４０３からのメッセージを計算機１０１の
メッセージ格納手段１０３に送信し格納することを決定
する。

【００９４】メッセージ送信手段３０３は、その決定に
基づき、そのメッセージを計算機１０１のメッセージ格
納手段１０３に送信する。

【００９５】以上のように、本実施例のメッセージ動的
負荷分散方式は、メッセージ処理手段１０２またはメッ
セージ処理手段２０２の処理時間とメッセージ格納手段
１０３またはメッセージ格納手段２０３に格納されてい
るメッセージの個数とを乗じた値をメッセージ処理手段
１０２またはメッセージ処理手段２０２の処理を待って
いるメッセージを全て処理する時間の近似値として算出
している。そして、計算機１０１または計算機２０１の
負荷の状況をこの近似値で判断することにより、メッセ
ージ処理手段１０２またはメッセージ処理手段２０２に
おいて処理待ちの状態の全てのメッセージを処理する時
間をできるだけ均等にでき、計算機１０１および計算機
２０１の各々にできるだけ均等にメッセージを送信する
ことが可能になる。

【００９６】

【発明の効果】以上説明したように、本発明のメッセー
ジ動的負荷分散方式によると、端末装置からの処理要求
のメッセージを処理実行計算機に送信する時点で、各処
理実行計算機からの負荷状況情報に基づいて適切に選択
した処理実行計算機にそのメッセージを送信するため、
「負荷の低い計算機でメッセージに対する処理が行える
にもかかわらず、その計算機にそのメッセージが送信さ
れず、負荷が高い計算機にそのメッセージが送信され、
処理に必要な時間が大きくなる」といったことが少なく
なり、メッセージの処理における処理時間を短縮するこ
とができ、分散トランザクションシステム全体としての
処理効率の向上を実現できるという効果が生じる。

【図面の簡単な説明】

【図１】本発明のメッセージ動的負荷分散方式の実施の
形態を示すブロック図である。

【図２】図１中のメッセージ分散手段の処理を示す流れ
図である。

【図３】図１に示すメッセージ動的負荷分散方式によっ
て取り扱われる負荷状況情報の内容を示す図である。

【図４】図１中のメッセージ処理手段およびメッセージ
格納手段の詳細な構成および処理の態様を示すブロック
図である。

【図５】本発明の一実施例の動作を説明するためのブロ
ック図である。

【図６】本発明の一実施例の動作を説明するためのブロ
ック図（処理実行計算機からの負荷状況情報の送信の態
様を示す図）である。

【図７】本発明の一実施例の動作を説明するためのブロ
ック図（処理実行計算機からの負荷状況情報の送信の態
様を示す図）である。

【図８】本発明の一実施例の動作を説明するためのブロ
ック図（分散制御計算機のメッセージ分散手段の処理の
態様を示す図）である。

【符号の説明】

１０１，２０１，３０１ 計算機 １０２，２０２ メッセージ処理手段 １０３，２０３ メッセージ格納手段 １０４，２０４ 負荷測定手段 １０５，２０５ 負荷状況送信手段 ３０２ メッセージ分散手段 ３０３ メッセージ送信手段 ３０４ 負荷状況受信手段 ４０１，４０２，４０３ 端末装置 ５０１，５１１ メッセージ格納域 ５０２，５１２ メッセージ数格納域 ６０１，６１１ 時間計測手段 ６０２，６１２ 処理時間格納域 ６０３，６１３ メッセージ処理ロジック ７０１ 負荷状況情報 ７０２ 計算機ＩＤ ７０３ メッセージ処理手段ＩＤ ７０４ メッセージ処理手段処理時間 ７０５ 格納メッセージ個数 ８０１，８０２ 負荷計算領域 ８０３ 負荷比較手段

Claims (3)

【特許請求の範囲】
1. 【請求項１】 複数の端末装置から処理要求のメッセー
   ジが送信され、分散して接続された複数の計算機の中か
   ら選択された計算機によって当該メッセージに対する処
   理を行う分散トランザクションシステムにおいて、 自己が存在する処理実行計算機において処理待ちのメッ
   セージと当該処理待ちのメッセージの個数とを格納する
   処理実行計算機内のメッセージ格納手段と、 前記メッセージ格納手段に格納されているメッセージに
   対する処理を実行し、最後に実行したメッセージに対す
   る処理のために要した処理時間を格納する処理実行計算
   機内のメッセージ処理手段と、 前記メッセージ格納手段に格納されているメッセージの
   個数と前記メッセージ処理手段に格納されている処理時
   間とに基づいて自己が存在する処理実行計算機の負荷を
   測定する処理実行計算機内の負荷測定手段と、 前記負荷測定手段による測定結果に基づく負荷状況情報
   を分散制御計算機に送信する処理実行計算機内の負荷状
   況送信手段と、 前記負荷状況送信手段から送信された負荷状況情報を受
   信する分散制御計算機内の負荷状況受信手段と、 前記負荷状況受信手段によって受信された各処理実行計
   算機からの負荷状況情報に基づいて端末装置からのメッ
   セージの送信先の処理実行計算機を決定する分散制御計
   算機内のメッセージ分散手段と、 前記メッセージ分散手段により決定された送信先の処理
   実行計算機に端末装置からのメッセージを送信する分散
   制御計算機内のメッセージ送信手段とを有することを特
   徴とするメッセージ動的負荷分散方式。
2. 【請求項２】 各処理実行計算機からの負荷状況情報を
   比較して負荷が最低の処理実行計算機をメッセージの送
   信先に決定するメッセージ分散手段を有することを特徴
   とする請求項１記載のメッセージ動的負荷分散方式。
3. 【請求項３】 計算機ＩＤ，メッセージ処理手段ＩＤ，
   メッセージ処理手段処理時間，および格納メッセージ個
   数からなる負荷状況情報を送信する負荷状況送信手段
   と、 各処理実行計算機からの負荷状況情報中のメッセージ処
   理手段処理時間および格納メッセージ個数の積の大小を
   比較して各処理実行計算機の負荷の大小を判定するメッ
   セージ分散手段とを有することを特徴とする請求項２記
   載のメッセージ動的負荷分散方式。