CN109040204A - For the data processing method of gateway, gateway component and sensor network - Google Patents

Abstract

The present invention provides a kind of data transmission method for gateway, comprising: receives the acquisition data that the sensor node as acquisition node corresponding with the gateway is sent；Judge the current work load of the gateway whether more than the first predetermined load；When the current work load of the gateway is less than first predetermined load, the acquisition data that the acquisition node is sent are received；When the current work load of the gateway is more than first predetermined load, is sent to the acquisition node for sending the acquisition data and wait indication signal；When the workload of the gateway is by being more than that first predetermined load is reduced to first predetermined load or less, to the sensor node for being used as temporary node and the sensor node as acquisition node sends data acquisition request.The present invention also provides a kind of gateway components and a kind of sensor network.The data transmission method may insure sensor network data transmission efficiency with higher and higher network utilization.

Description

Data processing method for gateway, gateway component and sensor network

technical field

The present invention relates to the field of the Internet of Things, in particular to a data processing method for a gateway, a gateway component for executing the data processing method, and a sensor network including the gateway component.

Background technique

As an important part of the Internet of Things, a sensor network includes multiple sensor nodes and multiple gateways, and the sensor network is responsible for acquiring physical world information and transmitting it to background applications. Among them, the main function of the sensor node is to collect data, and the gateway is used to process the data transmitted by its corresponding sensor node (for example, data compression integration, or protocol conversion), and then upload it to the background server for use by the background application.

For some sensor networks with complex detection environments, there will often be situations where a certain gateway receives too much data and cannot be processed in time, while other gateways have less workload, which not only reduces the data processing efficiency, but also causes waste of resources.

Therefore, how to improve the data processing efficiency of the sensor network and improve the utilization rate of the sensor network has become a technical problem to be solved urgently in this field.

Contents of the invention

It is an object of the present invention to provide a data processing method for a gateway, a gateway component performing the data processing method, and a sensor network included to the gateway component. The data method can improve data processing efficiency and resource utilization.

In order to achieve the above object, as an aspect of the present invention, a data transmission method for a gateway is provided, the gateway is used in a sensor network including a plurality of sensor nodes, and the gateway corresponds to a plurality of sensor nodes, wherein , the data transmission method includes:

receiving the collection data sent by the sensor node corresponding to the gateway and used as a collection node;

judging whether the current workload of the gateway exceeds a first predetermined load;

When the current workload of the gateway does not exceed the first predetermined load, receive the collection data sent by the collection node;

When the current workload of the gateway exceeds the first predetermined load, sending a waiting indication signal to the collection node that sends the collection data;

When the workload of the gateway decreases from exceeding the first predetermined load to below the first predetermined load, a data acquisition request is sent to the sensor node serving as a temporary storage node and the sensor node serving as a collection node.

Preferably, the data transmission method includes:

When the collection data from the collection node and the data from the temporary storage node are received at the same time, the data from the temporary storage node is preferentially processed.

Preferably, the data transmission method further includes:

When the time for which the workload of the gateway exceeds the first predetermined load exceeds a predetermined time, send an assisting processing instruction to the background server;

After receiving the assistance confirmation instruction sent by the background server, a forwarding instruction is sent to the temporary storage node and the collection node, the forwarding instruction includes the address of the backup gateway, and the current workload of the backup gateway is less than that of the second a predetermined load, and the second predetermined load is less than the first predetermined load;

After the forwarding instruction is sent, when the workload of the gateway drops below the first predetermined load, a cancel assistance instruction is sent to the background server.

Preferably, the data transmission method further includes:

receiving data from a sensor that does not correspond to the gateway and serves as a collection node and data from a sensor that does not correspond to the gateway and serves as a temporary storage node when the assisting processing instruction is received;

When the data of the sensor that does not correspond to the gateway and is used as the collection node and the data of the sensor that does not correspond to the gateway and is used as the temporary storage node are received at the same time, the data from the sensor that is used as the temporary storage node is preferentially processed. data.

As a second aspect of the present invention, a gateway component is provided, the gateway component is used in a sensor network including a plurality of sensor nodes, the gateway component corresponds to a plurality of sensor nodes, wherein the gateway component includes Gateway, communication module, judgment module and control module;

