(57)【要約】【課題】システムの開発時の負担を低減できるとともに、システム変更に対する柔軟性を備えた分散処理システムおよび分散処理方法を提供する。【解決手段】受付手段１１は、クライアント３，３，・・・からの情報処理の要求を受け付けて登録する。要求状況取得手段１２は、受付手段１１で受け付けた要求の受付状況を取得する。処理状況取得手段１３は、処理部２０，２０，・・・における処理状況を取得する。選択手段１５は、要求状況取得手段１２により取得された受付状況、および処理状況取得手段１３により取得された処理状況に基づいて、受付手段１１で要求を受け付けた個々の情報処理を実行する処理部２０を選択する。【選択図】図１
2007257280.tif 000002
【特許請求の範囲】
【請求項１】
情報処理を複数の処理先に振り分けて実行させる分散処理システムにおいて、
情報処理の要求を受け付ける受付手段と、
前記受付手段で受け付けた要求の受付状況を取得する要求状況取得手段と、
前記処理先における処理状況を取得する処理状況取得手段と、
前記要求状況取得手段により取得された前記受付状況、および前記処理状況取得手段により取得された前記処理状況に基づいて、前記受付手段で要求を受け付けた個々の情報処理の処理先を選択する選択手段と、
を備えることを特徴とする分散処理システム。
【請求項２】
前記処理先の能力を取得する能力取得手段を備え、
前記選択手段は前記能力取得手段により取得された能力に基づいて処理先を選択することを特徴とする請求項１に記載の分散処理システム。
【請求項３】
前記受付手段により受け付けた要求に対応する送信先を取得する送信先取得手段と、
前記送信先取得手段により取得された送信先に対し、前記処理先での処理結果を送信する送信手段と、
を備えることを特徴とする請求項１または２に記載の分散処理システム。
【請求項４】
情報処理を複数の処理先に振り分けて実行させる分散処理方法において、
情報処理の要求を受け付けるステップと、
前記要求を受け付けるステップで受け付けた要求の受付状況を取得するステップと、
前記処理先における処理状況を取得するステップと、
取得された前記受付状況、および取得された前記処理状況に基づいて、前記要求を受け付けるステップで要求を受け付けた個々の情報処理の処理先を選択するステップと、
を備えることを特徴とする分散処理方法。
【請求項５】
前記処理先の能力を取得するステップを備え、
前記選択するステップでは前記能力を取得するステップにより取得された能力に基づいて処理先を選択することを特徴とする請求項４に記載の分散処理方法。
【請求項６】
前記受付手段により受け付けた要求に対応する送信先を取得するステップと、
前記送信先を取得するステップにより取得された送信先に対し、前記処理先での処理結果を送信するステップと、
を備えることを特徴とする請求項４または５に記載の分散処理方法。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、情報処理を複数の処理先に振り分けて実行させる分散処理システムおよび分散処理方法に関する。
【背景技術】
【０００２】
検査対象や診断対象からデータを収集し、収集したデータに基づき、所定のアルゴリズムに従った検査や診断を実行するシステムが知られている。例えば、プラントに設置されたプラント設備の診断システムでは、プラント設備からデータを収集し、収集したデータに基づく情報処理を実行して診断を行い、診断結果を所定の送信先に送信することで、プラントで発生した異常等を検知、通知することが可能となる。
【発明の開示】
【発明が解決しようとする課題】
【０００３】
しかし、従来のシステムでは、クライアントからの要求の受け付け、データの収集、収集したデータに基づく情報処理、および処理結果の送信を含めた処理を連続的な一連の処理として実行しているため、システムの拡張性に欠け、処理負担の増大への対応等が困難であるという問題がある。
【０００４】
例えば、システム全体での処理能力を増強させるため、複数のコンピュータを用いた分散処理システムを導入することも考えられる。しかし、従来のシステムでは、情報処理や処理結果の送信を行うコンピュータ自身が、クライアントとの間でのやり取りを直接担当しているため、システム変更時には、システム側にも、クライアント側にも新たなエンジニアリング作業が必要となる。
【０００５】
【特許文献１】特開２００４−２８０８００号公報
【特許文献２】特開２００５−０７８１３０号公報
【０００６】
本発明の目的は、システムの開発時の負担を低減できるとともに、システム変更に対する柔軟性を備えた分散処理システムおよび分散処理方法を提供することにある。
【課題を解決するための手段】
【０００７】
本発明の分散処理システムは、情報処理を複数の処理先に振り分けて実行させる分散処理システムにおいて、情報処理の要求を受け付ける受付手段と、前記受付手段で受け付けた要求の受付状況を取得する要求状況取得手段と、前記処理先における処理状況を取得する処理状況取得手段と、前記要求状況取得手段により取得された前記受付状況、および前記処理状況取得手段により取得された前記処理状況に基づいて、前記受付手段で要求を受け付けた個々の情報処理の処理先を選択する選択手段と、を備えることを特徴とする。
この分散処理システムによれば、受付手段により情報処理の要求を受け付け、受付手段で要求を受け付けた個々の情報処理を処理先において処理するので、システムの開発時の負担を低減できるとともに、システム変更に対し柔軟に対応できる。
【０００８】
前記処理先の能力を取得する能力取得手段を備え、前記選択手段は前記能力取得手段により取得された能力に基づいて処理先を選択してもよい。
【０００９】
前記受付手段により受け付けた要求に対応する送信先を取得する送信先取得手段と、前記送信先取得手段により取得された送信先に対し、前記処理先での処理結果を送信する送信手段と、を備えてもよい。
【００１０】
本発明の分散処理方法は、情報処理を複数の処理先に振り分けて実行させる分散処理方法において、情報処理の要求を受け付けるステップと、前記要求を受け付けるステップで受け付けた要求の受付状況を取得するステップと、前記処理先における処理状況を取得するステップと、取得された前記受付状況、および取得された前記処理状況に基づいて、前記要求を受け付けるステップで要求を受け付けた個々の情報処理の処理先を選択するステップと、を備えることを特徴とする。
この分散処理方法によれば、受け付けるステップにより情報処理の要求を受け付け、要求を受け付けた個々の情報処理を処理先において処理するので、システムの開発時の負担を低減できるとともに、システム変更に対し柔軟に対応できる。
【００１１】
前記処理先の能力を取得するステップを備え、前記選択するステップでは前記能力を取得するステップにより取得された能力に基づいて処理先を選択してもよい。
【００１２】
前記受付手段により受け付けた要求に対応する送信先を取得するステップと、前記送信先を取得するステップにより取得された送信先に対し、前記処理先での処理結果を送信するステップと、を備えてもよい。
【発明の効果】
【００１３】
本発明の分散処理システムによれば、受付手段により情報処理の要求を受け付け、受付手段で要求を受け付けた個々の情報処理を処理先において処理するので、システムの開発時の負担を低減できるとともに、システム変更に対し柔軟に対応できる。
【００１４】
本発明の分散処理方法によれば、受け付けるステップにより情報処理の要求を受け付け、要求を受け付けた個々の情報処理を処理先において処理するので、システムの開発時の負担を低減できるとともに、システム変更に対し柔軟に対応できる。
【発明を実施するための最良の形態】
【００１５】
次に、本発明による分散処理システムの実施形態について説明する。
【実施例１】
【００１６】
以下、図１および図２を参照して、本発明による分散処理システムの実施例１について説明する。本実施例は、検査対象に対する検査のための情報処理を分散処理する例を示している。
【００１７】
図１は本実施例の分散処理システムの構成を示すブロック図である。
【００１８】
図１に示すように、本実施例の分散処理システムは、情報処理の手順を管理する管理部１０と、情報処理を分散して実行する処理部２０，２０，・・・とを具備する分散処理装置１を含んで構成される。処理部２０，２０，・・・は、それぞれ非同期で動作する別々のコンピュータを用いて構成される。
【００１９】
管理部１０は、クライアント３，３，・・・からの情報処理の要求を受け付けて登録する受付手段１１と、受付手段１１で受け付けた要求の受付状況を取得する要求状況取得手段１２と、処理部２０，２０，・・・における処理状況を取得する処理状況取得手段１３と、処理部２０各々の能力を取得する能力取得手段１４と、要求状況取得手段１２により取得された受付状況、処理状況取得手段１３により取得された処理状況および能力取得手段１４により取得された能力に基づいて、受付手段１１で要求を受け付けた個々の情報処理を実行する処理部２０を選択する選択手段１５と、受付手段１１により受け付けた要求に対応する送信先を取得する送信先取得手段１６と、送信先取得手段１６により取得されたクライアント送信先に対し、処理部２０での処理結果を送信する送信手段１７と、を備える。
【００２０】
図１において、クライアント３は、分散処理装置１に対し、検査対象４、検査内容およびクライアント送信先５を指定して検査を要求する。クライアント送信先５は、各クライアント３によって指定される検査結果の送信先である。
【００２１】
図２は分散処理装置１の動作手順を示すフローチャートである。
【００２２】
図２のステップＳ１〜ステップＳ６は、クライアント３からの情報処理の要求を受け付け、その情報処理の処理先となる処理部２０を選択する処理手順を示している。この手順は、管理部１０の制御に基づいて実行される。
【００２３】
図２のステップＳ１では、受付手段１１は、クライアント３からの要求が新たに登録されたか否か判断し、判断が肯定されるのを待ってステップＳ２へ進む。クライアント３からの要求には、検査対象を指定する情報、検査内容、および検査結果の送信先であるクライアント送信先５のアドレスを含んでいる。上記のように、受付手段１１は、要求を受け付けた場合、その要求を登録している。
【００２４】
ステップＳ２では、選択手段１５は、要求状況取得手段１２を介して受付手段１１の登録内容にアクセスし、要求の受付状況を取得する。受付状況には、今回新たに受け付けた要求の内容や選択部２０に未転送の要求についての情報が含まれる。
【００２５】
次に、ステップＳ３では、選択手段１５は、処理状況取得手段１３を介して各処理部２０の処理状況を取得する。処理状況には、各処理部２０に割り当てられた処理の負荷の程度や、各処理部２０における次の処理の受け入れ可能時刻等が含まれる。なお、要求状況取得手段１３は、定期的に処理部２０，２０，・・・から通知される各処理部２０の処理状況を取得、更新している。
【００２６】
次に、ステップＳ４では、選択手段１５は、能力取得手段１４を介して、各処理部２０の能力を取得する。能力には要求された処理を実行することが可能か否か、当該処理についての処理速度等の情報が含まれる。なお、能力取得手段１４は、適時、処理部２０，２０，・・・から通知される各処理部２０の能力を取得、更新している。
【００２７】
次に、ステップＳ５では、選択手段１５は、ステップＳ２〜ステップＳ４で取得された、要求の受付状況、各処理部２０の処理状況、および各処理部２０の能力に基づいて、今回受け付けた要求の処理を割り当てる処理部２０を選択する。ここでは、選択手段１５は、例えば、当該処理を実行できる能力があり、かつ現在最も負荷が軽い処理部２０を選択する。
【００２８】
次に、ステップＳ６では、選択手段１５は、ステップＳ５で選択された処理部２０に、今回受け付けた要求を転送し、ステップＳ１へ戻る。
【００２９】
要求を受け取った処理部２０は、要求で指定された検査対象４にアクセスして、検査に必要なデータを収集する。また、処理部２０は、収集されたデータを用いて、要求された検査内容に対応する所定のアルゴリズムに従った情報処理を実行する。情報処理により作成された検査結果は、要求に含まれていた検査結果の送信先アドレスとともに、管理部１０に向けて転送される。
【００３０】
図２のステップＳ１１〜ステップＳ１３は、処理部２０における情報処理により作成された検査結果をクライアント送信先５に送信する処理手順を示している。この手順は、管理部１０の制御に基づいて実行される。
【００３１】
図２のステップＳ１１では、処理部２０から転送されてきた検査結果が受信されたか否か判断し、判断が肯定されるのを待ってステップＳ１２へ進む。ステップＳ１２では、送信先取得手段１６は、要求に含まれていた検査結果の送信先アドレスを取得する。
【００３２】
次に、ステップＳ１３では、送信手段１７は、ステップＳ１２で取得された送信先アドレスに向けて検査結果を送信し、ステップＳ１１へ戻る。これにより、検査結果が、クライアント３によって指定された当該クライアント送信先５に向けて送信されることになる。
【００３３】
このように本実施例の分散処理システムによれば、受け付けた情報処理を複数の処理部２０に適宜、割り当てて分散処理するので、情報処理を効率的かつ迅速に処理できる。
【００３４】
また、クライアント３と処理部２０との間に管理部１０が介在するため、クライアント３は処理部２０の状況等を意識することなく、管理部１０への要求を行うだけで、必要な検査を実施できる。
【００３５】
また、クライアント数、検査対象数、依頼件数の増加に応じて、処理部２０の数あるいは能力を増加させることが可能となるので、状況の変化に柔軟に対応できる。また、処理部２０を増設したような場合でも、管理部１０によってシステム構成の変更を吸収できるため、クライアント３への影響を排除できる。
【００３６】
また、すべての検査に対してリソースとしての処理部２０，２０，・・・を共有化できるため、システム内の資源を効率的に利用できる。
【実施例２】
【００３７】
以下、図３および図４を参照して、本発明による分散処理システムの実施例２について説明する。本実施例は、フィールド機器やフィールド機器が接続される入出力モジュール等のプラント設備に対する診断のための情報処理を分散処理装置１により分散処理する例を示している。
【００３８】
図３は本実施例の分散処理システムの構成を示すブロック図である。
【００３９】
図３において、診断管理クライアント３Ａは、分散処理装置１に対し、診断対象であるプラント設備４Ａおよび診断内容を指定して、順次、診断を要求する。診断結果は診断管理クライアント３Ａに返される。
【００４０】
図４は分散処理装置１の動作手順を示すフローチャートである。
【００４１】
図４のステップＳ３１〜ステップＳ３６は、診断管理クライアントからの情報処理の要求を受け付け、その情報処理の処理先となる処理部２０を選択する処理手順を示している。この手順は、管理部１０の制御に基づいて実行される。
【００４２】
図４のステップＳ３１では、受付手段１１は、診断管理クライアント３Ａからの要求が新たに登録されたか否か判断し、判断が肯定されるのを待ってステップＳ２２へ進む。診断管理クライアント３Ａからの要求には、診断対象であるプラント設備４を指定する情報、診断内容、および診断結果の送信先である診断管理クライアント３Ａのアドレスを含んでいる。上記のように、受付手段３１は、要求を受け付けた場合、その要求を登録している。
【００４３】
ステップＳ３２では、選択手段１５は、要求状況取得手段１２を介して受付手段１１の登録内容にアクセスし、要求の受付状況を取得する。受付状況には、今回新たに受け付けた要求の内容や選択部２０に未転送の要求についての情報が含まれる。
【００４４】
次に、ステップＳ３３では、選択手段１５は、処理状況取得手段１３を介して各処理部２０の処理状況を取得する。処理状況には、各処理部２０に割り当てられた処理の負荷の程度や、各処理部２０における次の処理の受け入れ可能時刻等が含まれる。なお、要求状況取得手段１３は、定期的に処理部２０，２０，・・・から通知される各処理部２０の処理状況を取得、更新している。
【００４５】
次に、ステップＳ３４では、選択手段１５は、能力取得手段１４を介して、各処理部２０の能力を取得する。能力には要求された処理を実行することが可能か否か、当該処理についての処理速度等の情報が含まれる。なお、能力取得手段１４は、適時、処理部２０，２０，・・・から通知される各処理部２０の能力を取得、更新している。
【００４６】
次に、ステップＳ３５では、選択手段１５は、ステップＳ２〜ステップＳ４で取得された、要求の受付状況、各処理部２０の処理状況、および各処理部２０の能力に基づいて、今回受け付けた要求の処理を割り当てる処理部２０を選択する。ここでは、選択手段１５は、例えば、当該処理を実行できる能力があり、かつ現在最も負荷が軽い処理部２０を選択する。
【００４７】
次に、ステップＳ３６では、選択手段１５は、ステップＳ５で選択された処理部２０に、今回受け付けた要求を転送し、ステップＳ３１へ戻る。
【００４８】
要求を受け取った処理部２０は、要求で指定されたプラント設備５にアクセスして、診断に必要なデータを収集する。また、処理部２０は、収集されたデータを用いて、要求された診断内容に対応する所定のアルゴリズムに従った情報処理を実行する。情報処理により作成された診断結果は、要求に含まれていた検査結果の送信先アドレスとともに、管理部１０に向けて転送される。
【００４９】
図４のステップＳ４１〜ステップＳ４３は、処理部２０における情報処理により作成された診断結果を診断管理クライアント３Ａに送信する処理手順を示している。この手順は、管理部１０の制御に基づいて実行される。
【００５０】
図４のステップＳ４１では、処理部２０から転送されてきた診断結果が受信されたか否か判断し、判断が肯定されるのを待ってステップＳ１２へ進む。ステップＳ１２では、送信先取得手段１６は、要求に含まれていた診断結果の送信先アドレスを取得する。
【００５１】
次に、ステップＳ４３では、送信手段１７は、ステップＳ１２で取得された送信先アドレスに向けて診断結果を送信し、ステップＳ４１へ戻る。これにより、診断結果が、診断管理クライアント３Ａに向けて送信されることになる。
【００５２】
このように、本実施例の分散管理システムでは、プラントに設置された各種のプラント設備をリアルタイムに監視・診断し、異常等が検出された場合には、その検出結果を診断結果として診断管理クライアント３Ａに通知している。本実施例の分散処理システムによれば、受け付けた情報処理を複数の処理部２０に適宜、割り当てて分散処理するので、異常等の発生を迅速に通知することができる。
【００５３】
また、プラント設備の増設や診断項目の増加に応じて、処理部２０の数あるいは能力を増加させることが可能となるので、プラントの状況変化に柔軟に対応できる。また、処理部２０を増設したような場合でも、管理部１０によってシステム構成の変更を吸収できるため、診断管理クライアント３Ａを含むプラント管理システムへの影響を排除できる。
【００５４】
なお、上記各実施例において、管理部１０および処理部２０，２０，・・・を互いに離して設置し、インターネット等の公共回線あるいは専用回線で互いに接続してもよい。
【００５５】
また、クライアントから要求された処理を管理部１０において分割し、分割した処理を複数の処理部２０に割り当てるようにしてもよい。
【００５６】
以上説明したように、本発明による分散管理システムによれば、クライアントからの要求を受け付ける窓口を一元化するとともに、情報処理を実行する処理部２０をクライアントから切り離して機能させているので、システム構築作業の効率化を図ることができるとともに、システム規模の変化に対する柔軟性を確保することができる。
【００５７】
本発明の適用範囲は上記実施形態に限定されることはない。本発明は、情報処理を複数の処理先に振り分けて実行させる分散処理システムおよび分散処理システムに対し、広く適用することができる。
【図面の簡単な説明】
【００５８】
【図１】実施例１の分散処理システムの構成を示すブロック図。
【図２】分散処理装置の動作手順を示すフローチャート。
【図３】実施例２の分散処理システムの構成を示すブロック図。
【図４】分散処理装置の動作手順を示すフローチャート。
【符号の説明】
【００５９】
１１    受付手段
１２    要求状況取得手段
１３    処理状況取得手段
１４    能力取得手段
１５    選択手段
１６    送信先取得手段
１７    送信手段
２０    処理部（処理先）
【図１】
2007257280.tif 000003
【図２】
2007257280.tif 000004
【図３】
2007257280.tif 000005
【図４】
2007257280.tif 000006