Deprecated: The each() function is deprecated. This message will be suppressed on further calls in /home/zhenxiangba/zhenxiangba.com/public_html/phproxy-improved-master/index.php on line 456
JP5678819B2 - COMMUNICATION DEVICE, COMMUNICATION PROGRAM, AND COMMUNICATION METHOD - Google Patents
[go: Go Back, main page]

JP5678819B2 - COMMUNICATION DEVICE, COMMUNICATION PROGRAM, AND COMMUNICATION METHOD - Google Patents

COMMUNICATION DEVICE, COMMUNICATION PROGRAM, AND COMMUNICATION METHOD Download PDF

Info

Publication number
JP5678819B2
JP5678819B2 JP2011143395A JP2011143395A JP5678819B2 JP 5678819 B2 JP5678819 B2 JP 5678819B2 JP 2011143395 A JP2011143395 A JP 2011143395A JP 2011143395 A JP2011143395 A JP 2011143395A JP 5678819 B2 JP5678819 B2 JP 5678819B2
Authority
JP
Japan
Prior art keywords
task
event
communication device
information
communication
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Expired - Fee Related
Application number
JP2011143395A
Other languages
Japanese (ja)
Other versions
JP2013012853A (en
Inventor
園田 俊浩
俊浩 園田
剛陽 寺田
剛陽 寺田
芳樹 東角
芳樹 東角
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Fujitsu Ltd
Original Assignee
Fujitsu Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Fujitsu Ltd filed Critical Fujitsu Ltd
Priority to JP2011143395A priority Critical patent/JP5678819B2/en
Publication of JP2013012853A publication Critical patent/JP2013012853A/en
Application granted granted Critical
Publication of JP5678819B2 publication Critical patent/JP5678819B2/en
Expired - Fee Related legal-status Critical Current
Anticipated expiration legal-status Critical

Links

Images

Landscapes

  • Selective Calling Equipment (AREA)
  • Telephonic Communication Services (AREA)

Description

本発明は、通信する通信装置、通信プログラム、および通信方法に関する。   The present invention relates to a communication device, a communication program, and a communication method for communicating.

近年、機器の管理機能や通信機能を有する高機能な電力メータであるスマートメータを用いて、電力利用情報をサーバに収集し、課金サービス等に応用するスマートメータシステムの提供が行われつつある。以下の説明において、各スマートメータシステム内の各スマートメータからの電力情報、温度情報等の収集処理、および分析処理をタスクと呼称し、測定対象の属性である電力情報、温度情報、といった各スマートメータが測定可能な情報をイベントと呼称する。スマートメータシステムは、タスクを実行するサーバと、サーバに接続され、階層構造を有する中継器と、中継器に接続されたスマートメータが存在する。   In recent years, a smart meter system that collects power usage information in a server by using a smart meter, which is a high-performance power meter having a device management function and a communication function, and is applied to a billing service or the like is being provided. In the following description, collection processing and analysis processing of power information, temperature information, etc. from each smart meter in each smart meter system are referred to as tasks, and each smart such as power information, temperature information, which is a measurement target attribute. Information that can be measured by the meter is called an event. The smart meter system includes a server that executes a task, a repeater that is connected to the server and has a hierarchical structure, and a smart meter that is connected to the repeater.

イベントを収集する技術として、たとえば、Publish/Subscribeというものがある。具体的に、イベントを要求する送信装置は、イベント要求を送信する。イベント要求を受信した受信装置は、下位の装置から送信されてきたイベントを送信装置に送信する。なお、送信されてきたイベントを送信装置に送信するため、受信装置は、イベントと送信装置の識別情報を含む経路情報を登録しておき、イベントを受信した場合、登録された経路情報に従って、受信したイベントを送信装置に送信する。   As a technique for collecting events, there is, for example, Publish / Subscribe. Specifically, a transmission device that requests an event transmits an event request. The receiving device that has received the event request transmits the event transmitted from the lower device to the transmitting device. In addition, in order to transmit the transmitted event to the transmission device, the reception device registers route information including the event and the identification information of the transmission device. When the event is received, the reception device receives the event according to the registered route information. The event is transmitted to the transmission device.

また、スマートメータシステムは、イベントとタスクの増加に伴って、サーバの負荷が増大する。そこで、スマートメータシステムは、中継器にタスクを委譲することで、サーバの負荷を軽減することができる。タスクを委譲する技術に関連する技術として、たとえば、各中継器が自装置の処理能力に関する情報を登録しておき、タスクを委譲するサーバは、登録された情報のうち、タスクの処理能力等といった条件に合致した中継器にタスクを委譲するといったものがある。   In the smart meter system, the load on the server increases with an increase in events and tasks. Therefore, the smart meter system can reduce the load on the server by delegating the task to the repeater. As a technology related to the task delegation technology, for example, each repeater registers information on the processing capability of its own device, and the server delegating the task includes the task processing capability among the registered information. There are things such as delegating tasks to repeaters that meet the conditions.

特開2003−167808号公報Japanese Patent Laid-Open No. 2003-167808

しかしながら、上述した従来技術において、イベント要求を受けた中継器は、経路情報を登録するが、中継器がイベント要求に対応するイベントを受信しない場合もあり、この場合、使用されることのない経路情報が登録されてしまっていた。イベントが委譲されると各中継器でイベント情報が登録されていくため、登録される経路情報が増大してしまうという問題があった。   However, in the above-described prior art, the relay device that has received the event request registers the route information, but the relay device may not receive an event corresponding to the event request, and in this case, a route that is not used. Information has been registered. When an event is delegated, event information is registered in each repeater, so that there is a problem in that registered route information increases.

本発明は、上述した従来技術による問題点を解消するため、経路情報の増大を抑制できる通信装置、通信プログラム、および通信方法を提供することを目的とする。   An object of the present invention is to provide a communication device, a communication program, and a communication method that can suppress an increase in route information in order to solve the above-described problems caused by the related art.

上述した課題を解決し、目的を達成するため、本発明の一側面によれば、木構造のネットワーク内に存在し、下位の装置から測定対象の属性に関する特徴量の収集要求を受信すると測定対象の属性情報と下位の装置の識別情報とを自装置の記憶領域に記憶しつつ、収集要求を上位の装置に送信する通信装置であって、測定対象の属性に関する特徴量を複数の下位の装置から収集する装置のうちネットワーク内で最上位となる装置が自装置であるか否かを示す評価値を設定し、収集要求を受信した場合、設定された評価値が最上位となる装置を示しているか否かを判断し、評価値が最上位となる装置であると判断された場合、収集要求を上位の装置に送信しないように制御する通信装置、通信プログラム、および通信方法が提案される。   In order to solve the above-described problems and achieve the object, according to one aspect of the present invention, a measurement target exists in a tree-structured network and receives a feature amount collection request regarding the measurement target attribute from a lower-level device. The communication apparatus transmits the collection request to the upper apparatus while storing the attribute information and the identification information of the lower apparatus in the storage area of the own apparatus. Sets the evaluation value that indicates whether the highest device in the network is the device that collects from the network, and indicates the device that has the highest evaluation value when the collection request is received. A communication device, a communication program, and a communication method are proposed for controlling so that a collection request is not transmitted to a higher-order device when it is determined that the device has the highest evaluation value. .

本発明の一側面によれば、経路情報の増大を抑制できるという効果を奏する。   According to one aspect of the present invention, there is an effect that an increase in route information can be suppressed.

図1−1は、スマートメータシステム100の動作例を示す説明図(その1)である。1-1 is an explanatory diagram (part 1) of an operation example of the smart meter system 100. FIG. 図1−2は、スマートメータシステム100の動作例を示す説明図(その2)である。FIG. 1-2 is an explanatory diagram (part 2) of an operation example of the smart meter system 100. 図2は、実施の形態にかかる通信装置102のハードウェアを示すブロック図である。FIG. 2 is a block diagram of hardware of the communication device 102 according to the embodiment. 図3は、スマートメータシステム100の機能を示すブロック図である。FIG. 3 is a block diagram illustrating functions of the smart meter system 100. 図4は、経路情報テーブル104の記憶内容の一例を示す説明図である。FIG. 4 is an explanatory diagram illustrating an example of the contents stored in the route information table 104. 図5は、処理分割テーブル311の記憶内容の一例を示す説明図である。FIG. 5 is an explanatory diagram showing an example of the contents stored in the process division table 311. 図6は、メッセージタスク関係テーブル312の記憶内容の一例を示す説明図である。FIG. 6 is an explanatory diagram showing an example of the contents stored in the message task relation table 312. 図7は、タスク情報313のフォーマット例を示す説明図である。FIG. 7 is an explanatory diagram showing a format example of the task information 313. 図8は、サーバ101におけるタスク情報313の処理例を示す説明図である。FIG. 8 is an explanatory diagram illustrating a processing example of the task information 313 in the server 101. 図9は、メッセージ記憶テーブル331の記憶内容の一例を示す説明図である。FIG. 9 is an explanatory diagram showing an example of the stored contents of the message storage table 331. 図10は、イベント要求メッセージ332のフォーマット例を示す説明図である。FIG. 10 is an explanatory diagram showing a format example of the event request message 332. 図11は、タスクが委譲される状態を示す説明図(その1)である。FIG. 11 is an explanatory diagram (part 1) illustrating a state in which tasks are delegated. 図12は、タスクが委譲される状態を示す説明図(その2)である。FIG. 12 is an explanatory diagram (part 2) of the task being delegated. 図13は、タスクが委譲される状態を示す説明図(その3)である。FIG. 13 is an explanatory diagram (part 3) illustrating a state where tasks are delegated. 図14は、タスクが委譲される状態を示す説明図(その4)である。FIG. 14 is an explanatory diagram (part 4) illustrating a state in which tasks are delegated. 図15は、イベント要求メッセージ332が送信された状態を示す説明図である。FIG. 15 is an explanatory diagram showing a state in which the event request message 332 has been transmitted. 図16は、イベント333が収集される状態を示す説明図である。FIG. 16 is an explanatory diagram showing a state in which the event 333 is collected. 図17は、スマートメータシステム100におけるタスク委譲実行処理の一例を示すフローチャートである。FIG. 17 is a flowchart illustrating an example of task delegation execution processing in the smart meter system 100. 図18は、サーバ101におけるタスク委譲処理の一例を示すフローチャートである。FIG. 18 is a flowchart illustrating an example of task delegation processing in the server 101. 図19は、通信装置タスク委譲処理の一例を示すフローチャートである。FIG. 19 is a flowchart illustrating an example of the communication device task delegation process. 図20は、通信装置102におけるイベント分岐設定処理の一例を示すフローチャートである。FIG. 20 is a flowchart illustrating an example of event branch setting processing in the communication apparatus 102. 図21は、通信装置102におけるイベント要求メッセージ送信処理の一例を示すフローチャートである。FIG. 21 is a flowchart illustrating an example of an event request message transmission process in the communication apparatus 102. 図22は、通信装置102における経路情報設定処理の一例を示すフローチャートである。FIG. 22 is a flowchart illustrating an example of route information setting processing in the communication apparatus 102. 図23は、通信装置102におけるイベント収集処理の一例を示すフローチャートである。FIG. 23 is a flowchart illustrating an example of event collection processing in the communication apparatus 102. 図24は、通信装置102におけるタスク完了時処理の一例を示すフローチャートである。FIG. 24 is a flowchart illustrating an example of task completion processing in the communication apparatus 102.

以下に添付図面を参照して、開示の通信装置、通信プログラム、および通信方法の実施の形態を詳細に説明する。   Exemplary embodiments of a disclosed communication device, communication program, and communication method will be described below in detail with reference to the accompanying drawings.

図1−1、図1−2は、スマートメータシステム100の動作例を示す説明図である。スマートメータシステム100は、タスクを実行するサーバ101と、中継器となる通信装置102と、スマートメータを有する端末103と、を含む。図1−1で示す説明図は、タスクを委譲する場合の動作例を示しており、図1−2で示す説明図は、イベントを収集する場合の動作例を示している。   FIGS. 1-1 and 1-2 are explanatory diagrams illustrating an operation example of the smart meter system 100. FIG. The smart meter system 100 includes a server 101 that executes a task, a communication device 102 that serves as a relay, and a terminal 103 that includes a smart meter. The explanatory diagram shown in FIG. 1A shows an example of operation when a task is delegated, and the explanatory diagram shown in FIG. 1B shows an example of operation when an event is collected.

サーバ101は、端末103からの送信されるイベントを用いてタスクを実行する、CEP(Complex Event Processing)という技術が適用されたサーバである。通信装置102は、端末103からのイベントを中継し、サーバ101に送信する。端末103は、測定対象となるビルや家屋に設置されており、周期的に通信装置102にイベントを送信する。   The server 101 is a server to which a technique called CEP (Complex Event Processing) that executes a task using an event transmitted from the terminal 103 is applied. The communication device 102 relays the event from the terminal 103 and transmits it to the server 101. The terminal 103 is installed in a building or house to be measured, and periodically transmits an event to the communication device 102.

サーバ101、通信装置102、端末103の接続関係として、スマートメータシステム100は、木構造のネットワークであり、サーバ101が最上位の装置であり、端末103が末端の装置となる。サーバ101は、下位の装置として通信装置102−Gと接続している。通信装置102−Gは、下位の装置として通信装置102−E、通信装置102−Fと接続している。通信装置102−Fは、下位の装置として家屋に設置された端末103−F1と接続している。   As a connection relationship between the server 101, the communication device 102, and the terminal 103, the smart meter system 100 is a tree-structured network, the server 101 is the highest-level device, and the terminal 103 is the terminal device. The server 101 is connected to the communication device 102-G as a lower device. The communication device 102-G is connected to the communication device 102-E and the communication device 102-F as lower devices. The communication device 102-F is connected to a terminal 103-F1 installed in a house as a lower device.

通信装置102−Eは、下位の装置として通信装置102−C、通信装置102−Dと接続している。通信装置102−Dは、下位の装置として家屋に設置された端末103−D1、端末103−D2と接続している。通信装置102−Cは、下位の装置として通信装置102−A、通信装置102−Bと接続している。通信装置102−Bは、下位の装置として家屋に設置された端末103−B1およびビルに設置された端末103−B2と接続している。通信装置102−Aは、下位の装置としてビルに設置された端末103−A1と接続している。   The communication device 102-E is connected to the communication device 102-C and the communication device 102-D as lower devices. The communication device 102-D is connected to a terminal 103-D1 and a terminal 103-D2 installed in a house as lower devices. The communication device 102-C is connected to the communication device 102-A and the communication device 102-B as lower devices. The communication device 102-B is connected to a terminal 103-B1 installed in a house and a terminal 103-B2 installed in a building as lower devices. The communication device 102-A is connected to a terminal 103-A1 installed in the building as a lower device.

以下の説明において、ハードウェア、ソフトウェアの符号に“−S”となる接尾記号が付与されている場合は、サーバ101に関するハードウェア、ソフトウェアであることを示す。また、ハードウェア、ソフトウェアの符号に“−A”〜“−G”となる接尾記号が付与されている場合は、通信装置102−A〜通信装置102−Gに関するハードウェア、ソフトウェアであることを示す。   In the following description, when the suffix of “−S” is added to the hardware and software codes, this indicates hardware and software related to the server 101. Further, when suffixes “-A” to “-G” are given to the hardware and software codes, the hardware and software are related to the communication devices 102-A to 102-G. Show.

また、サーバ101と通信装置102は、経路情報テーブル104を有する。経路情報テーブル104は、タスクを委譲要求するメッセージ、またはイベントを受信したときに、メッセージ、イベントの転送先となる装置を記憶するテーブルである。また、経路情報テーブル104の1レコードを経路情報と定義する。たとえば、経路情報テーブル104−Gは、ビルの温度情報と家屋の温度情報を測定可能である温度センサが通信装置102−Eの方向に、家屋の温度センサが通信装置102−Fの方向に登録されていることが示されている。したがって、通信装置102−Gは、ビルの温度情報を用いるタスクの委譲要求を受信した場合、委譲要求を通信装置102−Eに送信する。   Further, the server 101 and the communication device 102 have a route information table 104. The route information table 104 is a table that stores a message or event transfer destination device when a message or event requesting task delegation is received. Also, one record of the route information table 104 is defined as route information. For example, in the path information table 104-G, a temperature sensor capable of measuring building temperature information and house temperature information is registered in the direction of the communication device 102-E, and a house temperature sensor is registered in the direction of the communication device 102-F. It has been shown that. Therefore, when receiving a task delegation request that uses building temperature information, the communication device 102-G transmits a delegation request to the communication device 102-E.

図1−1にて、サーバ101は、ビルの平均温度を算出するタスク111を通信装置102のいずれかに委譲要求するメッセージであるタスク委譲要求メッセージを通信装置102−Gに送信する。タスク委譲要求メッセージを受信した通信装置102は、イベントを複数の下位の装置から収集する装置のうち、スマートメータシステム100内で最上位となる装置が自装置であるか否かを示す評価値を設定する。以下の説明では、前述の条件が満たされた場合、通信装置102は、評価値を“分岐開始”として設定する。   In FIG. 1, the server 101 transmits a task delegation request message, which is a message for delegating a task 111 for calculating the average temperature of a building to one of the communication devices 102, to the communication device 102 -G. The communication device 102 that has received the task delegation request message receives an evaluation value indicating whether or not the highest device in the smart meter system 100 among the devices that collect events from a plurality of lower devices is its own device. Set. In the following description, when the above-described condition is satisfied, the communication apparatus 102 sets the evaluation value as “start of branch”.

また、通信装置102は、評価値が“分岐開始”として設定されたかを示す設定情報を下位の装置に送信する。本実施の形態では、通信装置102は、設定情報をタスク委譲要求メッセージに含めて送信する。評価値が“分岐開始”として設定されていない場合、設定情報は“未分岐”であり、設定された場合、“分岐済”であると定義する。   In addition, the communication apparatus 102 transmits setting information indicating whether the evaluation value is set as “branch start” to the lower apparatus. In the present embodiment, communication device 102 transmits setting information included in a task delegation request message. When the evaluation value is not set as “branch start”, the setting information is defined as “unbranched”, and when set, it is defined as “branched”.

初めに、通信装置102−Gは、複数の下位の装置から該当のイベントを収集する装置であるかを判断する。ビルの温度情報は通信装置102−E1つから収集されるため、通信装置102−Gは、評価値を“分岐開始”として設定せずに、経路情報テーブル104−Gに従って設定情報が“未分岐”となるタスク委譲要求メッセージを通信装置102−Eに転送する。同様に、通信装置102−Eも、評価値を“分岐開始”として設定せずに、経路情報テーブル104−Eに従ってタスク委譲要求メッセージを通信装置102−Cに転送する。   First, the communication device 102-G determines whether it is a device that collects a corresponding event from a plurality of lower devices. Since the building temperature information is collected from one communication device 102-E, the communication device 102-G does not set the evaluation value as “branch start”, and the setting information is “unbranched” according to the route information table 104-G. The task delegation request message that becomes “is transferred to the communication apparatus 102 -E. Similarly, the communication device 102-E also transfers the task delegation request message to the communication device 102-C according to the route information table 104-E without setting the evaluation value as “start of branch”.

タスク委譲要求メッセージを受信した通信装置102−Cは、設定情報が“未分岐”であり、ビルの温度情報が通信装置102−A、通信装置102−Bの複数から収集されるため、評価値112を“分岐開始”として設定する。設定後、通信装置102−Cは、通信装置102−Aに設定情報が“分岐済”となるタスク委譲要求メッセージを送信する。通信装置102−Aは、タスク111を実行する。   The communication device 102-C that has received the task delegation request message has the setting information “unbranched” and the building temperature information is collected from a plurality of communication devices 102-A and 102-B. 112 is set as “start of branch”. After the setting, the communication device 102-C transmits a task delegation request message in which the setting information becomes “branched” to the communication device 102-A. The communication device 102-A executes the task 111.

このように、スマートメータシステム100は、複数の下位の装置から該当のイベントを収集する装置のうちスマートメータシステム100内で最上位の装置に評価値を設定することで、イベントの分岐開始点が判断できる。図1−1の例では、通信装置102−D〜通信装置102−F側では、ビルの温度情報を収集しないため、イベントに対応する経路情報が存在しなくてよい。   As described above, the smart meter system 100 sets an evaluation value in the highest device in the smart meter system 100 among devices that collect the corresponding event from a plurality of lower devices, so that the branch start point of the event is set. I can judge. In the example of FIG. 1-1, the communication device 102-D to the communication device 102-F do not collect building temperature information, and therefore do not have route information corresponding to the event.

次に、図1−2に示す説明図にて、通信装置102−Aは、タスク111を実行するときに、イベントの収集要求であるイベント要求メッセージを上位の通信装置である通信装置102−Cに送信する。イベント要求メッセージを受信した通信装置102−Cは、ビルの温度情報を通信装置102−Aに送信する経路情報を経路情報テーブル104−Cに追加する。これにより、イベント収集において、通信装置102−Cは、通信装置102−Bからイベントを受信した場合、追加した経路情報に従って、イベントを通信装置102−Aに送信する。   Next, in the explanatory diagram illustrated in FIG. 1B, when the communication apparatus 102-A executes the task 111, the communication apparatus 102-C transmits an event request message that is an event collection request as a higher-level communication apparatus. Send to. Receiving the event request message, the communication device 102-C adds route information for transmitting the building temperature information to the communication device 102-A to the route information table 104-C. Thereby, in event collection, when receiving an event from the communication device 102-B, the communication device 102-C transmits the event to the communication device 102-A according to the added path information.

また、通信装置102−Cは、評価値112が“分岐開始”であるかを判断する。通信装置102−Cは、評価値112が“分岐開始”であるため、イベント要求メッセージを通信装置102−Eに送信しないように制御する。   Further, the communication apparatus 102-C determines whether or not the evaluation value 112 is “start of branch”. Since the evaluation value 112 is “start of branch”, the communication device 102-C controls not to transmit the event request message to the communication device 102-E.

これにより、通信装置102−Eはイベント要求メッセージを受信しないため、経路情報を追加することがなく、スマートメータシステム100は、経路情報の増大を抑制することができる。続けて、図1−1、図1−2で行った動作を実現するハードウェア、ソフトウェアの説明を図2〜図24を用いて行う。   Accordingly, since the communication device 102-E does not receive the event request message, the smart meter system 100 can suppress an increase in the route information without adding route information. Subsequently, hardware and software for realizing the operations performed in FIGS. 1-1 and 1-2 will be described with reference to FIGS.

図2は、実施の形態にかかる通信装置102のハードウェアを示すブロック図である。図2において、通信装置102は、CPU(Central Processing Unit)201と、ROM(Read‐Only Memory)202と、RAM(Random Access Memory)203と、を含む。また、通信装置102は、フラッシュROM204と、I/F(Interface)205と、を含む。また、各部はバス206によってそれぞれ接続されている。   FIG. 2 is a block diagram of hardware of the communication device 102 according to the embodiment. In FIG. 2, the communication apparatus 102 includes a CPU (Central Processing Unit) 201, a ROM (Read-Only Memory) 202, and a RAM (Random Access Memory) 203. The communication device 102 includes a flash ROM 204 and an I / F (Interface) 205. Each unit is connected by a bus 206.

ここで、CPU201は、通信装置102の全体の制御を司る。なお、通信装置102は、複数のCPUを含むマルチコアプロセッサシステムであってもよい。ここで、マルチコアプロセッサシステムとは、コアが複数搭載されたプロセッサを含むコンピュータのシステムである。   Here, the CPU 201 governs overall control of the communication apparatus 102. Note that the communication device 102 may be a multi-core processor system including a plurality of CPUs. Here, the multi-core processor system is a computer system including a processor in which a plurality of cores are mounted.

ROM202は、ブートプログラムなどのプログラムを記憶している。RAM203は、CPU201のワークエリアとして使用される。フラッシュROM204は、OS(Operating System)などのシステムソフトウェアやアプリケーションソフトウェア、本実施の形態にかかる通信プログラムなどを記憶している。たとえば、OSを更新する場合、通信装置102は、I/F205によって新しいOSを受信し、フラッシュROM204に格納されている古いOSを、受信した新しいOSに更新する。   The ROM 202 stores a program such as a boot program. The RAM 203 is used as a work area for the CPU 201. The flash ROM 204 stores system software such as an OS (Operating System), application software, a communication program according to the present embodiment, and the like. For example, when updating the OS, the communication apparatus 102 receives the new OS by the I / F 205 and updates the old OS stored in the flash ROM 204 to the received new OS.

I/F205は、通信回線を通じてサーバ101、他の通信装置102、端末103といった外部装置に接続されており、外部装置群と内部のインターフェースを司り、外部装置からのデータの入出力を制御する。   The I / F 205 is connected to an external device such as the server 101, another communication device 102, and the terminal 103 through a communication line. The I / F 205 manages an internal interface with the external device group and controls data input / output from the external device.

なお、サーバ101〜端末103間は、直接接続されていてもよいし、サーバ101〜端末103が同一LAN(Local Area Network)に存在しており、各装置間でL2スイッチ等を経由して接続されていてもよい。また、サーバ101〜端末103間は、WAN(Wide Area Network)、インターネットなどのネットワークを経由して接続してもよい。この場合、情報を暗号化するため、サーバ101〜端末103は、SSL(Secure Socket Layer)やIPsec(security architecture for Internet Protocol)を採用してもよい。また、通信装置102〜端末103間は、電力線搬送通信を介してもよい。   Note that the server 101 to the terminal 103 may be directly connected, or the server 101 to the terminal 103 exist in the same LAN (Local Area Network) and are connected to each other via an L2 switch or the like. May be. The server 101 to the terminal 103 may be connected via a network such as a WAN (Wide Area Network) and the Internet. In this case, in order to encrypt the information, the server 101 to the terminal 103 may employ SSL (Secure Socket Layer) or IPsec (security architecture for Internet Protocol). Moreover, between the communication apparatus 102 and the terminal 103 may be via power line carrier communication.

また、サーバ101のハードウェアは、たとえば、CPU、ROM、RAMに加え、磁気ディスクドライブ、磁気ディスク、光ディスクドライブ、光ディスクを含む。磁気ディスクドライブは、サーバ101内のCPUの制御に従って磁気ディスクに対するデータのリード/ライトを制御する。磁気ディスクは、磁気ディスクドライブの制御で書き込まれたデータを記憶する。光ディスクドライブは、サーバ101内のCPUの制御に従って光ディスクに対するデータのリード/ライトを制御する。光ディスクは、光ディスクドライブの制御で書き込まれたデータを記憶したり、光ディスクに記憶されたデータをコンピュータに読み取らせたりする。   The hardware of the server 101 includes, for example, a magnetic disk drive, a magnetic disk, an optical disk drive, and an optical disk in addition to the CPU, ROM, and RAM. The magnetic disk drive controls data read / write with respect to the magnetic disk according to the control of the CPU in the server 101. The magnetic disk stores data written under the control of the magnetic disk drive. The optical disc drive controls reading / writing of data with respect to the optical disc according to the control of the CPU in the server 101. The optical disk stores data written under the control of the optical disk drive, and allows the computer to read data stored on the optical disk.

また、端末103のハードウェアは、通信装置102が有するハードウェアに加え、家屋、ビル内の消費電力を測定するセンサを有する。さらに、端末103は、家屋、ビル内の温度を測定するセンサを有し、家屋、ビル内のエアーコンディショナーに接続していてもよい。   Further, the hardware of the terminal 103 includes a sensor that measures power consumption in a house or building in addition to the hardware included in the communication device 102. Furthermore, the terminal 103 may include a sensor that measures the temperature in the house or building, and may be connected to an air conditioner in the house or building.

(スマートメータシステム100の機能)
次に、スマートメータシステム100の機能について説明する。図3は、スマートメータシステム100の機能を示すブロック図である。スマートメータシステム100は、制御部301と、構文解析部302と、生成部303と、送信部304と、を含む。この制御部となる機能(制御部301〜送信部304)は、記憶装置に記憶されたプログラムをサーバ101のCPUが実行することにより、その機能を実現する。記憶装置とは、具体的には、たとえば、サーバ101のROM、RAM、フラッシュROMなどである。または、サーバ101のI/Fを経由して他のCPUが実行することにより、その機能を実現してもよい。
(Function of smart meter system 100)
Next, functions of the smart meter system 100 will be described. FIG. 3 is a block diagram illustrating functions of the smart meter system 100. Smart meter system 100 includes a control unit 301, a syntax analysis unit 302, a generation unit 303, and a transmission unit 304. The functions (control unit 301 to transmission unit 304) serving as the control unit are realized by the CPU of the server 101 executing the program stored in the storage device. Specifically, the storage device is a ROM, a RAM, a flash ROM, or the like of the server 101, for example. Alternatively, the function may be realized by another CPU executing via the I / F of the server 101.

また、スマートメータシステム100は、記憶部320と、受信部321と、設定部322と、判断部323と、制御部324と、送信部325と、受信部326と、追加部327と、送信部328と、を含む。この制御部となる機能(受信部321〜送信部328)は、記憶装置に記憶されたプログラムをCPU201が実行することにより、その機能を実現する。   The smart meter system 100 includes a storage unit 320, a reception unit 321, a setting unit 322, a determination unit 323, a control unit 324, a transmission unit 325, a reception unit 326, an addition unit 327, and a transmission unit. 328. The functions (reception unit 321 to transmission unit 328) serving as the control unit are realized by the CPU 201 executing the program stored in the storage device.

記憶装置とは、具体的には、たとえば、図2に示したROM202、RAM203、フラッシュROM204などである。または、I/F205を経由して他のCPUが実行することにより、その機能を実現してもよい。なお、記憶部320は、RAM203、フラッシュROM204といった記憶装置となる。また、図3で示す記憶部320〜送信部328は、通信装置102−Cの機能であるように図示されているが、通信装置102−A〜通信装置102−Gにも含まれる。   Specifically, the storage device is, for example, the ROM 202, the RAM 203, the flash ROM 204, or the like shown in FIG. Alternatively, the function may be realized by execution by another CPU via the I / F 205. The storage unit 320 is a storage device such as the RAM 203 and the flash ROM 204. In addition, the storage unit 320 to the transmission unit 328 illustrated in FIG. 3 are illustrated as functions of the communication device 102-C, but are also included in the communication device 102-A to the communication device 102-G.

また、スマートメータシステム100は、経路情報テーブル104と、処理分割テーブル311と、メッセージタスク関係テーブル312と、メッセージ記憶テーブル331にアクセス可能である。また、スマートメータシステム100は、タスク情報313と、タスク委譲要求メッセージ314と、イベント要求メッセージ332と、を生成する。また、スマートメータシステム100は、周期的にイベント333を取得する。   Further, the smart meter system 100 can access the route information table 104, the process division table 311, the message task relation table 312, and the message storage table 331. In addition, the smart meter system 100 generates task information 313, a task delegation request message 314, and an event request message 332. Moreover, the smart meter system 100 acquires the event 333 periodically.

なお、経路情報テーブル104は、サーバ101、通信装置102のそれぞれの記憶領域に格納されている。具体的に、サーバ101は、経路情報テーブル104−Sを有しており、通信装置102−A〜通信装置102−Gは、それぞれ、経路情報テーブル104−A〜経路情報テーブル104−Gを有している。処理分割テーブル311、メッセージタスク関係テーブル312は、サーバ101の記憶領域に格納されている。メッセージ記憶テーブル331は、通信装置102のそれぞれの記憶領域に格納されている。また、タスク情報313と、タスク委譲要求メッセージ314は、サーバ101にて生成される。イベント要求メッセージ332は、タスクが委譲された通信装置102にて生成される。   Note that the path information table 104 is stored in each storage area of the server 101 and the communication device 102. Specifically, the server 101 has a route information table 104-S, and the communication devices 102-A to 102-G have route information tables 104-A to 104-G, respectively. doing. The process division table 311 and the message task relation table 312 are stored in the storage area of the server 101. The message storage table 331 is stored in each storage area of the communication device 102. The task information 313 and the task delegation request message 314 are generated by the server 101. The event request message 332 is generated by the communication device 102 to which the task is delegated.

また、通信装置102は、木構造となるスマートメータシステム100に存在している。通信装置に接続される下位の装置の数は、1つでもよいし、2以上であってよい。また、通信装置102は、下位の装置から測定対象の属性に関する特徴量の収集要求を受信すると測定対象の属性情報と下位の装置の識別情報とを自装置の記憶領域に記憶しつつ、収集要求を上位の装置に送信する。   The communication device 102 exists in the smart meter system 100 having a tree structure. The number of lower-level devices connected to the communication device may be one or two or more. In addition, when the communication device 102 receives a collection request for the feature amount related to the attribute of the measurement target from the lower device, the communication device 102 stores the attribute information of the measurement target and the identification information of the lower device in the storage area of the own device, Is sent to the host device.

測定対象は、ビル、家屋といった、スマートメータに付随するセンサが測定する対象を示している。測定対象の属性情報とは、測定対象が有している特徴の種別となり、たとえば、温度情報、電力情報、といった種別を示している。測定対象の属性の特徴量とは、属性の具体的な値であり、たとえば、測定対象の属性情報が温度情報であれば、20[度]、といった値となる。また、測定対象の属性の特徴量は、数値でなくてもよく、たとえば、電力情報:高、中、低、といったような情報であってもよい。   The measurement object indicates an object to be measured by a sensor attached to the smart meter, such as a building or a house. The attribute information of the measurement object is a characteristic type of the measurement object, and indicates, for example, a type such as temperature information and power information. The characteristic amount of the attribute of the measurement target is a specific value of the attribute. For example, if the attribute information of the measurement target is temperature information, the characteristic amount is 20 [degrees]. Further, the feature quantity of the attribute to be measured need not be a numerical value, and may be information such as power information: high, medium, low, for example.

経路情報テーブル104は、タスク委譲要求メッセージ314、またはイベント333を受信したときに、タスク委譲要求メッセージ314、イベント333の転送先となる装置を記憶するテーブルである。経路情報テーブル104の詳細については、図4にて後述する。処理分割テーブル311は、タスクが実行する処理が複数の通信装置102で分割可能か否かを記憶するテーブルである。処理分割テーブル311の詳細は、詳細については、図5にて後述する。メッセージタスク関係テーブル312は、タスクとタスク委譲要求メッセージ314の関連を記憶するテーブルである。メッセージタスク関係テーブル312の詳細については、図6にて後述する。   The route information table 104 is a table that stores a device to which the task delegation request message 314 and the event 333 are transferred when the task delegation request message 314 or the event 333 is received. Details of the route information table 104 will be described later with reference to FIG. The process division table 311 is a table that stores whether or not a process executed by a task can be divided by a plurality of communication apparatuses 102. Details of the process division table 311 will be described later with reference to FIG. The message task relationship table 312 is a table that stores associations between tasks and task delegation request messages 314. Details of the message task relation table 312 will be described later with reference to FIG.

タスク情報313は、タスクを構文解析して得られるデータである。タスク情報313の詳細については、図7にて後述する。タスク委譲要求メッセージ314は、タスクの委譲を要求するときに下位の通信装置102に送信されるメッセージである。なお、タスク委譲要求メッセージ314の詳細は、図8にて後述する。   The task information 313 is data obtained by parsing the task. Details of the task information 313 will be described later with reference to FIG. The task delegation request message 314 is a message transmitted to the lower-level communication device 102 when requesting task delegation. Details of the task delegation request message 314 will be described later with reference to FIG.

また、メッセージ記憶テーブル331は、イベントに対応する評価値を記憶する。なお、メッセージ記憶テーブル331の詳細については、図9にて後述する。また、イベント要求メッセージ332は、イベントの収集要求を上位の通信装置102に送信されるメッセージである。なお、イベント要求メッセージ332の詳細については、図10にて後述する。   The message storage table 331 stores an evaluation value corresponding to the event. Details of the message storage table 331 will be described later with reference to FIG. The event request message 332 is a message for transmitting an event collection request to the higher-level communication device 102. Details of the event request message 332 will be described later with reference to FIG.

制御部301は、サーバ101を管理しており、たとえば、サーバ101の負荷が増大してきた場合、タスクを通信装置102のいずれかに委譲する機能を有する。たとえば、制御部301は、タスクの一覧が記憶されているタスクキューから一つのタスクを選択し、委譲対象となるタスクに設定する。なお、設定されたタスクの識別情報は、CPU201の汎用レジスタ、RAM203、フラッシュROM204などの記憶領域に記憶される。   The control unit 301 manages the server 101 and has a function of delegating a task to one of the communication devices 102 when the load on the server 101 increases, for example. For example, the control unit 301 selects one task from a task queue in which a list of tasks is stored, and sets it as a task to be delegated. The set task identification information is stored in a storage area such as the general-purpose register of the CPU 201, the RAM 203, or the flash ROM 204.

構文解析部302は、制御部301が選択した、委譲対象となるタスクを構文解析する。具体的には、構文解析部302は、タスクが準拠している規約に従って、構文解析を行う。たとえば、タスクがCEP技術で採用されるCQL(Continuous Query Language)に従って記述されている場合、サーバ101内のCQLパーサが構文解析を行う。構文解析して得られたデータが、タスク情報313である。タスク情報313は、CPU201の汎用レジスタ、RAM203、フラッシュROM204などの記憶領域に記憶される。   The syntax analysis unit 302 parses the task to be transferred selected by the control unit 301. Specifically, the syntax analysis unit 302 performs syntax analysis in accordance with a convention that the task complies with. For example, when a task is described according to CQL (Continuous Query Language) adopted in the CEP technology, the CQL parser in the server 101 performs syntax analysis. Data obtained by parsing is task information 313. The task information 313 is stored in a storage area such as the general-purpose register of the CPU 201, the RAM 203, and the flash ROM 204.

生成部303は、タスク情報313からタスク委譲要求メッセージ314を生成する機能を有する。たとえば、生成部303は、タスク情報313から、タスク委譲要求メッセージ314に固有なID(IDentification)と、評価値が“分岐開始”として設定されたかを示す設定情報を付与して、タスク委譲要求メッセージ314を生成する。   The generation unit 303 has a function of generating a task delegation request message 314 from the task information 313. For example, the generation unit 303 adds an ID (IDentification) unique to the task delegation request message 314 and setting information indicating whether the evaluation value is set as “start of branch” from the task information 313, and sends the task delegation request message 314 is generated.

送信部304は、生成されたタスク委譲要求メッセージ314を下位の通信装置102に送信する。たとえば、送信部304は、タスク委譲要求メッセージ314を通信装置102−Gに送信する。   The transmission unit 304 transmits the generated task delegation request message 314 to the lower communication apparatus 102. For example, the transmission unit 304 transmits a task delegation request message 314 to the communication device 102-G.

記憶部320は、測定対象の属性情報と測定対象の属性の特徴量を取得可能な下位の装置の識別情報との組合せを記憶する。具体的に、記憶部320は、経路情報テーブル104に測定対象の属性情報と測定対象の属性の特徴量を取得可能な下位の装置の識別情報との組合せを記憶する。   The storage unit 320 stores a combination of the attribute information of the measurement target and the identification information of the lower device that can acquire the feature amount of the measurement target attribute. Specifically, the storage unit 320 stores a combination of the attribute information of the measurement target and the identification information of the lower-level apparatus that can acquire the feature amount of the attribute of the measurement target in the route information table 104.

受信部321は、評価値が“分岐開始”として設定されたか否かを示す設定情報を上位の装置から受信する機能を有する。具体的に、受信部321は、設定情報を通信装置102−Eから受信する。なお、スマートメータシステム100の接続状態が変化しない場合、設定情報が変化する箇所も変化しない。具体的に、図1−1において、イベントがビルの温度情報である場合、設定情報は、通信装置102−Cで常に“分岐済”に設定される。   The receiving unit 321 has a function of receiving setting information indicating whether or not the evaluation value is set as “branch start” from a higher-level device. Specifically, the receiving unit 321 receives setting information from the communication device 102-E. When the connection state of the smart meter system 100 does not change, the location where the setting information changes does not change. Specifically, in FIG. 1-1, when the event is building temperature information, the setting information is always set to “branched” in the communication device 102-C.

したがって、同じイベントを用いる異なるタスクが委譲される場合、1つ目のタスク委譲要求メッセージ314が設定情報を含んでおり、2つ目のタスク委譲要求メッセージ314には、設定情報を含んでいなくてもよい。また、上位の装置は、設定情報単独で送信してもよい。なお、受信した設定情報は、CPU201の汎用レジスタ、RAM203、フラッシュROM204などの記憶領域に記憶される。   Therefore, when different tasks using the same event are delegated, the first task delegation request message 314 includes setting information, and the second task delegation request message 314 does not include setting information. May be. The upper apparatus may transmit the setting information alone. The received setting information is stored in a storage area such as the general-purpose register of the CPU 201, the RAM 203, and the flash ROM 204.

設定部322は、測定対象の属性に関する特徴量を複数の下位の装置から収集する装置のうちネットワーク内で最上位となる装置が自装置であるか否かを示す評価値を設定する機能を有する。また、設定部322は、受信部321によって設定情報を受信した場合、記憶部320に記憶された測定対象の属性の特徴量が取得可能な下位の装置の数と設定情報とに基づいて、自装置の評価値を設定してもよい。   The setting unit 322 has a function of setting an evaluation value indicating whether or not the highest device in the network among the devices that collect the feature values related to the measurement target attribute from a plurality of lower devices is the own device. . In addition, when the setting unit 322 receives the setting information by the receiving unit 321, the setting unit 322 automatically determines, based on the number of lower-level devices that can acquire the feature amount of the measurement target attribute stored in the storage unit 320 and the setting information. You may set the evaluation value of an apparatus.

具体的に、設定部322は、測定対象の属性の特徴量を取得可能な下位の装置が複数であり、設定情報が“未分岐”である場合に、評価値を“分岐開始”として設定する。また、設定部322は、測定対象の属性の特徴量を取得可能な下位の装置が単数である場合、評価値を設定しない。さらに、設定部322は、設定情報が“分岐済”である場合、評価値を設定しない。   Specifically, the setting unit 322 sets the evaluation value as “branch start” when there are a plurality of lower-level devices that can acquire the feature quantity of the measurement target attribute and the setting information is “unbranched”. . In addition, the setting unit 322 does not set the evaluation value when there is a single lower apparatus that can acquire the feature amount of the attribute to be measured. Furthermore, the setting unit 322 does not set an evaluation value when the setting information is “branched”.

また、評価値は、スマートメータシステム100の設計時に設定されていてもよい。スマートメータシステム100の接続状態が変化しない場合、評価値が設定される通信装置102も変化しない。具体的に、図1−1において、イベントがビルの温度情報である場合、評価値は、通信装置102−Cで常に“分岐開始”に設定される。したがって、スマートメータシステム100は、設計時に、通信装置102−Cに関してビルの温度情報に対応する評価値が予め設定していてもよい。なお、設定された評価値は、CPU201の汎用レジスタ、RAM203、フラッシュROM204などの記憶領域に記憶される。   The evaluation value may be set when the smart meter system 100 is designed. When the connection state of the smart meter system 100 does not change, the communication device 102 to which the evaluation value is set does not change. Specifically, in FIG. 1-1, when the event is building temperature information, the evaluation value is always set to “start of branching” in the communication device 102-C. Therefore, in the smart meter system 100, an evaluation value corresponding to the building temperature information may be set in advance for the communication device 102-C at the time of design. The set evaluation value is stored in a storage area such as the general-purpose register of the CPU 201, the RAM 203, or the flash ROM 204.

判断部323は、収集要求を受信した場合、設定部322によって設定された評価値が“分岐開始”を示しているか否かを判断する機能を有する。判断結果は、CPU201の汎用レジスタ、RAM203、フラッシュROM204などの記憶領域に記憶される。   When receiving the collection request, the determination unit 323 has a function of determining whether or not the evaluation value set by the setting unit 322 indicates “branch start”. The determination result is stored in a storage area such as the general-purpose register of the CPU 201, the RAM 203, or the flash ROM 204.

制御部324は、判断部323にて評価値が“分岐開始”であると判断された場合、収集要求を上位の装置に送信しないように制御する機能を有する。たとえば、制御部324は、イベント要求メッセージ332を通信装置102−Eに送信しないように制御する。   The control unit 324 has a function of controlling the collection request not to be transmitted to a higher-level device when the determination unit 323 determines that the evaluation value is “start of branching”. For example, the control unit 324 controls the event request message 332 not to be transmitted to the communication device 102-E.

送信部325は、収集要求を上位の装置に送信する機能を有する。たとえば、送信部325は、評価値が設定されていないと判断された場合、イベント要求メッセージ332を通信装置102−Eに送信する。   The transmission unit 325 has a function of transmitting a collection request to a higher-level device. For example, when it is determined that the evaluation value is not set, the transmission unit 325 transmits the event request message 332 to the communication device 102-E.

受信部326は、イベントの収集要求を下位の装置から受信する機能を有する。たとえば、受信部326は、イベント要求メッセージ332を通信装置102−Aから受信する。なお、受信したイベント要求メッセージ332は、CPU201の汎用レジスタ、RAM203、フラッシュROM204などの記憶領域に記憶される。   The receiving unit 326 has a function of receiving an event collection request from a lower apparatus. For example, the reception unit 326 receives the event request message 332 from the communication device 102-A. The received event request message 332 is stored in a storage area such as the general-purpose register of the CPU 201, the RAM 203, or the flash ROM 204.

追加部327は、受信部326によって収集要求を受信した場合、測定対象の属性情報と下位の装置の識別情報を記憶部320に追加する機能を有する。たとえば、収集対象となるイベントがビルの温度情報であり、通信装置102−Aからイベント要求メッセージ332を受信した場合、追加部327は、ビルの温度情報と通信装置102−Aの識別情報を有する経路情報を経路情報テーブル104−Cに追加する。   The addition unit 327 has a function of adding the attribute information of the measurement target and the identification information of the lower device to the storage unit 320 when receiving the collection request by the reception unit 326. For example, when the event to be collected is building temperature information and the event request message 332 is received from the communication device 102-A, the adding unit 327 includes the building temperature information and the identification information of the communication device 102-A. The route information is added to the route information table 104-C.

送信部328は、下位の装置から測定対象の属性の特徴量を受信した場合、追加部327によって追加された記憶部320を参照して、測定対象の属性の特徴量を送信する機能を有する。たとえば、送信部328は、通信装置102−Bからイベント333を受信した場合、経路情報テーブル104−Cに追加された経路情報を参照して、通信装置102−Aにイベント333を送信する。   The transmission unit 328 has a function of transmitting the feature amount of the measurement target attribute with reference to the storage unit 320 added by the addition unit 327 when receiving the feature amount of the measurement target attribute from the lower apparatus. For example, when receiving the event 333 from the communication device 102-B, the transmission unit 328 refers to the route information added to the route information table 104-C and transmits the event 333 to the communication device 102-A.

図4は、経路情報テーブル104の記憶内容の一例を示す説明図である。経路情報テーブル104には、下位方向に接続されている端末103、通信装置102の情報が登録されている。経路情報テーブル104は、2つのテーブルを含んでおり、タスクを委譲する場合に参照されるタスク委譲用テーブル401と、イベントを収集する場合に参照されるイベント収集用テーブル402と、を含む。なお、図4で示す経路情報テーブル104は、通信装置102−C内に存在する経路情報テーブル104−Cを例としている。   FIG. 4 is an explanatory diagram illustrating an example of the contents stored in the route information table 104. In the route information table 104, information of the terminal 103 and the communication device 102 connected in the lower direction is registered. The route information table 104 includes two tables, and includes a task delegation table 401 that is referred to when a task is delegated, and an event collection table 402 that is referred to when an event is collected. Note that the route information table 104 illustrated in FIG. 4 is an example of the route information table 104-C existing in the communication device 102-C.

タスク委譲用テーブル401は、センサ種別、測定対象、委譲先識別情報という3つのフィールドを含む。センサ種別フィールドには、タスクの命令によって測定されるセンサの識別子が格納される。センサの識別子は、たとえば、温度を測定する温度センサを示す識別子、電力を測定する電力センサ等を示す識別子である。測定対象フィールドには、センサが測定する対象を示す識別子が格納される。委譲先識別情報フィールドには、タスクの委譲先となる装置の識別情報が格納される。装置の識別情報としては、たとえば、装置のIP(Internet Protcol)アドレスや、MAC(Media Access Control)アドレス等が採用される。   The task delegation table 401 includes three fields: sensor type, measurement object, and delegation destination identification information. In the sensor type field, an identifier of a sensor measured by a task command is stored. The sensor identifier is, for example, an identifier indicating a temperature sensor that measures temperature, an identifier indicating a power sensor that measures power, or the like. In the measurement object field, an identifier indicating an object to be measured by the sensor is stored. In the delegation destination identification information field, identification information of a device that is a task delegation destination is stored. As device identification information, for example, an IP (Internet Protocol) address, a MAC (Media Access Control) address, or the like of the device is employed.

次に、タスク委譲用テーブル401にレコードが登録される契機を説明する。通信装置102−Aがスマートメータシステム100に接続された場合、通信装置102−Aは、自身のタスク委譲用テーブル401−Aの内容をSubscribeメッセージとして通信装置102−Cに送信する。続けて、通信装置102−Cは、受信したSubscribeメッセージをタスク委譲用テーブル401−Cに登録する。たとえば、通信装置102−AからのSubscribeメッセージが“センサ種別:温度センサ、測定対象:ビル”であれば、通信装置102−Cは、Subscribeメッセージをレコード401−C−1として登録する。   Next, a trigger for registering a record in the task delegation table 401 will be described. When the communication device 102-A is connected to the smart meter system 100, the communication device 102-A transmits the contents of its own task delegation table 401-A to the communication device 102-C as a Subscribe message. Subsequently, the communication apparatus 102-C registers the received Subscribe message in the task delegation table 401-C. For example, if the Subscribe message from the communication device 102-A is “sensor type: temperature sensor, measurement target: building”, the communication device 102-C registers the Subscribe message as the record 401-C-1.

同様に、通信装置102−Cは、通信装置102−BからのSubscribeメッセージをレコード401−C−2、レコード401−C−3として登録する。このように、タスク委譲用テーブル401は、通信装置102、端末103の接続時にレコードが追加され、以後固定である。なお、タスクを委譲する場合の具体的なタスク委譲用テーブル401の参照方法としては、図11〜図14にて後述する。   Similarly, the communication device 102-C registers the Subscribe message from the communication device 102-B as a record 401-C-2 and a record 401-C-3. Thus, the task delegation table 401 is added with a record when the communication apparatus 102 and the terminal 103 are connected, and is fixed thereafter. A specific method for referencing the task delegation table 401 when delegating a task will be described later with reference to FIGS.

イベント収集用テーブル402は、イベント種別、測定対象、収集先識別情報という3つのフィールドを含む。イベント種別フィールドには、収集対象となるイベントの種別が格納される。たとえば、イベント種別フィールドには、温度情報、電力情報等が格納される。測定対象フィールドには、センサが測定する対象を示す識別子が格納される。収集先識別情報フィールドには、イベント収集先となる通信装置の識別情報が格納される。なお、イベント収集用テーブル402にレコードが登録される契機については、図15にて後述し、イベントを収集する場合の具体的なイベント収集用テーブル402の参照方法としては、図16にて後述する。   The event collection table 402 includes three fields: event type, measurement target, and collection destination identification information. The event type field stores the type of event to be collected. For example, temperature information, power information, and the like are stored in the event type field. In the measurement object field, an identifier indicating an object to be measured by the sensor is stored. In the collection destination identification information field, identification information of a communication device that is an event collection destination is stored. The trigger for registering a record in the event collection table 402 will be described later with reference to FIG. 15, and a specific method for referring to the event collection table 402 when collecting an event will be described later with reference to FIG. .

また、テーブル403は、タスク委譲用テーブル401−Cとイベント収集用テーブル402−Cを結合して表示している。以下の図では、経路情報テーブル104のデータを、テーブル403のように結合して表示する。   The table 403 displays the task delegation table 401-C and the event collection table 402-C in combination. In the following figure, the data of the route information table 104 are combined and displayed as a table 403.

なお、タスク委譲用テーブル401およびイベント収集用テーブル402の測定対象フィールドは、イベントをクラス分けするために用いられる情報である。図4の例では、温度情報、電力情報といったイベントを、ビルの温度情報、家屋の温度情報、といったようにクラス分けすることができる。他の条件でイベントをクラス分けする場合、タスク委譲用テーブル401およびイベント収集用テーブル402は、他の条件を格納するフィールドを含む。   Note that the measurement target fields of the task delegation table 401 and the event collection table 402 are information used to classify events. In the example of FIG. 4, events such as temperature information and power information can be classified as building temperature information and house temperature information. When classifying events under other conditions, the task delegation table 401 and the event collection table 402 include fields for storing other conditions.

図5は、処理分割テーブル311の記憶内容の一例を示す説明図である。処理分割テーブル311は、処理名称、処理分割フラグという2つのフィールドを含む。処理名称フィールドには、タスクが実行する処理の名称が格納される。処理分割フラグフィールドには、該当の処理が分割可能か否かを示すフラグが格納される。具体的に、処理分割フラグフィールドには、分割可能を示す“可”識別子と、分割不可を示す“不可”識別子のいずれか一方が格納される。   FIG. 5 is an explanatory diagram showing an example of the contents stored in the process division table 311. The process division table 311 includes two fields, a process name and a process division flag. The process name field stores the name of the process executed by the task. The process division flag field stores a flag indicating whether or not the corresponding process can be divided. Specifically, in the process division flag field, either a “permitted” identifier indicating that division is possible or a “not permitted” identifier indicating that division is not possible is stored.

たとえば、レコード311−1は、タスクが実行する処理が平均であり、平均を行う処理が分割不可であることを示している。続けて、レコード311−2は、タスクが実行する処理が通知であり、通知を行う処理が分割可能であることを示している。さらに、レコード311−3は、タスクが実行する処理が累積であり、累積を行う処理が分割不可であることを示している。なお、スマートメータシステム100で実行可能な処理は、設計段階で決定されており、どの処理が分割可能か否かは設計段階で決定しておく。   For example, the record 311-1 indicates that the process executed by the task is an average, and the process that performs the average cannot be divided. Subsequently, the record 311-2 indicates that the process executed by the task is a notification, and the process of performing the notification can be divided. Further, the record 311-3 indicates that the process executed by the task is cumulative, and the process for performing accumulation cannot be divided. The processes that can be executed by the smart meter system 100 are determined at the design stage, and which processes can be divided are determined at the design stage.

図6は、メッセージタスク関係テーブル312の記憶内容の一例を示す説明図である。メッセージタスク関係テーブル312は、通信装置102にタスクを委譲する場合に生成されるタスク委譲要求メッセージ314と委譲元のタスクとの関係を記憶しておくテーブルである。メッセージタスク関係テーブル312は、委譲されるタスクごとに記憶されている。   FIG. 6 is an explanatory diagram showing an example of the contents stored in the message task relation table 312. The message task relationship table 312 is a table that stores the relationship between the task delegation request message 314 generated when delegating a task to the communication apparatus 102 and the task of delegation. The message task relation table 312 is stored for each task to be delegated.

メッセージタスク関係テーブル312は、メッセージID、タスクという2つのフィールドを含む。メッセージIDフィールドには、タスク委譲要求メッセージ314のIDが格納される。メッセージIDは、メッセージを一意で識別可能な値であればよく、たとえば、重複しないランダムの値であってもよい。タスクフィールドには、委譲対象となるタスクが格納される。なお、タスクを一意に識別可能なタスクIDが存在する場合、メッセージタスク関係テーブル312は、タスクフィールドの代わりに、タスクIDを格納するタスクIDフィールドを有していてもよい。   The message task relationship table 312 includes two fields: message ID and task. In the message ID field, the ID of the task delegation request message 314 is stored. The message ID only needs to be a value that uniquely identifies the message, and may be, for example, a random value that does not overlap. The task field stores a task to be delegated. When there is a task ID that can uniquely identify a task, the message task relation table 312 may have a task ID field for storing the task ID instead of the task field.

たとえば、図6に示すレコード312−1は、メッセージIDが“0x153959b2”であり、タスクが“select 平均(ビルの温度情報) from 地域A and 地域B where X>30”であることを示している。また、レコード312−2は、メッセージIDが“0x15638092”であり、タスクが“select 平均(ビルの温度情報) from 地域A where X>30”であることを示している。   For example, the record 312-1 illustrated in FIG. 6 indicates that the message ID is “0x153959b2”, and the task is “select average (building temperature information) from area A and area B where X> 30”. . The record 312-2 indicates that the message ID is “0x15638092” and the task is “select average (building temperature information) from area A where X> 30”.

図7は、タスク情報313のフォーマット例を示す説明図である。図7で示す説明図は、タスク701と、タスク701を構文解析して得られたタスク情報313を示している。タスク701は、以下に示す情報となる。   FIG. 7 is an explanatory diagram showing a format example of the task information 313. The explanatory diagram shown in FIG. 7 shows a task 701 and task information 313 obtained by parsing the task 701. The task 701 is information shown below.

select 平均(ビルの温度情報) from 地域A and 地域B where X>30   select average (building temperature information) from area A and area B where X> 30

サーバ101は、タスク701を構文解析し、タスク情報313を生成する。タスク情報313は、処理名称、イベント、結果通知条件、処理分割フラグという4つのフィールドを含む。   The server 101 parses the task 701 and generates task information 313. The task information 313 includes four fields: process name, event, result notification condition, and process division flag.

処理名称フィールドには、タスクが実行する処理の名称が格納される。イベントフィールドには、タスクが実行する際に要求されるイベントが格納される。また、イベントフィールドにはクラス分けされたイベントが格納されてもよい。クラス分けされたイベントとは、たとえば、スマートメータシステム100内の温度情報に対して、ビルの温度情報、家屋の温度情報、といったように、測定対象でクラス分けされたイベントである。なお、イベントは、ビル、家屋といった建屋以外の情報でクラス分けされていてもよい。たとえば、ビル内にオフィスと店舗や飲食店が入居している場合、スマートメータシステム100は、ビルの温度情報を、オフィスの温度情報、店舗の温度情報、飲食店の温度情報といったようにクラス分けしてもよい。   The process name field stores the name of the process executed by the task. The event field stores an event required when the task is executed. The event field may store events classified into classes. The classified event is an event classified according to a measurement object such as building temperature information and house temperature information with respect to the temperature information in the smart meter system 100, for example. The events may be classified according to information other than buildings such as buildings and houses. For example, when an office, a store, and a restaurant are in the building, the smart meter system 100 classifies the building temperature information into office temperature information, store temperature information, restaurant temperature information, and the like. May be.

結果通知条件フィールドには、タスクの処理の結果、通知を行う条件が格納される。処理分割フラグフィールドには、該当の処理が分割可能か否かを示すフラグが格納される。たとえば、図7で示すタスク情報313は、タスクが実行する処理が平均であり、タスクが要求するイベントがビルの温度情報であり、結果通知条件が平均温度が30℃以上になったときであり、処理分割不可であることを示している。   The result notification condition field stores a condition for performing notification as a result of task processing. The process division flag field stores a flag indicating whether or not the corresponding process can be divided. For example, the task information 313 shown in FIG. 7 is when the processing executed by the task is average, the event requested by the task is building temperature information, and the result notification condition is when the average temperature is 30 ° C. or higher. This indicates that the process cannot be divided.

図8は、サーバ101におけるタスク情報313の処理例を示す説明図である。サーバ101は、タスク情報313からタスク委譲要求メッセージ314を生成する。タスク委譲要求メッセージ314は、タスク情報313に、複数通信装置イベント分岐済フラグフィールドと、メッセージIDフィールドが追加されている。   FIG. 8 is an explanatory diagram illustrating a processing example of the task information 313 in the server 101. The server 101 generates a task delegation request message 314 from the task information 313. In the task delegation request message 314, a multi-communication device event branched flag field and a message ID field are added to the task information 313.

複数通信装置イベント分岐済フラグフィールドは、評価値が“分岐開始”として設定されたかを示す設定情報が格納される。複数通信装置イベント分岐済フラグフィールドは、たとえば、いずれかの通信装置102にて、評価値が“分岐開始”と設定された場合、“分岐済”が格納され、評価値が“分岐開始”と設定されていない場合、“未分岐”が格納される。タスク委譲要求メッセージ314が生成された時点では、複数通信装置イベント分岐済フラグフィールドは、“未分岐”を格納している。メッセージIDフィールドは、タスク委譲要求メッセージ314を特定するIDであり、メッセージタスク関係テーブル312のメッセージIDフィールドの値が格納される。   The multi-communication device event branch completed flag field stores setting information indicating whether the evaluation value is set as “branch start”. In the multi-communication device event branch completed flag field, for example, when the evaluation value is set to “branch start” in any of the communication devices 102, “branched” is stored, and the evaluation value is “branch start”. If not set, “unbranched” is stored. At the time when the task delegation request message 314 is generated, the multi-communication device event branched flag field stores “unbranched”. The message ID field is an ID for identifying the task delegation request message 314, and stores the value of the message ID field of the message task relation table 312.

たとえば、図8の例で示すタスク委譲要求メッセージ314は、評価値が“分岐開始”として設定されていない状態であり、また、メッセージIDが“0x153959b2”であることを示している。   For example, the task delegation request message 314 shown in the example of FIG. 8 indicates that the evaluation value is not set as “start of branching” and the message ID is “0x153959b2”.

図9は、メッセージ記憶テーブル331の記憶内容の一例を示す説明図である。メッセージ記憶テーブル331は、メッセージID、イベント状態という2つのフィールドを含む。メッセージIDフィールドには、受信したタスク委譲要求メッセージ314のメッセージIDが格納される。イベント状態フィールドには、イベントを複数の下位の装置から収集する装置のうち、スマートメータシステム100内で最上位となる装置が自装置であるか否かを示す評価値が格納される。具体的に、イベント状態フィールドは、複数の下位の通信装置102からイベントを収集し、かつスマートメータシステム100内の最上位の装置となる場合、識別子として“分岐開始”を格納する。また、該当の通信装置102が端末103に接続されている場合、イベント状態フィールドは、識別子として“末端”を格納する。   FIG. 9 is an explanatory diagram showing an example of the stored contents of the message storage table 331. The message storage table 331 includes two fields, message ID and event status. In the message ID field, the message ID of the received task delegation request message 314 is stored. The event status field stores an evaluation value indicating whether or not the highest device in the smart meter system 100 among the devices that collect events from a plurality of lower devices is the self device. Specifically, the event status field stores “branch start” as an identifier when collecting events from a plurality of lower-level communication devices 102 and becoming the highest-level device in the smart meter system 100. When the communication device 102 is connected to the terminal 103, the event status field stores “terminal” as an identifier.

たとえば、図9で示すレコード331−1は、メッセージID“0x153959b2”で示されるタスク委譲要求メッセージ314のイベントが下位の通信装置102のうち、2以上の通信装置102から収集されることを示している。また、レコード331−2は、メッセージID“0x15638092”で示されるタスク委譲要求メッセージ314を受信した該当の通信装置102が、端末103に接続されていることを示している。   For example, the record 331-1 illustrated in FIG. 9 indicates that the event of the task delegation request message 314 indicated by the message ID “0x153959b2” is collected from two or more communication devices 102 among the lower-level communication devices 102. Yes. The record 331-2 indicates that the corresponding communication apparatus 102 that has received the task delegation request message 314 indicated by the message ID “0x15638092” is connected to the terminal 103.

図10は、イベント要求メッセージ332のフォーマット例を示す説明図である。テーブルは、イベント、メッセージIDという2つのフィールドを含む。イベントフィールドには、タスク委譲要求メッセージ314にて要求されたイベントが格納される。メッセージIDフィールドには、タスク委譲要求メッセージ314のメッセージIDが格納される。たとえば、図10で示すイベント要求メッセージ332は、要求されるイベントがビルの温度情報であり、メッセージIDが“0x153959b2”であることを示している。   FIG. 10 is an explanatory diagram showing a format example of the event request message 332. The table includes two fields: event and message ID. The event field stores the event requested by the task delegation request message 314. The message ID of the task delegation request message 314 is stored in the message ID field. For example, the event request message 332 illustrated in FIG. 10 indicates that the requested event is building temperature information and the message ID is “0x153959b2”.

本実施の形態にかかるスマートメータシステム100は、図3に示した機能と、図4〜図10にて示したデータによって、タスク委譲、イベント収集を行う。次に、図11〜図16にて、スマートメータシステム100にてタスクが委譲されていく状態と、イベントが収集される状態と、について説明する。   The smart meter system 100 according to the present embodiment performs task delegation and event collection based on the functions shown in FIG. 3 and the data shown in FIGS. Next, a state where tasks are delegated in the smart meter system 100 and a state where events are collected will be described with reference to FIGS.

図11は、タスクが委譲される状態を示す説明図(その1)である。図11で示すスマートメータシステム100にて、サーバ101は、通信装置102−Gに対してタスク委譲要求メッセージ314を送信する。通信装置102−Gは、タスク委譲要求メッセージ314のイベントフィールドに格納されたイベントを取得可能な通信装置102を、経路情報テーブル104−Gから検出する。ビルの温度情報を取得可能な通信装置102は、経路情報テーブル104−Gより、通信装置102−E1つである。したがって、通信装置102−Gは、メッセージ記憶テーブル331−Gにレコードを追加せず、また、タスク委譲要求メッセージ314を変更しないで通信装置102−Eに送信する。   FIG. 11 is an explanatory diagram (part 1) illustrating a state in which tasks are delegated. In the smart meter system 100 illustrated in FIG. 11, the server 101 transmits a task delegation request message 314 to the communication device 102 -G. The communication apparatus 102-G detects the communication apparatus 102 that can acquire the event stored in the event field of the task delegation request message 314 from the route information table 104-G. From the route information table 104-G, there is one communication device 102-E that can acquire building temperature information. Therefore, the communication apparatus 102-G does not add a record to the message storage table 331-G, and transmits the task delegation request message 314 to the communication apparatus 102-E without changing it.

図12は、タスクが委譲される状態を示す説明図(その2)である。図12で示すスマートメータシステム100は、通信装置102−Eが通信装置102−Gからタスク委譲要求メッセージ314を受信した状態である。通信装置102−Eは、タスク委譲要求メッセージ314のイベントフィールドに格納されたイベントを取得可能な通信装置102を、経路情報テーブル104−Eから検出する。ビルの温度情報を取得可能な通信装置102は、経路情報テーブル104−Eより、通信装置102−C1つである。したがって、通信装置102−Eは、メッセージ記憶テーブル331−Eにレコードを追加せず、また、タスク委譲要求メッセージ314を変更しないで通信装置102−Cに送信する。   FIG. 12 is an explanatory diagram (part 2) of the task being delegated. The smart meter system 100 illustrated in FIG. 12 is in a state where the communication device 102-E has received the task delegation request message 314 from the communication device 102-G. The communication device 102-E detects from the route information table 104-E the communication device 102 that can acquire the event stored in the event field of the task delegation request message 314. From the route information table 104-E, the number of communication devices 102 that can acquire building temperature information is one communication device 102-C. Therefore, the communication device 102-E does not add a record to the message storage table 331-E, and transmits the task delegation request message 314 to the communication device 102-C without changing it.

図13は、タスクが委譲される状態を示す説明図(その3)である。図13で示すスマートメータシステム100は、通信装置102−Cが通信装置102−Eからタスク委譲要求メッセージ314を受信した状態である。通信装置102−Cは、タスク委譲要求メッセージ314のイベントフィールドに格納されたイベントを取得可能な通信装置102を、経路情報テーブル104−Cから検出する。ビルの温度情報を取得可能な通信装置102は、経路情報テーブル104−Cより、通信装置102−A、通信装置102−Bの2つである。   FIG. 13 is an explanatory diagram (part 3) illustrating a state where tasks are delegated. The smart meter system 100 illustrated in FIG. 13 is in a state where the communication device 102-C has received the task delegation request message 314 from the communication device 102-E. The communication device 102-C detects the communication device 102 that can acquire the event stored in the event field of the task delegation request message 314 from the route information table 104-C. Two communication devices 102 that can acquire building temperature information are the communication device 102-A and the communication device 102-B based on the route information table 104-C.

このように、複数の通信装置102を検出したため、通信装置102−Cは、タスク委譲要求メッセージ314の複数通信装置イベント分岐済フラグを“未分岐”から“分岐済”に設定する。続けて、通信装置102−Cは、メッセージ記憶テーブル331−Cに新規レコードを追加し、メッセージIDフィールドにタスク委譲要求メッセージ314のメッセージIDフィールドの値を設定し、イベント状態フィールドに“分岐開始”を設定する。設定後、通信装置102−Cは、タスクを委譲する通信装置102として、通信装置102−Aを選択し、フィールドの値が変更されたタスク委譲要求メッセージ314を通信装置102−Aに送信する。   Thus, since a plurality of communication devices 102 are detected, the communication device 102-C sets the multi-communication device event branch completed flag of the task delegation request message 314 from “not branched” to “branched”. Subsequently, the communication apparatus 102-C adds a new record to the message storage table 331-C, sets the value of the message ID field of the task delegation request message 314 in the message ID field, and “starts branching” in the event status field. Set. After the setting, the communication apparatus 102-C selects the communication apparatus 102-A as the communication apparatus 102 that delegates the task, and transmits a task delegation request message 314 in which the field value is changed to the communication apparatus 102-A.

図14は、タスクが委譲される状態を示す説明図(その4)である。図14で示すスマートメータシステム100は、通信装置102−Aが通信装置102−Cからタスク委譲要求メッセージ314を受信した状態である。通信装置102−Aは、下位の通信装置102を有しておらず、端末103−A1と接続している状態である。この状態で、通信装置102−Aは、メッセージ記憶テーブル331−Aに新規レコードを追加し、メッセージIDフィールドにタスク委譲要求メッセージ314のメッセージIDフィールドの値を設定し、イベント状態フィールドに“末端”を設定する。また、通信装置102−Aは、タスク委譲要求メッセージ314の複数通信装置イベント分岐済フラグフィールドの値を判断する。   FIG. 14 is an explanatory diagram (part 4) illustrating a state in which tasks are delegated. In the smart meter system 100 illustrated in FIG. 14, the communication device 102 -A has received the task delegation request message 314 from the communication device 102 -C. The communication device 102-A does not have the lower-level communication device 102 and is connected to the terminal 103-A1. In this state, the communication apparatus 102-A adds a new record to the message storage table 331-A, sets the value of the message ID field of the task delegation request message 314 in the message ID field, and sets “end” in the event status field. Set. Further, the communication device 102-A determines the value of the multi-communication device event branching flag field of the task delegation request message 314.

図14の例では、複数通信装置イベント分岐済フラグフィールドが“分岐済”であるため、上位の通信装置102にて、イベントが収集されることを示している。したがって、通信装置102−Aは、イベント要求メッセージ332を通信装置102−Cに送信する。イベント要求メッセージ332が送信された様子については、図15にて後述する。   In the example of FIG. 14, since the multi-communication device event branching flag field is “branched”, it indicates that the higher-level communication device 102 collects events. Accordingly, the communication device 102-A transmits the event request message 332 to the communication device 102-C. The manner in which the event request message 332 is transmitted will be described later with reference to FIG.

図15は、イベント要求メッセージ332が送信された状態を示す説明図である。図15で示すスマートメータシステム100は、通信装置102−Cが通信装置102−Aからイベント要求メッセージ332を受信した状態である。通信装置102−Cは、イベント要求メッセージ332を受信し、イベント収集用テーブル402−Cに経路情報を追加する。図15の例では、通信装置102−Cは、イベント種別フィールドに“温度情報”、測定対象フィールドに“ビル”、収集先識別情報フィールドに“通信装置102−A”を設定する。   FIG. 15 is an explanatory diagram showing a state in which the event request message 332 has been transmitted. The smart meter system 100 illustrated in FIG. 15 is in a state where the communication device 102-C has received the event request message 332 from the communication device 102-A. The communication apparatus 102-C receives the event request message 332 and adds route information to the event collection table 402-C. In the example of FIG. 15, the communication device 102-C sets “temperature information” in the event type field, “building” in the measurement target field, and “communication device 102-A” in the collection destination identification information field.

また、通信装置102−Cは、イベント要求メッセージ332のメッセージIDフィールドと同一のメッセージIDがメッセージ記憶テーブル331−Cに存在し、かつ、該当のレコードのイベント状態が“分岐開始”であるかを判断する。図15の例では、条件に当てはまるため、通信装置102−Cは、イベント要求メッセージ332を通信装置102−Eに送信しない。   Further, the communication apparatus 102-C determines whether the same message ID as the message ID field of the event request message 332 exists in the message storage table 331-C, and the event state of the corresponding record is “branch start”. to decide. In the example of FIG. 15, since the condition is met, the communication device 102-C does not transmit the event request message 332 to the communication device 102-E.

図16は、イベント333が収集される状態を示す説明図である。図16で示すスマートメータシステム100は、通信装置102−Bからイベント333が送信され、通信装置102−Cが受信した状態を示している。通信装置102−Cは、受信したイベント333に対応する経路情報がイベント収集用テーブル402−Cに登録されているかを判断する。図16の例では、レコード1601が対応した経路情報であることを想定する。通信装置102−Cは、レコード1601に従って、受信したイベント333を通信装置102−Aに送信する。   FIG. 16 is an explanatory diagram showing a state in which the event 333 is collected. The smart meter system 100 illustrated in FIG. 16 illustrates a state in which an event 333 is transmitted from the communication device 102-B and received by the communication device 102-C. The communication apparatus 102-C determines whether route information corresponding to the received event 333 is registered in the event collection table 402-C. In the example of FIG. 16, it is assumed that the record 1601 is corresponding route information. The communication device 102-C transmits the received event 333 to the communication device 102-A according to the record 1601.

次に、図17にて図11〜図16で示した動作を行うタスク委譲実行処理のフローチャートについて説明を行う。タスク委譲実行処理は、サーバ101の負荷が増大してきた場合に実行される処理である。   Next, a flowchart of task delegation execution processing for performing the operations shown in FIGS. 11 to 16 will be described with reference to FIG. The task delegation execution process is a process executed when the load on the server 101 increases.

図17は、スマートメータシステム100におけるタスク委譲実行処理の一例を示すフローチャートである。タスク委譲実行処理は、タスク委譲処理、経路情報設定処理、イベント収集処理、タスク完了時処理、という5つの処理を実行する。タスク委譲処理には、サーバ101が実行するサーバタスク委譲処理と、通信装置102が実行する通信装置タスク委譲処理が存在する。   FIG. 17 is a flowchart illustrating an example of task delegation execution processing in the smart meter system 100. The task delegation execution process executes five processes: a task delegation process, a route information setting process, an event collection process, and a task completion process. The task delegation process includes a server task delegation process executed by the server 101 and a communication apparatus task delegation process executed by the communication apparatus 102.

サーバ101は、サーバタスク委譲処理を実行する(ステップS1701)。次に、通信装置102は、通信装置タスク委譲処理を実行する(ステップS1702)。通信装置タスク委譲処理によりタスクの委託先が決定された後、通信装置102は、経路情報設定処理を実行する(ステップS1703)。経路情報が設定された後、タスクが委譲された通信装置102の上位となる通信装置102は、イベント収集処理を実行する(ステップS1704)。イベントが収集された後、タスクが委譲された通信装置102は、タスク完了時処理を実行し(ステップS1705)、スマートメータシステム100は、タスク委譲実行処理を終了する。   The server 101 executes server task delegation processing (step S1701). Next, the communication device 102 executes communication device task delegation processing (step S1702). After the task delegation process is determined by the communication apparatus task delegation process, the communication apparatus 102 executes a route information setting process (step S1703). After the route information is set, the communication device 102, which is the host device of the communication device 102 to which the task is delegated, executes event collection processing (step S1704). After the events are collected, the communication device 102 to which the task has been delegated executes a task completion process (step S1705), and the smart meter system 100 ends the task delegation execution process.

図18は、サーバ101におけるタスク委譲処理の一例を示すフローチャートである。サーバ101は、制御部301からタスクを受け付ける(ステップS1801)。なお、タスクにタスクIDが存在する場合、サーバ101は、制御部301からタスクIDを受け付けてもよい。続けて、サーバ101は、下位に通信装置102を有するか否かを判断する(ステップS1802)。通信装置102が無い場合(ステップS1802:No)、サーバ101は、タスクを委譲する通信装置102が無いため、タスク委譲処理を終了する。この場合、サーバ101は、委譲する予定であったタスクをそのまま実行する。   FIG. 18 is a flowchart illustrating an example of task delegation processing in the server 101. The server 101 receives a task from the control unit 301 (step S1801). If the task has a task ID, the server 101 may accept the task ID from the control unit 301. Subsequently, the server 101 determines whether or not it has the communication device 102 at the lower level (step S1802). If there is no communication device 102 (step S1802: No), the server 101 ends the task delegation process because there is no communication device 102 to delegate the task. In this case, the server 101 executes the task that was scheduled to be delegated as it is.

通信装置102を有する場合(ステップS1802:Yes)、サーバ101は、受け付けたタスクを構文解析し、タスク情報313を生成する(ステップS1803)。具体的に、サーバ101は、受け付けたタスクから、処理名称、イベント、結果通知条件、処理分割フラグに該当する箇所を構文解析から取得して、タスク情報313を生成する。なお、処理分割フラグは、処理分割テーブル311を参照して設定される。   When the communication apparatus 102 is included (step S1802: Yes), the server 101 parses the received task and generates task information 313 (step S1803). Specifically, the server 101 obtains a part corresponding to the process name, event, result notification condition, and process division flag from the received task from the syntax analysis, and generates task information 313. The process division flag is set with reference to the process division table 311.

タスク情報313の生成後、サーバ101は、タスク情報313からタスク委譲要求メッセージ314を生成する(ステップS1804)。具体的に、サーバ101は、タスク情報313に対して、複数通信装置イベント分岐済フラグフィールドと、メッセージIDフィールドと、を追加して、タスク委譲要求メッセージ314を生成する。なお、複数通信装置イベント分岐済フラグフィールドは、“未分岐”が設定されており、メッセージIDフィールドは、メッセージタスク関係テーブル312を参照して設定される。   After generating the task information 313, the server 101 generates a task delegation request message 314 from the task information 313 (step S1804). Specifically, the server 101 adds a multiple communication device event branched flag field and a message ID field to the task information 313 to generate a task delegation request message 314. Note that “unbranched” is set in the multi-communication device event branched flag field, and the message ID field is set with reference to the message task relation table 312.

タスク委譲要求メッセージ314の生成後、サーバ101は、下位の通信装置102のうち複数の通信装置102が、タスク委譲要求メッセージ314のイベントフィールドに格納されたイベントを取得可能か否かを判断する(ステップS1805)。複数の通信装置102が該当のイベントを取得可能である場合(ステップS1805:Yes)、サーバ101は、タスク委譲要求メッセージ314の複数通信装置イベント分岐済フラグフィールドフラグを“分岐済”に設定する(ステップS1806)。   After the task delegation request message 314 is generated, the server 101 determines whether or not a plurality of communication devices 102 among the lower-level communication devices 102 can acquire the event stored in the event field of the task delegation request message 314 ( Step S1805). If a plurality of communication devices 102 can acquire the event (step S1805: YES), the server 101 sets the multi-communication device event branch completed flag field flag of the task delegation request message 314 to “branched” ( Step S1806).

複数通信装置イベント分岐済フラグフィールドの設定後、または単数の通信装置102が該当のイベントを取得可能である場合(ステップS1805:No)、サーバ101は、タスク委譲要求メッセージ314を下位の通信装置102に送信する(ステップS1807)。送信後、サーバ101は、タスクの終了を受け付ける(ステップS1808)。具体的に、サーバ101は、タスク結果メッセージを受け付けることでタスクの終了を受け付ける。タスクの終了を受け付けた後、サーバ101は、サーバタスク委譲処理を実行する。続けて、タスク委譲要求メッセージ314を受信した通信装置102が、通信装置タスク委譲処理を実行する。   After the setting of the multi-communication device event branched flag field or when a single communication device 102 can acquire the event (step S1805: No), the server 101 sends a task delegation request message 314 to the lower communication device 102. (Step S1807). After the transmission, the server 101 accepts the end of the task (step S1808). Specifically, the server 101 receives the task end by receiving the task result message. After accepting the end of the task, the server 101 executes server task delegation processing. Subsequently, the communication device 102 that has received the task delegation request message 314 executes communication device task delegation processing.

図19は、通信装置タスク委譲処理の一例を示すフローチャートである。通信装置タスク委譲処理は、サーバ101で実行されるサーバタスク委譲処理、または、上位の通信装置タスク委譲処理、からのタスク委譲要求メッセージ314を受信したときに実行される。   FIG. 19 is a flowchart illustrating an example of the communication device task delegation process. The communication device task delegation process is executed when a task delegation request message 314 is received from a server task delegation process executed by the server 101 or a higher-level communication device task delegation process.

通信装置102は、タスク委譲要求メッセージ314を受信する(ステップS1901)。受信後、通信装置102は、下位に通信装置102を有するか否かを判断する(ステップS1902)。通信装置102が無い場合(ステップS1902:No)、通信装置102は、タスク委譲要求メッセージ314の複数通信装置イベント分岐済フラグフィールドが“分岐済”か否かを判断する(ステップS1903)。“分岐済”である場合(ステップS1903:Yes)、通信装置102は、イベント要求メッセージ送信処理を実行する(ステップS1904)。イベント要求メッセージ送信処理の詳細については、図21にて後述する。また、イベント要求メッセージを受信した上位の通信装置は、経路情報設定処理を実行する(ステップS1703)。   The communication device 102 receives the task delegation request message 314 (step S1901). After reception, the communication device 102 determines whether or not it has the communication device 102 at the lower level (step S1902). When there is no communication device 102 (step S1902: No), the communication device 102 determines whether or not the multi-communication device event branched flag field of the task delegation request message 314 is “branched” (step S1903). If it is “branched” (step S1903: YES), the communication apparatus 102 executes an event request message transmission process (step S1904). Details of the event request message transmission process will be described later with reference to FIG. In addition, the higher-level communication device that has received the event request message executes route information setting processing (step S1703).

イベント要求メッセージ送信処理の終了後、または“未分岐”である場合(ステップS1903:No)、通信装置102は、タスク委譲要求メッセージ314の処理名称フィールドに対応する処理を実行する(ステップS1905)。処理を実行後、通信装置102は、通信装置タスク委譲処理を終了し、タスク完了時処理を実行する(ステップS1705)。また、経路情報設定処理を実行する(ステップS1703)。   After the end of the event request message transmission process or when it is “unbranched” (step S1903: No), the communication apparatus 102 executes a process corresponding to the process name field of the task delegation request message 314 (step S1905). After executing the process, the communication apparatus 102 ends the communication apparatus task delegation process and executes a task completion process (step S1705). Further, a route information setting process is executed (step S1703).

通信装置102を有する場合(ステップS1902:Yes)、通信装置102は、下位の通信装置102のうち複数の通信装置102が、タスク委譲要求メッセージ314のイベントフィールドのイベントを取得可能か否かを判断する(ステップS1906)。複数の通信装置102が該当のイベントを取得可能である場合(ステップS1906:Yes)、通信装置102は、処理分割が可能か否かを判断する(ステップS1907)。処理分割が可能か否かの判断については、受信したタスク委譲要求メッセージ314の処理分割フラグフィールドを参照することで判断することができる。   When the communication device 102 is included (step S1902: Yes), the communication device 102 determines whether or not the plurality of communication devices 102 among the lower-level communication devices 102 can acquire the event in the event field of the task delegation request message 314. (Step S1906). When a plurality of communication devices 102 can acquire the corresponding event (step S1906: Yes), the communication device 102 determines whether or not processing division is possible (step S1907). The determination of whether or not the process division is possible can be made by referring to the process division flag field of the received task delegation request message 314.

処理分割が可能である場合(ステップS1907:Yes)、通信装置102は、イベントを取得可能な下位の通信装置102全てにタスク委譲要求メッセージ314を転送する(ステップS1908)。これにより、タスクは分割されて処理されることになる。   If the process can be divided (step S1907: YES), the communication apparatus 102 transfers the task delegation request message 314 to all lower-level communication apparatuses 102 that can acquire the event (step S1908). As a result, the task is divided and processed.

処理分割が可能でない場合(ステップS1907:No)、通信装置102は、イベント分岐設定処理を実行する(ステップS1909)。イベント分岐設定処理の詳細については、図20にて後述する。単数の通信装置102が該当のイベントを取得可能である場合(ステップS1906:No)、通信装置102は、イベントを取得可能な下位の通信装置102にタスク委譲要求メッセージ314を送信する(ステップS1910)。   If the process division is not possible (step S1907: NO), the communication apparatus 102 executes an event branch setting process (step S1909). Details of the event branch setting process will be described later with reference to FIG. When the single communication device 102 can acquire the event (step S1906: No), the communication device 102 transmits the task delegation request message 314 to the lower communication device 102 that can acquire the event (step S1910). .

ステップS1908〜ステップS1910にてタスク委譲要求メッセージ314を送信した通信装置102は、通信装置タスク委譲処理を終了する。続けて、タスク委譲要求メッセージ314を受信した下位の通信装置102が、通信装置タスク委譲処理を実行する。   The communication apparatus 102 that has transmitted the task delegation request message 314 in steps S1908 to S1910 ends the communication apparatus task delegation process. Subsequently, the lower-level communication device 102 that has received the task delegation request message 314 executes communication device task delegation processing.

図20は、通信装置102におけるイベント分岐設定処理の一例を示すフローチャートである。イベント分岐設定処理は、ステップS1907:Noのルートを通ったときに実行される。通信装置102は、タスク委譲要求メッセージ314の複数通信装置イベント分岐済フラグフィールドが“分岐済”か否かを判断する(ステップS2001)。“未分岐”である場合(ステップS2001:No)、通信装置102は、タスク委譲要求メッセージ314の複数通信装置イベント分岐済フラグフィールドを“分岐済”に設定する(ステップS2002)。   FIG. 20 is a flowchart illustrating an example of event branch setting processing in the communication apparatus 102. The event branch setting process is executed when the route of step S1907: No is passed. The communication device 102 determines whether or not the multi-communication device event branched flag field of the task delegation request message 314 is “branched” (step S2001). If it is “unbranched” (step S2001: No), the communication device 102 sets the multi-communication device event branch completed flag field of the task delegation request message 314 to “branched” (step S2002).

続けて、通信装置102は、メッセージ記憶テーブル331に新規レコードを追加し(ステップS2003)、追加されたレコードのメッセージIDフィールドにタスク委譲要求メッセージ314のメッセージIDを設定する(ステップS2004)。記憶後、通信装置102は、追加されたレコードのイベント分岐状態フィールドに“分岐開始”を設定する(ステップS2005)。   Subsequently, the communication apparatus 102 adds a new record to the message storage table 331 (step S2003), and sets the message ID of the task delegation request message 314 in the message ID field of the added record (step S2004). After storage, the communication apparatus 102 sets “branch start” in the event branch state field of the added record (step S2005).

ステップS2005の処理終了後、または“分岐済”である場合(ステップS2001:Yes)、通信装置102は、下位の通信装置102のうちタスクを委譲する通信装置102を選択する(ステップS2006)。なお、具体的な選択方法としては、下位の通信装置102のうち、ランダムで選択してもよいし、イベントを多く送信する可能性が高い通信装置102を、タスクを委譲する通信装置102に選択してもよい。   After the process of step S2005 is completed, or when it is “branched” (step S2001: Yes), the communication apparatus 102 selects the communication apparatus 102 that delegates the task from the lower-level communication apparatuses 102 (step S2006). As a specific selection method, the communication device 102 may be selected at random from among the lower-level communication devices 102, or the communication device 102 that is likely to transmit many events is selected as the communication device 102 that delegates the task. May be.

選択後、通信装置102は、選択された通信装置102にタスク委譲要求メッセージ314を送信する(ステップS2007)。送信後、通信装置102は、イベント分岐設定処理を終了する。選択された通信装置102は、通信装置タスク委譲処理を実行する(ステップS1702)。   After the selection, the communication device 102 transmits a task delegation request message 314 to the selected communication device 102 (step S2007). After the transmission, the communication apparatus 102 ends the event branch setting process. The selected communication device 102 executes communication device task delegation processing (step S1702).

図21は、通信装置102におけるイベント要求メッセージ送信処理の一例を示すフローチャートである。イベント要求メッセージ送信処理は、ステップS1903:Yesのルートを通ったときに実行される。通信装置102は、受信したタスク委譲要求メッセージ314から、イベント要求メッセージ332を生成する(ステップS2101)。具体的に、通信装置102は、タスク委譲要求メッセージ314のイベントフィールドとメッセージIDフィールドから、イベント要求メッセージ332を生成する。   FIG. 21 is a flowchart illustrating an example of an event request message transmission process in the communication apparatus 102. The event request message transmission process is executed when the route of step S1903: Yes is passed. The communication apparatus 102 generates an event request message 332 from the received task delegation request message 314 (step S2101). Specifically, the communication apparatus 102 generates an event request message 332 from the event field and message ID field of the task delegation request message 314.

続けて、通信装置102は、メッセージ記憶テーブル331に新規レコードを追加する(ステップS2102)。追加後、通信装置102は、追加されたレコードのメッセージIDフィールドにタスク委譲要求メッセージ314のメッセージIDを設定する(ステップS2103)。設定後、通信装置102は、追加されたレコードのイベント分岐状態フィールドに“末端”を設定する(ステップS2104)。   Subsequently, the communication apparatus 102 adds a new record to the message storage table 331 (step S2102). After the addition, the communication apparatus 102 sets the message ID of the task delegation request message 314 in the message ID field of the added record (step S2103). After the setting, the communication apparatus 102 sets “end” in the event branch state field of the added record (step S2104).

メッセージ記憶テーブル331への設定後、通信装置102は、イベント要求メッセージ332を上位の通信装置102に送信する(ステップS2105)。なお、上位がサーバ101である場合、通信装置102は、イベント要求メッセージ332をサーバ101に送信する。ステップS2105の処理終了後、通信装置102は、ステップS1905の処理を実行する。   After setting in the message storage table 331, the communication device 102 transmits an event request message 332 to the higher-level communication device 102 (step S2105). If the upper level is the server 101, the communication apparatus 102 transmits an event request message 332 to the server 101. After the process of step S2105 is completed, the communication apparatus 102 executes the process of step S1905.

図22は、通信装置102における経路情報設定処理の一例を示すフローチャートである。経路情報設定処理は、下位の通信装置102が実行し通信装置タスク委譲処理、または、下位の通信装置102が実行した経路情報設定処理から実行される。   FIG. 22 is a flowchart illustrating an example of route information setting processing in the communication apparatus 102. The path information setting process is executed from the communication apparatus task delegation process executed by the lower communication apparatus 102 or the path information setting process executed by the lower communication apparatus 102.

通信装置102は、イベント要求メッセージ332を受信する(ステップS2201)。続けて、通信装置102は、受信したイベント要求メッセージ332のメッセージIDフィールドと同一のメッセージIDがメッセージ記憶テーブル331に存在するか否かを判断する(ステップS2202)。同一のメッセージIDが存在する場合(ステップS2202:Yes)、通信装置102は、存在したメッセージIDのレコードのイベント分岐状態が“分岐開始”であるか否かを判断する(ステップS2203)。   The communication device 102 receives the event request message 332 (step S2201). Subsequently, the communication apparatus 102 determines whether the same message ID as the message ID field of the received event request message 332 exists in the message storage table 331 (step S2202). If the same message ID exists (step S2202: YES), the communication apparatus 102 determines whether the event branch state of the record with the existing message ID is “start of branch” (step S2203).

イベント分岐状態が“分岐開始”である場合(ステップS2203:Yes)、通信装置102は、イベント収集用テーブル402に経路情報を設定する(ステップS2204)。具体的に、経路情報として、通信装置102は、イベント要求メッセージ332のイベントフィールドから、イベント種別フィールドと、測定対象フィールドとを設定する。さらに、通信装置102は、イベント要求メッセージ332の送信先となる通信装置102の識別情報から収集先識別情報フィールドを設定する。経路情報の設定後、通信装置102は、イベント収集処理を実行する(ステップS1704)。   When the event branch state is “start of branch” (step S2203: Yes), the communication apparatus 102 sets route information in the event collection table 402 (step S2204). Specifically, as route information, the communication apparatus 102 sets an event type field and a measurement target field from the event field of the event request message 332. Further, the communication apparatus 102 sets a collection destination identification information field from the identification information of the communication apparatus 102 that is the transmission destination of the event request message 332. After setting the route information, the communication apparatus 102 executes an event collection process (step S1704).

同一のメッセージIDが存在しない場合(ステップS2202:No)、または、“分岐開始”でない場合(ステップS2203:No)、通信装置102は、イベント収集用テーブル402に経路情報を設定する(ステップS2205)。経路情報の設定後、通信装置102は、受信したイベント要求メッセージ332を上位の通信装置102に送信する(ステップS2206)。イベント要求メッセージ332を送信後、通信装置102は、イベント収集処理を実行する。また、イベント要求メッセージ332を受信した上位の通信装置102は、経路情報設定処理を実行する(ステップS1703)。   When the same message ID does not exist (step S2202: No), or when it is not “start of branch” (step S2203: No), the communication apparatus 102 sets route information in the event collection table 402 (step S2205). . After setting the route information, the communication apparatus 102 transmits the received event request message 332 to the upper communication apparatus 102 (step S2206). After transmitting the event request message 332, the communication device 102 executes event collection processing. In addition, the higher-level communication device 102 that has received the event request message 332 executes route information setting processing (step S1703).

図23は、通信装置102におけるイベント収集処理の一例を示すフローチャートである。イベント収集処理は、ステップS2204またはステップS2206によって経路情報が設定された後、イベント333を受信したときに実行される。なお、端末103からのイベントの送信については、予め決められた周期で送信される。   FIG. 23 is a flowchart illustrating an example of event collection processing in the communication apparatus 102. The event collection process is executed when the event 333 is received after the route information is set in step S2204 or step S2206. Note that the event transmission from the terminal 103 is performed in a predetermined cycle.

通信装置102は、下位の通信装置102からイベント333を受信する(ステップS2301)。イベント333の受信後、通信装置102は、受信したイベント333に対応する経路情報がイベント収集用テーブル402に登録されているか否かを判断する(ステップS2302)。具体的な判断方法として、通信装置102は、受信したイベントと、イベント収集用テーブル402のイベント種別フィールドが一致するレコードが存在するか否かを確認することで、受信したイベント333に対応する経路情報が登録されていることを判断する。   The communication device 102 receives the event 333 from the lower-level communication device 102 (step S2301). After receiving the event 333, the communication apparatus 102 determines whether route information corresponding to the received event 333 is registered in the event collection table 402 (step S2302). As a specific determination method, the communication apparatus 102 confirms whether or not there is a record in which the received event matches the event type field of the event collection table 402, so that a route corresponding to the received event 333 is obtained. Determine that the information is registered.

対応する経路情報が登録されている場合(ステップS2302:Yes)、通信装置102は、受信したイベント333を経路情報に従った通信装置102に送信する(ステップS2303)。イベント333を送信後、通信装置102は、イベント収集処理を終了する。対応する経路情報が登録されていない場合(ステップS2302:No)、通信装置102は、受信したイベント333を上位の通信装置102に送信し(ステップS2304)、イベント収集処理を終了する。   When the corresponding route information is registered (step S2302: Yes), the communication device 102 transmits the received event 333 to the communication device 102 according to the route information (step S2303). After transmitting the event 333, the communication apparatus 102 ends the event collection process. When the corresponding route information is not registered (step S2302: No), the communication apparatus 102 transmits the received event 333 to the higher-level communication apparatus 102 (step S2304), and ends the event collection process.

図24は、通信装置102におけるタスク完了時処理の一例を示すフローチャートである。タスク完了時処理は、ステップS1905にて処理を実行した後に実行される。通信装置102は、イベント333を受信し、委譲されたタスクに入力する(ステップS2401)。次に、通信装置102は、タスクからの結果があったか否かを判断する(ステップS2402)。タスクから結果がない場合(ステップS2402:No)、通信装置102は、ステップS2401の処理に移行する。   FIG. 24 is a flowchart illustrating an example of task completion processing in the communication apparatus 102. The task completion process is executed after the process is executed in step S1905. The communication apparatus 102 receives the event 333 and inputs it to the delegated task (step S2401). Next, the communication apparatus 102 determines whether or not there is a result from the task (step S2402). When there is no result from a task (step S2402: No), the communication apparatus 102 transfers to the process of step S2401.

タスクから結果がある場合(ステップS2402:Yes)、通信装置102は、タスク結果メッセージを生成する(ステップS2403)。なお、タスク結果メッセージは、メッセージIDとタスク結果を格納する2つのフィールドを含む。生成後、通信装置102は、タスク結果メッセージを上位の通信装置102に送信する(ステップS2404)。なお、上位の通信装置102が存在しなく、サーバ101である場合、通信装置102は、サーバ101にタスク結果メッセージを送信する。送信後、通信装置102はタスク完了時処理を終了する。   When there is a result from the task (step S2402: Yes), the communication apparatus 102 generates a task result message (step S2403). The task result message includes two fields for storing a message ID and a task result. After the generation, the communication device 102 transmits a task result message to the higher-level communication device 102 (step S2404). When the upper communication device 102 does not exist and is the server 101, the communication device 102 transmits a task result message to the server 101. After the transmission, the communication apparatus 102 ends the task completion process.

なお、ステップS1808にてタスク結果メッセージを受け付けたサーバ101は、メッセージタスク関係テーブル312を参照することで、どのタスクが完了したかを判断することができる。また、タスク結果メッセージを受け付けた通信装置102は、タスク結果メッセージのメッセージIDとメッセージ記憶テーブル331のメッセージIDフィールドが一致するレコードを削除してもよい。   The server 101 that has received the task result message in step S1808 can determine which task has been completed by referring to the message task relation table 312. In addition, the communication apparatus 102 that has received the task result message may delete a record in which the message ID of the task result message matches the message ID field of the message storage table 331.

以上説明したように、通信装置、通信プログラム、および通信方法によれば、イベントの収集要求を下位の装置から受信した場合、イベントを複数の下位の装置から収集する装置のうち最上位の装置が自装置であることを示す評価値が設定されているかを判断する。設定されている場合、通信装置は、収集要求を上位の装置に送信しない。これにより、通信装置は、上位の装置にイベントの収集要求を送信しないため、使用されない経路情報が追加されなくなるため、上位の装置の経路情報の増大を抑制することができる。   As described above, according to the communication device, the communication program, and the communication method, when an event collection request is received from a lower device, the highest device among the devices that collect events from a plurality of lower devices It is determined whether or not an evaluation value indicating that the own apparatus is set. When set, the communication device does not transmit the collection request to the higher-level device. As a result, the communication device does not transmit an event collection request to the higher-level device, so that unused route information is not added, so that an increase in the route information of the higher-level device can be suppressed.

また、収集要求を送信しないため、通信装置は、ネットワーク内の通信量を削減することができる。さらに、経路情報の増大を抑制することで、通信装置は、タスク委譲、イベント収集における送信先を検索する際に、検索対象となる経路情報の母集団が小さくなるため、検索を高速に行えるようになる。   Further, since the collection request is not transmitted, the communication device can reduce the communication amount in the network. Furthermore, by suppressing the increase in route information, the communication device can search faster because the population of route information to be searched becomes smaller when searching for a destination for task delegation and event collection. become.

また、通信装置は、イベントとイベントを取得可能な下位の装置の識別情報を記憶し、評価値が設定されたかを示す設定情報を上位の装置から受信した場合、イベントを取得可能な装置の数と設定情報に基づいて、自装置の評価値を設定してもよい。これにより、通信装置は、評価値を予め保持しておかずに、収集されるイベントに応じて評価値を設定することができる。たとえば、イベントを用いるタスクの委譲要求を受信したときに、通信装置は、自装置の評価値を設定することができる。   In addition, the communication device stores the event and the identification information of the lower device from which the event can be acquired, and when the setting information indicating whether the evaluation value is set is received from the upper device, the number of devices from which the event can be acquired. Based on the setting information, the evaluation value of the own device may be set. Thereby, the communication device can set the evaluation value according to the collected event without holding the evaluation value in advance. For example, when receiving a task delegation request using an event, the communication device can set the evaluation value of the device itself.

また、通信装置は、上位の装置から設定情報を受信した場合、イベントを取得可能な下位の装置が複数であり、設定情報が設定されていないことを示すときに、評価値を設定してもよい。これにより、通信装置は、上位の装置では自装置以外からイベントを取得しないことが判断できるため、評価値を設定し、経路情報の増大を抑制することができる。   Further, when the communication device receives setting information from the upper device, the communication device may set an evaluation value when there are a plurality of lower devices that can acquire the event and the setting information is not set. Good. As a result, the communication device can determine that the host device does not acquire an event from a device other than its own device, and thus can set an evaluation value and suppress an increase in route information.

なお、本実施の形態で説明した通信方法は、予め用意されたプログラムをパーソナル・コンピュータやワークステーション等のコンピュータで実行することにより実現することができる。本通信プログラムは、ハードディスク、フレキシブルディスク、CD−ROM、MO、DVD等のコンピュータで読み取り可能な記録媒体に記録され、コンピュータによって記録媒体から読み出されることによって実行される。また本通信プログラムは、インターネット等のネットワークを介して配布してもよい。   The communication method described in this embodiment can be realized by executing a program prepared in advance on a computer such as a personal computer or a workstation. The communication program is recorded on a computer-readable recording medium such as a hard disk, a flexible disk, a CD-ROM, an MO, and a DVD, and is executed by being read from the recording medium by the computer. The communication program may be distributed via a network such as the Internet.

100 スマートメータシステム
101 サーバ
102 通信装置
103 端末
104 経路情報テーブル
301、324 制御部
302 構文解析部
303 生成部
304、325、328 送信部
311 処理分割テーブル
312 メッセージタスク関係テーブル
313 タスク情報
314 タスク委譲要求メッセージ
320 記憶部
321、326 受信部
322 設定部
323 判断部
327 追加部
331 メッセージ記憶テーブル
332 イベント要求メッセージ
333 イベント
DESCRIPTION OF SYMBOLS 100 Smart meter system 101 Server 102 Communication apparatus 103 Terminal 104 Path | route information table 301,324 Control part 302 Syntax analysis part 303 Generation | occurrence | production part 304,325,328 Transmission part 311 Process division | segmentation table 312 Message task relation table 313 Task information 314 Task transfer request Message 320 Storage unit 321, 326 Reception unit 322 Setting unit 323 Judgment unit 327 Addition unit 331 Message storage table 332 Event request message 333 Event

Claims (3)

木構造のネットワーク内に存在し、下位の装置から測定対象の属性に関する特徴量の収集要求を受信すると前記測定対象の属性情報と前記下位の装置の識別情報とを自装置の記憶領域に記憶しつつ、前記収集要求を上位の装置に送信する通信装置であって、
前記測定対象の属性情報と前記測定対象の属性の特徴量を取得可能な前記下位の装置の識別情報との組合せを記憶する記憶部と、
前記測定対象の属性に関する特徴量を複数の前記下位の装置から収集する装置のうち前記ネットワーク内で最上位となる装置が前記自装置であるか否かを示す評価値が最上位となる装置として設定されたか否かを示す設定情報を前記上位の装置から受信する受信部と、
前記受信部によって前記設定情報を受信した場合、前記記憶部に記憶された前記測定対象の属性の特徴量を取得可能な前記下位の装置が複数であり、前記設定情報が前記最上位となる装置に設定されていないことを示すときに、前記評価値を前記最上位となる装置として設定する設定部と、
前記収集要求を受信した場合、前記設定部によって設定された前記評価値が前記最上位となる装置を示しているか否かを判断する判断部と、
前記判断部にて前記評価値が前記最上位となる装置であると判断された場合、前記収集要求を前記上位の装置に送信しないように制御する制御部と、
を備えることを特徴とする通信装置。
When a feature quantity collection request regarding the measurement target attribute is received from a lower-level device that exists in the tree-structured network, the measurement target attribute information and the lower-level device identification information are stored in the storage area of the own device. Meanwhile, a communication device that transmits the collection request to a host device,
A storage unit that stores a combination of the attribute information of the measurement target and the identification information of the lower-level device capable of acquiring the feature amount of the attribute of the measurement target;
As an apparatus that has the highest evaluation value indicating whether or not the highest apparatus in the network is the self apparatus among the apparatuses that collect the feature quantities related to the measurement target attribute from the plurality of lower apparatuses. A receiving unit that receives setting information indicating whether or not the setting has been made from the higher-level device; and
When the setting information is received by the receiving unit, there are a plurality of the lower devices capable of acquiring the feature quantity of the attribute of the measurement target stored in the storage unit, and the setting information is the highest device A setting unit that sets the evaluation value as the highest-level device when indicating that it is not set to,
When receiving the collection request, a determination unit that determines whether the evaluation value set by the setting unit indicates the highest-level device;
A control unit that controls not to transmit the collection request to the higher-level device when the determination unit determines that the evaluation value is the highest-level device;
A communication apparatus comprising:
木構造のネットワーク内に存在し、下位の装置から測定対象の属性に関する特徴量の収集要求を受信すると前記測定対象の属性情報と前記下位の装置の識別情報とを特定の装置の記憶領域に記憶しつつ、前記収集要求を上位の装置に送信し、前記測定対象の属性情報と前記測定対象の属性の特徴量を取得可能な前記下位の装置の識別情報との組合せを記憶する記憶部を有する通信装置に実行させる通信プログラムであって、
前記測定対象の属性に関する特徴量を複数の前記下位の装置から収集する装置のうち前記ネットワーク内で最上位となる装置が前記特定の装置であるか否かを示す評価値が最上位となる装置として設定されたか否かを示す設定情報を前記上位の装置から受信し、
前記設定情報を受信した場合、前記記憶部に記憶された前記測定対象の属性の特徴量を取得可能な前記下位の装置が複数であり、前記設定情報が前記最上位となる装置に設定されていないことを示すときに、前記評価値を前記最上位となる装置として設定し、
前記収集要求を受信した場合、設定された前記評価値が前記最上位となる装置を示しているか否かを判断し、
前記評価値が前記最上位となる装置であると判断された場合、前記収集要求を前記上位の装置に送信しないように制御する、
処理を前記特定の装置に実行させる通信プログラム。
Receiving a feature amount collection request relating to a measurement target attribute from a lower-level device that exists in a tree-structured network, the measurement target attribute information and the lower-level device identification information are stored in a storage area of a specific device. However, the storage unit stores the combination of the attribute information of the measurement object and the identification information of the lower apparatus that can acquire the feature amount of the attribute of the measurement object by transmitting the collection request to the upper apparatus. A communication program to be executed by a communication device,
A device having the highest evaluation value indicating whether or not the highest device in the network is the specific device among the devices that collect the feature quantities related to the measurement target attribute from the plurality of lower devices. Receiving setting information indicating whether or not it is set as from the higher-level device,
When the setting information is received, there are a plurality of lower-level devices that can acquire the feature quantity of the measurement target attribute stored in the storage unit, and the setting information is set in the highest-level device. When indicating that there is no, set the evaluation value as the top-level device,
When the collection request is received, it is determined whether or not the set evaluation value indicates the highest-level device;
When it is determined that the evaluation value is the highest-level device, control is performed so that the collection request is not transmitted to the higher-level device.
A communication program for causing the specific device to execute processing.
木構造のネットワーク内に存在し、下位の装置から測定対象の属性に関する特徴量の収集要求を受信すると前記測定対象の属性情報と前記下位の装置の識別情報とを特定の装置の記憶領域に記憶しつつ、前記収集要求を上位の装置に送信し、前記測定対象の属性情報と前記測定対象の属性の特徴量を取得可能な前記下位の装置の識別情報との組合せを記憶する記憶部を有する通信装置が実行する通信方法であって、
前記測定対象の属性に関する特徴量を複数の前記下位の装置から収集する装置のうち前記ネットワーク内で最上位となる装置が前記特定の装置であるか否かを示す評価値が最上位となる装置として設定されたか否かを示す設定情報を前記上位の装置から受信し、
前記設定情報を受信した場合、前記記憶部に記憶された前記測定対象の属性の特徴量を取得可能な前記下位の装置が複数であり、前記設定情報が前記最上位となる装置に設定されていないことを示すときに、前記評価値を前記最上位となる装置として設定し、
前記収集要求を受信した場合、設定された前記評価値が前記最上位となる装置を示しているか否かを判断し、
前記評価値が前記最上位となる装置であると判断された場合、前記収集要求を前記上位の装置に送信しないように制御する、
処理を前記特定の装置が実行する通信方法。
Receiving a feature amount collection request relating to a measurement target attribute from a lower-level device that exists in a tree-structured network, the measurement target attribute information and the lower-level device identification information are stored in a storage area of a specific device. However, the storage unit stores the combination of the attribute information of the measurement object and the identification information of the lower apparatus that can acquire the feature amount of the attribute of the measurement object by transmitting the collection request to the upper apparatus. A communication method executed by a communication device,
A device having the highest evaluation value indicating whether or not the highest device in the network is the specific device among the devices that collect the feature quantities related to the measurement target attribute from the plurality of lower devices. Receiving setting information indicating whether or not it is set as from the higher-level device,
When the setting information is received, there are a plurality of lower-level devices that can acquire the feature quantity of the measurement target attribute stored in the storage unit, and the setting information is set in the highest-level device. When indicating that there is no, set the evaluation value as the top-level device,
When the collection request is received, it is determined whether or not the set evaluation value indicates the highest-level device;
When it is determined that the evaluation value is the highest-level device, control is performed so that the collection request is not transmitted to the higher-level device.
A communication method in which the specific device executes processing.
JP2011143395A 2011-06-28 2011-06-28 COMMUNICATION DEVICE, COMMUNICATION PROGRAM, AND COMMUNICATION METHOD Expired - Fee Related JP5678819B2 (en)

Priority Applications (1)

Application Number Priority Date Filing Date Title
JP2011143395A JP5678819B2 (en) 2011-06-28 2011-06-28 COMMUNICATION DEVICE, COMMUNICATION PROGRAM, AND COMMUNICATION METHOD

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
JP2011143395A JP5678819B2 (en) 2011-06-28 2011-06-28 COMMUNICATION DEVICE, COMMUNICATION PROGRAM, AND COMMUNICATION METHOD

Publications (2)

Publication Number Publication Date
JP2013012853A JP2013012853A (en) 2013-01-17
JP5678819B2 true JP5678819B2 (en) 2015-03-04

Family

ID=47686376

Family Applications (1)

Application Number Title Priority Date Filing Date
JP2011143395A Expired - Fee Related JP5678819B2 (en) 2011-06-28 2011-06-28 COMMUNICATION DEVICE, COMMUNICATION PROGRAM, AND COMMUNICATION METHOD

Country Status (1)

Country Link
JP (1) JP5678819B2 (en)

Family Cites Families (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2001167135A (en) * 1999-12-13 2001-06-22 Mitsubishi Electric Corp Data transfer device and mobile wireless terminal device
JP2003167808A (en) * 2001-11-29 2003-06-13 Nippon Telegr & Teleph Corp <Ntt> Processing method, processing system, trust device, program, and recording medium
JP5190031B2 (en) * 2009-06-22 2013-04-24 株式会社日立製作所 Automatic meter reading system and control message transmission method

Also Published As

Publication number Publication date
JP2013012853A (en) 2013-01-17

Similar Documents

Publication Publication Date Title
CN112352234B (en) A system for handling concurrent property graph queries
Wu et al. Parallelizing skyline queries for scalable distribution
US10338967B2 (en) Systems and methods for predicting performance of applications on an internet of things (IoT) platform
JP5664098B2 (en) Composite event distribution apparatus, composite event distribution method, and composite event distribution program
JP5245711B2 (en) Distributed data processing system, distributed data processing method, and distributed data processing program
JP5360457B2 (en) Distributed directory server, distributed directory system, distributed directory method, and program
CN110334036A (en) A kind of method and apparatus for realizing data cached scheduling
JP3944176B2 (en) Search request transmitting apparatus and program
US20200084121A1 (en) Node of a Network and a Method of Operating the Same for Resource Distribution
US10812390B2 (en) Intelligent load shedding of traffic based on current load state of target capacity
CN108228432A (en) A kind of distributed link tracking, analysis method and server, global scheduler
TWI454949B (en) Distributed resource management systems and methods for resource management thereof
US20140379100A1 (en) Method for requesting control and information processing apparatus for same
JP7310378B2 (en) Information processing program, information processing method, and information processing apparatus
EP2345965A1 (en) Device and method for storing file
CN106571935B (en) Resource scheduling method and equipment
Javanmardi et al. An architecture for scheduling with the capability of minimum share to heterogeneous Hadoop systems: AK Javanmardi et al.
JP5678819B2 (en) COMMUNICATION DEVICE, COMMUNICATION PROGRAM, AND COMMUNICATION METHOD
JP5725043B2 (en) Communication device and communication method
CN118890361A (en) A data synchronization method, device, medium and equipment across a multi-level network structure
US11394648B2 (en) Information processing apparatus and information processing method
JP4594877B2 (en) Computer resource allocation management method and computer resource allocation management apparatus
CN111078160A (en) Data migration and storage method and device based on call proportion and response duration
JPWO2016067370A1 (en) Information processing apparatus, method, and program
CN113055476B (en) Cluster type service system, method, medium and computing equipment

Legal Events

Date Code Title Description
A621 Written request for application examination

Free format text: JAPANESE INTERMEDIATE CODE: A621

Effective date: 20140304

A977 Report on retrieval

Free format text: JAPANESE INTERMEDIATE CODE: A971007

Effective date: 20141107

TRDD Decision of grant or rejection written
A01 Written decision to grant a patent or to grant a registration (utility model)

Free format text: JAPANESE INTERMEDIATE CODE: A01

Effective date: 20141209

A61 First payment of annual fees (during grant procedure)

Free format text: JAPANESE INTERMEDIATE CODE: A61

Effective date: 20141222

R150 Certificate of patent or registration of utility model

Ref document number: 5678819

Country of ref document: JP

Free format text: JAPANESE INTERMEDIATE CODE: R150

LAPS Cancellation because of no payment of annual fees