The communication module is used to receive the collected data sent by the sensor node corresponding to the gateway and used as a collection node;

The judging module is used to judge whether the current workload of the gateway exceeds the first predetermined load, and generate a judging result;

The control module is configured to control the communication module to receive the collection data sent by the collection node corresponding to the gateway when the current workload of the gateway does not exceed the first predetermined load;

The control module is configured to generate a waiting indication signal when receiving a judgment result that the current workload of the gateway exceeds the first predetermined load, and control the communication module to send the waiting indication signal to the A collection node for collecting data;

The control module is further configured to receive a judgment that the current workload of the gateway does not exceed the first predetermined load after receiving a judgment result that the current workload of the gateway exceeds the first predetermined load As a result, a data acquisition signal is generated, and the communication module is controlled to send the data acquisition signal to the temporary storage node and the collection node.

Preferably, the control module is configured to control the gateway to preferentially process the data from the temporary storage node when the communication module simultaneously receives the collected data from the collection node and the data from the temporary storage node .

Preferably, the control module is configured to generate an assisting processing instruction when the workload of the gateway exceeds the first predetermined load for a predetermined time, and control the communication module to send the assisting processing instruction to the background server ;

The control module is further configured to send a forwarding instruction to the temporary storage node and the collection node through the communication module after receiving the assistance confirmation instruction sent by the background server through the communication module, and the forwarding instruction including an address of a backup gateway, the current workload of the backup gateway is less than a second predetermined load, and the second predetermined load is less than the first predetermined load;

The control module is further configured to generate a cancellation assistance instruction when the workload of the gateway drops below the first predetermined load after sending the forwarding instruction, and send it to the background server through the communication module Cancel assist order.

Preferably, the control module is further configured to simultaneously receive, through the communication module, data from a sensor not corresponding to the gateway and used as a collection node and not associated with When the gateway corresponds to the data of the sensor used as the temporary storage node and sends it to the gateway, the control module is also used to control the gateway to preferentially process the data from the sensor used as the temporary storage node.

As a third aspect of the present invention, a sensor network is provided, the sensor network includes a plurality of sensor nodes and a plurality of gateway components, and the sensor nodes correspond to predetermined gateway components according to predetermined rules, wherein the The gateway component is the gateway component provided by the present invention;

The sensor node is used to send the collected data to the sensor node used as a temporary storage node after receiving the waiting indication signal;

The sensor node is also used to receive collected data sent by other sensor nodes;

The sensor node is also configured to send data to a corresponding gateway component when receiving a data acquisition request.

Preferably, the sensor network also includes a background server

The background server is configured to send the assisting processing instruction to a gateway serving as a backup gateway after receiving the assisting processing instruction;

The background server is further configured to, when receiving the cancel assistance instruction, send the cancel assistance instruction to a gateway serving as a standby gateway.

Description of drawings

The accompanying drawings are used to provide a further understanding of the present invention, and constitute a part of the description, together with the following specific embodiments, are used to explain the present invention, but do not constitute a limitation to the present invention. In the attached picture:

Fig. 1 is the flow chart of the data processing method for gateway provided by the present invention;

Fig. 2 is the module schematic diagram of the gateway component provided by the present invention;

Fig. 3 is a block diagram of the sensor network provided by the present invention.

Explanation of reference signs

210: gateway 220: communication module

230: judgment module 240: control module

311～316: sensor nodes

320: background server

Detailed ways

Specific embodiments of the present invention will be described in detail below in conjunction with the accompanying drawings. It should be understood that the specific embodiments described here are only used to illustrate and explain the present invention, and are not intended to limit the present invention.

As an aspect of the present invention, a data transmission method for a gateway is provided, the gateway is used in a sensor network including a plurality of sensor nodes, and the gateway corresponds to a plurality of sensor nodes, wherein, as shown in FIG. 1 , the data transmission method includes:

In step S110, receiving the collection data sent by the sensor node used as the collection node corresponding to the gateway;

In step S120, judging whether the current workload of the gateway exceeds a first predetermined load;

In step S130, when the current workload of the gateway does not exceed the first predetermined load, receive the collection data sent by the collection node;

In step S140, when the current workload of the gateway exceeds the first predetermined load, a waiting indication signal is sent to the collection node that sends the collected data;

