(57)【要約】【課題】メモリデータベースシステムではメインメモリ上にデータベースを構築し性能を確保する特性上、業務プログラム・データベースが１つのマシン上に括りついており、外乱などによるマシンの性能劣化が直接システム全体の性能劣化に繋がる。また、上記問題へ対応するため冗長化構成とした場合において、スローダウン状態にならないと検知・切り替えできず、さらに、切り替え時にはメインメモリ上のデータベースを一旦ディスクに出力し、別マシン（待機マシン）にて再度メインメモリ上に読み込む必要があり、オーバーヘッドが大きく業務停止時間が長時間化する可能性がある。【解決手段】複数のマシン上に同一システムを構築し、各マシン上で同一処理を実行させ、最も早く処理が完了したマシンの結果を採用する。また、結果を各マシンに配布・同期させる。【選択図】図１
2009271733.tif 000002
【特許請求の範囲】
【請求項１】
コンピュータシステムにおける業務システムを対象に、メインメモリ上にデータベース
を構築するシステムにおいて、複数のマシン上に同じサービスを提供する実行プロセスを
動作させ、各実行プロセスで同一処理を実行した結果、他実行プロセスからの更新情報が
通知されていない実行プロセスの処理が終了した場合に、当該実行プロセスが最速で処理
を完了したと判断し、他実行プロセスに更新情報を通知するとともに、クライアントプロ
セスへ応答を送信し、また、他実行プロセスの処理を中断させることで同期を取ることを
特徴としたシステムによる性能の安定化方法。
【請求項２】
請求項１において、前記の同期により最速で処理を完了した実行プロセスから他実行
プロセスへ更新情報が通知され、他実行プロセスでは通知された更新情報を基に自身のデ
ータベースを更新することを特徴としたシステムによる処理結果の同期方法。
【請求項３】
請求項１において、マシン間での更新情報の通知がすれ違った際には、あらかじめ各
実行プロセスに設定された優先度を基に更新結果を選択し、データベースを更新すること
を特徴としたシステムによるマシン間の整合性保持方法。
【請求項４】
請求項１において、採用された処理結果を各実行プロセスが持つデータベースへ反映
させることを特徴としたシステムによる障害発生時の切り替え時間短縮方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、コンピュータを使用した業務システムにおけるメモリデータベースに関する
ものである。
【背景技術】
【０００２】
メインメモリ上にデータベースを構築するシステム（メモリデータベースシステム）は
、メインメモリ上にデータベースを構築し性能を確保する技術である。
【０００３】
【特許文献１】特開平７−３３４４０２号公報
【発明の開示】
【発明が解決しようとする課題】
【０００４】
メモリデータベースシステムではメインメモリ上にデータベースを構築し性能を確保す
る特性上、業務プログラム・データベースが１つのマシン上に括りついており、ディクス
装置の軽度障害やオペレーションミス等による不必要なプログラム実行などの外乱による
マシンの性能劣化が直接システム全体の性能劣化に繋がる。また、上記問題及びハード障
害に対応するため冗長化構成とした場合において、切り替え時にはメインメモリ上のデー
タベースを一旦ディスクに出力し、別マシン（待機マシン）にて再度メインメモリ上に読
み込む必要があり、オーバーヘッドが大きく業務停止時間が長時間化する可能性がある。
【０００５】
第１の発明の目的は、複数のマシン上に同一システムを構築し、各マシン上で同一処理
を実行・同期することにより最も早く処理が完了したマシンの結果が採用され、システム
全体が外乱などによるマシンの性能劣化の影響を受けないことにある。
【０００６】
第２の発明の目的は、最も早く処理が完了したマシンの結果を各マシンに反映すること
により、マシン障害発生時の切り替え時間を短縮することにある。
【課題を解決するための手段】
【０００７】
第１の発明の目的を達成するために、各マシン上で実施した処理の処理結果を同期する
、クラスタ同期機能を提供する。
【０００８】
第２の発明の目的を達成するために、処理結果を各マシンのデータベースへ反映する機
能を提供する。
【発明の効果】
【０００９】
本発明によれば、メモリデータベースシステムにおいて、複数台のマシンで同一処理を
実行することにより、特定マシンでの性能劣化・マシン障害の影響を受けず安定したシス
テム性能を提供することが可能となる。
【発明を実施するための最良の形態】
【００１０】
以下、本発明を実施する為の最良の形態を図面に基づき詳細に説明する。
【００１１】
図１は、本発明における実施例の構成を示すものである。本実施例は、ネットワークを
介して接続されている複数の計算機1a、1b、1c、1d、1e、サービス要求を行う複数のクラ
イアントプロセス2a、2b、サービス実行を行う複数の実行プロセス3a、3b、3c、クライア
ントからの処理要求を登録する入力キュー4a、4b、4c、データベース5a、5b、5c、データ
ベースの更新内容を登録する更新キュー6a、6b、6c、各実行プロセスを管理するクラスタ
情報7a、7b、7cで構成される。入力キュー4a、4b、4c、データベース5a、5b、5c、更新キ
ュー6a、6b、6c、クラスタ情報7a、7b、7cはメインメモリ中に存在する。実行プロセス3a
、3b、3c、には優先度及びノードIDが設定されている。ノードIDは全実行プロセス内で一
意に付けられた実行プロセスのIDである。本実施例では優先度は3aが優先度 高、3bが優
先度 中、3cが優先度 低に、ノードIDは3aがNODE-A、3bがNODE-B、3cがNODE-Cに設定され
ている。
【００１２】
図２は、クライアントプロセスと実行プロセスが備える機能を示したものである。
【００１３】
クライアントプロセス2は、他プロセスとネットワークを介して情報をやり取りする送
受信部21、送信したデータの送達確認・再送を行う送達確認部22、送信先実行プロセスの
マルチキャストアドレスを管理する送信先管理部23を備える。
【００１４】
実行プロセス3は、クライアントプロセスと同様に送受信部31、送達確認部32を備える
ほか、各実行プロセス間での同期を取るクラスタ同期部33、クラスタの状態を管理するク
ラスタ管理部34、業務処理そのものを実施する業務処理部35を備える。
【００１５】
図３(a)、図３(b)、図３(c)、図３(d)は、本発明の前提となるクライアントプロセスか
ら実行プロセスへのサービス要求送信及び処理の同期機能の処理概要を説明したものであ
る。
【００１６】
クライアントプロセス2は送信先管理部23を介して各実行プロセスが属するマルチキャ
ストアドレスを取得する(S201)。送信先管理部23はあらかじめ設定されたマルチキャスト
アドレスを管理している。取得したマルチキャストアドレスに対し送受信部21を介してサ
ービス要求を送信する(S202)。マルチキャストを使用することにより、各実行プロセスに
同一のサービス要求を送信することが可能となる。
【００１７】
実行プロセス(優先度 高)3aは送受信部31によりサービス要求を受信する(S301)とサー
ビス要求を入力キュー4aに登録(S302)し、送達確認部32により他実行プロセスからのサー
ビス要求結果の受信待ち(S303)となる。実行プロセス(優先度 中)3b及び実行プロセス(優
先度 低)3cは、送受信部31によりサービス要求を受信する(S401,S501)とサービス要求を
入力キュー(4b,4c)に登録(S402,S502)する。送達確認部32により登録に成功したかを判定
(S403,S503)した結果、成功した場合はサービス要求成功応答(S404,S504)を実行プロセス
(優先度 高)3aに対して送信する。失敗した場合はサービス要求失敗応答(S405,S505)を実
行プロセス(優先度 高)3aに対して送信する。
【００１８】
実行プロセス(優先度 高)3aは、送達確認部32にてすべての実行プロセスからのサービ
ス要求結果を受信または一定時間経過しても受信できなかったかを判定(S304)し、一定時
間経過しても受信できなかった場合には、クラスタ管理部34に受信できなかった実行プロ
セスについてクラスタ同期対象から外すようクラスタ同期対象外通知電文を送信する(S30
5)。クラスタ同期対象の実行プロセス全ての結果がサービス要求成功応答かを判定する(S
306)。すべて成功であれば、他実行サーバに対して送受信部31を介してサービス要求成功
応答を送信(S307)し、クライアント2に対してもサービス要求成功応答を送信(S308)する
。１つでもサービス要求失敗応答があった場合は、他実行サーバに対して送受信部31を介
してサービス要求失敗応答を送信(S309)し、クライアント2に対してもサービス要求失敗
応答を送信(S310)を送信する。
【００１９】
実行プロセス(優先度 中)3bは、送達確認部32にて実行プロセス(優先度 高)3aからのサ
ービス要求成功/サービス要求失敗応答を受信(S406)する。受信結果を判定(S407)し一定
時間経過しても受信できなかった場合には自実行プロセスのクラスタ管理部34に、受信で
きなかった実行プロセスをクラスタ同期対象から外すよう通知する(S408)。
【００２０】
実行プロセス(優先度 低)3cは、送達確認部32にて実行プロセス(優先度 高)3aからのサ
ービス要求成功/サービス要求失敗を受信する(S506)。受信結果を判定(S507)し一定時間
経過しても実行プロセス(優先度 高)3aからのサービス要求成功/サービス要求失敗が受信
できなかった場合には自実行プロセスのクラスタ管理部34に、受信できなかった実行プロ
セスをクラスタ同期対象から外すよう通知する(S508)。
【００２１】
このことにより、全実行プロセスがクライアントプロセスからの処理要求を受信したこ
とを同期することができ、全実行プロセスで同一サービス要求を処理させることが可能と
なる。
【００２２】
クライアントプロセス2はサービス要求送信後、送達確認部でサービス受信成功応答お
よびサービス受信失敗応答を待つ(S203)。
【００２３】
送達確認部は、サービス受信成功応答の受信に成功した場合にはサービス要求成功と判
断し、サービス受信失敗応答を受信した場合もしくは受信がタイムアウトした場合にはサ
ービス要求を再送する(S204)。
【００２４】
図７は、クライアントプロセスから実行プロセスへ送信するサービス要求電文D001の構
造を説明したものである。サービス要求電文は、電文種別D002、送信元であるクライアン
トプロセスのIPアドレスD003、送信元であるクライアントプロセスのポート番号D004、サ
ービス要求電文ID D005、サービス要求電文のリトライ回数D006、サービス要求種別D007
、サービス要求本文D008で構成される。電文種別D002は、このメッセージがサービス要求
電文であることを示す情報である。送信元のIPアドレスD003と送信元のポート番号D004は
受信側がクライアントプロセスを識別するための情報であり、また、受信側からクライア
ントプロセスへ応答を送信するための宛先情報でもある。サービス要求電文ID D005は、
クライアントプロセス側で送信するサービス要求ごとに一意になるように設定するIDであ
り、受信側で当該サービス要求電文が受信済みであるか新規電文であるかを判定し、また
、以降の同期処理において処理要求を区別するために使用する。サービス要求電文のリト
ライ回数D006は、クライアントが同一サービス要求電文のリトライを行うたびにインクリ
メントする。サービス要求種別D007は、実行プロセスがサービス要求を実行するために使
用する情報であり、サービス実行結果の応答可否などを指定する。サービス要求種別の内
容はクライアントプロセスと受信側プロセス間のインタフェースに依存する。サービス要
求本文D008は、クライアントプロセス上のユーザプログラムでユーザが設定したメッセー
ジ本文であり、実行プロセスで動作する業務処理部に渡される情報である。
【００２５】
図８は実行プロセス間及び実行プロセスからクライアントプロセスに対して送信される
サービス要求成功／失敗応答の電文構造を説明したものである。サービス受信成功／失敗
応答は、電文種別D011、送信元のIPアドレスD012、送信元のポート番号D013、サービス要
求電文ID D014、サービス要求電文のリトライ回数D015、サービス要求受信結果D016で構
成される。電文種別D011は、この電文がサービス要求電文に対する応答であることを示す
情報である。送信元のIPアドレスD012と送信元のポート番号D013は、クライアントプロセ
スまたは受信側実行プロセスで送信元のプロセスを識別するために使用する。サービス要
求電文ID D014とサービス要求電文のリトライ回数D015は、送信元がサービス要求の応答
を送信するとき、該当するサービス要求電文のサービス要求電文IDとリトライ回数を複写
する。クライアントプロセスまたは受信側実行プロセスでは、この情報から該当するサー
ビス要求電文を判定する。サービス要求受信結果D016には、サービス受信成功であるかサ
ービス受信失敗であるかの情報を設定する。
【００２６】
図９は実行プロセス内に存在する入力キューの構造を説明したものである。入力キュー
には図７で説明されたサービス要求電文D001が、そのまま順番に登録されており、FIFOに
て順番に処理される。
【００２７】
図４(a)、図４(b)は、処理結果の最速判断及び処理結果を各マシンのデータベースへ反
映する機能の処理概要を説明したものである。
【００２８】
各実行プロセス3の業務処理部35は、入力キュー4に登録されたサービス要求を取り出し
(S601)業務処理を実行する(S602)。業務処理が完了後、更新キュー6に更新情報が登録さ
れているかを確認する(S603)。更新キュー6に更新情報が格納されている場合、更新キュ
ー内の最も優先度の高い実行プロセスで業務処理を行なった結果の更新情報でデータベー
スを更新する(S607)。更新キューに更新情報が格納されていない場合、自実行プロセスで
のデータベース更新結果を更新キュー6に登録(S604)し、各実行プロセスに対して送受信
部31を介して更新情報を送信する(S605)。各実行プロセスでは業務処理部35と並行してク
ラスタ同期部33が動作しており、クラスタ同期部33が更新情報を受信する(S608)。更新情
報を更新キュー6に登録(S609)し、登録結果を判定する(S610)。更新キュー6への登録が失
敗している場合、更新キューに登録失敗した旨の応答を送信する(S616)。更新キュー6へ
の登録が成功している場合、更新キュー6に自実行プロセスの更新情報が登録されており
、業務処理部35が自情報有りによる待ち合わせ処理中(S617)ではないかを確認する(S611)
。自実行プロセスの更新情報が登録されていないか、自情報有り応答受信による待ち合わ
せ処理中の場合、自実行プロセスで業務処理を実行中であれば実行を中止させる(S612)。
自実行プロセスの業務処理部35が、自情報有り応答受信による待ち合わせ処理中の場合に
は、待ち合わせている更新情報を登録した旨を業務処理部35に通知する(S613)。更新情報
を更新キューに登録成功した旨を、更新情報を送信した実行プロセスに応答する(S614)。
業務処理の実行を中止した実行プロセスは処理を先(S603)に進め、更新キュー6に更新情
報が登録されているかを確認し、更新情報が登録されていることから更新キュー内の最も
優先度の高い実行プロセスで業務処理を行なった結果の更新情報でデータベースを更新す
る(S607)。自実行プロセスの更新情報が登録されており、自情報有りによる待ち合わせ処
理中(S617)でない場合、自情報有りを送信した実行プロセスに応答する(S615)。更新情報
を送信した実行プロセスは各実行プロセスからの応答を受信(S606)し、一定時間内にすべ
ての実行プロセスからの応答を受信したかを判定、また、更新キューに登録失敗した旨の
応答を送信した実行プロセスがあったかを判定する(S617)。一定時間内に応答が返って来
なかった実行プロセスがあった場合、または、更新キューに登録失敗した旨の応答を送信
した実行プロセスがあった場合、自実行プロセスのクラスタ管理部34に受信できなかった
実行プロセスまたは更新キューに登録失敗した実行プロセスをクラスタ同期対象から外す
よう通知する(S618)。受信した応答に自情報有りがあるかを判定(S619)し、自情報有りが
あれば、当該実行プロセスからの更新情報が更新キューに登録されるか、当該実行プロセ
スからの更新情報が更新キューに登録された旨をクラスタ同期部33から通知されるまで待
ち合わせる(S620)。更新キュー内の最も優先度の高い更新情報でデータベースを更新する
(S621)。更新キュー内の最も優先度の高い更新情報が自実行プロセスの情報だったかを判
断(S622)し、自実行プロセスの情報だった場合にはクライアントプロセスに業務結果を送
信し(S623)、自実行プロセスの情報ではなかった場合にはクライアントプロセスに業務結
果を送信しない(S624)。
【００２９】
このことにより、業務処理が最も早く終了した実行プロセスの結果、または、業務処理
がほぼ同時に終了した場合には最も優先度が高い実行プロセスの結果を各実行プロセスに
伝播・データベースへ反映することが可能となる。
【００３０】
例えば、入力キューにサービス要求を登録後、図１の計算機1cにて障害が発生した場合
、計算機1d、1eの実行プロセス3b、3cが処理を行なう。計算機1d、1eの実行プロセス3b、
3cは図４(a)、図４(b)の処理フローに従い、業務処理部35は、入力キュー4に登録された
サービス要求を取り出し(S601)業務処理を実行する(S602)。ここで、実行プロセス3bが先
に処理を終えたと仮定すると、実行プロセス3bは業務処理が完了後、更新キュー6に更新
情報が登録されているかを確認する(S603)。実行プロセス3cはまだ処理を終えていない為
、更新キューに更新情報は格納されていない。従って自実行プロセスでのデータベース更
新結果を更新キュー6に登録(S604)し、各実行プロセスに対して送受信部31を介して更新
情報を送信する(S605)。実行プロセス3cではクラスタ同期部33が更新情報を受信し(S608)
更新情報を更新キュー6に登録(S609)する。更新キュー6への登録が成功すると、更新キュ
ー6に自実行プロセスの更新情報が登録されており、業務処理部35が自情報有りによる待
ち合わせ処理中(S617)ではないかを確認する(S611)。実行プロセス3cでは自実行プロセス
の更新情報が登録されておらず、自実行プロセスで業務処理を実行中であるため実行を中
止させる(S612)。更新情報を更新キューに登録成功した旨を、更新情報を送信した実行プ
ロセスに応答する(S614)。業務処理の実行を中止した実行プロセスは処理を先(S603)に進
め、更新キュー6に更新情報が登録されているかを確認し、実行プロセス3bでの更新情報
のみが登録されていることから当該更新情報でデータベースを更新する(S607)。実行プロ
セス3bは各実行プロセスからの応答を受信(S606)し、一定時間内にすべての実行プロセス
からの応答を受信したかを判定、また、更新キューに登録失敗した旨の応答を送信した実
行プロセスがあったかを判定する(S617)。このとき実行プロセス3cからの応答はあるが、
計算機1cは障害が発生しているため実行プロセス3aからの応答は無い。自実行プロセスの
クラスタ管理部34に受信できなかった実行プロセス3aをクラスタ同期対象から外すよう通
知する(S618)。実行プロセス3cから受信した応答に自情報有りがあるかを判定(S619)する
が、自情報有りではないため更新キュー内の最も優先度の高い更新情報でデータベースを
更新する(S621)。このとき、更新キューに登録されている更新情報は自実行プロセスで実
行した結果のみである。更新キュー内の最も優先度の高い更新情報が自実行プロセスの情
報だったかを判断(S622)し、自実行プロセスの情報であるためクライアントプロセスに業
務結果を送信する(S623)。
【００３１】
図１０は実行プロセス間で送信されるデータベースの更新結果電文の構造を説明したも
のである。更新結果電文は、電文種別D021、送信元である実行プロセスのIPアドレスD022
、送信元である実行プロセスのポート番号D023、サービス要求電文ID D024、優先度D025
、更新結果D026で構成される。電文種別D021は、この電文がデータベースの更新結果電文
であることを示す情報である。送信元のIPアドレスD022と送信元のポート番号D023は、受
信側実行プロセスで送信元のプロセスを識別するために使用する。サービス要求電文ID D
024は送信元が更新結果電文を送信する際、該当するサービス要求電文のサービス要求電
文IDを複写する。受信側実行プロセスでは、この情報から該当するサービス要求電文を判
定する。優先度D025は送信元が更新結果電文を送信する際、自実行プロセスの優先度を設
定し、更新結果D026はデータベースを更新した結果そのものである。この優先度及び更新
結果を使用しデータベースを更新する。
【００３２】
図１１は、各実行プロセス更新キューの構造を説明したものである。更新キューは優先
度D031、サービス要求ID D032、更新結果D033で構成される。自実行プロセスで更新した
情報を登録する場合には、優先度 D031には自実行プロセスの優先度、サービス要求ID D0
32には処理したサービス要求電文のサービス要求ID、更新結果D033には自実行プロセスで
更新した更新情報を設定する。更新結果電文で送信された他実行プロセスで更新した情報
を登録する場合には、更新結果電文に格納されている優先度、サービス要求ID、更新結果
をそれぞれ複写する。データベース更新時には更新キューの情報から該当するサービス要
求電文と同じサービス要求IDを持つ更新情報の中から最も優先度の高いデータにて更新す
る。
【００３３】
図１２は、各実行プロセスが更新結果電文を受信した際に送信する更新キュー登録応答
電文の構造を説明したものである。更新キュー登録応答電文は、電文種別D041、送信元で
ある実行プロセスのIPアドレスD042、送信元である実行プロセスのポート番号D043、サー
ビス要求電文ID D044、自情報有無D045、結果D046で構成される。電文種別D041は、この
電文が更新キュー登録応答電文であることを示す情報である。送信元のIPアドレスD042と
送信元のポート番号D043は、受信側実行プロセスで送信元のプロセスを識別するために使
用する。サービス要求電文ID D044は、送信元がサービス要求の応答を送信するとき、該
当する更新結果電文のサービス要求電文IDを複写する。自情報有無D045は送信元が自実行
プロセスの更新結果が更新キューに存在しているかどうかを示すフラグである。受信元は
本フラグがONである場合には、送信元実行プロセスの業務処理部35から更新結果電文が送
信されるのを待ち合わせる。待ち合わせ中に受信した更新結果電文への応答時は本フラグ
はOFFとする。結果D046は正常に更新キューに登録できたかどうかを示す情報である。正
常に更新キューに登録できなかった場合には、クラスタ管理部34にてクラスタ同期対象か
ら外される。
【００３４】
図５はクラスタ管理部34が行なうクラスタ管理の処理概要について説明したものである
。
【００３５】
クラスタ管理部34は、自実行プロセスまたは他実行プロセスよりクラスタ同期対象外通
知電文を受ける(S701)と、クラスタ管理部34で管理しているクラスタ情報からクラスタ同
期対象外通知電文内に格納されているノードIDを検索し、受け取った通知と同一のノード
IDが既にクラスタ同期対象外かを判定する(S702)。クラスタ同期対象であれば通知された
ノードIDのクラスタ管理情報をクラスタ同期対象外に設定する(S703)。クラスタ同期対象
の実行プロセスがあるかを判断(S704)し、クラスタ同期対象の実行プロセスがない場合に
はシステム管理者に通知する(S709)。自実行プロセスの優先度が高でない場合、自実行プ
ロセスの優先度を１段階上げる(S705)。通知元が自実行プロセスによる通知（図3(a) S30
5、図3(c) S408、図3(d) S508、図4(b) S615で行なわれる通知）かを判定し(S706)、自実
行プロセスからの通知であった場合、他実行プロセスのクラスタ管理部に対してS703にて
クラスタ同期対象外に設定したノードIDをクラスタ同期対象から外す旨通知する(S707)。
他実行プロセスからの通知（S707で行なわれる通知）であった場合、通知元実行プロセス
の優先度を１段階上げる(S708)。
【００３６】
図１３は、クラスタ管理部34で管理しているクラスタ情報の構造について説明したもの
である。クラスタ情報は、自ノードID D061、自IPアドレスD062、自ポート番号D063、自
優先度D064、他ノードID D065、他IPアドレスD066、他ポート番号D067、他優先度D068で
構成される。これらの値は実行プロセス起動時に定義にて与えられ、それを保持している
。自ノードID D061は全実行プロセス内で一意に付けられた自実行プロセスのIDである。
本IDを使用し各実行プロセスを管理する。自IPアドレスD062、自ポート番号D063は各種通
信で使用する為の自実行プロセスの情報を保持している。自優先度D064は自実行プロセス
の優先度を保持する。他ノードID D065は全実行プロセス内で一意に付けられた他実行プ
ロセスのIDである。他IPアドレスD066、他ポート番号D067は他実行プロセスのIPアドレス
及びポート番号であり、各種通信にて使用される。他優先度D068は他実行プロセスの優先
度を保持する。自優先度及び他優先度は、クラスタ同期対象外通知によりクラスタ同期対
象から外す実行プロセスが発生した場合には、その都度変化する。他IPアドレス、他ポー
ト番号、他優先度は構成される実行プロセスの数だけ存在する。
【００３７】
図１４は、各実行プロセスから送信されるクラスタ同期対象外通知電文の構造について
説明したものである。クラスタ同期対象外電文は、電文種別D061、送信元である実行プロ
セスのIPアドレスD062、送信元であるクライアントプロセスのポート番号D063、自ノード
ID D064、対象外ノードID D065で構成される。電文種別D061は、この電文がクラスタ同期
対象外通知電文であることを示す情報である。送信元のIPアドレスD062と送信元のポート
番号D063は、受信側実行プロセスで送信元のプロセスを識別するために使用する。自ノー
ドID D064には送信元にて送信元実行プロセスに付与されているノードIDが設定される。
対象外ノードID D065はクラスタ同期対象外とする実行プロセスに付与されているノードI
Dが設定される。本電文を受信すると対象外ノードIDに指定されたノードIDを持つ実行プ
ロセスが同期対象から外される。
【００３８】
図６は切り離し済みの実行プロセスから各種電文を受信した場合の動作を説明したもの
である。切り離し済みの実行プロセスが各種電文を送信する(S620)。受信した実行プロセ
スの送受信部31では各種電文を受信する(S621)と、切り離し済みではないかを判定する(S
622)。送信元実行プロセスが切り離し済みであった場合、切り離し済み電文を送信し送信
元に通知する(S623)。送信元は切り離し済み電文を受信する(S624)と、一切の処理を停止
する(S625)。
【００３９】
図１５は、実行プロセス間で送信される切り離し済み電文の構造を説明したものである
。切り離し済み電文、電文種別D071、送信元である実行プロセスのIPアドレスD072、送信
元である実行プロセスのポート番号D073、で構成される。電文種別D071は、この電文が切
り離し済み電文であることを示す情報である。送信元のIPアドレスD072と送信元のポート
番号D073は、受信側実行プロセスで送信元のプロセスを識別するために使用する。本電文
を受信した実行プロセスは一切の処理を停止する。
【図面の簡単な説明】
【００４０】
【図１】システム構成図。
【図２】プロセスの機能構成図。
【図３（ａ）】サービス要求送信及び処理同期のフロー。
【図３（ｂ）】サービス要求送信及び処理同期のフロー。
【図３（ｃ）】サービス要求送信及び処理同期のフロー。
【図３（ｄ）】サービス要求送信及び処理同期のフロー。
【図４（ａ）】データベースへ更新結果を反映する処理のフロー。
【図４（ｂ）】データベースへ更新結果を反映する処理のフロー。
【図５】切り離し済み実行プロセスからの電文受信処理フロー。
【図６】クラスタ管理処理フロー。
【図７】サービス要求電文。
【図８】サービス要求成功／失敗応答電文。
【図９】入力キュー。
【図１０】データベースの更新結果電文。
【図１１】更新キュー。
【図１２】更新キュー登録応答電文。
【図１３】クラスタ情報。
【図１４】クラスタ同期対象外通知電文。
【図１５】切り離し済み電文。
【符号の説明】
【００４１】
１ａ…計算機、１ｂ…計算機、１ｃ…計算機、１ｄ…計算機、１ｅ…計算機、２ａ…ク
ライアントプロセス、２ｂ…クライアントプロセス、３ａ…実行プロセス、３ｂ…実行プ
ロセス、３ｃ…実行プロセス、４ａ…入力キュー、４ｂ…入力キュー、４ｃ…入力キュー
、５ａ…データベース、５ｂ…データベース、５ｃ…データベース、６ａ…更新キュー、
６ｂ…更新キュー、６ｃ…更新キュー、７ａ…クラスタ情報、７ｂ…クラスタ情報、７ｃ
…クラスタ情報、２１…送受信部、２２…送達確認部、２３…送信先管理部、３１…送受
信部、３２…送達確認部、３３…クラスタ同期部、３４…クラスタ管理部、３５…業務部
。
【図１】
2009271733.tif 000003
【図２】
2009271733.tif 000004
【図３（ａ）】
2009271733.tif 000005
【図３（ｂ）】
2009271733.tif 000006
【図３（ｃ）】
2009271733.tif 000007
【図３（ｄ）】
2009271733.tif 000008
【図４（ａ）】
2009271733.tif 000009
【図４（ｂ）】
2009271733.tif 000010
【図５】
2009271733.tif 000011
【図６】
2009271733.tif 000012
【図７】
2009271733.tif 000013
【図８】
2009271733.tif 000014
【図９】
2009271733.tif 000015
【図１０】
2009271733.tif 000016
【図１１】
2009271733.tif 000017
【図１２】
2009271733.tif 000018
【図１３】
2009271733.tif 000019
【図１４】
2009271733.tif 000020
【図１５】
2009271733.tif 000021