(57)【特許請求の範囲】
【請求項１】
それぞれが記憶装置と演算装置とを有する複数の構成要素からなり、前記複数の構成要素それぞれが、前記構成要素の属性を示す共通した種類の属性データを前記記憶装置に格納している分散システムにおける、前記構成要素のそれぞれによる前記属性データの一致化方法であって、
前記構成要素のそれぞれが、
設定時刻になった場合にまたは前回の属性データの一致化から設定周期分の時間が経過した場合にまたは事前に定義されたイベントが発生した場合に、属性データの一致化要求を他の構成要素へ送信し、
前記一致化要求を前記他の構成要素へ送信した場合に、または属性データの一致化要求を他の構成要素から受け取った場合に、自記憶装置内の属性データを前記他の構成要素へ送信し、
前記他の構成要素から、当該他の構成要素が有する属性データを受け取った場合に、前記他の構成要素から受け取った属性データ内容に基づいて、前記演算装置を用いて、当該構成要素自身が保持すべき属性データ内容を決定し、
前記自記憶装置に格納している前記属性データ内容を、決定した前記属性データ内容に修正し、
前記他の構成要素から受け取った属性データのすべてが、同一のデータでない場合に、前記他の構成要素に、再び属性データ内容の一致化要求を行う
ことを特徴とする属性データの一致化方法。
【請求項２】
請求項１に記載の属性データの一致化方法において、
前記属性データ内容の決定は、一定期間内に前記他の構成要素から受け取った属性データを用いて行う
ことを特徴とする属性データの一致化方法。
【請求項３】
請求項１に記載の属性データの一致化方法において、
前記属性データ内容の決定は、所定数の前記他の構成要素から受け取った属性データを用いて行う
ことを特徴とする属性データの一致化方法。
【請求項４】
請求項１に記載の属性データの一致化方法において、
当該構成要素による属性データの修正方法を、所定の周期で繰り返し実行する
ことを特徴とする属性データの一致化方法。
【請求項５】
それぞれが記憶装置と演算装置とを有する複数のＩＣタグからなり、前記複数の構成要素それぞれが、前記ＩＣタグの属性を示す共通した種類の属性データを前記記憶装置に格納している分散システムであって、
前記ＩＣタグのそれぞれは、
設定時刻になった場合にまたは前回の属性データの一致化から設定周期分の時間が経過した場合にまたは事前に定義されたイベントが発生した場合に、属性データの一致化要求を他のＩＣタグへ送信し、
前記一致化要求を前記他のＩＣタグへ送信した場合に、または属性データの一致化要求を他のＩＣタグから受け取った場合に、自記憶装置内の属性データを前記他のＩＣタグへ送信し、
前記他のＩＣタグから、当該他のＩＣタグが有する属性データを受け取った場合に、前記他のＩＣタグから受け取った属性データ内容に基づいて、前記演算装置を用いて、当該ＩＣタグ自身が保持すべき属性データ内容を決定し、
前記自記憶装置に格納している前記属性データ内容を、決定した前記属性データ内容に修正し、
前記他のＩＣタグから受け取った属性データのすべてが、同一のデータでない場合に、前記他のＩＣタグに、再び属性データ内容の一致化要求を行う手段とを備える
ことを特徴とする分散システム。
【請求項６】
それぞれが記憶装置と演算装置とを有する複数の構成要素からなり、前記複数の構成要素それぞれが、前記構成要素の属性を示す共通した種類の属性データを前記記憶装置に格納している分散システムにおける、前記構成要素のそれぞれによる前記属性データの一致化方法であって、
前記構成要素のそれぞれが、
設定時刻になった場合にまたは前回の属性データの一致化から設定周期分の時間が経過した場合にまたは事前に定義されたイベントが発生した場合に、他の構成要素が送信する生存信号を取得し、
前記属性データの一致化要求を、生存信号を送信した前記他の構成要素へ送信し、
前記一致化要求を前記他の構成要素へ送信した場合に、または属性データの一致化要求を他の構成要素から受け取った場合に、自記憶装置内の属性データのうち前記一致化要求に対応する属性データを前記他の構成要素へ送信し、
前記一致化要求に対応する属性データを前記他の構成要素から受信し、
前記他の構成要素から受信された前記一致化要求に対応する属性データに基づいて、前記自記憶装置内の前記一致化要求に対応する属性データの更新の要否を判定し、
前記属性データの更新が要であると判定した場合に、前記自記憶装置内の前記一致化要求に対応する属性データを、前記他の構成要素から受信された前記一致化要求に対応する属性データに更新し、
前記他の構成要素から受信された前記一致化要求に対応する属性データのすべてが、同一のデータでない場合に、再び属性データの一致化要求を前記他の構成要素へ送信する
ことを特徴とする属性データの一致化方法。
【請求項７】
請求項６に記載の属性データの一致化方法において、
前記構成要素のそれぞれが、
前記構成要素のそれぞれが有する内部時計の補正メッセージが、前記他の構成要素から受信した前記一致化要求に含まれている場合に、前記補正メッセージが示す時刻までの前記設定時刻または前記設定周期による前記属性データの一致化の処理をキャンセルする
ことを特徴とする属性データの一致化方法。
【請求項８】
請求項６に記載の属性データの一致化方法において、
前記構成要素のそれぞれが、
前記他の構成要素から受信された前記一致化要求に対応する属性データのうち同一のデータの数に応じて決定された前記一致化要求に対応する属性データに基づいて、前記自記憶装置内の前記一致化要求に対応する属性データの更新の要否を判定し、
前記属性データの更新が要であると判定した場合に、前記自記憶装置内の前記一致化要求に対応する属性データを、前記同一のデータの数に応じて決定された前記一致化要求に対応する属性データに更新する
ことを特徴とする属性データの一致化方法。
【請求項９】
それぞれが記憶装置と演算装置とを有する複数のＩＣタグからなり、前記複数のＩＣタグそれぞれが、前記ＩＣタグの属性を示す共通した種類の属性データを前記記憶装置に格納している分散システムであって、
前記ＩＣタグのそれぞれは、
設定時刻になった場合にまたは前回の属性データの一致化から設定周期分の時間が経過した場合にまたは事前に定義されたイベントが発生した場合に、他のＩＣタグが送信する生存信号を取得し、
前記属性データの一致化要求を、生存信号を送信した前記他のＩＣタグへ送信し、
前記一致化要求を前記他のＩＣタグへ送信した場合に、または属性データの一致化要求を他のＩＣタグから受け取った場合に、自記憶装置内の属性データのうち前記一致化要求に対応する属性データを前記他のＩＣタグへ送信し、
前記一致化要求に対応する属性データを前記他のＩＣタグから受信し、
前記他のＩＣタグから受信された前記一致化要求に対応する属性データに基づいて、前記自記憶装置内の前記一致化要求に対応する属性データの更新の要否を判定し、
前記属性データの更新が要であると判定した場合に、前記自記憶装置内の前記一致化要求に対応する属性データを、前記他のＩＣタグから受信された前記一致化要求に対応する属性データに更新し、
前記他のＩＣタグから受信された前記一致化要求に対応する属性データのすべてが、同一のデータでない場合に、再び属性データの一致化要求を前記他のＩＣタグへ送信する
ことを特徴とする分散システム。
【請求項１０】
請求項９に記載の分散システムにおいて、
前記ＩＣタグのそれぞれは、
前記ＩＣタグのそれぞれが有する内部時計の補正メッセージが、前記他のＩＣタグから受信した前記一致化要求に含まれている場合に、前記補正メッセージが示す時刻までの前記設定時刻または前記設定周期による前記属性データの一致化の処理をキャンセルする
ことを特徴とする分散システム。
【請求項１１】
請求項９に記載の分散システムにおいて、
前記ＩＣタグのそれぞれは、
前記他のＩＣタグから受信された前記一致化要求に対応する属性データのうち同一のデータの数に応じて決定された前記一致化要求に対応する属性データに基づいて、前記自記憶装置内の前記一致化要求に対応する属性データの更新の要否を判定し、
前記属性データの更新が要であると判定した場合に、前記自記憶装置内の前記一致化要求に対応する属性データを、前記同一のデータの数に応じて決定された前記一致化要求に対応する属性データに更新する
ことを特徴とする分散システム。
【発明の詳細な説明】
【０００１】
【発明の属する技術分野】
本発明は参入・離脱の発生する一つ以上の演算装置を有する構成要素からなる分散システムにおいて、分散して保持される共有データ間の一致化方法に関するものである。
【０００２】
【従来の技術】
本発明は分散システムにおいて、分散して保持される共有データ間の一致化方法に関するものである。分散システムにおいて、マスタデータとその部分集合のデータを複製として保持する複数のデータベースが分散して存在する際の複製データの更新方法に関しては、特開平10-320256に記載の分散データベースシステムのデータ更新制御方法および装置が知られている。
【０００３】
この方法によると、マスタデータを保持するマスタデータベース側に更新履歴ファイルを保持し、該マスタデータの更新発生時に、更新履歴ファイルの変更を行なうようにする。参照要求があった際に必ずマスタデータの更新履歴ファイルを参照し、更新があればマスタデータの保持するデータを取得する事としている。このようにする事でマスタデータベースのデータ更新と複製データベースのデータ更新を別々に行なう事が可能となり、マスタデータベースの更新に必要な時間を低減する事ができる。
【０００４】
さらに、多重化されたデータから正当なデータの検出を行なう方法としては、特開昭61-58050に記載の多重処理系の異常検出装置が知られている。この装置によると、多数決論理アルゴリズムを使用しており、多重化された処理系において処理されるデータを受信側で一定期間収集する。一定期間経過後、それまでに受信されたデータの内、同一の値を保持するデータ数の最も多いものを真値として取得する。
【０００５】
【発明が解決しようとする課題】
上記したような従来型の分散システムにおける共有データの一致化方式においては、マスタデータが存在していた。そのため、構成要素の参入・離脱が発生するような場合においては、マスタデータを保持する機器として離脱する事が無いものを設置する必要があり、冗長な構成となる可能性が高かった。あるいはマスタデータを保持する機器が離脱した場合にはシステムとして機能しなくなる危険性が高かった。
【０００６】
さらに上記したような特徴を持つため、マスタデータを保持する機器の故障などが発生した場合にもシステムとして機能しなくなる危険性が高く、それを回避するためにマスタデータを保持する機器の多重化を行なう必要があり、冗長な構成となる可能性が高かった。
【０００７】
さらに、上記した多重化されたデータからの正当なデータの検出を行なう多重処理系の異常検出装置においては、正当なデータを出す装置の数が多いという仮定のもとに成り立っている。そのため、人間の介在するシステム等においては、必ずしも数の多いものが、正当なデータであるという事にならないため問題となってくる。さらに、構成する機器の数が膨大である場合には一度に全てのデータの一致化を行なう事が難しいため、上記した手法では問題となってくる。
【０００８】
本発明は上記状況に鑑みてなされたもので、分散して保持する共有データの管理方法として、マスタおよび複製という区別をする事なしに管理する事とした。そして、これらの分散して保持する共有データの一致化においては、該共有データを保持する機器において、同一の値の共有データを保持する機器の多寡による事により分散システムを冗長な構成とする事なしに分散して保持される共有データの管理を行なう事を目的としている。この際に、データの正当性を示す重要度を定義し、該重要度を用いて重みづけをしてデータの一致化を行なう。
【０００９】
【課題を解決するための手段】
上記目的を達成するために本発明においては、一つ以上の演算装置を有する複数の構成要素からなる分散システムにおいて、該構成要素の参入・離脱が発生する際に、分散して共有データを保持し、かつ、これら複数の共有データ間においてマスタデータ、複製データという区別を無くした。そして、これらの共有データ間の一致化を多数決方式により行なう事とした。ここで、これらにより行われる多数決方式において、該共有データ毎に重要度を定義し、この重要度を重みとして共有データ間の一致化時の多数決方式に流用する。ここで、多数決方式とは、構成する機器間で同一のデータ値を保有する機器数の多寡に応じて、データの一致化をする方式である。重要度の定義方法としては、データの更新回数に基づいて決定する。あるいは、重要度の定義はデータの更新イベントを元に決定する。あるいは、重要度の定義はデータの更新時刻を元に決定する。
【００１０】
ここで、多数決方式により行われる共有データ間の一致化は該構成要素の要求に基づいて行われる。あるいは、いずれかの共有データへのアクセスに基づいて多数決方式によって共有データ間の一致化が行われる。あるいは、事前に定義された設定情報に基づいて周期的に共有データ間の一致化が多数決方式により行われる。あるいは事前に定義された設定情報に基づいて設定された時刻となった時に共有データ間の一致化が多数決方式により行われる。ここで、上記の設定情報は該分散システムの運用中に利用者により変更が行なわれてもよい。また、これらの一致化を繰り返す。
【００１１】
上述のように、マスタデータ、複製データの区別をする事なく分散して保持される共有データ間の一致化をする事によって、構成要素の参入・離脱があるシステムにおいても冗長な構成を取る必要がなくなる。さらに、マスタデータを保持する機器の故障等による周囲の構成要素への影響を低減する事が可能となる。さらに、多数決方式においてそれぞれのデータあるいは機器毎に定義される重要度を重みとして用いるため、多数決方式の結果、得られるデータの正当性が増す。さらに、データの一致化を繰り返すことによりより多くのデータの一致化が図れる。
【００１２】
【発明の実施の形態】
以下、本発明の実施の形態について図面により詳細に説明する。
【００１３】
（実施例１）図１は本発明の分散システムにおける情報一致化方法を小売店などにおける販売価格管理システムに適用した例を示す該略図である。１は販売店における商品の棚状の陳列ケースを示し、陳列ケース１の中に商品２が陳列されている。ここで、商品２としては、例えば缶入りの飲料であったり、生鮮食料品であったりしてよい。さらに、商品２は小売店によって販売価格が異なるものである。また、これらの商品にはＩＣタグ３が貼り付けられている。ＩＣタグ３には図２に示すような情報が保持されている。商品ＩＤ１１はＩＣタグ３が貼り付けられている商品の種別を示す情報である。価格１２はＩＣタグ３が貼り付けれれている商品の実際の販売価格を示す情報であり、この図の例では１００円という事になっている。
【００１４】
さらに、有効期間１３は価格１２の設定が有効で価格１２を実際の販売価格とする期間を示しており、例えばセール時など一定期間のみ価格変更となる場合に利用する事が可能である。さらに、この例の場合有効期間１３では、開始日時は設定されておらず、また、終了日時は１９９９年１２月３０日までとなっている。この場合は有効期間１３の設定時点から価格１２が有効である事を示している。
【００１５】
さらに、有効期間１３は無期限と設定する事も可能である。あるいは、有効期間１３はタイムセールのようなものを設定する事も可能であり、このようなものの場合には顧客が陳列ケース１から商品を出した時点での時刻をＩＣタグ３に記憶させ、これからタイムセール中の価格か否かを判定してもよい。また、標準価格１４は通常時の販売価格を示すものであり、有効期間１１がすぎた際の販売価格を示す。図１の４はＩＣタグ３の図２に示す設定情報を設定する機器を示している。販売価格の管理を行なう運用者５は機器４によって販売価格の初期設定を行なう。この設定は販売価格の初期設定時、設定変更時などの画一的に関連する商品の価格の変更を行なう際に限られる。ここで、設定時においては、機器４より図３に示す情報を無線により商品２に貼り付けられているＩＣタグ３に対して送信する。
【００１６】
図４に機器４より情報を受信したＩＣタグ３における処理の流れを示す。ＩＣタグ３は常時、設定情報変更要求の受信待機を行なっている。まず、ＳＴ１において設定情報変更要求メッセージを機器４より受信する。受信するメッセージは図３に示されるもので、変更要求送信先の商品の種別を示す商品ＩＤ２１と設定する価格２２、および、価格２２が商品２の販売価格として有効な期間を示す有効期間２３よりなる。次にＳＴ２に進み、受信した設定情報変更要求メッセージの商品ＩＤ２１が妥当かどうかの判定を行なう。例えば、ＩＣタグ３に保持されている商品ＩＤ１１と設定情報変更要求メッセージの商品ＩＤ２１が同一かどうかという判定が行なわれる。ＳＴ２における判定の結果、商品ＩＤが妥当だと判定されると、ＳＴ３において、ＩＣタグ３に保持されている価格１２と有効期間１３が設定情報変更要求メッセージの価格２２と有効期間２３にそれぞれ置き換えられる。この処理が終了すると再び設定情報変更要求受信待機となる。また、ＳＴ２において、商品ＩＤが妥当でないと判定されると、この処理が終了し、再び設定情報変更要求受信待機となる。
【００１７】
次に本発明の分散システムにおける共有データ間の一致化方法での処理の流れを図５に示す。まず、ＳＴ１１において、設定時刻になっているか否かの判定が行なわれる。あるいは、前回の情報一致化処理実行時から設定周期分時間が経過しているか否かの判定が行なわれる。ここで、ＳＴ１１において利用する起動時刻３１、前回の情報一致化処理実行時刻を示す前回起動時刻３２、設定周期３３といった情報を図６に示すようなテーブルの形でＩＣタグ３に持たせてもよい。起動時刻３１に関しては複数設定してもよい。あるいは、起動時刻３１、設定周期３３は設定しなくてもよい。
【００１８】
ＳＴ１１において設定時刻になっていないあるいは設定周期分時間が経過していないと判定されるとＳＴ１２に進む。ＳＴ１２においては、一致化処理の起動トリガとして事前に定義されたイベントの発生の有無の判定が行なわれる。ここで、該イベントとしては、構成要素の参入・離脱や共有データへのアクセス等が考えられ、この実施例に沿えば、例えば顧客による商品２の購入、陳列ケース１の商品２の不足に伴う該商品２の補充、あるいは、ＩＣタグ３の保持する価格１２の確認等が考えられる。ＳＴ１２において、該イベントが発生しなかったと判定されるとＳＴ１３に進む。ＳＴ１３では、他構成要素からの一致化要求の有無が判定される。ここで、他構成要素からの一致化要求がないと判定されると、一定時間待機した後、ＳＴ１１に戻る。ここで、ＳＴ１１において設定時刻になっているあるいは設定周期分時間が経過していると判定されるとＳＴ１４に進む。
【００１９】
また、ＳＴ１２において、該イベントが発生したと判定されるとＳＴ１４に進む。また、ＳＴ１３において、他構成要素からの一致化要求があると判定されると、ＳＴ１６に進む。この際に、ＩＣタグ３が保持する内部時計の補正メッセージも同時に受信され、このメッセージを元にＩＣタグ３の保持する内部時計の補正を行なう。補正メッセージを受信するとその補正メッセージが示す時刻までの設定時刻、設定周期の共有データの一致化処理をキャンセルする。ＳＴ１４においては、構成要素の取得を行なう。ここで、構成要素の取得に関しては、それぞれの構成要素が周期的に送信する生存信号を用いたものなどが考えられる。また、本実施例における構成要素としては同一の陳列ケース１上の商品２（ＩＣタグ３）全てである。
【００２０】
次にＳＴ１５に進み、これらの構成要素に対して一致化要求メッセージの送信を行なう。この一致化要求メッセージに該メッセージ送出構成要素によるそれぞれのＩＣタグ３が保持する内部時計に対しての補正メッセージを添付し、送信する。ＳＴ１６においては、一致化要求のあった共有データに関して、ＩＣタグ３が保持するデータの送信を行なう。ここで、共有データとしては、例えば、ＩＣタグ３が保持する価格１２および有効期間１３が考えられる。さらに、ＳＴ１７において、ＳＴ１６で送出された該共有データの受信を行なう。該メッセージの取得においては一定期間該メッセージの取得を行ない、ＳＴ１８に進むとしてもよい。あるいは、ＳＴ１４で取得した構成要素数を元にして、一定数番目までのメッセージを取得した場合にＳＴ１８に進むとしてもよい。
【００２１】
ＳＴ１８においては、該共有データの更新が必要か否かといった判定を行なう。この判定においてはＳＴ１７において取得したメッセージのみを利用する。ＳＴ１７において取得したメッセージのうち、同一の値のデータが一番多かったものを該共有データの値とする。ここで、それぞれのデータに関して重要度をＩＣタグ３において機器毎、あるいは、データ毎に設定し、この重要度を重みとして上記評価に流用する。この重要度による評価は共有データ数が不定のために、例えば最初から陳列ケースにある商品は数が少なくてもデータの信頼性が高いなどにより単純に多数決方式のみで決定できない事に依存する。そのため、これらの場合においては、例えば、データ更新の回数に応じて重要度があがる。あるいは、機器４にデータの更新を行われた際の重要度を高くするなどの事が可能である。あるいは、利用者による直接のデータ値の設定時に重要度を高くするとしてもよい。あるいは、データ更新時刻に応じてデータ更新時刻の遅いものの重要度を高くするとしてもよい。この判定結果により、該共有データの更新が必要と判定されるとＳＴ１９に進み、該共有データの更新を行なう。
【００２２】
ここで、取得したデータが全て同一のデータでなかった場合には、全てのデータの一致化が行なわれていない可能性があるとして、再びデータの一致化要求を行ってもよい。そして、一定時間待機の後、ＳＴ１１に戻る。また、ＳＴ１８において該共有データの更新が不要と判定されると、一定時間待機の後、ＳＴ１１に戻る。このように一致化をする事により、小売店毎に異なる販売価格を入荷時に毎回設定する事なしに、データ入力を行なう事が可能となる。
【００２３】
なお、本発明は、図７に示すシステムを用いて、商品の広告方法にも適用可能である。販売価格が一致化された場合、一致化された販売価格を含んだ、商店の情報処理装置からインターネットなどのネットワークを介して、顧客の情報処理装置に送信するようにしてもよい。ここで、商店の情報処理装置を介さずに、商品から顧客に送信するようにしてもよい。また、顧客への連絡は、顧客の情報処理装置に送信するのでなく、ファクシミリ、電話などで送信するようにしてもよい。また、さらに広告を顧客に送信するのでなく、商店内などのディスプレイに表示する構成としてもよい。
【００２４】
また、さらに、一致化された値段を用いて、図７に示すシステムで電子商取引を実行してもよい。このためには、商店の情報処理装置が記憶している商品に関する情報のうち、値段を示す情報を、一致化された場合に訂正する。そして、訂正された値段に基づいて、電子商取引を実行する。
【００２５】
【発明の効果】
以上説明したように本発明によれば、マスタデータ、複製データの区別無く、分散して保持される共有データの一致化を行なう事ができるので、構成要素の参入・離脱が常時起こりうる分散システムにおいても機能する。さらに、これらの分散して保持する共有データの一致化においては、該共有データを保持する機器において、同一の値の共有データを保持する機器の多寡によって該共有データの一致化を行なう事により分散システムを冗長な構成とする事なしに該共有データの管理を行なう事ができる。さらにデータあるいは機器毎に重要度を定義して、多数決方式による重みづけに利用しているため、より正当性の高いデータを得る事が可能となる。さらに、繰り返しデータの一致化を行なうようにしているため、より多くのデータの一致化を行なう事が出来る。
【図面の簡単な説明】
【図１】本発明を小売店などにおける販売価格管理システムに適用した例を示す該略図である。
【図２】商品に貼り付けるＩＣタグに保持される設定情報管理テーブルを示す構成図である。
【図３】商品への設定情報変更要求メッセージの内容を示す構成図である。
【図４】ＩＣタグの初期設定および設定変更時の処理を示すフローチャートである。
【図５】ＩＣタグにおいて分散して保持される共有データの一致化処理を示すフローチャートである。
【図６】ＩＣタグに保持される一致化処理の起動条件を示すテーブルの構成図である。
【図７】本発明を広告方法に適用するためのシステム構成を示す図である。
【符号の説明】
１：陳列ケース、２：商品、３：タグ、４：機器、５：運用者、１１：商品ＩＤ、１２：価格、１３：有効期間
【図１】
0004158297.tif 000002
【図２】
0004158297.tif 000003
【図３】
0004158297.tif 000004
【図４】
0004158297.tif 000005
【図５】
0004158297.tif 000006
【図６】
0004158297.tif 000007
【図７】
0004158297.tif 000008