In step S150, when the workload of the gateway decreases from exceeding the first predetermined load to below the first predetermined load, send data to the sensor node used as a temporary storage node and the sensor node used as a collection node Get request.

In the sensor network, multiple sensor nodes and multiple gateways are included. There is a corresponding relationship between sensor nodes and gateways, for example, one gateway may correspond to multiple sensors. In the present invention, there is no special requirement on how to select temporary storage nodes, for example, idle sensor nodes can be used as temporary storage nodes.

In the present invention, there is no special requirement on the first predetermined load. The user may determine the first predetermined load according to performance parameters of the gateway. For example, the first predetermined load may be 70% of the full load of the gateway.

When the current workload of the gateway exceeds the first predetermined load, the data processing speed will decrease. In the present invention, when it is judged that the current workload of the gateway exceeds the first predetermined load, the collected data sent by the collection node is no longer received, and only the data already received by the gateway is processed to increase the processing speed. At the same time, the gateway sends a waiting indication signal to the collection node that sends the collected data, and the collection node sends the collection data to the sensor node used as a temporary storage node after receiving the waiting indication signal, so that it can fully Utilize idle nodes in the sensor network.

As mentioned above, when the current workload of the gateway exceeds the first predetermined load, no new data will be received. Therefore, after the gateway works for a period of time, its load will drop to the first predetermined load Next, in this case, a data acquisition request is sent to the sensor node used as a temporary storage node, and the temporary storage node sends the data temporarily stored in the node to the gateway after receiving the data acquisition request, and the The gateway continues processing.

In the data transmission method provided by the present invention, the data processing speed of the gateway can be ensured, and the devices in the Internet of Things can be fully utilized.

It is easy to understand that, when the judgment result in step S120 is "the current work of the gateway does not exceed the first predetermined load", the gateway continues to receive the collected data from the collection node.

In order to process data in a timely manner, preferably, the data transmission method includes:

In step S160, when the collection data from the collection node and the data from the temporary storage node are received at the same time, the data from the temporary storage node is preferentially processed.

For ease of description, the data from the temporary storage node in step S160 is called data A, and the data from the collection node in step S160 is called data B. It is easy to understand that the data A is also collected by the collection node, and the collection node collects the data A earlier than the collection data B. Therefore, the real-time performance of data processing by the gateway can be improved through step S160.

Preferably, the data transmission method further includes:

In step S170, when the workload of the gateway exceeds the first predetermined load and the time exceeding the first predetermined load exceeds a predetermined time, send an assisting processing instruction to the background server;

In step S180, after receiving the assistance confirmation instruction sent by the background server, a forwarding instruction is sent to the temporary storage node and the collection node, the forwarding instruction includes the address of the standby gateway, the current address of the standby gateway The workload is less than a second predetermined load, and the second predetermined load is less than the first predetermined load.

In the present invention, using the standby gateway in a relatively idle state to process the data that the current gateway has no time to process can not only improve the utilization rate of the sensor network, but also improve the efficiency of data processing.

When the load of the gateway drops below the first predetermined load, the collected data may continue to be received. Accordingly, the standby state of the standby gateway should be released. Specifically, the data transmission method also includes:

After the forwarding instruction is sent to the temporary storage node and the collection node, when the current workload of the gateway is lower than the first predetermined load, a cancel assistance instruction is sent to the background server.

It should be pointed out that the backup gateway and the current gateway belong to the same sensor network. That is to say, in the same sensor network, any gateway may be used as a backup gateway. Correspondingly, the data transmission method also includes:

In step S191, when the assisting processing instruction is received, data from a sensor not corresponding to the gateway and used as a collection node and data from a sensor not corresponding to the gateway and used as a temporary storage node are received;

In step S192, when data from a sensor not corresponding to the gateway and used as a collection node and data from a sensor not corresponding to the gateway and used as a temporary storage node are received at the same time, preferentially process data from a sensor used as a temporary storage node Store the sensor data of the node.

Further, the data transmission method also includes:

After receiving the cancellation assistance instruction, send a confirmation cancellation assistance instruction to the background server.

As a second aspect of the present invention, a gateway component is provided, the gateway component is used in a sensor network including a plurality of sensor nodes, and the gateway component corresponds to a plurality of sensor nodes, wherein, as shown in FIG. 2 , The gateway component includes a gateway 210 , a communication module 220 , a judgment module 230 and a control module 240 .

