CN112055059B - A method for device electing a representative - Google Patents

Abstract

The invention relates to the technical field of industrial Internet of things and discloses a method for selecting representatives by equipment, which comprises the steps that terminal equipment randomly generates a priority value, and the terminal equipment broadcasts and sends notification messages comprising the priority value and identification information to a network; the terminal equipment receives the notification message sent by the rest terminal equipment, generates a priority table according to the priority value and the identification information of the terminal equipment, and arranges the priority values in the sequence from big to small; the terminal equipment judges whether more than two equal priority values exist, if so, judges whether the equal priority values are the priority values of the terminal equipment, if so, the terminal equipment returns to the first step, otherwise, the terminal equipment returns to the second step; otherwise, determining the layer where the representative device is located and the representative device of the layer where the representative device is located according to the representative device judging strategy; the method for selecting the representatives by the equipment can select the representatives of the terminal equipment in the industrial Internet of things by the representatives, and the load of the platform server and the channel is reduced by sending the heartbeat packet to the platform server by the representatives.

Description

A method for device electing a representative

technical field

The present invention relates to the technical field of industrial internet of things, in particular to a method for selecting a representative of a device.

Background technique

With the help of industrial Internet of Things technology or platform, enterprises can connect and monitor elements such as people, machines, materials, methods, environment, and testing in the workshop in real time. Taking the traditional plastic woven manufacturing industry as an example, its production line equipment mainly includes wire drawing machines, circular looms, printing machines, hemming machines, weighbridges, etc. Each device has an average of 5-8 sensors and 1-2 PLCs. A medium-sized manufacturer needs to use about 220 devices. In order to collect all the production data of the devices, it needs to be equipped with about 1,500 IoT terminal devices. The IoT terminal devices are connected to the underlying sensors, PLC, and weighbridge serial interfaces.

These IoT terminal devices send the collected data to the platform through the network, so that managers can view it in real time, or provide basic data for further in-depth mining. The platform has the obligation to monitor the status information of the IoT terminal device itself (such as whether the device is online, whether it is running normally, etc.), due to factors such as network security or technology, the platform will not take the initiative to inquire or collect information about the terminal device, and it is up to the terminal The device itself sends some necessary information to the platform in the form of heartbeat packets.

Assuming that the terminal device sends a heartbeat packet per second, the platform needs to receive 1,500 heartbeat packets per second from one of the above-mentioned medium-sized manufacturers. If there are 100 companies of the same size in the area managed by the platform, the platform needs to process 150,000 Heartbeat packets, based on 100Mb bandwidth and 1KB of each heartbeat packet (UPD packet, each heartbeat data is individually encapsulated into a packet), can process about 100*1000/10/1000=10000 heartbeat packets per second. That is to say, processing the heartbeat packets of 150,000 terminal devices requires 1.5Gb bandwidth.

Such a large amount of data processing puts forward quite high requirements on network bandwidth, number of servers, server cluster scheduling, etc., and brings a great burden to the system platform, network and other components. Therefore, how to reduce the data processing amount of the platform 1. Reducing the burden on the system platform and the network is a problem to be solved in the prior art.

Contents of the invention

Aiming at the deficiencies in the prior art, the purpose of the present invention is to provide a method for selecting a representative of a device, which can select a representative of a terminal device in the Industrial Internet of Things, and send a heartbeat packet to the platform server through the representative, reducing The number of heartbeat packets received and processed by the platform server to reduce the burden on the platform server and channels.

In order to achieve the above object, the present invention provides the following technical solutions:

A method for selecting a representative of a device, the method is applied to the Industrial Internet of Things, comprising:

S1: The terminal device randomly generates a priority value, stores the generated priority value, and marks it as its own priority value, and the terminal device broadcasts a notification message to the network, and the notification message includes sending the notification message The priority value and identification information of the terminal equipment;

S2: The terminal device receives notification messages sent by all terminal devices except itself, and generates a priority table according to the received notification messages, its own priority value and identification information, and the priority table includes one-to-one information related to each terminal device. Corresponding priority values and identification information, the priority values are arranged in descending order in the priority table;

S3: The terminal device checks the priority table, and judges whether there are two or more terminal devices with equal priority values in the priority table, if yes, the terminal device executes S301, and if not, the terminal device executes S302;

S301: Determine whether the priority value in the case of equality is its own priority value, if yes, re-execute S1, if not, re-execute S2;

