JP7202818B2 - data collection device - Google Patents
data collection device Download PDFInfo
- Publication number
- JP7202818B2 JP7202818B2 JP2018167556A JP2018167556A JP7202818B2 JP 7202818 B2 JP7202818 B2 JP 7202818B2 JP 2018167556 A JP2018167556 A JP 2018167556A JP 2018167556 A JP2018167556 A JP 2018167556A JP 7202818 B2 JP7202818 B2 JP 7202818B2
- Authority
- JP
- Japan
- Prior art keywords
- data
- transmission
- relay
- collection
- collection target
- 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.)
- Active
Links
Images
Landscapes
- Computer And Data Communications (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
- Information Transfer Between Computers (AREA)
Description
本願は、収集対象機器において生成するデータを冗長化されたデータサーバに送信するデータ収集装置に関するものである。 The present application relates to a data collection device that transmits data generated in collection target equipment to redundant data servers.
複数台の計算機がネットワークにより接続されたシステムにおいて、１台の計算機が他の複数の計算機に同一データを送信するようにしたものがある。
このようなシステムにおいて、データ配信計算機はユニキャスト送信により複数のデータ受信計算機のうちの代表受信計算機にデータを送信し、このデータを受信した代表受信計算機は、データ中継部により他の全てのデータ受信計算機のデータ受信部にブロードキャスト送信し、指定されたデータ受信計算機は、受信完了返答部により受信完了返答をデータ配信計算機に返信するようにしたものが知られている（特許文献１参照）。
In a system in which a plurality of computers are connected by a network, there is a system in which one computer transmits the same data to a plurality of other computers.
In such a system, a data distribution computer transmits data to a representative receiving computer out of a plurality of data receiving computers by unicast transmission, and the representative receiving computer that has received this data transmits all other data through a data relay section. A system is known in which data is broadcast to the data receiving unit of the receiving computer, and the designated data receiving computer returns a reception completion response to the data distribution computer by the reception completion response unit (see Patent Document 1).
従来のデータ送信方法では、１つのデータをまず代表受信計算機が受信し、この代表受信計算機が受信したデータを複数の他の受信計算機に対してそれぞれ送信していたため、データ１つ当たりに代表受信計算機にかかる処理負荷は受信計算機（データサーバ）の台数に比例して大きくなる。
また、対象システム内のデータ配信計算機である収集対象機器等に何らかの問題が発生した際、機器内に生成されるデータの量は膨大な量となり、これらのデータをリアルタイムにデータ受信計算機に送信する場合、データの生成速度が送信速度を上回って、データの送信が行えない場合がある。
In the conventional data transmission method, one data is first received by a representative receiving computer, and the data received by this representative receiving computer is transmitted to a plurality of other receiving computers. The processing load on computers increases in proportion to the number of receiving computers (data servers).
In addition, when some problem occurs in the collection target equipment, which is the data distribution computer in the target system, the amount of data generated in the equipment becomes enormous, and this data is sent to the data reception computer in real time. In some cases, the data generation speed exceeds the transmission speed, and the data cannot be transmitted.
本願は、上記のような課題を解決するためになされたものであり、１つの収集対象機器が複数のデータサーバに対して同じデータを送信する際、収集対象機器にかかる処理の負荷を軽減するようにしたデータ収集装置を得ることを目的とするものである。 The present application was made to solve the above problems, and reduces the processing load on the collection target device when one collection target device transmits the same data to multiple data servers. It is an object of the present invention to obtain a data collection device configured as follows.
本願に係るデータ収集装置は、データの収集対象機器において生成するデータを冗長化した複数のデータサーバに送信するデータ収集装置であって、収集対象機器は、データの生成速度が送信速度を上回った場合は、少なくとも１台のデータサーバへの送信が完了すれば複数のデータサーバの全台への送信が完了したとみなす送信機能手段を備え、データサーバは、収集対象機器から受信したデータを互いに照合し、受信していないデータがあれば他のデータサーバから送信してもらうことで、複数のデータサーバ間でデータを補完するデータ補完機能手段を備えたものである。 A data collection device according to the present application is a data collection device that transmits data generated by a data collection target device to a plurality of redundant data servers, and the collection target device has a data generation speed that exceeds the transmission speed. In this case, the transmission function means is provided for determining that the transmission to all of the plurality of data servers is completed when the transmission to at least one data server is completed, and the data server exchanges the data received from the equipment to be collected with each other. It is provided with data complementing function means for complementing data between a plurality of data servers by collating and requesting transmission from other data servers if there is data that has not been received.
また、本願に係るデータ収集装置は、データの収集対象機器において生成するデータを冗長化した複数のデータサーバに送信するデータ収集装置であって、収集対象機器とデータサーバ間のデータ送信処理を中継する複数の中継装置を設け、収集対象機器は、データの生成速度が送信速度を上回った場合は、少なくとも１台の中継装置への送信が完了すれば複数の中継装置の全台への送信が完了したとみなす送信機能手段を備え、複数の中継装置は、収集対象機器から受信したデータを複数のデータサーバに転送する転送手段を備え、転送手段から転送されたデータにより複数のデータサーバのデータの欠落を補うことを特徴とする。
また、本願に係るデータ収集装置は、データの収集対象機器において生成するデータを冗長化した複数のデータサーバに送信するデータ収集装置であって、収集対象機器とデータサーバ間のデータ送信処理を中継する複数の中継装置を設け、収集対象機器は、データの生成速度が送信速度を上回った場合は、少なくとも１台の中継装置への送信が完了すれば複数の中継装置の全台への送信が完了したとみなす送信機能手段を備え、複数の中継装置は、収集対象機器から受信したデータを互いに照合し、受信していないデータがあれば、受信している他の中継装置から送信してもらうことにより、複数の中継装置間でデータを補完するデータ補完機能手段を備えたことにより、補完されたデータを複数の中継装置から複数のデータサーバに送信することを特徴とする。
Further, a data collection device according to the present application is a data collection device that transmits data generated in a data collection target device to a plurality of redundant data servers, and relays data transmission processing between the collection target device and the data server. If the speed of data generation exceeds the transmission speed of the equipment to be collected, the transmission to all of the multiple relay devices will be completed when the transmission to at least one relay device is completed. The plurality of relay devices are provided with transmission function means for determining completion, the plurality of relay devices are provided with transfer means for transferring data received from the collection target equipment to the plurality of data servers, and the data transferred from the transfer means are used to transfer the data of the plurality of data servers. is characterized by compensating for the lack of
Further, a data collection device according to the present application is a data collection device that transmits data generated in a data collection target device to a plurality of redundant data servers, and relays data transmission processing between the collection target device and the data server. If the speed of data generation exceeds the transmission speed of the equipment to be collected, the transmission to all of the multiple relay devices will be completed when the transmission to at least one relay device is completed. Equipped with transmission function means for determining completion, a plurality of relay devices compare data received from collection target equipment with each other, and if there is data that has not been received, it is sent from another relay device that has received it. Thus, by providing data complementing function means for complementing data between a plurality of relay devices, the complemented data is transmitted from a plurality of relay devices to a plurality of data servers.
本願のデータ収集装置は、１つの収集対象機器が複数のデータサーバに対して同じデータを送信する際、収集対象機器にかかる送信負荷を軽減しつつ送信速度を向上できる。 The data collection device of the present application can improve the transmission speed while reducing the transmission load on the collection target device when one collection target device transmits the same data to a plurality of data servers.
実施の形態１．
以下、本願の実施の形態１におけるデータ収集装置を図１から図５に基づいて説明する。
図１はデータ収集装置におけるシステムの全体構成図、図２は収集動作を示すフローチャート図である。
図１に示すデータ収集装置は、対象システム内の制御機器または計算機等でデータを生成する収集対象機器１と、収集対象機器１から送信されるデータをリアルタイムで受信する冗長化された複数台のデータサーバ２、３とで構成されている。なお、実施の形態１では、データサーバ２、３は二重化された２台の場合を例に説明するが、２台以上の多重化された複数台のデータサーバにおいても同様である。
Embodiment 1.
A data collection device according to Embodiment 1 of the present application will be described below with reference to FIGS. 1 to 5. FIG.
FIG. 1 is a diagram showing the overall system configuration of the data collection device, and FIG. 2 is a flow chart showing the collection operation.
The data collection device shown in FIG. It consists of
収集対象機器１とデータサーバ２との間、収集対象機器１とデータサーバ３との間のネットワークは独立しており、２台のデータサーバ２、３の間はデータサーバ２とデータサーバ３が互いにデータを送受信できるように接続されているものとする。
収集対象機器１は、データを生成する速度が送信する速度を上回った場合は、少なくとも１台のデータサーバ２への送信が完了すれば複数のデータサーバ２、３の全台への送信が完了したとみなす送信機能手段１１を備えている。一方、データサーバ２、３は、収集対象機器１から受信したデータを互いに照合し、受信していないデータがあれば他のデータサーバから送信してもらうことで、複数のデータサーバ２、３間のデータを補完するデータ補完機能手段２１、３１を備えている。
The network between the collection target device 1 and the
If the data generation speed exceeds the data transmission speed, the collection target device 1 completes transmission to all of the plurality of
次に実施の形態１のデータ収集装置における動作について図２から図５を用いて説明する。
図２において、ステップＳ１１は、収集対象機器１におけるデータの生成速度とデータの送信速度を比較する。データの生成速度に対してデータの送信速度が十分確保されている場合（ＹＥＳ）、ステップＳ１２に進み、収集対象機器１は両系のデータサーバ２及びデータサーバ３に対し、一つのデータを同時に送信する。この場合、図３に示すようにデータサーバ２及びデータサーバ３は収集対象機器１から送信されるすべてのパケットデータＡ、Ｂ、Ｃを同時に受信できる。
Next, the operation of the data collection device of Embodiment 1 will be described with reference to FIGS. 2 to 5. FIG.
In FIG. 2, step S11 compares the data generation speed and the data transmission speed in the collection target device 1 . If the data transmission speed is sufficiently secured for the data generation speed (YES), the process proceeds to step S12, and the collection target device 1 simultaneously transmits one piece of data to the
収集対象機器１におけるデータの生成量が増大し、データの送信速度を生成速度が上回り始めた場合、未送信のデータが収集対象機器１の送信バッファの容量を圧迫する。ステップＳ１１において、データの生成速度がデータの送信速度よりも大きい場合（ＮＯ）、ステップＳ１３に進み、収集対象機器１は２台のデータサーバ２及びデータサーバ３のどちらか一方のデータサーバにデータを送信する。
When the amount of data generated in the collection target device 1 increases and the generation speed begins to exceed the data transmission speed, unsent data puts pressure on the capacity of the transmission buffer of the collection target device 1 . In step S11, if the data generation speed is higher than the data transmission speed (NO), the process proceeds to step S13, and the collection target device 1 stores data in one of the two
この場合、図４に示すように２台のデータサーバ２及びデータサーバ３のどちらか一方にデータを送信できれば（送り先のうち１つからＡＣＫ信号を受けた場合）、送信機能手段１１は全てのデータサーバへの送信が完了と判断し、収集対象機器１の送信バッファ内のデータを削除し、新たなデータを格納する。図４においては、収集対象機器１から送信されるパケットデータＡはデータサーバ２に、続くパケットデータＢはデータサーバ３に、続くパケットデータＣはデータサーバ２に送信される。
In this case, if data can be transmitted to one of the two
ステップＳ１３で、収集対象機器１は２台のデータサーバ２及びデータサーバ３のどちらか一方のデータサーバにデータを送信した場合は、ステップＳ１４に進み、データサーバ２及び３のデータ補完機能手段２１、３１は、受信したデータを互いに照合し、受信していないデータがあれば他のデータサーバから送信してもらうことで、複数のデータサーバ２、３間でデータを互いに補完する。
データ補完機能手段２１、３１は、受信したデータを互いに照合する場合、受信したデータの識別子を他のデータサーバに送信し、他のデータサーバが受信していないデータを送信しあうことでデータサーバ間のデータを補完する。
In step S13, when the device 1 to be collected has transmitted data to one of the two
When matching the received data, the data complementing function means 21 and 31 transmit the identifier of the received data to the other data server, and transmit the data that the other data server has not received. Complement the data in between.
この場合、図５に示すように、一方のデータサーバにのみ送信されたデータは送信されなかったデータサーバ内には存在しないため、データサーバ２及びデータサーバ３間にて受信したデータの照合を行い、足りないデータを互いに補完する。図５においては、データサーバ２はパケットデータＢが存在しないためデータサーバ３からパケットデータＢを受信する。一方、データサーバ３はパケットデータＡ、Ｃが存在しないためデータサーバ２からパケットデータＡ、Ｃを受信する。こうして、データサーバ２及びデータサーバ３は収集対象機器１からのパケットデータＡ、Ｂ、Ｃをすべて収集したことになる。
In this case, as shown in FIG. 5, the data sent to only one data server does not exist in the data server to which it was not sent. and complement each other with missing data. In FIG. 5,
実施の形態１のデータ収集装置は、１つの収集対象機器１が２台以上のデータサーバ２、３に対して同じデータを送信する際に、収集対象機器１は、１台のデータサーバへの送信が完了すれば複数のデータサーバの全台への送信が完了したとみなす送信機能手段１１を備え、データサーバ２、３は、受信したデータを互いに照合して複数のデータサーバ間のデータを補完するデータ補完機能手段２１、３１を備えることで、収集対象機器１が負担する送信負荷を軽減することができる。
In the data collection apparatus of Embodiment 1, when one collection target device 1 transmits the same data to two or
実施の形態２．
次に、本願の実施の形態２におけるデータ収集装置を図６および図７に基づいて説明する。図６はデータ収集装置におけるシステムの全体構成図、図７は収集動作を示すフローチャート図である。
実施の形態１では、２台のデータサーバ２及び３間でデータを補完することによって、データの欠落を補う場合について述べたが、データを補完する処理の分だけデータサーバ側に負荷が加わってしまう。
Next, a data collection device according to
In the first embodiment, a case has been described in which missing data is compensated for by complementing data between the two
そこで、図６に示すように収集対象機器１とデータサーバ２間および収集対象機器１とデータサーバ３間に、それぞれデータ送信処理を中継する中継装置４及び中継装置５を設け、中継装置４及び中継装置５には収集対象機器１から送信されたデータをデータサーバ２、３に転送する転送手段４１、５１を備えている。
中継装置４及び中継装置５は、収集対象機器１から受信したデータをそれぞれのデータサーバ２、３に振り分けることで実施の形態１と同様の効果を得ることが出来るようにしたものである。
Therefore, as shown in FIG. 6, a
The
収集対象機器１は、データを生成する速度が送信する速度を上回った場合は、少なくとも１台の中継装置４または中継装置５への送信が完了すれば複数の中継装置４及び中継装置５の全台への送信が完了したとみなす送信機能手段１１を備えている。
その他の構成は図１の実施の形態１と同じにつき、同じ又は相当部分には同じ符号を付して説明を省略する。
When the data generation speed exceeds the data transmission speed, the collection target device 1 sends data to all of the plurality of
Other configurations are the same as those of the first embodiment shown in FIG. 1, and the same or corresponding parts are denoted by the same reference numerals, and descriptions thereof are omitted.
図７のフローチャート図において、ステップＳ２１は、収集対象機器１におけるデータの生成速度とデータの送信速度を比較する。データの生成速度に対してデータの送信速度が十分確保されている場合（ＹＥＳ）、ステップＳ２２に進み、収集対象機器１は中継装置４及び中継装置５に対して同じデータを同時に送信する。ステップＳ２３はデータを受信した中継装置４及び中継装置５は続けてデータサーバ２及びデータサーバ３に対して同じデータを同時に転送する。こうしてデータサーバ２及びデータサーバ３は収集対象機器１から送信されるすべてのパケットデータＡ、Ｂ、Ｃを受信できる。
In the flowchart of FIG. 7, step S21 compares the data generation speed and the data transmission speed in the collection target device 1 . If the data transmission speed is sufficient for the data generation speed (YES), the process proceeds to step S22, and the collection target device 1 simultaneously transmits the same data to the
収集対象機器１におけるデータの生成量が増大し、データの送信速度を生成速度が上回り始めて、収集対象機器１の送信バッファ内が未送信のデータで満たされた場合、バッファの容量を圧迫する。ステップＳ２１において、データの生成速度がデータの送信速度よりも大きい場合（ＮＯ）、ステップＳ２４に進み、収集対象機器１は２台の中継装置４及び中継装置５のどちらか一方の中継装置にデータを送信する。
When the amount of data generated in the collection target equipment 1 increases and the generation speed begins to exceed the data transmission speed, and the transmission buffer of the collection target equipment 1 is filled with untransmitted data, the capacity of the buffer is squeezed. In step S21, if the data generation speed is higher than the data transmission speed (NO), the process proceeds to step S24, and the collection target device 1 transmits data to either one of the two
この場合、図６に示すように２台の中継装置４及び中継装置５のどちらか一方にデータを送信できれば、収集対象機器１の送信機能手段１１は全ての中継装置への送信が完了と判断し、収集対象機器１の送信バッファ内のデータを削除し、新たなデータを格納する。
ステップＳ２４の後のステップＳ２５に進み、中継装置４および中継装置５が受信したデータは、中継装置４、５の転送手段４１、５１により両系の２つのデータサーバ２及びデータサーバ３にそれぞれデータを転送する。
In this case, as shown in FIG. 6, if data can be transmitted to either one of the two
Proceeding to step S25 after step S24, the data received by the
ステップＳ２４においては、図６に示すように、収集対象機器１から送信されるパケットデータＡは中継装置４に送信され、続くパケットデータＢは中継装置５に送信され、続くパケットデータＣは中継装置４に送信される。ステップＳ２５において、中継装置４は２つのデータサーバ２及びデータサーバ３にパケットデータＡとＣを転送し、中継装置５は２つのデータサーバ２及びデータサーバ３にパケットデータＢを転送する。こうしてデータサーバ２及びデータサーバ３は収集対象機器１からのパケットデータＡ、Ｂ、Ｃをすべて収集したことになる。
このように受信したデータを中継装置４、５が各データサーバ２、３にそれぞれ転送することで、実施の形態１の補完処理と同様の効果を得ることが出来る。
In step S24, as shown in FIG. 6, packet data A transmitted from the collection target device 1 is transmitted to the
By having the
実施の形態３．
次に、本願の実施の形態３におけるデータ収集装置を図８および図９に基づいて説明する。図８はデータ収集装置におけるシステムの全体構成図、図９は収集動作を示すフローチャート図である。
実施の形態２では、２つの中継装置４、５がそれぞれデータサーバ２、３にデータを転送することで、データの欠落を補う場合について述べたが、実施の形態３では図８に示すように中継装置４、５には、収集対象機器１から受信したデータを互いに照合し、受信していないデータがあれば他の中継装置から送信してもらうことで、複数の中継装置４、５間のデータを補完するデータ補完機能手段４２、５２を備えている。
その他の構成は図６の実施の形態２と同じにつき、同じ又は相当部分には同じ符号を付して説明を省略する。
Next, a data collection device according to
In the second embodiment, the two
The rest of the configuration is the same as that of the second embodiment shown in FIG. 6, so the same or corresponding parts are denoted by the same reference numerals and the description thereof is omitted.
実施の形態３の動作を図９のフローチャート図を用いて説明する。
図９のフローチャート図において、ステップＳ３１は、収集対象機器１におけるデータの生成速度とデータの送信速度を比較する。データの生成速度に対してデータの送信速度が十分確保されている場合（ＹＥＳ）、ステップＳ３２に進み、収集対象機器１は中継装置４及び中継装置５に対して同じデータを同時に送信する。ステップＳ３３はデータを受信した中継装置４及び中継装置５は続けてデータサーバ２及びデータサーバ３に対して同じデータを同時に転送する。こうしてデータサーバ２及びデータサーバ３は収集対象機器１から送信されるすべてのパケットデータＡ、Ｂ、Ｃを受信できる。
The operation of the third embodiment will be described with reference to the flow chart of FIG.
In the flowchart of FIG. 9, step S31 compares the data generation speed and the data transmission speed in the collection target device 1 . If the data transmission speed is sufficient for the data generation speed (YES), the process proceeds to step S32, and the collection target device 1 simultaneously transmits the same data to the
収集対象機器１におけるデータの生成量が増大し、データの送信速度を生成速度が上回り始めて、収集対象機器１の送信バッファ内が未送信のデータで満たされた場合、バッファの容量を圧迫する。ステップＳ３１において、データの生成速度がデータの送信速度よりも大きい場合（ＮＯ）、ステップＳ３４に進み、収集対象機器１は２台の中継装置４及び中継装置５のどちらか一方の中継装置にデータを送信する。
２台の中継装置４及び中継装置５のどちらか一方にデータを送信できれば、収集対象機器１の送信機能手段１１は全ての中継装置への送信が完了と判断し、収集対象機器１の送信バッファ内のデータを削除し、新たなデータを格納する。
When the amount of data generated in the collection target equipment 1 increases and the generation speed begins to exceed the data transmission speed, and the transmission buffer of the collection target equipment 1 is filled with untransmitted data, the capacity of the buffer is squeezed. In step S31, if the data generation speed is higher than the data transmission speed (NO), the processing proceeds to step S34, and the collection target device 1 transmits the data to either one of the two
If the data can be transmitted to either one of the two
ステップＳ３４においては、図８に示すように、収集対象機器１から送信されるパケットデータＡは中継装置４に送信され、続くパケットデータＢは中継装置５に送信され、続くパケットデータＣは中継装置４に送信される。
ステップＳ３４で、収集対象機器１は２台の中継装置４及び中継装置５のどちらか一方の中継装置にデータを送信した場合は、ステップＳ３５に進み、中継装置４及び中継装置５のデータ補完機能手段４２、５２は、受信したデータを互いに照合し、受信していないデータがあれば他の中継装置から送信してもらうことで、複数の中継装置４、５間でデータを互いに補完する。
In step S34, as shown in FIG. 8, packet data A transmitted from the collection target device 1 is transmitted to the
In step S34, when the device to be collected 1 transmits data to either one of the two
ステップＳ３５においては、中継装置４はデータ補完機能手段４２により中継装置５にパケットデータＡとＣを転送し、中継装置５はデータ補完機能手段５２により中継装置４にパケットデータＢを転送する。こうして中継装置４及び中継装置５は収集対象機器１からのパケットデータＡ、Ｂ、Ｃをすべて収集したことになる。
続くステップＳ３６では、中継装置４はデータサーバ２にパケットデータＡ、Ｂ、Ｃの送信処理を行い、中継装置５はデータサーバ３にパケットデータＡ、Ｂ、Ｃの送信処理を行い、データサーバ２、３には収集対象機器１からのデータはすべて揃った状態で記録される。
In step S35, the
In subsequent step S36, the
データ補完機能手段４２、５２は、受信したデータを互いに照合する場合、受信したデータの識別子を他のデータサーバに送信し、他のデータサーバが受信していないデータを送信しあうことでデータサーバ間のデータを補完する。
実施の形態３では、収集対象機器１から送信されたデータを中継装置４、５が受信し、中継装置４、５間でお互いにデータを補完してデータサーバ２、３にデータを送信することで、１つのデータサーバが２台の中継装置からデータを受信する必要がなくなり、中継装置からデータを受信する負荷を軽減することが出来る。
また、データを中継装置４、５間で補完することで収集対象機器１が負担するはずであった送信負荷を中継装置４、５に肩代わりさせ、少なくとも１台の中継装置にデータを送信し、収集対象機器１の送信負荷を軽減しつつ送信速度を向上し、送信したデータのバッファを早期に開放させることでメモリ消費を抑えることができる。
When matching the received data, the data complementing function means 42 and 52 transmit the identifier of the received data to the other data server, and transmit the data that the other data server has not received to each other. Complement the data in between.
In the third embodiment, the
Further, by interpolating the data between the
実施の形態４．
次に、本願の実施の形態４におけるデータ収集装置を図１０および図１１に基づいて説明する。図１０はデータ収集装置におけるシステムの全体構成図、図１１は収集動作を示すフローチャート図である。
実施の形態３では中継装置４、５間でデータの補完処理を行う場合について述べたが、実施の形態４では、図１０に示すように片系の中継装置４が機能停止に陥った場合のみ、欠落したデータの再送要求を収集対象機器１に行うことでデータの補完を行い、データの欠落を防ぐことが出来るようにしたものである。
Next, a data collection device according to
In the third embodiment, the case where the data complementing process is performed between the
実施の形態４では、中継装置４及び中継装置５に、データ補完に失敗した際または中継装置４、５の一方に異常があった場合は、収集対象機器１に対してデータの再送要求を行う再送要求処理手段４３、５３を備えている。
その他の構成は図８の実施の形態３と同じにつき、同じ又は相当部分には同じ符号を付して説明を省略する。
In the fourth embodiment, when the
The rest of the configuration is the same as that of the third embodiment shown in FIG. 8, so the same or corresponding parts are denoted by the same reference numerals and description thereof is omitted.
実施の形態４の動作を図１１のフローチャート図を用いて説明する。
図１１のフローチャート図において、ステップＳ４１からステップＳ４４までは、実施の形態３の図９に示すステップＳ３１からステップＳ３４までと同じであり、説明を省略する。
ステップＳ４４においては、図１０に示すように、収集対象機器１から送信されるパケットデータＡは中継装置４に送信され、続くパケットデータＢは中継装置５に送信され、続くパケットデータＣは中継装置４に送信される。
The operation of the fourth embodiment will be described with reference to the flow chart of FIG.
In the flowchart of FIG. 11, steps S41 to S44 are the same as steps S31 to S34 shown in FIG. 9 of
In step S44, as shown in FIG. 10, packet data A transmitted from the collection target device 1 is transmitted to the
ステップＳ４５では、２台の中継装置４及び中継装置５が正常に動作しているかどうかを判断し、両系の中継装置４、５が正常に動作している場合（ＹＥＳ）、収集対象機器１は２台の中継装置４及び中継装置５のどちらか一方の中継装置にデータを送信した後に、ステップＳ４６に進む。ステップＳ４６では、中継装置４及び中継装置５のデータ補完機能手段４２、５２は、受信したデータを互いに照合し、受信していないデータがあれば他の中継装置から送信してもらうことで、複数の中継装置４、５間でデータを互いに補完する。このデータ補完の仕方は実施の形態３のステップＳ３５と同じである。
その後、ステップＳ４７では、中継装置４はデータサーバ２にパケットデータＡ、Ｂ、Ｃの送信処理を行い、中継装置５はデータサーバ３にパケットデータＡ、Ｂ、Ｃの送信処理を行い、両系のデータサーバ２、３には収集対象機器１からのデータはすべて揃った状態で記録される。
In step S45, it is determined whether the two
Thereafter, in step S47, the
ステップＳ４５において、２台の中継装置４及び中継装置５の一方、例えば中継装置５が異常となって機能停止した場合（ＮＯ）、停止した中継装置５にのみ送信されていたパケットデータＢは保管することが出来ず、データサーバ２、３まで到達することが出来ない。
中継装置４または中継装置５の一方が機能停止した場合はステップＳ４８に進み、正常の中継装置４は受信済みのデータについて確認を行い、再送要求処理手段４３により未受信のパケットデータＢを再送するよう収集対象機器１に要求する。収集対象機器１は要求されたパケットデータＢを中継装置４に送信する。
In step S45, when one of the two
If either the
ステップＳ４９において、中継装置４は異常の中継装置５が受信すべきだったパケットデータＢを受信した後に、両系のデータサーバ２とデータサーバ３にそれぞれパケットデータＡ、Ｂ、Ｃの送信処理を行う。こうしてデータサーバ２、３は収集対象機器１からのデータをすべて揃った状態で記録される。
実施の形態４のデータ収集装置は、一方の中継装置が機能停止しても最小限の負荷で処理を継続することが出来る。
In step S49, after receiving the packet data B that should have been received by the
The data collection device of
実施の形態５．
次に、本願の実施の形態５におけるデータ収集装置を図１２および図１３に基づいて説明する。図１２はデータ収集装置におけるシステムの全体構成図、図１３は収集動作を示すフローチャート図である。
実施の形態５では図１２に示すように、中継装置４および中継装置５にそれぞれデータを記録する記憶装置４４および記憶装置５４を設け、片系の中継装置が機能停止した場合、稼働中の中継装置内の記憶装置内にデータを記録する機能を追加するようにしたものである。その他の構成は図１０の実施の形態４と同じにつき、同じ又は相当部分には同じ符号を付して説明を省略する。
Next, a data collection device according to
In the fifth embodiment, as shown in FIG. 12, a
実施の形態５では、片系の中継装置が機能停止した場合、稼働中の中継装置内の記憶装置内にデータを記録する機能を追加することで、機能停止していた中継装置が復旧時に機能停止中に受信できなかったデータについて補完を行えるようする。これによって、機能復旧時の処理負荷を収集対象機器１に掛けることなく復旧することが出来る。 In the fifth embodiment, by adding a function to record data in a storage device in a relay device in operation when one relay device has stopped functioning, the relay device that has stopped functioning can be restored to function. Make it possible to supplement data that could not be received during suspension. As a result, recovery can be performed without imposing a processing load on the collection target device 1 at the time of function recovery.
実施の形態５の動作を図１３のフローチャート図を用いて説明する。
図１３のフローチャート図において、ステップＳ５１からステップＳ５９までは、実施の形態４の図１１に示すステップＳ４１からステップＳ４９までと同じであり、説明を省略する。
The operation of the fifth embodiment will be described with reference to the flow chart of FIG.
In the flowchart of FIG. 13, steps S51 to S59 are the same as steps S41 to S49 shown in FIG. 11 of the fourth embodiment, and description thereof is omitted.
ステップＳ５９において、中継装置４は異常の中継装置５が受信すべきだったパケットデータＢを再送要求により受信した後に、データサーバ２とデータサーバ３にそれぞれパケットデータＡ、Ｂ、Ｃの送信処理を行う。こうして両系のデータサーバ２、３は収集対象機器１からのパケットデータＡ、Ｂ、Ｃをすべて揃った状態で記録される。
ステップＳ６０において、中継装置４はデータサーバ２とデータサーバ３にそれぞれパケットデータＡ、Ｂ、Ｃの送信処理を行う一方、異常の中継装置５が復旧するまで、受信したパケットデータＡ、Ｂ、Ｃを記憶装置４４に記憶する。
In step S59, after receiving the packet data B that should have been received by the
In step S60, the
ステップＳ６１は、機能停止していた中継装置５が復旧した際には、中継装置４、５間でデータの補完処理を行い、処理を継続していた中継装置４の記憶装置４４内に記録されていたデータともデータの照合を行い、中継装置５の記憶装置５４は記録されていないデータがあれば中継装置４の記憶装置４４からデータを補完する処理を行う。
データの補完が完了後、処理を継続していた中継装置４は記憶装置４４内にデータを記録することを止め、通常通りの処理を行う。これによって、中継装置５の復旧時にシステムにかかる処理を抑え、通常の多重化システムを復旧することが出来る。
In step S61, when the
After completion of data complementation, the
本開示は、様々な例示的な実施の形態及び実施例が記載されているが、１つ、または複数の実施の形態に記載された様々な特徴、態様、及び機能は特定の実施の形態の適用に限られるのではなく、単独で、または様々な組み合わせで実施の形態に適用可能である。
従って、例示されていない無数の変形例が、本願に開示される技術の範囲内において想定される。例えば、少なくとも１つの構成要素を変形する場合、追加する場合または省略する場合、さらには、少なくとも１つの構成要素を抽出し、他の実施の形態の構成要素と組み合わせる場合が含まれるものとする。
While this disclosure describes various exemplary embodiments and examples, various features, aspects, and functions described in one or more of the embodiments may vary from particular embodiment to embodiment. The embodiments are applicable singly or in various combinations without being limited to the application.
Therefore, countless modifications not illustrated are envisioned within the scope of the technology disclosed in the present application. For example, modification, addition or omission of at least one component, extraction of at least one component, and combination with components of other embodiments shall be included.
１：収集対象機器、２、３：データサーバ、４、５：中継装置、１１：送信機能手段、
２１、３１：データ補完機能手段、４１、５１：転送手段、
４２、５２：データ補完機能手段、４３、５３：再送要求処理手段、
４４、５４：記憶装置。
1: collection target device, 2, 3: data server, 4, 5: relay device, 11: transmission function means,
21, 31: data complementing function means; 41, 51: transfer means;
42, 52: data supplement function means; 43, 53: retransmission request processing means;
44, 54: Storage devices.
Claims (6)
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2018167556A JP7202818B2 (en) | 2018-09-07 | 2018-09-07 | data collection device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| JP2018167556A JP7202818B2 (en) | 2018-09-07 | 2018-09-07 | data collection device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| JP2020042388A JP2020042388A (en) | 2020-03-19 |
| JP7202818B2 true JP7202818B2 (en) | 2023-01-12 |
Family
ID=69798551
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| JP2018167556A Active JP7202818B2 (en) | 2018-09-07 | 2018-09-07 | data collection device |
Country Status (1)
| Country | Link |
|---|---|
| JP (1) | JP7202818B2 (en) |
Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2000278297A (en) | 1999-03-29 | 2000-10-06 | Yokogawa Electric Corp | Communication device in distributed object system |
| JP2004072551A (en) | 2002-08-08 | 2004-03-04 | Telemann Communications Co Ltd | Parity check method and broadcast network system |
| JP2011007675A (en) | 2009-06-26 | 2011-01-13 | Fujitsu Telecom Networks Ltd | Wind speed monitoring system |
| JP2016187122A (en) | 2015-03-27 | 2016-10-27 | 富士通株式会社 | Video data processing apparatus, video data processing system, video data processing method, and video data processing program |
| JP2018067864A (en) | 2016-10-21 | 2018-04-26 | 株式会社日立製作所 | Communication terminal |
-
2018
- 2018-09-07 JP JP2018167556A patent/JP7202818B2/en active Active
Patent Citations (5)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| JP2000278297A (en) | 1999-03-29 | 2000-10-06 | Yokogawa Electric Corp | Communication device in distributed object system |
| JP2004072551A (en) | 2002-08-08 | 2004-03-04 | Telemann Communications Co Ltd | Parity check method and broadcast network system |
| JP2011007675A (en) | 2009-06-26 | 2011-01-13 | Fujitsu Telecom Networks Ltd | Wind speed monitoring system |
| JP2016187122A (en) | 2015-03-27 | 2016-10-27 | 富士通株式会社 | Video data processing apparatus, video data processing system, video data processing method, and video data processing program |
| JP2018067864A (en) | 2016-10-21 | 2018-04-26 | 株式会社日立製作所 | Communication terminal |
Also Published As
| Publication number | Publication date |
|---|---|
| JP2020042388A (en) | 2020-03-19 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| US20100014418A1 (en) | Connection recovery device, method and computer-readable medium storing therein processing program | |
| EP1107533B1 (en) | Load distribution in a network | |
| US8898311B2 (en) | Data communication method and information processing device | |
| JP4087271B2 (en) | Proxy response device and network system | |
| KR20150086649A (en) | Apparatus and method for distribution processing of data, storage server | |
| JP2014512149A (en) | Packet processing method and router during server failure | |
| CN100499507C (en) | Disaster recovery system, method and network device | |
| CN104202385A (en) | Data backup and updating method of distributed file system | |
| CN110708397A (en) | Apparatus and method for data delivery in Delay Tolerant Networks (DTNs) | |
| EP2798507B1 (en) | Enhanced acknowledgement handling in communication packet transfer | |
| CN113595893B (en) | Route receiving system, route receiving method, device, equipment and medium | |
| JP7202818B2 (en) | data collection device | |
| CN110808917B (en) | Multilink aggregation data retransmission method and transmitting equipment | |
| JP2010287987A (en) | Mail server system and congestion control method | |
| US20060159010A1 (en) | Information processing system, information processing device, and information processing method and program therefor | |
| JP2016220095A (en) | Data transmission device, data transmission system, and data transmission method | |
| CN117041025A (en) | Data transmission method and device, storage medium and electronic equipment | |
| KR102286913B1 (en) | Network management apparatus and control method thereof | |
| KR20180099143A (en) | Apparatus and method for recovering tcp-session | |
| CN104125301A (en) | Multi-line data transmission method | |
| JP2013179430A (en) | Inter-device synchronizing and switching method, and inter-device switching system | |
| EP0843450A2 (en) | Distributed media processing server and communication network using the same | |
| KR101982416B1 (en) | SDN for system for distributed storing data by TCP communication using plurality of data nodes, Switch included the SDN and Method for controlling the switch | |
| JP5794748B2 (en) | Switch, transmission method, program, recording medium | |
| CN101510883B (en) | Method for transmission of SIP message |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| A621 | Written request for application examination |
Free format text: JAPANESE INTERMEDIATE CODE: A621 Effective date: 20210816 |
|
| RD02 | Notification of acceptance of power of attorney |
Free format text: JAPANESE INTERMEDIATE CODE: A7422 Effective date: 20210816 |
|
| A977 | Report on retrieval |
Free format text: JAPANESE INTERMEDIATE CODE: A971007 Effective date: 20220527 |
|
| A131 | Notification of reasons for refusal |
Free format text: JAPANESE INTERMEDIATE CODE: A131 Effective date: 20220607 |
|
| A521 | Request for written amendment filed |
Free format text: JAPANESE INTERMEDIATE CODE: A523 Effective date: 20220803 |
|
| 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: 20221129 |
|
| A61 | First payment of annual fees (during grant procedure) |
Free format text: JAPANESE INTERMEDIATE CODE: A61 Effective date: 20221226 |
|
| R151 | Written notification of patent or utility model registration |
Ref document number: 7202818 Country of ref document: JP Free format text: JAPANESE INTERMEDIATE CODE: R151 |
|
| R250 | Receipt of annual fees |
Free format text: JAPANESE INTERMEDIATE CODE: R250 |