It should be pointed out that the gateway component provided by the present invention is used to implement the above data transmission method provided by the present invention.

The communication module 220 is used to execute step S110, that is, the communication module 220 is used to receive the collection data sent by the sensor node corresponding to the gateway and used as a collection node.

The judging module 230 is configured to execute step S120, that is, the judging module 230 is configured to judge whether the current workload of the gateway 210 exceeds the first predetermined load, and generate a judging result.

The control module 240 is used for executing step S130 to step S150. That is, the control module 240 is configured to control the communication module 220 to receive the collection data sent by the collection node corresponding to the gateway 210 when the current workload of the gateway 210 does not exceed the first predetermined load.

The control module 240 is also configured to generate a waiting indication signal when receiving the judgment result that the current workload of the gateway 210 exceeds the first predetermined load, and control the communication module 220 to send the waiting indication signal to the collection node.

The control module 240 is further configured to generate a data acquisition signal, and control the communication module 220 to send the data acquisition signal to the temporary storage node and the collection node.

The advantages and beneficial effects of the data transmission method provided by the present invention have been introduced in detail above, and will not be repeated here.

In order to process the data in time, preferably, the control module 230 is also used to execute step S160, that is, the control module 240 is used to receive the collected data from the collection node and the data from the temporary storage node at the same time when the communication module 220 , the control gateway 210 preferentially processes the data from the temporary storage node.

Preferably, the control module 240 is also used to execute step S170 and step S180. Specifically, the control module 240 is configured to generate an assisting processing instruction when the workload of the gateway 210 exceeds the first predetermined load for a predetermined time, and control the communication module 220 to send the assisting processing instruction to the background server.

The control module 240 is also configured to send a forwarding instruction to the temporary storage node and the collection node through the communication module 220 after receiving the assistance confirmation instruction sent by the background server through the communication module 220, and the forwarding instruction includes a backup gateway address, the current workload of the standby gateway is less than a second predetermined load, and the second predetermined load is less than the first predetermined load.

Preferably, the control module 240 is further configured to generate a cancellation assistance instruction when the workload of the gateway 210 drops below the first predetermined load after sending the forwarding instruction, and send it to the background server through the communication module 220 Cancel assist order.

As mentioned above, the gateway in the gateway component can also be used as a standby gateway. Correspondingly, the control module 240 is also used to control the communication module 220 to receive the The data of the sensor that does not correspond to and is used as the collection node and the data of the sensor that does not correspond to the gateway and is used as the temporary storage node are sent to the gateway 210, and the gateway 210 is controlled to preferentially process the data from the sensor that is used as the temporary storage node. data.

As a third aspect of the present invention, a sensor network is provided. As shown in FIG. 3 , the sensor network includes a plurality of sensor nodes and a plurality of gateway components, and the sensor nodes communicate with predetermined gateway components according to predetermined rules. Correspondingly, the gateway component is the above-mentioned gateway component provided by the present invention.

The sensor node is used to send the collected data to the sensor node used as a temporary storage node after receiving the waiting indication signal, and the sensor node is also used to receive the collected data sent by other sensor nodes, and the sensor node is also used to receive the data acquisition When requested, data is sent to the corresponding gateway component.

In the present invention, there is no special limitation on the predetermined rule. For example, the predetermined rule may include: sensor nodes that are no more than X meters away from the gateway component are sensor nodes corresponding to the gateway component. Correspondingly, the sensor components that are more than X meters away from the gateway component are sensor nodes that do not correspond to the gateway component.

Sensor nodes 311 , 312 , 313 , 314 , 315 , 316 , gateway component A and gateway component B are shown in FIG. 3 . Gateway component A corresponds to sensor nodes 311 , 312 , 313 , and gateway component B corresponds to sensor nodes 314 , 315 , 316 .

As mentioned above, each sensor node can be used as both a collection node and a temporary storage node.

After the sensor node that has used the temporary storage node receives the forwarding instruction, it sends the temporarily stored data received by the temporary storage node to the gateway used as the backup gateway.