S302: Determine the layer where the user is located, the representative device of the layer where the user is located, and the representative device of the layer below the layer where the user is located according to the determination strategy of the representative device.

In the present invention, preferably, the representative device determination strategy includes: dividing all priority values into n first-level priority value segments, and the device with the largest priority value in each first-level priority value segment is used as Layer 1 equipment, each layer 1 priority value segment is divided into n layer 2 priority value segments after excluding the priority value of layer 1 devices, and the priority value in each layer 2 priority value segment is the largest The device of the first layer is used as the second layer device, and each first layer device is the representative device of the second layer device in the first layer priority value segment where it is located, and so on, until the m-1th layer representative device is determined, Both m and n are manually set, defining the m-1th layer device as the upper layer of the m-th layer device, and each m-1th layer device is in the m-1th layer priority value segment where it is located The representative device of the m-th layer device.

In the present invention, preferably, also include:

S4: The terminal device sends a notification message to its own representative device in the upper layer, sends a representative notification message to other terminal devices in the lower layer where it is the representative device, and receives the notification message from the upper layer The representative notification message sent by its own representative device, receives the notification message sent to it by other terminal devices with itself as the representative device in the lower layer, and updates its own priority according to the received representative notification message and notification message. A level table, the representative notification message includes the priority value and identification information of the representative device sending the representative notification message and the priority value and identification information of the terminal device it represents.

In the present invention, preferably, also include:

S5: When the terminal device cannot receive the representative notification message sent by its own representative device in the upper layer of the layer where it is located, define the representative device as the original representative device, and send notifications to other terminal devices represented by the original representative device Receive notification messages sent by other terminal devices represented by the original representative device, and update the priority table according to the received notification messages, and determine the strategy from the original representative device according to the updated priority table and representative device. other terminal devices and determine the representative device among itself.

In the present invention, preferably, the decision strategy of the representative device includes: dividing all priority values into x y-th layer priority value segments, and the device with the largest priority value in each y-th layer priority value segment is used as The y-th layer priority value segment is the representative device at the y-th layer, and the priority values of all the y-th layer representative devices are divided into x y-1 layer priority value segments, and each y-1 layer has priority The device with the highest priority value in the level value segment is used as the representative device in the y-1th layer priority value segment at the y-1 layer, and so on until the representative device of the first layer is determined, and x and y are artificially set It is determined that the device at layer y-1 is defined as the upper layer of the device at layer y, and each device at layer y-1 is the representative device of the device at layer y in the priority value segment of layer y-1 where it is located. .

In the present invention, preferably, the priority value is between 1 and ²³² .

In the present invention, preferably, the identification information includes the physical address and/or network address of the terminal device.

Compared with prior art, the beneficial effect of the present invention is:

The method for selecting a representative of a device according to the present invention sets a priority value for a device terminal, and makes the terminal devices issue priority values and identification information to each other to form a priority table, and stratifies and arranges the terminal devices through the priority table, so as to select The representative devices of each layer are sent out, so that the terminal device can only send messages to the representative devices of this layer, and the representative devices of this layer send messages to the representative devices of higher layers, progressively, and finally complete the work of sending heartbeat packets to the platform server. The number of representative devices at the highest level is small, and the number of heartbeat packets that the platform server needs to receive and process is significantly reduced, which not only meets the requirements of the terminal device to report its own status, but also reduces the burden on the platform server and channels, and improves the industrial Internet of Things. work efficiency.

Description of drawings

FIG. 1 is a flow chart of Embodiment 1 of the present invention.

Fig. 2 is a flowchart of Embodiment 2 of the present invention.

Fig. 3 is a flow chart of Embodiment 3 of the present invention.

Detailed ways

The following will clearly and completely describe the technical solutions in the embodiments of the present invention with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are only some, not all, embodiments of the present invention. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the protection scope of the present invention.

It should be noted that when a component is said to be "fixed" to another component, it can be directly on the other component or there can also be an intervening component. When a component is said to be "connected" to another component, it may be directly connected to the other component or there may be intervening components at the same time. When a component is said to be "set on" another component, it may be set directly on the other component or there may be an intervening component at the same time. The terms "vertical," "horizontal," "left," "right," and similar expressions are used herein for purposes of illustration only.

Unless otherwise defined, all technical and scientific terms used herein have the same meaning as commonly understood by one of ordinary skill in the technical field of the invention. The terms used herein in the description of the present invention are for the purpose of describing specific embodiments only, and are not intended to limit the present invention. As used herein, the term "and/or" includes any and all combinations of one or more of the associated listed items.

