サービス連携装置、サービス連携方法およびサービス連携プログラム
【課題】負荷状況に応じてリソース環境を的確に変更する。
【解決手段】メッセージ受信部１１と、送信先への経路決定部３１と、メッセージ送信部４１と、受信メッセージの流入データ量計測部１２と、送信メッセージの流出データ量計測部４２と、流入データ量および流出データ量に基づいて流入超過状態になるか否かを判定する第１判定部２１と、流入超過状態になる場合に一時記憶部５３を経由する経路に変更する経路変更部３２と、リソースの増強指令発行部２２と、一時記憶部のメッセージの宛先に増強リソースを追加する経路追加部３３と、流入データ量および流出データ量に基づいて流入超過状態が解消するか否かを判定する第２判定部２３と、流入超過状態が解消する場合に当初の経路に戻す経路再変更部３４と、リソースの解放指令発行部２４とを備える。
【解決手段】メッセージ受信部１１と、送信先への経路決定部３１と、メッセージ送信部４１と、受信メッセージの流入データ量計測部１２と、送信メッセージの流出データ量計測部４２と、流入データ量および流出データ量に基づいて流入超過状態になるか否かを判定する第１判定部２１と、流入超過状態になる場合に一時記憶部５３を経由する経路に変更する経路変更部３２と、リソースの増強指令発行部２２と、一時記憶部のメッセージの宛先に増強リソースを追加する経路追加部３３と、流入データ量および流出データ量に基づいて流入超過状態が解消するか否かを判定する第２判定部２３と、流入超過状態が解消する場合に当初の経路に戻す経路再変更部３４と、リソースの解放指令発行部２４とを備える。
【発明の詳細な説明】
【技術分野】
【０００１】
本発明は、サービス連携装置、サービス連携方法およびサービス連携プログラムに関する。
【背景技術】
【０００２】
ＳＯＡ(Service Oriented Architecture：サービス指向アーキテクチャ)のシステムを構築する際に、ＥＳＢ(Enterprise Service Bus)でシステム間を連携する構成が一般に採用されている。
【０００３】
特許文献１には複数のサブシステムをＥＳＢで連携するシステムが記載されている。このようなシステムでは、一部のサブシステムに障害が発生して停止してしまうと、稼働中の他のサブシステムから送られてくる処理要求が滞留することになる。この滞留した処理要求は、障害が復旧した後に、定常的に発生する通常の処理要求に加えて処理することになる。この場合、滞留分は、通常の処理能力の余力の範囲で処理することになるため、滞留分を解消するには多大な時間を要してしまう。
【０００４】
この滞留問題の対策として、滞留することを想定して予めリソースを余分に拡張しておくことや、滞留が始まってから不足分のリソースを増強することが考えられる。特許文献２および３に記載のシステムは、複数のサーバを用意することで予めリソースを余分に拡張している。
【０００５】
特許文献２には、クライアントからリクエストを受信した場合に、複数用意したサーバのうち、レスポンス待ち状態のリクエスト数が閾値未満であるいずれかのサーバに対してリクエストを転送する負荷分散制御システムが記載されている。特許文献３には、データ送信装置から処理対象データを受信した場合に、複数用意したサーバの稼働状態とネットワークの状態とに基づいて処理対象データの転送先となるサーバを決定するデータ転送システムが記載されている。
【０００６】
特許文献２および３に記載のシステムでは、障害に備えて、常時、大量のリソースを余分に確保することとなるため、コストがかさんでしまう。他方、上記滞留開始後にリソースを増強する対応策では、リソースの増強が完了するまで不安定な状態でシステムを稼働することになってしまう。
【０００７】
上記コスト高や不安定稼働の問題の対策として、特許文献４には、クラウド環境下のデータセンターのリソースを利用し、サービス負荷の予測状況に基づいてシステム構成を変更する構成管理システムが記載されている。
【先行技術文献】
【特許文献】
【０００８】
【特許文献１】特開２０１０−９２１８号公報
【特許文献２】特開２００８−４０７１８号公報
【特許文献３】特開２０１０−３１２１号公報
【特許文献４】特開２０１１−１１３２６７号公報
【発明の概要】
【発明が解決しようとする課題】
【０００９】
特許文献４に記載のシステムでは、運用者が、負荷の予測状況に基づいて、適切なシステム構成のスナップショットを検索・選定しなければならない。したがって、例えば運用経験が浅いと、システム構成の検索・選定に手間を要するとともに、不適切なシステム構成を選定してしまうおそれがある。
【００１０】
本発明は、上述した課題を解決するためになされたものであり、負荷状況に応じてリソース環境を的確に変更することができるサービス連携装置、サービス連携方法およびサービス連携プログラムを提供することを目的の一つとする。
【課題を解決するための手段】
【００１１】
本発明の一態様であるサービス連携装置は、連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置であって、前記メッセージを受信するメッセージ受信部と、前記連携先サーバにメッセージを送信する際の経路を決定する経路決定部と、前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信部と、前記メッセージ受信部が受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測部と、前記メッセージ送信部が送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測部と、前記メッセージ受信部が受信した前記メッセージごとに、前記メッセージ受信部が前記メッセージの受信を開始した開始時刻、前記メッセージ送信部が前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶部と、前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定部と、前記第１判定部が流入超過状態になると判定した場合に、前記経路決定部が決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更部と、リソースの増強指令を外部に発行する増強指令発行部と、前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加部と、前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定部と、前記第２判定部が流入超過状態が解消すると判定した場合に、前記経路追加部が追加した前記メッセージの宛先を削除し、前記経路変更部が変更した前記経路を変更前の前記経路に戻す経路再変更部と、リソースの解放指令を外部に発行する解放指令発行部と、を備える。
【００１２】
本発明の一態様であるサービス連携方法は、連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置が、前記メッセージを受信するメッセージ受信ステップと、前記連携先サーバにメッセージを送信する際の経路を決定する経路決定ステップと、前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信ステップと、前記メッセージ受信ステップにおいて受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測ステップと、前記メッセージ送信ステップにおいて送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測ステップと、前記メッセージ受信ステップにおいて受信した前記メッセージごとに、前記メッセージ受信において前記メッセージの受信を開始した開始時刻、前記メッセージ送信において前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶ステップと、前記データ量記憶ステップが記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定ステップと、前記第１判定ステップにおいて流入超過状態になると判定した場合に、前記経路決定において決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更ステップと、リソースの増強指令を外部に発行する増強指令発行ステップと、前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加ステップと、前記データ量記憶部において記憶した前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定ステップと、前記第２判定ステップにおいて流入超過状態が解消すると判定した場合に、前記経路追加部において追加した前記メッセージの宛先を削除し、前記経路変更部において変更した前記経路を変更前の前記経路に戻す経路再変更ステップと、リソースの解放指令を外部に発行する解放指令発行ステップと、を含む。
【００１３】
本発明の一態様であるサービス連携プログラムは、上記サービス連携方法に含まれる各ステップをコンピュータに実行させる。
【発明の効果】
【００１４】
本発明によれば、負荷状況に応じてリソース環境を的確に変更することができる。
【図面の簡単な説明】
【００１５】
【図１】サービス連携システムのシステム構成を例示する図である。
【図２】第１実施形態におけるサービス連携装置の機能構成を例示する図である。
【図３】第１実施形態におけるデータ量記憶部のデータ構成を例示する図である。
【図４】経路情報記憶部のデータ構成を例示する図である。
【図５】経路情報記憶部に格納される経路情報の一例を示す図である。
【図６】経路情報記憶部に格納される経路情報の一例を示す図である。
【図７】第１実施形態におけるサービス連携装置がデータを格納する際の動作を説明するためのフローチャートである。
【図８】第１実施形態におけるサービス連携装置がリソースを増強する際の動作を説明するためのフローチャートである。
【図９】第１実施形態におけるサービス連携装置がリソースを解放する際の動作を説明するためのフローチャートである。
【図１０】変形例におけるデータ量記憶部のデータ構成を例示する図である。
【図１１】変形例におけるサービス連携装置がリソースを増強する際の動作を説明するためのフローチャートである。
【図１２】変形例におけるサービス連携装置がリソースを解放する際の動作を説明するためのフローチャートである。
【図１３】第２実施形態におけるサービス連携装置の機能構成を例示する図である。
【図１４】第２実施形態におけるデータ量記憶部のデータ構成を例示する図である。
【図１５】第２実施形態におけるサービス連携装置がリソースを増強する際の初期運用段階の動作を説明するためのフローチャートである。
【図１６】第２実施形態におけるサービス連携装置がリソースを増強する際の通常運用段階の動作を説明するためのフローチャートである。
【図１７】第２実施形態におけるサービス連携装置がリソースを解放する際の動作を説明するためのフローチャートである。
【発明を実施するための形態】
【００１６】
以下、添付図面を参照して、本発明に係るサービス連携装置、サービス連携方法およびサービス連携プログラムの好適な実施形態について説明する。
【００１７】
[第１実施形態]
まず、第１実施形態におけるサービス連携装置を含むサービス連携システムの構成について説明する。図１は、サービス連携システムのシステム構成を例示する図である。サービス連携システム１００は、サービス連携装置１と、連携元サーバ２と、連携先サーバ３とを備える。サービス連携装置１と、連携元サーバ２および連携先サーバ３とは、それぞれネットワーク４、５を介して接続する。サービス連携装置１は、連携元サーバから受信したメッセージを連携先サーバに送信する。サービス連携装置１は、受信したメッセージを、そのまま連携先サーバに転送してもよいし、データを加工してから連携先サーバに送信してもよい。
【００１８】
サービス連携装置１は、物理的には、例えば、ＣＰＵ（Central Processing Unit）と、記憶装置と、入出力インターフェースとを含む。記憶装置は、例えば、ＣＰＵで処理されるプログラムおよびデータを記憶するＲＯＭ（Read Only Memory）やＨＤＤ（Hard Disk Drive）、主として制御処理のための各種作業領域として使用するＲＡＭ（Random Access Memory）等を含む。これらの要素は、互いにバスを介して接続する。ＣＰＵが、ＲＯＭに記憶されたプログラムを実行し、入出力インターフェースを介して受信されるメッセージや、ＲＡＭに展開されるデータ等を処理することで、サービス連携装置１における以下の各機能を実現する。
【００１９】
図２を参照して、サービス連携装置１の機能構成について説明する。サービス連携装置１は、機能的には、例えば、入力部１０と、制御部２０と、ルーティング部３０と、出力部４０と、記憶部５０とを有する。記憶部５０は、各部が参照・更新するデータを記憶する。記憶部５０は、例えば、データ量記憶部５１と、経路情報記憶部５２と、一時記憶部５３とを含む。一時記憶部５３は、メッセージを一時的に格納する記憶部である。
【００２０】
図３を参照して、データ量記憶部５１のデータ構成について説明する。データ量記憶部５１は、データ項目として、例えば、流入開始時刻項目、流出終了時刻項目、流入データ量項目および流出データ量項目を有する。流入開始時刻項目は、連携元サーバ２からメッセージの受信を開始した時刻を格納する。流出終了時刻項目は、連携先サーバ３へのメッセージの送信を終了した時刻を格納する。流入データ量項目は、連携元サーバ２から受信したメッセージのデータ量を格納する。流出データ量項目は、連携先サーバ３に送信したメッセージのデータ容量を格納する。
【００２１】
図４を参照して、経路情報記憶部５２のデータ構成について説明する。経路情報記憶部５２は、データ項目として、例えば、連携元項目および連携先量項目を有する。連携元項目は、経路の開始要素を特定する情報を格納する。連携先項目は、経路の終了要素を特定する情報を格納する。図４に示す経路情報は、連携元サーバ２から連携先サーバ３への経路であることを示す。
【００２２】
図１に示す入力部１０は、メッセージ受信部１１と、流入データ量計測部１２とを有する。
【００２３】
メッセージ受信部１１は、連携元サーバ２が送信したメッセージを受信する。メッセージ受信部１１は、メッセージの受信開始時刻を、データ量記憶部５１の流入開始時刻項目に格納する。
【００２４】
流入データ量計測部１２は、メッセージ受信部１１が受信するメッセージのデータ容量である流入データ量を計測する。流入データ量計測部１２は、流入データ量をデータ量記憶部５１の流入データ量項目に格納する。
【００２５】
制御部２０は、第１判定部２１と、増強指令発行部２２と、第２判定部２３と、解放指令発行部２４とを有する。
【００２６】
第１判定部２１は、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、流入超過状態になるか否かを判定する。具体的に、第１判定部２１は、流入データ量が流出データ量を超過する状態が継続している場合に、流入超過状態になると判定する。一方、第１判定部２１は、流入データ量が流出データ量を超過する状態が継続しない場合に、流入超過状態にならないと判定する。どの程度継続している場合に、流入超過状態になるのかは、過去の継続時間と流入状態との関係を考慮して適宜設定することができる。
【００２７】
増強指令発行部２２は、第１判定部２１が流入超過状態になると判定した場合に、リソースを増強するように指示する増強指令を外部に発行する。増強対象のリソースは、連携先サーバ３の処理能力を拡大可能なリソースであればよい。増強対象のリソースとして、例えば、サーバ装置、クラウド環境下の仮想サーバ装置等を用いることができる。発行先となる外部は、例えば、連携先サーバ３や、サービス連携システム１００を統括する管理サーバ等が該当する。
【００２８】
第２判定部２３は、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、流入超過状態が解消するか否かを判定する。具体的に、第２判定部２３は、流入データ量および流出データ量の双方が通常処理量以下となる状態が継続している場合に、流入超過状態が解消すると判定する。一方、第２判定部２３は、流入データ量および流出データ量の双方が通常処理量以下になる状態が継続しない場合に、流入超過状態が解消しないと判定する。どの程度継続している場合に流入超過状態が解消するのかは、過去の継続時間と流入状態との関係を考慮して適宜設定することができる。
【００２９】
解放指令発行部２４は、第２判定部２３が流入超過状態が解消すると判定した場合に、増強指令に応じて増強したリソースを解放するように指示する解放指令を外部に発行する。
【００３０】
ルーティング部３０は、経路決定部３１と、経路変更部３２と、経路追加部３３と、経路再変更部３４とを有する。
【００３１】
経路決定部３１は、連携先サーバ３にメッセージを送信する際の経路を決定する。経路決定部３１は、決定した経路に関する経路情報を、経路情報記憶部５２に格納する。
【００３２】
経路変更部３２は、第１判定部２１が流入超過状態になると判定した場合に、経路決定部３１が決定した経路を、一時記憶部５３を経由して連携先サーバ３に送信する経路に変更する。経路変更部３２は、経路情報記憶部５２に格納されている経路情報を変更後の経路情報に更新する。
【００３３】
図５に、図４の経路情報から変更した後の経路情報を例示する。図５に示す経路情報は、連携元サーバ２から一時記憶部５３への経路と、一時記憶部５３から連携先サーバ３への経路とを含むことを示す。
【００３４】
図１に示す経路追加部３３は、増強指令発行部２２が発行した増強指令に応じてリソースが増強された場合に、一時記憶部５３に格納しているメッセージの宛先となる連携先に、増強されたリソースを追加する。経路追加部３３は、追加したリソースへの経路情報を、経路情報記憶部５２に格納されている経路情報に追加する。
【００３５】
図６に、図５の経路情報に対して増強サーバへの経路を追加した後の経路情報を例示する。図６に示す経路情報は、連携元サーバ２から一時記憶部５３への経路と、一時記憶部５３から連携先サーバ３への経路とに加え、一時記憶部５３から増強サーバへの経路を含むことを示す。
【００３６】
図１に示す経路再変更部３４は、第２判定部２３が流入超過状態が解消すると判定した場合に、経路追加部３３が追加した経路を削除し、経路変更部３２が変更した経路を変更前の経路に戻す。経路再変更部３４は、経路情報記憶部５２に格納されている経路情報を、決定当初の経路情報に戻して更新する。具体的には、図６に示す経路情報が図４に示す経路情報に戻されることになる。
【００３７】
出力部４０は、メッセージ送信部４１と、流出データ量計測部４２とを有する。
【００３８】
メッセージ送信部４１は、経路情報記憶部５２が記憶する経路情報に従って、メッセージを連携先サーバ宛てに送信する。メッセージ送信部４１は、メッセージの送信終了時刻を、データ量記憶部５１の流出数量時刻項目に格納する。
【００３９】
流出データ量計測部４２は、メッセージ送信部４１が送信したメッセージのデータ容量である流出データ量を計測する。流出データ量計測部４２は、流出データ量をデータ量記憶部５１の流出データ量項目に格納する。
【００４０】
次に、図７を参照して、第１実施形態におけるサービス連携装置がデータを格納する際の動作について説明する。
【００４１】
最初に、メッセージ受信部１１は、連携元サーバ２からメッセージを受信し（ステップＳ１０１）、メッセージの受信開始時刻を、データ量記憶部５１の流入開始時刻項目に格納する。
【００４２】
続いて、流入データ量計測部１２は、上記ステップＳ１０１で受信したメッセージの流入データ量を計測し（ステップＳ１０２）、流入データ量をデータ量記憶部５１の流入データ量項目に格納する。
【００４３】
続いて、経路決定部３１は、連携元サーバ２から連携先サーバ３への経路を決定し（ステップＳ１０３）、経路情報を経路情報記憶部５２に格納する。
【００４４】
続いて、メッセージ送信部４１は、連携先サーバ宛てにメッセージを送信し（ステップＳ１０４）、メッセージの送信終了時刻を、データ量記憶部５１の流出数量時刻項目に格納する。
【００４５】
続いて、流出データ量計測部４２は、上記ステップＳ１０４で送信したメッセージの流出データ量を計測し（ステップＳ１０５）、流出データ量をデータ量記憶部５１の流出データ量項目に格納する。
【００４６】
次に、図８を参照して、第１実施形態におけるサービス連携装置がリソースを増強する際の動作について説明する。
【００４７】
最初に、第１判定部２１は、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、流入データ量が流出データ量を超過する状態が継続しているか否かを判定する（ステップＳ２０１）。
【００４８】
上記ステップＳ２０１の判定がＹＥＳである場合（ステップＳ２０１；ＹＥＳ）に、経路変更部３２は、経路決定部３１が決定した経路を、一時記憶部５３を経由して連携先サーバ３に送信する経路に変更し（ステップＳ２０２）、経路情報記憶部５２を更新する。
【００４９】
続いて、増強指令発行部２２は、サーバを増強するように指示する増強指令を外部に発行する（ステップＳ２０３）。
【００５０】
続いて、増強指令発行部２２は、上記ステップＳ２０３で発行した増強指令に応じてサーバが増強されたか否かを判定する（ステップＳ２０４）。
【００５１】
上記ステップＳ２０４の判定がＹＥＳである場合（ステップＳ２０４；ＹＥＳ）に、経路追加部３３は、増強されたサーバを、一時記憶部５３に格納しているメッセージの宛先となる連携先に追加し（ステップＳ２０５）、経路情報記憶部５２を更新する。
【００５２】
次に、図９を参照して、第１実施形態におけるサービス連携装置がリソースを解放する際の動作について説明する。
【００５３】
最初に、第２判定部２３は、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、流入データ量および流出データ量の双方が通常処理量以下となる状態が継続しているか否かを判定する（ステップＳ３０１）。
【００５４】
上記ステップＳ３０１の判定がＹＥＳである場合（ステップＳ３０１；ＹＥＳ）に、経路再変更部３４は、上記図８のステップＳ２０５で追加した増強サーバを連携先から削除し（ステップＳ３０２）、上記図８のステップＳ２０２で変更した経路を、一時記憶部５３を経由しない経路に戻して（ステップＳ３０３）、経路情報記憶部５２を更新する。
【００５５】
続いて、解放指令発行部２４は、上記図８のステップＳ２０３で発行した増強指令に応じて増強されたサーバを解放するように指示する解放指令を外部に発行する（ステップＳ３０４）。
【００５６】
上述したように、第１実施形態におけるサービス連携装置１によれば、第１判定部２１が流入超過状態になると判定した場合に、経路変更部３２が一時記憶部５３を経由する経路に変更することができる。これにより、メッセージが滞留する場合には、一時記憶部５３にメッセージを格納してから連携先に対する処理を実行することができるため、滞留時に備えて確保するサービス連携装置１の主記憶装置の容量を削減することが可能となる。
【００５７】
また、第１実施形態におけるサービス連携装置１によれば、第１判定部２１が流入超過状態になると判定した場合に、増強指令発行部２２がサーバの増強指令を発行し、経路追加部３３が一時記憶部５３に格納されているメッセージの宛先に増強されたサーバを追加することができる。これにより、メッセージが滞留する場合には、敏速に連携先を増強し、連携先の処理能力を増強することができるため、滞留解消までに要する時間を短縮することが可能となる。
【００５８】
また、第１実施形態におけるサービス連携装置１によれば、第１判定部２１が流入超過状態になると判定した場合に、経路変更部３２が滞留分を一時退避可能な経路に変更し、増強指令発行部２２がリクエスト量に応じてリソースを増強させることができる。また、第２判定部２３が、流入超過状態が解消すると判定した場合には、経路再変更部３４が処理効率の高い元の経路に戻し、解放指令発行部２４が増強リソースを解放することができる。これにより、滞留状況に応じて処理能力を変更することが可能となり、滞留時に必要なリソースのコストを抑制することが可能となる。
【００５９】
それゆえに、第１実施形態におけるサービス連携装置１によれば、負荷状況に応じてリソース環境を的確に変更することが可能となる。
【００６０】
なお、上述した第１実施形態では、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、第１判定部２１が流入超過状態になるか否かを判定し、第２判定部２３が流入超過状態が解消するか否かを判定しているが、各判定の条件はこれらに限定されない。例えば、データ量記憶部５１が記憶する流入開始時刻から流出終了時刻までの時間である処理時間の増減傾向に基づいて、第１判定部２１が流入超過状態になるか否かを判定し、第２判定部２３が流入超過状態が解消するか否かを判定することとしてもよい。
【００６１】
処理時間の増減傾向がどの程度増加している場合に、流入超過状態になるのかは、過去の増加傾向と流入状態との関係を考慮して適宜設定することができる。また、処理時間の増減傾向がどの程度減少している場合に、流入超過状態が解消するのかは、過去の減少傾向と流入状態との関係を考慮して適宜設定することができる。
【００６２】
この変形例では、判定のたびに処理時間を算出してもよいが、予め処理時間を算出してデータ量記憶部５１に記憶させておいてもよい。図１０に、処理時間項目を追加した場合のデータ量記憶部５１のデータ構成を例示する。データ量記憶部５１は、データ項目として、図３に示す各データ項目に加え、処理時間項目をさらに有する。処理時間項目は、流入開始から流出終了までに要した時間を格納する。
【００６３】
次に、図１１を参照して、変形例におけるサービス連携装置がリソースを増強する際の動作について説明する。ここでは、図８に示す第１実施形態の動作と異なるステップＳ２０１ａについて説明する。
【００６４】
第１判定部２１は、データ量記憶部５１が記憶する処理時間に基づいて、処理時間の増加傾向が流入が超過する傾向に該当するか否かを判定する（ステップＳ２０１ａ）。この判定がＹＥＳである場合（ステップＳ２０１ａ；ＹＥＳ）に、経路変更部３２は、経路決定部３１が決定した経路を、一時記憶部５３を経由して連携先サーバ３に送信する経路に変更する（ステップＳ２０２）。これ以降の処理は、上述した図８のステップＳ２０３以降の処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００６５】
次に、図１２を参照して、変形例におけるサービス連携装置がリソースを解放する際の動作について説明する。ここでは、図９に示す第１実施形態の動作と異なるステップＳ３０１ａについて説明する。
【００６６】
第２判定部２３は、データ量記憶部５１が記憶する処理時間に基づいて、処理時間の減少傾向が流入超過が解消する傾向に該当するか否かを判定する（ステップＳ３０１ａ）。この判定がＹＥＳである場合（ステップＳ３０１ａ；ＹＥＳ）に、経路再変更部３４は、増強サーバを連携先から削除する（ステップＳ３０２）。これ以降の処理は、上述した図９のステップＳ３０３以降の処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００６７】
[第２実施形態]
本発明の第２実施形態について説明する。図１３は、第２実施形態におけるサービス連携装置の機能構成を例示する図である。第２実施形態におけるサービス連携装置１Ｓが、上述した第１実施形態におけるサービス連携装置１と相違する点は、制御部２０に傾向分析部２５Ｓを追加した点、データ量記憶部５１にデータ項目を追加した点、ならびに第１判定部２１および第２判定部２３の判定条件を変更した点である。それ以外の構成については、第１実施形態におけるサービス連携装置の各構成と同様である。したがって、各構成要素には同一の符号を付し、その説明は省略する。以下においては、主に第１実施形態との相違点について説明する。
【００６８】
図１４に示すように、第２実施形態におけるデータ量記憶部５１Ｓは、データ項目として、図３に示す各データ項目に加え、流入超過状態項目をさらに有する。流入超過状態項目は、流入開始時刻から流出終了時刻までの間にメッセージが流入超過状態になったかどうかを示す情報を格納する。例えば、流入が超過した場合には“有”を格納し、流入が超過しなかった場合には“無”を格納する。
【００６９】
図１３に示す制御部２０Ｓは、図２に示す制御部２０の各部に加え、傾向分析部２５Ｓをさらに有する。
【００７０】
傾向分析部２５Ｓは、データ量記憶部５１Ｓに格納されている過去のデータを分析し、流入データ量および流出データ量と流入超過状態との関係を解析する。具体的に、傾向分析部２５Ｓは、流入超過状態項目に“有”が設定されているメッセージに対応する流入データ量および流出データ量を分析し、流入超過状態になる可能性が高い流入データ量および流出データ量の推移傾向の特徴（以下、「流入超過時の特徴」という。）を算出する。また、傾向分析部２５Ｓは、流入超過状態項目に“無”が設定されているメッセージに対応する流入データ量および流出データ量を分析し、流入超過状態が解消する可能性が高い流入データ量および流出データ量の推移傾向の特徴（以下、「流入超過解消時の特徴」という。）を算出する。
【００７１】
第２実施形態における第１判定部２１Ｓは、傾向分析部２５Ｓが算出した流入超過時の特徴に基づいて、流入超過状態になるか否かを判定する。具体的に、第１判定部２１Ｓは、判定対象となる流入データ量および流出データ量が、流入超過時の特徴と類似する場合に、流入超過状態になると判定する。
【００７２】
第２実施形態における第２判定部２３Ｓは、傾向分析部２５Ｓが算出した流入超過解消時の特徴に基づいて、流入超過状態が解消するか否かを判定する。具体的に、第２判定部２３Ｓは、判定対象となる流入データ量および流出データ量が、流入超過解消時の特徴と類似する場合に、流入超過状態が解消すると判定する。
【００７３】
次に、図１５および図１６を参照して、第２実施形態におけるサービス連携装置がリソースを増強する際の動作について説明する。図１５は、傾向分析部２５Ｓによる分析結果が流入超過状態を判定可能な所定数以上蓄積されるまでの初期運用段階の動作を示すフローチャートである。ここでは、図８に示す第１実施形態の動作と異なるステップＳ２０６について説明する。なお、ステップＳ２０１〜ステップＳ２０５までの処理は、上述した図８のステップＳ２０１〜ステップＳ２０５までの処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００７４】
ステップＳ２０６において、傾向分析部２５Ｓは、データ量記憶部５１Ｓに格納されている過去のデータから、流入超過時の特徴や流入超過解消時の特徴を算出する。
【００７５】
図１６は、傾向分析部２５Ｓによる分析結果が流入超過状態を判定可能な所定数以上蓄積された後の通常運用段階の動作を示すフローチャートである。ここでは、図１５に示す初期運用段階の動作と異なるステップＳ２０１ｂについて説明する。
【００７６】
第１判定部２１Ｓは、判定対象となる流入データ量および流出データ量が、流入超過時の特徴と類似するか否かを判定する（ステップＳ２０１ｂ）。この判定がＹＥＳである場合（ステップＳ２０１ｂ；ＹＥＳ）に、経路変更部３２は、経路決定部３１が決定した経路を、一時記憶部５３を経由して連携先サーバ３に送信する経路に変更する（ステップＳ２０２）。これ以降の処理は、上述した図８のステップＳ２０３以降および図１５のステップＳ２０６の処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００７７】
次に、図１７を参照して、第２実施形態におけるサービス連携装置がリソースを解放する際の動作について説明する。ここでは、図９に示す第１実施形態の動作と異なるステップＳ３０１ｂについて説明する。
【００７８】
第２判定部２３は、判定対象となる流入データ量および流出データ量が、流入超過解消時の特徴と類似するか否かを判定する（ステップＳ３０１ｂ）。この判定がＹＥＳである場合（ステップＳ３０１ｂ；ＹＥＳ）に、経路再変更部３４は、増強サーバを連携先から削除する（ステップＳ３０２）。これ以降の処理は、上述した図９のステップＳ３０３以降の処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００７９】
第２実施形態におけるサービス連携装置１Ｓは、上述した第１実施形態におけるサービス連携装置１が奏する効果に加え、以下の効果を奏する。第２実施形態におけるサービス連携装置１Ｓによれば、傾向分析部２５Ｓが、データ量記憶部５１に蓄積された過去のデータに基づいて流入超過時の特徴や流入超過解消時の特徴を算出し、第１判定部２１Ｓがその特徴に基づいて流入超過状態になるか否かを判定し、第２判定部２３Ｓがその特徴に基づいて流入超過状態が解消するか否かを判定することができる。これにより、滞留の発生や解消を過去の実績に基づいて精度良く予測することができるため、リソース環境を負荷状況に応じて、より的確に変更することが可能となる。
【００８０】
なお、上述した各実施形態は、単なる例示に過ぎず、各実施形態に明示していない種々の変形や技術の適用を排除するものではない。すなわち、本発明は、その趣旨を逸脱しない範囲で様々な形態に変形して実施することができる。
【００８１】
また、上述した各実施形態の一部または全部は、以下の付記のようにも記載され得るが、本発明を以下のように限定するものではない。
【００８２】
（付記１）連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置であって、前記メッセージを受信するメッセージ受信部と、前記連携先サーバにメッセージを送信する際の経路を決定する経路決定部と、前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信部と、前記メッセージ受信部が受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測部と、前記メッセージ送信部が送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測部と、前記メッセージ受信部が受信した前記メッセージごとに、前記メッセージ受信部が前記メッセージの受信を開始した開始時刻、前記メッセージ送信部が前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶部と、前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定部と、前記第１判定部が流入超過状態になると判定した場合に、前記経路決定部が決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更部と、リソースの増強指令を外部に発行する増強指令発行部と、前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加部と、前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定部と、前記第２判定部が流入超過状態が解消すると判定した場合に、前記経路追加部が追加した前記メッセージの宛先を削除し、前記経路変更部が変更した前記経路を変更前の前記経路に戻す経路再変更部と、リソースの解放指令を外部に発行する解放指令発行部と、を備えることを特徴とするサービス連携装置。
【００８３】
（付記２） 前記第１判定部は、前記流入データ量が前記流出データ量を超過する状態が継続している場合に、流入超過状態になると判定し、前記第２判定部は、前記流入データ量が前記流出データ量の双方が通常処理量以下となる状態が継続している場合に、流入超過状態が解消すると判定する、ことを特徴とする付記１記載のサービス連携装置。
【００８４】
（付記３） 前記第１判定部は、前記データ量記憶部が記憶する前記開始時刻から前記終了時刻までの時間である処理時間の増加傾向に基づいて、流入超過状態になるか否かを判定し、前記第２判定部は、前記処理時間の減少傾向に基づいて、流入超過状態が解消するか否かを判定する、ことを特徴とする付記１記載のサービス連携装置。
【００８５】
（付記４） 前記データ量記憶部は、前記メッセージ受信部が受信した前記メッセージごとに、前記開始時刻から前記終了時刻までの間における前記メッセージの流入超過状態をさらに対応付けて記憶し、前記第１判定部は、前記データ量記憶部が記憶する前記流入超過状態に流入が超過している状態であることを示す超過情報が設定されている前記メッセージに対応する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定し、前記第２判定部は、前記データ量記憶部が記憶する前記流入超過状態に流入が超過していない状態であることを示す非超過情報が設定されている前記メッセージに対応する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する、ことを特徴とする付記１記載のサービス連携装置。
【００８６】
（付記５） 連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置が、前記メッセージを受信するメッセージ受信ステップと、前記連携先サーバにメッセージを送信する際の経路を決定する経路決定ステップと、前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信ステップと、前記メッセージ受信ステップにおいて受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測ステップと、前記メッセージ送信ステップにおいて送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測ステップと、前記メッセージ受信ステップにおいて受信した前記メッセージごとに、前記メッセージ受信において前記メッセージの受信を開始した開始時刻、前記メッセージ送信において前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶ステップと、前記データ量記憶ステップが記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定ステップと、前記第１判定ステップにおいて流入超過状態になると判定した場合に、前記経路決定において決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更ステップと、リソースの増強指令を外部に発行する増強指令発行ステップと、前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加ステップと、前記データ量記憶部において記憶した前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定ステップと、前記第２判定ステップにおいて流入超過状態が解消すると判定した場合に、前記経路追加部において追加した前記メッセージの宛先を削除し、前記経路変更部において変更した前記経路を変更前の前記経路に戻す経路再変更ステップと、リソースの解放指令を外部に発行する解放指令発行ステップと、を含むことを特徴とするサービス連携方法。
【００８７】
（付記６） 付記５に記載の各ステップをコンピュータに実行させるためのサービス連携プログラム。
【符号の説明】
【００８８】
１、１Ｓ サービス連携装置
２ 連携元サーバ
３ 連携先サーバ
４、５ ネットワーク
１０ 入力部
１１ メッセージ受信部
１２ 流入データ量計測部
２０、２０Ｓ 制御部
２１、２１Ｓ 第１判定部
２２ 増強指令発行部
２３、２３Ｓ 第２判定部
２４ 解放指令発行部
２５Ｓ 傾向分析部
３０ ルーティング部
３１ 経路決定部
３２ 経路変更部
３３ 経路追加部
３４ 経路再変更部
４０ 出力部
４１ メッセージ送信部
４２ 流出データ量計測部
５０ 記憶部
５１、５１Ｓ データ量記憶部
５２ 経路情報記憶部
５３ 一時記憶部
１００ サービス連携システム
【技術分野】
【０００１】
本発明は、サービス連携装置、サービス連携方法およびサービス連携プログラムに関する。
【背景技術】
【０００２】
ＳＯＡ(Service Oriented Architecture：サービス指向アーキテクチャ)のシステムを構築する際に、ＥＳＢ(Enterprise Service Bus)でシステム間を連携する構成が一般に採用されている。
【０００３】
特許文献１には複数のサブシステムをＥＳＢで連携するシステムが記載されている。このようなシステムでは、一部のサブシステムに障害が発生して停止してしまうと、稼働中の他のサブシステムから送られてくる処理要求が滞留することになる。この滞留した処理要求は、障害が復旧した後に、定常的に発生する通常の処理要求に加えて処理することになる。この場合、滞留分は、通常の処理能力の余力の範囲で処理することになるため、滞留分を解消するには多大な時間を要してしまう。
【０００４】
この滞留問題の対策として、滞留することを想定して予めリソースを余分に拡張しておくことや、滞留が始まってから不足分のリソースを増強することが考えられる。特許文献２および３に記載のシステムは、複数のサーバを用意することで予めリソースを余分に拡張している。
【０００５】
特許文献２には、クライアントからリクエストを受信した場合に、複数用意したサーバのうち、レスポンス待ち状態のリクエスト数が閾値未満であるいずれかのサーバに対してリクエストを転送する負荷分散制御システムが記載されている。特許文献３には、データ送信装置から処理対象データを受信した場合に、複数用意したサーバの稼働状態とネットワークの状態とに基づいて処理対象データの転送先となるサーバを決定するデータ転送システムが記載されている。
【０００６】
特許文献２および３に記載のシステムでは、障害に備えて、常時、大量のリソースを余分に確保することとなるため、コストがかさんでしまう。他方、上記滞留開始後にリソースを増強する対応策では、リソースの増強が完了するまで不安定な状態でシステムを稼働することになってしまう。
【０００７】
上記コスト高や不安定稼働の問題の対策として、特許文献４には、クラウド環境下のデータセンターのリソースを利用し、サービス負荷の予測状況に基づいてシステム構成を変更する構成管理システムが記載されている。
【先行技術文献】
【特許文献】
【０００８】
【特許文献１】特開２０１０−９２１８号公報
【特許文献２】特開２００８−４０７１８号公報
【特許文献３】特開２０１０−３１２１号公報
【特許文献４】特開２０１１−１１３２６７号公報
【発明の概要】
【発明が解決しようとする課題】
【０００９】
特許文献４に記載のシステムでは、運用者が、負荷の予測状況に基づいて、適切なシステム構成のスナップショットを検索・選定しなければならない。したがって、例えば運用経験が浅いと、システム構成の検索・選定に手間を要するとともに、不適切なシステム構成を選定してしまうおそれがある。
【００１０】
本発明は、上述した課題を解決するためになされたものであり、負荷状況に応じてリソース環境を的確に変更することができるサービス連携装置、サービス連携方法およびサービス連携プログラムを提供することを目的の一つとする。
【課題を解決するための手段】
【００１１】
本発明の一態様であるサービス連携装置は、連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置であって、前記メッセージを受信するメッセージ受信部と、前記連携先サーバにメッセージを送信する際の経路を決定する経路決定部と、前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信部と、前記メッセージ受信部が受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測部と、前記メッセージ送信部が送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測部と、前記メッセージ受信部が受信した前記メッセージごとに、前記メッセージ受信部が前記メッセージの受信を開始した開始時刻、前記メッセージ送信部が前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶部と、前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定部と、前記第１判定部が流入超過状態になると判定した場合に、前記経路決定部が決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更部と、リソースの増強指令を外部に発行する増強指令発行部と、前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加部と、前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定部と、前記第２判定部が流入超過状態が解消すると判定した場合に、前記経路追加部が追加した前記メッセージの宛先を削除し、前記経路変更部が変更した前記経路を変更前の前記経路に戻す経路再変更部と、リソースの解放指令を外部に発行する解放指令発行部と、を備える。
【００１２】
本発明の一態様であるサービス連携方法は、連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置が、前記メッセージを受信するメッセージ受信ステップと、前記連携先サーバにメッセージを送信する際の経路を決定する経路決定ステップと、前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信ステップと、前記メッセージ受信ステップにおいて受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測ステップと、前記メッセージ送信ステップにおいて送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測ステップと、前記メッセージ受信ステップにおいて受信した前記メッセージごとに、前記メッセージ受信において前記メッセージの受信を開始した開始時刻、前記メッセージ送信において前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶ステップと、前記データ量記憶ステップが記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定ステップと、前記第１判定ステップにおいて流入超過状態になると判定した場合に、前記経路決定において決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更ステップと、リソースの増強指令を外部に発行する増強指令発行ステップと、前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加ステップと、前記データ量記憶部において記憶した前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定ステップと、前記第２判定ステップにおいて流入超過状態が解消すると判定した場合に、前記経路追加部において追加した前記メッセージの宛先を削除し、前記経路変更部において変更した前記経路を変更前の前記経路に戻す経路再変更ステップと、リソースの解放指令を外部に発行する解放指令発行ステップと、を含む。
【００１３】
本発明の一態様であるサービス連携プログラムは、上記サービス連携方法に含まれる各ステップをコンピュータに実行させる。
【発明の効果】
【００１４】
本発明によれば、負荷状況に応じてリソース環境を的確に変更することができる。
【図面の簡単な説明】
【００１５】
【図１】サービス連携システムのシステム構成を例示する図である。
【図２】第１実施形態におけるサービス連携装置の機能構成を例示する図である。
【図３】第１実施形態におけるデータ量記憶部のデータ構成を例示する図である。
【図４】経路情報記憶部のデータ構成を例示する図である。
【図５】経路情報記憶部に格納される経路情報の一例を示す図である。
【図６】経路情報記憶部に格納される経路情報の一例を示す図である。
【図７】第１実施形態におけるサービス連携装置がデータを格納する際の動作を説明するためのフローチャートである。
【図８】第１実施形態におけるサービス連携装置がリソースを増強する際の動作を説明するためのフローチャートである。
【図９】第１実施形態におけるサービス連携装置がリソースを解放する際の動作を説明するためのフローチャートである。
【図１０】変形例におけるデータ量記憶部のデータ構成を例示する図である。
【図１１】変形例におけるサービス連携装置がリソースを増強する際の動作を説明するためのフローチャートである。
【図１２】変形例におけるサービス連携装置がリソースを解放する際の動作を説明するためのフローチャートである。
【図１３】第２実施形態におけるサービス連携装置の機能構成を例示する図である。
【図１４】第２実施形態におけるデータ量記憶部のデータ構成を例示する図である。
【図１５】第２実施形態におけるサービス連携装置がリソースを増強する際の初期運用段階の動作を説明するためのフローチャートである。
【図１６】第２実施形態におけるサービス連携装置がリソースを増強する際の通常運用段階の動作を説明するためのフローチャートである。
【図１７】第２実施形態におけるサービス連携装置がリソースを解放する際の動作を説明するためのフローチャートである。
【発明を実施するための形態】
【００１６】
以下、添付図面を参照して、本発明に係るサービス連携装置、サービス連携方法およびサービス連携プログラムの好適な実施形態について説明する。
【００１７】
[第１実施形態]
まず、第１実施形態におけるサービス連携装置を含むサービス連携システムの構成について説明する。図１は、サービス連携システムのシステム構成を例示する図である。サービス連携システム１００は、サービス連携装置１と、連携元サーバ２と、連携先サーバ３とを備える。サービス連携装置１と、連携元サーバ２および連携先サーバ３とは、それぞれネットワーク４、５を介して接続する。サービス連携装置１は、連携元サーバから受信したメッセージを連携先サーバに送信する。サービス連携装置１は、受信したメッセージを、そのまま連携先サーバに転送してもよいし、データを加工してから連携先サーバに送信してもよい。
【００１８】
サービス連携装置１は、物理的には、例えば、ＣＰＵ（Central Processing Unit）と、記憶装置と、入出力インターフェースとを含む。記憶装置は、例えば、ＣＰＵで処理されるプログラムおよびデータを記憶するＲＯＭ（Read Only Memory）やＨＤＤ（Hard Disk Drive）、主として制御処理のための各種作業領域として使用するＲＡＭ（Random Access Memory）等を含む。これらの要素は、互いにバスを介して接続する。ＣＰＵが、ＲＯＭに記憶されたプログラムを実行し、入出力インターフェースを介して受信されるメッセージや、ＲＡＭに展開されるデータ等を処理することで、サービス連携装置１における以下の各機能を実現する。
【００１９】
図２を参照して、サービス連携装置１の機能構成について説明する。サービス連携装置１は、機能的には、例えば、入力部１０と、制御部２０と、ルーティング部３０と、出力部４０と、記憶部５０とを有する。記憶部５０は、各部が参照・更新するデータを記憶する。記憶部５０は、例えば、データ量記憶部５１と、経路情報記憶部５２と、一時記憶部５３とを含む。一時記憶部５３は、メッセージを一時的に格納する記憶部である。
【００２０】
図３を参照して、データ量記憶部５１のデータ構成について説明する。データ量記憶部５１は、データ項目として、例えば、流入開始時刻項目、流出終了時刻項目、流入データ量項目および流出データ量項目を有する。流入開始時刻項目は、連携元サーバ２からメッセージの受信を開始した時刻を格納する。流出終了時刻項目は、連携先サーバ３へのメッセージの送信を終了した時刻を格納する。流入データ量項目は、連携元サーバ２から受信したメッセージのデータ量を格納する。流出データ量項目は、連携先サーバ３に送信したメッセージのデータ容量を格納する。
【００２１】
図４を参照して、経路情報記憶部５２のデータ構成について説明する。経路情報記憶部５２は、データ項目として、例えば、連携元項目および連携先量項目を有する。連携元項目は、経路の開始要素を特定する情報を格納する。連携先項目は、経路の終了要素を特定する情報を格納する。図４に示す経路情報は、連携元サーバ２から連携先サーバ３への経路であることを示す。
【００２２】
図１に示す入力部１０は、メッセージ受信部１１と、流入データ量計測部１２とを有する。
【００２３】
メッセージ受信部１１は、連携元サーバ２が送信したメッセージを受信する。メッセージ受信部１１は、メッセージの受信開始時刻を、データ量記憶部５１の流入開始時刻項目に格納する。
【００２４】
流入データ量計測部１２は、メッセージ受信部１１が受信するメッセージのデータ容量である流入データ量を計測する。流入データ量計測部１２は、流入データ量をデータ量記憶部５１の流入データ量項目に格納する。
【００２５】
制御部２０は、第１判定部２１と、増強指令発行部２２と、第２判定部２３と、解放指令発行部２４とを有する。
【００２６】
第１判定部２１は、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、流入超過状態になるか否かを判定する。具体的に、第１判定部２１は、流入データ量が流出データ量を超過する状態が継続している場合に、流入超過状態になると判定する。一方、第１判定部２１は、流入データ量が流出データ量を超過する状態が継続しない場合に、流入超過状態にならないと判定する。どの程度継続している場合に、流入超過状態になるのかは、過去の継続時間と流入状態との関係を考慮して適宜設定することができる。
【００２７】
増強指令発行部２２は、第１判定部２１が流入超過状態になると判定した場合に、リソースを増強するように指示する増強指令を外部に発行する。増強対象のリソースは、連携先サーバ３の処理能力を拡大可能なリソースであればよい。増強対象のリソースとして、例えば、サーバ装置、クラウド環境下の仮想サーバ装置等を用いることができる。発行先となる外部は、例えば、連携先サーバ３や、サービス連携システム１００を統括する管理サーバ等が該当する。
【００２８】
第２判定部２３は、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、流入超過状態が解消するか否かを判定する。具体的に、第２判定部２３は、流入データ量および流出データ量の双方が通常処理量以下となる状態が継続している場合に、流入超過状態が解消すると判定する。一方、第２判定部２３は、流入データ量および流出データ量の双方が通常処理量以下になる状態が継続しない場合に、流入超過状態が解消しないと判定する。どの程度継続している場合に流入超過状態が解消するのかは、過去の継続時間と流入状態との関係を考慮して適宜設定することができる。
【００２９】
解放指令発行部２４は、第２判定部２３が流入超過状態が解消すると判定した場合に、増強指令に応じて増強したリソースを解放するように指示する解放指令を外部に発行する。
【００３０】
ルーティング部３０は、経路決定部３１と、経路変更部３２と、経路追加部３３と、経路再変更部３４とを有する。
【００３１】
経路決定部３１は、連携先サーバ３にメッセージを送信する際の経路を決定する。経路決定部３１は、決定した経路に関する経路情報を、経路情報記憶部５２に格納する。
【００３２】
経路変更部３２は、第１判定部２１が流入超過状態になると判定した場合に、経路決定部３１が決定した経路を、一時記憶部５３を経由して連携先サーバ３に送信する経路に変更する。経路変更部３２は、経路情報記憶部５２に格納されている経路情報を変更後の経路情報に更新する。
【００３３】
図５に、図４の経路情報から変更した後の経路情報を例示する。図５に示す経路情報は、連携元サーバ２から一時記憶部５３への経路と、一時記憶部５３から連携先サーバ３への経路とを含むことを示す。
【００３４】
図１に示す経路追加部３３は、増強指令発行部２２が発行した増強指令に応じてリソースが増強された場合に、一時記憶部５３に格納しているメッセージの宛先となる連携先に、増強されたリソースを追加する。経路追加部３３は、追加したリソースへの経路情報を、経路情報記憶部５２に格納されている経路情報に追加する。
【００３５】
図６に、図５の経路情報に対して増強サーバへの経路を追加した後の経路情報を例示する。図６に示す経路情報は、連携元サーバ２から一時記憶部５３への経路と、一時記憶部５３から連携先サーバ３への経路とに加え、一時記憶部５３から増強サーバへの経路を含むことを示す。
【００３６】
図１に示す経路再変更部３４は、第２判定部２３が流入超過状態が解消すると判定した場合に、経路追加部３３が追加した経路を削除し、経路変更部３２が変更した経路を変更前の経路に戻す。経路再変更部３４は、経路情報記憶部５２に格納されている経路情報を、決定当初の経路情報に戻して更新する。具体的には、図６に示す経路情報が図４に示す経路情報に戻されることになる。
【００３７】
出力部４０は、メッセージ送信部４１と、流出データ量計測部４２とを有する。
【００３８】
メッセージ送信部４１は、経路情報記憶部５２が記憶する経路情報に従って、メッセージを連携先サーバ宛てに送信する。メッセージ送信部４１は、メッセージの送信終了時刻を、データ量記憶部５１の流出数量時刻項目に格納する。
【００３９】
流出データ量計測部４２は、メッセージ送信部４１が送信したメッセージのデータ容量である流出データ量を計測する。流出データ量計測部４２は、流出データ量をデータ量記憶部５１の流出データ量項目に格納する。
【００４０】
次に、図７を参照して、第１実施形態におけるサービス連携装置がデータを格納する際の動作について説明する。
【００４１】
最初に、メッセージ受信部１１は、連携元サーバ２からメッセージを受信し（ステップＳ１０１）、メッセージの受信開始時刻を、データ量記憶部５１の流入開始時刻項目に格納する。
【００４２】
続いて、流入データ量計測部１２は、上記ステップＳ１０１で受信したメッセージの流入データ量を計測し（ステップＳ１０２）、流入データ量をデータ量記憶部５１の流入データ量項目に格納する。
【００４３】
続いて、経路決定部３１は、連携元サーバ２から連携先サーバ３への経路を決定し（ステップＳ１０３）、経路情報を経路情報記憶部５２に格納する。
【００４４】
続いて、メッセージ送信部４１は、連携先サーバ宛てにメッセージを送信し（ステップＳ１０４）、メッセージの送信終了時刻を、データ量記憶部５１の流出数量時刻項目に格納する。
【００４５】
続いて、流出データ量計測部４２は、上記ステップＳ１０４で送信したメッセージの流出データ量を計測し（ステップＳ１０５）、流出データ量をデータ量記憶部５１の流出データ量項目に格納する。
【００４６】
次に、図８を参照して、第１実施形態におけるサービス連携装置がリソースを増強する際の動作について説明する。
【００４７】
最初に、第１判定部２１は、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、流入データ量が流出データ量を超過する状態が継続しているか否かを判定する（ステップＳ２０１）。
【００４８】
上記ステップＳ２０１の判定がＹＥＳである場合（ステップＳ２０１；ＹＥＳ）に、経路変更部３２は、経路決定部３１が決定した経路を、一時記憶部５３を経由して連携先サーバ３に送信する経路に変更し（ステップＳ２０２）、経路情報記憶部５２を更新する。
【００４９】
続いて、増強指令発行部２２は、サーバを増強するように指示する増強指令を外部に発行する（ステップＳ２０３）。
【００５０】
続いて、増強指令発行部２２は、上記ステップＳ２０３で発行した増強指令に応じてサーバが増強されたか否かを判定する（ステップＳ２０４）。
【００５１】
上記ステップＳ２０４の判定がＹＥＳである場合（ステップＳ２０４；ＹＥＳ）に、経路追加部３３は、増強されたサーバを、一時記憶部５３に格納しているメッセージの宛先となる連携先に追加し（ステップＳ２０５）、経路情報記憶部５２を更新する。
【００５２】
次に、図９を参照して、第１実施形態におけるサービス連携装置がリソースを解放する際の動作について説明する。
【００５３】
最初に、第２判定部２３は、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、流入データ量および流出データ量の双方が通常処理量以下となる状態が継続しているか否かを判定する（ステップＳ３０１）。
【００５４】
上記ステップＳ３０１の判定がＹＥＳである場合（ステップＳ３０１；ＹＥＳ）に、経路再変更部３４は、上記図８のステップＳ２０５で追加した増強サーバを連携先から削除し（ステップＳ３０２）、上記図８のステップＳ２０２で変更した経路を、一時記憶部５３を経由しない経路に戻して（ステップＳ３０３）、経路情報記憶部５２を更新する。
【００５５】
続いて、解放指令発行部２４は、上記図８のステップＳ２０３で発行した増強指令に応じて増強されたサーバを解放するように指示する解放指令を外部に発行する（ステップＳ３０４）。
【００５６】
上述したように、第１実施形態におけるサービス連携装置１によれば、第１判定部２１が流入超過状態になると判定した場合に、経路変更部３２が一時記憶部５３を経由する経路に変更することができる。これにより、メッセージが滞留する場合には、一時記憶部５３にメッセージを格納してから連携先に対する処理を実行することができるため、滞留時に備えて確保するサービス連携装置１の主記憶装置の容量を削減することが可能となる。
【００５７】
また、第１実施形態におけるサービス連携装置１によれば、第１判定部２１が流入超過状態になると判定した場合に、増強指令発行部２２がサーバの増強指令を発行し、経路追加部３３が一時記憶部５３に格納されているメッセージの宛先に増強されたサーバを追加することができる。これにより、メッセージが滞留する場合には、敏速に連携先を増強し、連携先の処理能力を増強することができるため、滞留解消までに要する時間を短縮することが可能となる。
【００５８】
また、第１実施形態におけるサービス連携装置１によれば、第１判定部２１が流入超過状態になると判定した場合に、経路変更部３２が滞留分を一時退避可能な経路に変更し、増強指令発行部２２がリクエスト量に応じてリソースを増強させることができる。また、第２判定部２３が、流入超過状態が解消すると判定した場合には、経路再変更部３４が処理効率の高い元の経路に戻し、解放指令発行部２４が増強リソースを解放することができる。これにより、滞留状況に応じて処理能力を変更することが可能となり、滞留時に必要なリソースのコストを抑制することが可能となる。
【００５９】
それゆえに、第１実施形態におけるサービス連携装置１によれば、負荷状況に応じてリソース環境を的確に変更することが可能となる。
【００６０】
なお、上述した第１実施形態では、データ量記憶部５１が記憶する流入データ量および流出データ量に基づいて、第１判定部２１が流入超過状態になるか否かを判定し、第２判定部２３が流入超過状態が解消するか否かを判定しているが、各判定の条件はこれらに限定されない。例えば、データ量記憶部５１が記憶する流入開始時刻から流出終了時刻までの時間である処理時間の増減傾向に基づいて、第１判定部２１が流入超過状態になるか否かを判定し、第２判定部２３が流入超過状態が解消するか否かを判定することとしてもよい。
【００６１】
処理時間の増減傾向がどの程度増加している場合に、流入超過状態になるのかは、過去の増加傾向と流入状態との関係を考慮して適宜設定することができる。また、処理時間の増減傾向がどの程度減少している場合に、流入超過状態が解消するのかは、過去の減少傾向と流入状態との関係を考慮して適宜設定することができる。
【００６２】
この変形例では、判定のたびに処理時間を算出してもよいが、予め処理時間を算出してデータ量記憶部５１に記憶させておいてもよい。図１０に、処理時間項目を追加した場合のデータ量記憶部５１のデータ構成を例示する。データ量記憶部５１は、データ項目として、図３に示す各データ項目に加え、処理時間項目をさらに有する。処理時間項目は、流入開始から流出終了までに要した時間を格納する。
【００６３】
次に、図１１を参照して、変形例におけるサービス連携装置がリソースを増強する際の動作について説明する。ここでは、図８に示す第１実施形態の動作と異なるステップＳ２０１ａについて説明する。
【００６４】
第１判定部２１は、データ量記憶部５１が記憶する処理時間に基づいて、処理時間の増加傾向が流入が超過する傾向に該当するか否かを判定する（ステップＳ２０１ａ）。この判定がＹＥＳである場合（ステップＳ２０１ａ；ＹＥＳ）に、経路変更部３２は、経路決定部３１が決定した経路を、一時記憶部５３を経由して連携先サーバ３に送信する経路に変更する（ステップＳ２０２）。これ以降の処理は、上述した図８のステップＳ２０３以降の処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００６５】
次に、図１２を参照して、変形例におけるサービス連携装置がリソースを解放する際の動作について説明する。ここでは、図９に示す第１実施形態の動作と異なるステップＳ３０１ａについて説明する。
【００６６】
第２判定部２３は、データ量記憶部５１が記憶する処理時間に基づいて、処理時間の減少傾向が流入超過が解消する傾向に該当するか否かを判定する（ステップＳ３０１ａ）。この判定がＹＥＳである場合（ステップＳ３０１ａ；ＹＥＳ）に、経路再変更部３４は、増強サーバを連携先から削除する（ステップＳ３０２）。これ以降の処理は、上述した図９のステップＳ３０３以降の処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００６７】
[第２実施形態]
本発明の第２実施形態について説明する。図１３は、第２実施形態におけるサービス連携装置の機能構成を例示する図である。第２実施形態におけるサービス連携装置１Ｓが、上述した第１実施形態におけるサービス連携装置１と相違する点は、制御部２０に傾向分析部２５Ｓを追加した点、データ量記憶部５１にデータ項目を追加した点、ならびに第１判定部２１および第２判定部２３の判定条件を変更した点である。それ以外の構成については、第１実施形態におけるサービス連携装置の各構成と同様である。したがって、各構成要素には同一の符号を付し、その説明は省略する。以下においては、主に第１実施形態との相違点について説明する。
【００６８】
図１４に示すように、第２実施形態におけるデータ量記憶部５１Ｓは、データ項目として、図３に示す各データ項目に加え、流入超過状態項目をさらに有する。流入超過状態項目は、流入開始時刻から流出終了時刻までの間にメッセージが流入超過状態になったかどうかを示す情報を格納する。例えば、流入が超過した場合には“有”を格納し、流入が超過しなかった場合には“無”を格納する。
【００６９】
図１３に示す制御部２０Ｓは、図２に示す制御部２０の各部に加え、傾向分析部２５Ｓをさらに有する。
【００７０】
傾向分析部２５Ｓは、データ量記憶部５１Ｓに格納されている過去のデータを分析し、流入データ量および流出データ量と流入超過状態との関係を解析する。具体的に、傾向分析部２５Ｓは、流入超過状態項目に“有”が設定されているメッセージに対応する流入データ量および流出データ量を分析し、流入超過状態になる可能性が高い流入データ量および流出データ量の推移傾向の特徴（以下、「流入超過時の特徴」という。）を算出する。また、傾向分析部２５Ｓは、流入超過状態項目に“無”が設定されているメッセージに対応する流入データ量および流出データ量を分析し、流入超過状態が解消する可能性が高い流入データ量および流出データ量の推移傾向の特徴（以下、「流入超過解消時の特徴」という。）を算出する。
【００７１】
第２実施形態における第１判定部２１Ｓは、傾向分析部２５Ｓが算出した流入超過時の特徴に基づいて、流入超過状態になるか否かを判定する。具体的に、第１判定部２１Ｓは、判定対象となる流入データ量および流出データ量が、流入超過時の特徴と類似する場合に、流入超過状態になると判定する。
【００７２】
第２実施形態における第２判定部２３Ｓは、傾向分析部２５Ｓが算出した流入超過解消時の特徴に基づいて、流入超過状態が解消するか否かを判定する。具体的に、第２判定部２３Ｓは、判定対象となる流入データ量および流出データ量が、流入超過解消時の特徴と類似する場合に、流入超過状態が解消すると判定する。
【００７３】
次に、図１５および図１６を参照して、第２実施形態におけるサービス連携装置がリソースを増強する際の動作について説明する。図１５は、傾向分析部２５Ｓによる分析結果が流入超過状態を判定可能な所定数以上蓄積されるまでの初期運用段階の動作を示すフローチャートである。ここでは、図８に示す第１実施形態の動作と異なるステップＳ２０６について説明する。なお、ステップＳ２０１〜ステップＳ２０５までの処理は、上述した図８のステップＳ２０１〜ステップＳ２０５までの処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００７４】
ステップＳ２０６において、傾向分析部２５Ｓは、データ量記憶部５１Ｓに格納されている過去のデータから、流入超過時の特徴や流入超過解消時の特徴を算出する。
【００７５】
図１６は、傾向分析部２５Ｓによる分析結果が流入超過状態を判定可能な所定数以上蓄積された後の通常運用段階の動作を示すフローチャートである。ここでは、図１５に示す初期運用段階の動作と異なるステップＳ２０１ｂについて説明する。
【００７６】
第１判定部２１Ｓは、判定対象となる流入データ量および流出データ量が、流入超過時の特徴と類似するか否かを判定する（ステップＳ２０１ｂ）。この判定がＹＥＳである場合（ステップＳ２０１ｂ；ＹＥＳ）に、経路変更部３２は、経路決定部３１が決定した経路を、一時記憶部５３を経由して連携先サーバ３に送信する経路に変更する（ステップＳ２０２）。これ以降の処理は、上述した図８のステップＳ２０３以降および図１５のステップＳ２０６の処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００７７】
次に、図１７を参照して、第２実施形態におけるサービス連携装置がリソースを解放する際の動作について説明する。ここでは、図９に示す第１実施形態の動作と異なるステップＳ３０１ｂについて説明する。
【００７８】
第２判定部２３は、判定対象となる流入データ量および流出データ量が、流入超過解消時の特徴と類似するか否かを判定する（ステップＳ３０１ｂ）。この判定がＹＥＳである場合（ステップＳ３０１ｂ；ＹＥＳ）に、経路再変更部３４は、増強サーバを連携先から削除する（ステップＳ３０２）。これ以降の処理は、上述した図９のステップＳ３０３以降の処理と同一内容となるため、各処理には同一のステップ番号を付し、その説明を省略する。
【００７９】
第２実施形態におけるサービス連携装置１Ｓは、上述した第１実施形態におけるサービス連携装置１が奏する効果に加え、以下の効果を奏する。第２実施形態におけるサービス連携装置１Ｓによれば、傾向分析部２５Ｓが、データ量記憶部５１に蓄積された過去のデータに基づいて流入超過時の特徴や流入超過解消時の特徴を算出し、第１判定部２１Ｓがその特徴に基づいて流入超過状態になるか否かを判定し、第２判定部２３Ｓがその特徴に基づいて流入超過状態が解消するか否かを判定することができる。これにより、滞留の発生や解消を過去の実績に基づいて精度良く予測することができるため、リソース環境を負荷状況に応じて、より的確に変更することが可能となる。
【００８０】
なお、上述した各実施形態は、単なる例示に過ぎず、各実施形態に明示していない種々の変形や技術の適用を排除するものではない。すなわち、本発明は、その趣旨を逸脱しない範囲で様々な形態に変形して実施することができる。
【００８１】
また、上述した各実施形態の一部または全部は、以下の付記のようにも記載され得るが、本発明を以下のように限定するものではない。
【００８２】
（付記１）連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置であって、前記メッセージを受信するメッセージ受信部と、前記連携先サーバにメッセージを送信する際の経路を決定する経路決定部と、前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信部と、前記メッセージ受信部が受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測部と、前記メッセージ送信部が送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測部と、前記メッセージ受信部が受信した前記メッセージごとに、前記メッセージ受信部が前記メッセージの受信を開始した開始時刻、前記メッセージ送信部が前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶部と、前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定部と、前記第１判定部が流入超過状態になると判定した場合に、前記経路決定部が決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更部と、リソースの増強指令を外部に発行する増強指令発行部と、前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加部と、前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定部と、前記第２判定部が流入超過状態が解消すると判定した場合に、前記経路追加部が追加した前記メッセージの宛先を削除し、前記経路変更部が変更した前記経路を変更前の前記経路に戻す経路再変更部と、リソースの解放指令を外部に発行する解放指令発行部と、を備えることを特徴とするサービス連携装置。
【００８３】
（付記２） 前記第１判定部は、前記流入データ量が前記流出データ量を超過する状態が継続している場合に、流入超過状態になると判定し、前記第２判定部は、前記流入データ量が前記流出データ量の双方が通常処理量以下となる状態が継続している場合に、流入超過状態が解消すると判定する、ことを特徴とする付記１記載のサービス連携装置。
【００８４】
（付記３） 前記第１判定部は、前記データ量記憶部が記憶する前記開始時刻から前記終了時刻までの時間である処理時間の増加傾向に基づいて、流入超過状態になるか否かを判定し、前記第２判定部は、前記処理時間の減少傾向に基づいて、流入超過状態が解消するか否かを判定する、ことを特徴とする付記１記載のサービス連携装置。
【００８５】
（付記４） 前記データ量記憶部は、前記メッセージ受信部が受信した前記メッセージごとに、前記開始時刻から前記終了時刻までの間における前記メッセージの流入超過状態をさらに対応付けて記憶し、前記第１判定部は、前記データ量記憶部が記憶する前記流入超過状態に流入が超過している状態であることを示す超過情報が設定されている前記メッセージに対応する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定し、前記第２判定部は、前記データ量記憶部が記憶する前記流入超過状態に流入が超過していない状態であることを示す非超過情報が設定されている前記メッセージに対応する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する、ことを特徴とする付記１記載のサービス連携装置。
【００８６】
（付記５） 連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置が、前記メッセージを受信するメッセージ受信ステップと、前記連携先サーバにメッセージを送信する際の経路を決定する経路決定ステップと、前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信ステップと、前記メッセージ受信ステップにおいて受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測ステップと、前記メッセージ送信ステップにおいて送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測ステップと、前記メッセージ受信ステップにおいて受信した前記メッセージごとに、前記メッセージ受信において前記メッセージの受信を開始した開始時刻、前記メッセージ送信において前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶ステップと、前記データ量記憶ステップが記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定ステップと、前記第１判定ステップにおいて流入超過状態になると判定した場合に、前記経路決定において決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更ステップと、リソースの増強指令を外部に発行する増強指令発行ステップと、前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加ステップと、前記データ量記憶部において記憶した前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定ステップと、前記第２判定ステップにおいて流入超過状態が解消すると判定した場合に、前記経路追加部において追加した前記メッセージの宛先を削除し、前記経路変更部において変更した前記経路を変更前の前記経路に戻す経路再変更ステップと、リソースの解放指令を外部に発行する解放指令発行ステップと、を含むことを特徴とするサービス連携方法。
【００８７】
（付記６） 付記５に記載の各ステップをコンピュータに実行させるためのサービス連携プログラム。
【符号の説明】
【００８８】
１、１Ｓ サービス連携装置
２ 連携元サーバ
３ 連携先サーバ
４、５ ネットワーク
１０ 入力部
１１ メッセージ受信部
１２ 流入データ量計測部
２０、２０Ｓ 制御部
２１、２１Ｓ 第１判定部
２２ 増強指令発行部
２３、２３Ｓ 第２判定部
２４ 解放指令発行部
２５Ｓ 傾向分析部
３０ ルーティング部
３１ 経路決定部
３２ 経路変更部
３３ 経路追加部
３４ 経路再変更部
４０ 出力部
４１ メッセージ送信部
４２ 流出データ量計測部
５０ 記憶部
５１、５１Ｓ データ量記憶部
５２ 経路情報記憶部
５３ 一時記憶部
１００ サービス連携システム
【特許請求の範囲】
【請求項１】
連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置であって、
前記メッセージを受信するメッセージ受信部と、
前記連携先サーバにメッセージを送信する際の経路を決定する経路決定部と、
前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信部と、
前記メッセージ受信部が受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測部と、
前記メッセージ送信部が送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測部と、
前記メッセージ受信部が受信した前記メッセージごとに、前記メッセージ受信部が前記メッセージの受信を開始した開始時刻、前記メッセージ送信部が前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶部と、
前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定部と、
前記第１判定部が流入超過状態になると判定した場合に、前記経路決定部が決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更部と、
リソースの増強指令を外部に発行する増強指令発行部と、
前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加部と、
前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定部と、
前記第２判定部が流入超過状態が解消すると判定した場合に、前記経路追加部が追加した前記メッセージの宛先を削除し、前記経路変更部が変更した前記経路を変更前の前記経路に戻す経路再変更部と、
リソースの解放指令を外部に発行する解放指令発行部と、
を備えることを特徴とするサービス連携装置。
【請求項２】
前記第１判定部は、前記流入データ量が前記流出データ量を超過する状態が継続している場合に、流入超過状態になると判定し、
前記第２判定部は、前記流入データ量が前記流出データ量の双方が通常処理量以下となる状態が継続している場合に、流入超過状態が解消すると判定する、
ことを特徴とする請求項１記載のサービス連携装置。
【請求項３】
前記第１判定部は、前記データ量記憶部が記憶する前記開始時刻から前記終了時刻までの時間である処理時間の増加傾向に基づいて、流入超過状態になるか否かを判定し、
前記第２判定部は、前記処理時間の減少傾向に基づいて、流入超過状態が解消するか否かを判定する、
ことを特徴とする請求項１記載のサービス連携装置。
【請求項４】
前記データ量記憶部は、前記メッセージ受信部が受信した前記メッセージごとに、前記開始時刻から前記終了時刻までの間における前記メッセージの流入超過状態をさらに対応付けて記憶し、
前記第１判定部は、前記データ量記憶部が記憶する前記流入超過状態に流入が超過している状態であることを示す超過情報が設定されている前記メッセージに対応する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定し、
前記第２判定部は、前記データ量記憶部が記憶する前記流入超過状態に流入が超過していない状態であることを示す非超過情報が設定されている前記メッセージに対応する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する、
ことを特徴とする請求項１記載のサービス連携装置。
【請求項５】
連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置が、
前記メッセージを受信するメッセージ受信ステップと、
前記連携先サーバにメッセージを送信する際の経路を決定する経路決定ステップと、
前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信ステップと、
前記メッセージ受信ステップにおいて受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測ステップと、
前記メッセージ送信ステップにおいて送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測ステップと、
前記メッセージ受信ステップにおいて受信した前記メッセージごとに、前記メッセージ受信において前記メッセージの受信を開始した開始時刻、前記メッセージ送信において前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶ステップと、
前記データ量記憶ステップが記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定ステップと、
前記第１判定ステップにおいて流入超過状態になると判定した場合に、前記経路決定において決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更ステップと、
リソースの増強指令を外部に発行する増強指令発行ステップと、
前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加ステップと、
前記データ量記憶部において記憶した前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定ステップと、
前記第２判定ステップにおいて流入超過状態が解消すると判定した場合に、前記経路追加部において追加した前記メッセージの宛先を削除し、前記経路変更部において変更した前記経路を変更前の前記経路に戻す経路再変更ステップと、
リソースの解放指令を外部に発行する解放指令発行ステップと、
を含むことを特徴とするサービス連携方法。
【請求項６】
請求項５に記載の各ステップをコンピュータに実行させるためのサービス連携プログラム。
【請求項１】
連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置であって、
前記メッセージを受信するメッセージ受信部と、
前記連携先サーバにメッセージを送信する際の経路を決定する経路決定部と、
前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信部と、
前記メッセージ受信部が受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測部と、
前記メッセージ送信部が送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測部と、
前記メッセージ受信部が受信した前記メッセージごとに、前記メッセージ受信部が前記メッセージの受信を開始した開始時刻、前記メッセージ送信部が前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶部と、
前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定部と、
前記第１判定部が流入超過状態になると判定した場合に、前記経路決定部が決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更部と、
リソースの増強指令を外部に発行する増強指令発行部と、
前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加部と、
前記データ量記憶部が記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定部と、
前記第２判定部が流入超過状態が解消すると判定した場合に、前記経路追加部が追加した前記メッセージの宛先を削除し、前記経路変更部が変更した前記経路を変更前の前記経路に戻す経路再変更部と、
リソースの解放指令を外部に発行する解放指令発行部と、
を備えることを特徴とするサービス連携装置。
【請求項２】
前記第１判定部は、前記流入データ量が前記流出データ量を超過する状態が継続している場合に、流入超過状態になると判定し、
前記第２判定部は、前記流入データ量が前記流出データ量の双方が通常処理量以下となる状態が継続している場合に、流入超過状態が解消すると判定する、
ことを特徴とする請求項１記載のサービス連携装置。
【請求項３】
前記第１判定部は、前記データ量記憶部が記憶する前記開始時刻から前記終了時刻までの時間である処理時間の増加傾向に基づいて、流入超過状態になるか否かを判定し、
前記第２判定部は、前記処理時間の減少傾向に基づいて、流入超過状態が解消するか否かを判定する、
ことを特徴とする請求項１記載のサービス連携装置。
【請求項４】
前記データ量記憶部は、前記メッセージ受信部が受信した前記メッセージごとに、前記開始時刻から前記終了時刻までの間における前記メッセージの流入超過状態をさらに対応付けて記憶し、
前記第１判定部は、前記データ量記憶部が記憶する前記流入超過状態に流入が超過している状態であることを示す超過情報が設定されている前記メッセージに対応する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定し、
前記第２判定部は、前記データ量記憶部が記憶する前記流入超過状態に流入が超過していない状態であることを示す非超過情報が設定されている前記メッセージに対応する前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する、
ことを特徴とする請求項１記載のサービス連携装置。
【請求項５】
連携元サーバから受信したメッセージを連携先サーバに送信するサービス連携装置が、
前記メッセージを受信するメッセージ受信ステップと、
前記連携先サーバにメッセージを送信する際の経路を決定する経路決定ステップと、
前記メッセージを前記連携先サーバ宛てに送信するメッセージ送信ステップと、
前記メッセージ受信ステップにおいて受信した前記メッセージのデータ容量である流入データ量を計測する流入データ量計測ステップと、
前記メッセージ送信ステップにおいて送信した前記メッセージのデータ容量である流出データ量を計測する流出データ量計測ステップと、
前記メッセージ受信ステップにおいて受信した前記メッセージごとに、前記メッセージ受信において前記メッセージの受信を開始した開始時刻、前記メッセージ送信において前記メッセージの送信を終了した終了時刻、流入データ量、および流出データ量を対応付けて記憶するデータ量記憶ステップと、
前記データ量記憶ステップが記憶する前記流入データ量および前記流出データ量に基づいて、流入超過状態になるか否かを判定する第１判定ステップと、
前記第１判定ステップにおいて流入超過状態になると判定した場合に、前記経路決定において決定した前記経路を、前記メッセージを一時的に格納する一時記憶部を経由して前記連携先サーバに送信する前記経路に変更する経路変更ステップと、
リソースの増強指令を外部に発行する増強指令発行ステップと、
前記増強指令に応じてリソースが増強された場合に、増強されたリソースを、前記一時記憶部に格納している前記メッセージの宛先に追加する経路追加ステップと、
前記データ量記憶部において記憶した前記流入データ量および前記流出データ量に基づいて、流入超過状態が解消するか否かを判定する第２判定ステップと、
前記第２判定ステップにおいて流入超過状態が解消すると判定した場合に、前記経路追加部において追加した前記メッセージの宛先を削除し、前記経路変更部において変更した前記経路を変更前の前記経路に戻す経路再変更ステップと、
リソースの解放指令を外部に発行する解放指令発行ステップと、
を含むことを特徴とするサービス連携方法。
【請求項６】
請求項５に記載の各ステップをコンピュータに実行させるためのサービス連携プログラム。
【図１】
【図２】
【図３】
【図４】
【図５】
【図６】
【図７】
【図８】
【図９】
【図１０】
【図１１】
【図１２】
【図１３】
【図１４】
【図１５】
【図１６】
【図１７】
【図２】
【図３】
【図４】
【図５】
【図６】
【図７】
【図８】
【図９】
【図１０】
【図１１】
【図１２】
【図１３】
【図１４】
【図１５】
【図１６】
【図１７】
【公開番号】特開２０１３−１０１５３０（Ｐ２０１３−１０１５３０Ａ）
【公開日】平成２５年５月２３日（２０１３．５．２３）
【国際特許分類】
【出願番号】特願２０１１−２４５３５６（Ｐ２０１１−２４５３５６）
【出願日】平成２３年１１月９日（２０１１．１１．９）
【出願人】（０００００４２３７）日本電気株式会社 (19,353)
【Ｆターム（参考）】
【公開日】平成２５年５月２３日（２０１３．５．２３）
【国際特許分類】
【出願日】平成２３年１１月９日（２０１１．１１．９）
【出願人】（０００００４２３７）日本電気株式会社 (19,353)
【Ｆターム（参考）】
[ Back to top ]