Preferably, the sensor network further includes a background server 320, and the background server 320 is configured to send the assisting processing instruction to a gateway serving as a standby gateway after receiving the assisting processing instruction. Moreover, the background server 320 is further configured to, when receiving the cancel assistance instruction, send the cancel assistance instruction to a gateway serving as a standby gateway.

The working principle of the sensor network provided by the present invention will be introduced below with reference to FIG. 3 . As shown in FIG. 3 , the sensor network includes sensor nodes 311 , 312 , 313 , 314 , 315 , and 316 , a gateway component A and a gateway component B. Gateway component A corresponds to sensor nodes 311 , 312 , 313 , and gateway component B corresponds to sensor nodes 314 , 315 , 316 .

For ease of explanation, the sensor node 311 is used as a collection node for sending data to the gateway component A, and when the current workload of the gateway in the gateway component A exceeds the first predetermined load, the sensor node 312 is designated as a temporary storage node.

Specifically, when the current workload of the gateway in the gateway component A exceeds the first predetermined load, the gateway component A sends a waiting indication signal to the sensor node 311;

After the sensor node 311 receives the waiting instruction signal, it sends the collected data to the sensor node 312, and the sensor node 312 temporarily stores the data;

When the workload of the gateway in the gateway component A drops below the first predetermined load, a data acquisition request is sent to the sensor node 311 and the sensor node 312;

After the sensor node 311 and the sensor node 312 receive the data acquisition request, the sensor node 311 directly sends the collected data to the gateway component A, and the sensor node 312 sends the temporarily stored data to the gateway component A;

After the gateway component A receives the data from the sensor node 311 and the data from the sensor node 312, it preferentially processes the data sent by the sensor node 312;

If after a predetermined time (for example, one hour), the workload of the gateway in the gateway component A still exceeds the first predetermined load, the gateway component A sends an assisting processing instruction to the background server 320;

After the background server 320 receives the assisting processing instruction, it queries the gateway component (for example, gateway component B) whose workload is lower than the second predetermined load in the sensor network, and uses it as a backup gateway, and the background server 320 performs the assisting processing The command is sent to the backup gateway;

After receiving the confirmation information of the gateway component B, the background server 320 sends an assistance confirmation instruction to the gateway component A;

After the gateway component A receives the assistance confirmation instruction, it sends a forwarding instruction to the sensor node 311 and the sensor node 312, and the forwarding instruction includes the address of the gateway in the gateway component B;

Sensor node 311 and sensor node 312 send data to gateway component B;

When the current workload of the gateway in the gateway component A is lower than the first predetermined load, a cancel assistance instruction is sent to the background server 320;

After the background server 320 receives the cancellation assistance instruction, it sends the cancellation assistance instruction to the gateway component B;

The gateway component A sends a data acquisition instruction to the sensor node 311 and the sensor node 312;

The gateway component A, the gateway component B, the sensor node 311, and the sensor node 312 resume normal working states.

It can be understood that, the above embodiments are only exemplary embodiments adopted for illustrating the principle of the present invention, but the present invention is not limited thereto. For those skilled in the art, various modifications and improvements can be made without departing from the spirit and essence of the present invention, and these modifications and improvements are also regarded as the protection scope of the present invention.

Claims (10)

1. a kind of data transmission method for gateway, the gateway is used for the sensor network including multiple sensor nodes In, and the gateway corresponds to multiple sensor nodes, which is characterized in that the data transmission method includes:

Receive the acquisition data that the sensor node as acquisition node corresponding with the gateway is sent；

Judge the current work load of the gateway whether more than the first predetermined load；

When the current work load of the gateway is less than first predetermined load, adopting for the acquisition node transmission is received Collect data；

When the current work load of the gateway is more than first predetermined load, to the acquisition section for sending the acquisition data Point, which is sent, waits indication signal；

When the workload of the gateway is by being more than that first predetermined load is reduced to first predetermined load or less, to Sensor node as temporary node and the sensor node as acquisition node send data acquisition request.

2. data transmission method according to claim 1, which is characterized in that the data transmission method includes:

When receiving acquisition data from the acquisition node simultaneously and from the data of the temporary node, priority processing Data from the temporary node.

3. data transmission method according to claim 1 or 2, which is characterized in that the data transmission method further include:

When the time that the workload of the gateway is more than first predetermined load being more than the predetermined time, to background server Issue assist process instruction；