Embodiment one:

Please refer to Fig. 1, a preferred embodiment of the present invention provides a method for device representative selection, including:

S1: The terminal device randomly generates a priority value, stores the generated priority value, and marks it as its own priority value, and the terminal device broadcasts a notification message to the network, and the notification message includes the priority of the terminal device that sent the notification message value and identifying information.

Wherein, the identification information may include information such as a physical address and/or a network address of the terminal device that can accurately identify the identity of the terminal device, so that relevant messages can be sent to the terminal device. In order to store data such as the priority value and identification information of the terminal device itself and other terminal devices, the terminal device should be equipped with a data storage unit and have functions such as writing and deleting to realize data storage and update.

Priority values are defined by a computer program before each terminal device starts working. The number and specific values of priority values can be set according to the needs of actual industrial production. For example, if there are 100,000 terminal devices in an industrial Internet of Things area, the number of non-repeating priority values should be at least 100,000, and priority The maximum value for level is at least 100000. Preferably, the priority value can be any value between 1 and ²³² , and the number of selectable priority values is 4294967296, which can meet the actual needs of industrial production.

For example, there are 100,000 terminal devices in the network, and the priority value is between 1 and 100,000. The priority value randomly generated by terminal device A is 1000. Terminal device A will send notification messages to other 99999 devices in the network. The notification message The notification message contains identification information such as the physical address and/or network address of the terminal device A. Other devices can recognize and find the terminal device A through the identification information. The notification message also includes the priority value of the terminal device A. Other devices can send the terminal device A Information that the priority value of device A is 1000 is stored.

S2: The terminal device receives notification messages sent by all terminal devices except itself, and generates a priority table according to the received notification messages, its own priority value and identification information, and the priority table includes the one-to-one corresponding priority of each terminal device. Priority values and identification information are arranged in descending order of priority values.

For example, terminal device A separates the identification information and priority value of each terminal device and its own priority value from the received notification message, summarizes them, and arranges them in descending order of priority values to form a priority table , in the priority table, terminal device A has a corresponding relationship with the priority value of 1000, and other terminal devices also have a corresponding relationship with their priority values.

S3: The terminal device checks the priority table, and judges whether there are more than two terminal devices with equal priority values in the priority table, if yes, the terminal device executes S301, and if not, the terminal device executes S302.

S301: Determine whether the priority value in the case of being equal is its own priority value, if yes, re-execute S1 and S2, if not, re-execute S2;

S302: Determine the layer where the user is located, the representative device of the layer where the user is located, and the representative device of the layer below the layer where the user is located according to the determination strategy of the representative device.

For example, terminal device A checks that there are no more than two equal priority values in the priority table, indicating that there are no duplicate priority values, then terminal device A classifies each terminal device in the priority table according to the representative device decision strategy. Layer, determine the representative equipment of each layer, and determine which layer it is in, so as to determine the representative equipment of its own layer and the representative equipment of the next layer of its own layer.

As another example, terminal device A checks that there are two or more equal priority values in the priority table, indicating that there are duplicate priority values, and the subsequent steps of layering and determining the representative devices of each layer cannot be performed, then terminal device A further checks Whether there is a priority value of other devices equal to its own priority value in the priority table, judge whether its own priority value is a duplicate value, if its own priority value is indeed a duplicate value, then terminal device A starts from S1 starts to execute the steps of this method, after executing S1 and S2, judge whether there is a repeated priority value in S3 again, until there is no repeated priority value, then execute S302, determine the layer where the self is located, and the layer where the self is located A representative device and a representative device of the next layer of its own layer.

For another example, there are duplicate priority values in the priority table, but the priority value of terminal device A is checked and judged to determine that its own priority value is not a duplicate value, then it only needs to wait for the terminal device with duplicate priority value to be regenerated Priority value, update the priority table, so it is necessary to re-execute S2 and S3 until there is no repeated priority value, then execute S302 to determine the layer where you are, the representative device of your own layer, and the next layer of your own layer representative equipment.

In this embodiment, the representative device decision strategy includes: dividing all priority values into n first-level priority value segments, and the device with the highest priority value in each first-level priority value segment is regarded as the first-level device , each layer 1 priority value segment is divided into n layer 2 priority value segments after excluding the priority value of the first layer device, and the device with the highest priority value in each layer 2 priority value segment is taken as the first For layer 2 devices, each layer 1 device is the representative device of the layer 2 device in the priority value segment of the first layer where it is located, and so on, until the representative device of layer m-1 is determined, m and n are both Through artificial setting, the m-1th layer device is defined as the upper layer of the m-th layer device, and each m-1th layer device is the m-th layer device in the m-1th layer priority value segment where it is located representative equipment.

For example, 100,000 terminal devices in the network are divided into one hundred Layer 1 priority value segments, divided into 3 layers, the first Layer 1 priority value segment is 1 to 1000, and the second Layer 1 priority value segment is The priority value range is from 1001 to 2000, ... the hundredth layer 1 priority value range is from 99001 to 100000. The priority value of terminal device A is 1000, it is located in the first priority value range of the first layer 1 to 1000, and it is the device with the highest priority value in the priority value range of the first layer, then terminal device A is the first 1st floor equipment. End-devices with priority values 1 to 999 are divided into one hundred Layer 2 priority value segments, with the first Layer 2 priority value segment being 1 to 10 and the second Layer 2 priority value segment being 11 to 20, ... the hundredth layer 2 priority value range is 991 to 999, then the second layer equipment includes one hundred terminals with priority values 10, 20, 30... 970, 980, 990, 999 devices, all of which are represented by terminal device A. Then other terminal devices that belong to neither layer 1 nor layer 2 are layer 3 devices.

In addition to the order of selecting representative devices from the upper layer to the lower layer, the strategy of selecting representative devices from the bottom to the top can also be adopted. In this embodiment, the decision strategy of the representative device includes: dividing all priority values into x y-th priority value segments, and the device with the highest priority value in each y-th layer priority value segment is used as the y-th layer The priority value segment is the representative device at the yth layer, divide the priority values of all the representative devices at the yth layer into x y-1 layer priority value segments, and each y-1 layer priority value segment The device with the highest priority value is used as the representative device in the y-1 layer priority value segment of the y-1 layer, and so on until the representative device of the 1st layer is determined. The y-1 layer device is the upper layer of the y-th layer device, and each y-1-th layer device is a representative device of the y-th layer device in the y-1 layer priority value segment where it is located.

Through the above method, the terminal devices in the Industrial Internet of Things can select representative devices, and send heartbeat packets to the platform server through the representative devices, reducing the number of heartbeat packets received and processed by the platform server, and reducing the burden on the platform server and channels.

Embodiment two:

Please refer to Figure 2. When the number of terminal devices in the network increases or decreases, the information in the priority table is inaccurate. The terminal device needs to update the priority table in real time to facilitate the clear mapping between the terminal device and the representative device. For this reason, in this embodiment, the method for a device to elect a representative further includes:

S4: The terminal device sends a notification message to its own representative device in the upper layer, sends a representative notification message to other terminal devices in the lower layer where it is the representative device, and receives the notification message from the upper layer The representative notification message sent by its own representative device, receives the notification message sent to it by other terminal devices with itself as the representative device in the lower layer, and updates its own priority according to the received representative notification message and notification message. The representative notification message includes the priority value and identification information of the representative device sending the representative notification message and the priority value and identification information of the terminal device it represents.

For example, the representative device of terminal device A is terminal device α, and the devices it represents include terminal devices B, C, D, E, F, etc., then terminal device A sends a notification message to terminal device α, and sends notification messages to terminal devices B and C , D, E, F, etc. send representative notification messages, receive representative notification messages sent by terminal equipment α, receive notification messages sent by terminal equipment B, C, D, E, F, etc., and according to the received representative notification messages and notification messages Update its own priority table.

Embodiment three:

When one of the representative devices is offline due to other reasons, the terminal device needs to re-elect its representative device, and then move closer to it to ensure the stability of the network. In this embodiment, the method for the device to elect a representative further includes:

S5: When the terminal device cannot receive the representative notification message sent by its own representative device in the layer above the layer where it is located, define the representative device as the original representative device, and send the notification message to other terminal devices represented by the original representative device, Receive notification messages sent to it by other terminal devices represented by its original representative device, and update the priority table according to the received notification message, and receive information from other terminal devices represented by the original representative device and itself according to the updated priority table. Select the terminal device with the highest priority value as the representative device.