After receiving the assistance confirmation instruction that the background server is sent, sent out to the temporary node and the acquisition node Forwarding is sent to instruct, the forwarding instruction includes the address of standby gateway, and the current work load of the standby gateway is less than second Predetermined load, and second predetermined load is less than first predetermined load；

After sending the forwarding instruction, when the workload of the gateway is reduced to first predetermined load or less, to institute It states background server and sends and cancel assistance instruction.

4. data transmission method according to claim 3, which is characterized in that the data transmission method further include:

When receiving assist process instruction, receive from sensor that is not corresponding with the gateway and being used as acquisition node The data of data and sensor that is not corresponding with the gateway and being used as temporary node；

When simultaneously receive it is not corresponding with the gateway and as acquisition node sensor data and not with the gateway When the data of sensor that is corresponding and being used as temporary node, data of the priority processing from the sensor for being used as temporary node.

5. a kind of gateway component, the gateway component is used in the sensor network including multiple sensor nodes, the gateway Component is corresponding with multiple sensor nodes, which is characterized in that the gateway component include gateway, communication module, judgment module and Control module；

The communication module is used to receive the acquisition number that the sensor node as acquisition node corresponding with the gateway is sent According to；

The judgment module is used to judge that the current work load of the gateway whether more than the first predetermined load, and to generate judgement As a result；

The control module is used for when the current work load of the gateway is less than first predetermined load, described in control Communication module receives the acquisition data that acquisition node corresponding with the gateway is sent；

The control module is used to receiving the current work load for determining the gateway be more than first predetermined load It is generated when judging result and waits indication signal, and controlled the communication module and the waiting indication signal is sent to described in transmission Acquire the acquisition node of data；

The control module is also used to receiving the current work load for determining the gateway be more than first predetermined load Judging result after receive the judgement knot for determining that the current work load of the gateway is less than first predetermined load again Data acquisition signal is generated when fruit, and control the communication module by the data acquisition signal be sent to the temporary node and The acquisition node.

6. gateway component according to claim 5, which is characterized in that the control module is used for same in the communication module When receive acquisition data from the acquisition node and when from the data of the temporary node, it is preferential to control the gateway Handle the data from the temporary node.

7. gateway component according to claim 5 or 6, which is characterized in that the control module is used in the gateway Workload, which is more than the time of first predetermined load, generates assist process instruction when being more than the predetermined time, and controls described logical Assist process instruction is sent to background server by letter module；

The control module is also used to refer in the assistance confirmation for receiving the background server transmission by the communication module After order, forwarding instruction, the forwarding instruction packet are sent to the temporary node and the acquisition node by the communication module Include the address of standby gateway, the current work load of the standby gateway is less than the second predetermined load, and second predetermined negative Lotus is less than first predetermined load；

The control module is also used to after sending the forwarding instruction, when the workload of the gateway is reduced to described first When below predetermined load, generates and cancel assistance instruction, and sent by the communication module to the background server and cancel association Help instruction.

8. gateway component according to claim 7, which is characterized in that the control module is also used to by the communication After module receives assist process instruction, is received simultaneously by the communication module and come from not corresponding with the gateway and be used as The Data Concurrent of the data of the sensor of acquisition node and sensor that is not corresponding with the gateway and being used as temporary node is sent When to the gateway, the control module is also used to control the gateway priority processing from the sensor for being used as temporary node Data.

9. a kind of sensor network, the sensor network includes multiple sensor nodes and multiple gateway components, the sensing Device node is corresponding with scheduled gateway component with according to pre-defined rule, which is characterized in that the gateway component is claim 5 To gateway component described in any one of 8；

The sensor node is used to adopt after receiving waiting indication signal to the sensor node transmission for being used as temporary node Collect data；

The sensor node is also used to receive the acquisition data of other sensors node transmission；

The sensor node is also used to when receiving data acquisition request, sends data to corresponding gateway component.

10. sensor network according to claim 9, which is characterized in that the sensor network further includes background service Device, the gateway component are gateway component described in claim 7 or 8,

The background server is used to send the assistance to the gateway for being used as standby gateway after receiving assist process instruction Process instruction；

The background server be also used to receive it is described disappear assistance instruction when, the cancellation assistance instruction is sent to and is used as The gateway of standby gateway.