For example, when terminal device A is offline, terminal devices B, C, D, E, F, etc. represented by it define terminal device A as the original representative device. Terminal devices B, C, D, E, F, etc. send notification messages to each other, and at the same time receive the notification messages sent by each other, and update the priority table according to the received notification messages, and select the one with the highest priority value according to the updated priority table. As the representative device, assuming that the priority value of terminal device B in the updated priority table is the largest, then terminal device B is the representative device, representing terminal devices C, D, E, F, etc. Send a heartbeat packet.

The above description is a detailed description of the preferred feasible embodiments of the present invention, but the embodiments are not used to limit the scope of the patent application of the present invention. All equivalent changes or modifications completed under the technical spirit suggested by the present invention shall belong to The scope of patents covered by the present invention.

Claims (5)

1. A method of device electing representatives, the method being applied to an industrial internet of things comprising:

s1: the terminal equipment randomly generates a priority value, stores the generated priority value, marks the priority value as the priority value of the terminal equipment, and broadcasts and sends a notification message to a network, wherein the notification message comprises the priority value and identification information of the terminal equipment sending the notification message;

s2: the terminal equipment receives notification messages sent by all terminal equipment except the terminal equipment, and generates a priority table according to the received notification messages, the priority values and the identification information of the terminal equipment, wherein the priority table comprises priority values and the identification information which are in one-to-one correspondence with the terminal equipment, and the priority values are arranged in the priority table in sequence from large to small;

s3: the terminal equipment checks the priority table, judges whether more than two terminal equipment have equal priority values in the priority table, if so, the terminal equipment executes S301, and if not, the terminal equipment executes S302;

s301: judging whether the priority value of the condition of equality is the priority value of the priority value per se, if so, re-executing the step S1, and if not, re-executing the step S2;

s302: determining a layer where the representative device is located, the representative device of the layer where the representative device is located and the representative device of the next layer of the layer where the representative device is located according to a representative device judging strategy;

the representative device determination policy includes: dividing all priority values into n 1 st layer priority value segments, wherein the device with the largest priority value in each 1 st layer priority value segment is used as 1 st layer device, removing the priority value of the 1 st layer device in each 1 st layer priority value segment and then dividing the device into n 2 nd layer priority value segments, wherein the device with the largest priority value in each 2 nd layer priority value segment is used as 2 nd layer device, each 1 st layer device is the representative device of the 2 nd layer device in the 1 st layer priority value segment, and so on until the m-1 st layer representative device is determined, m and n are defined as the upper layer of the m-1 st layer device through artificial setting, and each m-1 st layer device is the representative device of the m-1 st layer device in the m-1 st layer priority value segment;

further comprises:

s4: the terminal device sends a notification message to its own representative device in the upper layer of the layer, sends a representative notification message to other terminal devices taking itself as a representative device in the lower layer of the layer, receives the representative notification message sent by its own representative device in the upper layer of the layer, receives the notification message sent by other terminal devices taking itself as a representative device in the lower layer of the layer, and updates its own priority table according to the received representative notification message and notification message, wherein the representative notification message comprises the priority value and identification information of the representative device sending the representative notification message and the priority value and identification information of the terminal device represented by the representative notification message.

2. A method of selecting a representative device according to claim 1, further comprising:

s5: when the terminal equipment cannot receive the representative notification message sent by the representative equipment of the terminal equipment in the upper layer of the layer, the representative equipment is defined as original representative equipment, notification messages are sent to other terminal equipment represented by the original representative equipment, the notification messages sent by other terminal equipment represented by the original representative equipment are received, the priority table is updated according to the received notification messages, and the representative equipment is determined from the other terminal equipment represented by the original representative equipment and the terminal equipment according to the updated priority table and the representative equipment judging strategy.

3. The method for selecting a representative of a device according to claim 1, wherein said representative device decision strategy comprises: dividing all priority values into x y-layer priority value segments, wherein the device with the largest priority value in each y-layer priority value segment is used as the representative device of the y-layer priority value segment in the y-layer, dividing the priority values of all the representative devices of the y-layer into x y-1-layer priority value segments, using the device with the largest priority value in each y-1-layer priority value segment as the representative device of the y-1-layer priority value segment in the y-1-layer, and so on until the 1-layer representative device is determined, defining the y-1-layer device as the last layer of the y-layer device through manual setting, and each y-1-layer device is the representative device of the y-layer device in the y-1-layer priority value segment.

4. A method of selecting a representative device according to claim 1, wherein the priority value is between 1 and 2 ³² Between them.

5. A method of selecting a representative of a device according to claim 1, characterized in that the identification information comprises the physical address and/or network address of the terminal device.

Images