CN112367259B - Internet of things data message distribution method and device - Google Patents
Internet of things data message distribution method and device Download PDFInfo
- Publication number
- CN112367259B CN112367259B CN202110050564.6A CN202110050564A CN112367259B CN 112367259 B CN112367259 B CN 112367259B CN 202110050564 A CN202110050564 A CN 202110050564A CN 112367259 B CN112367259 B CN 112367259B
- Authority
- CN
- China
- Prior art keywords
- target
- data
- equipment
- internet
- node
- 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
- 238000000034 method Methods 0.000 title claims abstract description 44
- 230000005540 biological transmission Effects 0.000 claims abstract description 88
- 238000004891 communication Methods 0.000 claims abstract description 21
- 230000004044 response Effects 0.000 claims description 21
- 238000004806 packaging method and process Methods 0.000 claims description 10
- 239000002699 waste material Substances 0.000 abstract 1
- 239000002609 medium Substances 0.000 description 12
- 230000008569 process Effects 0.000 description 4
- 238000010586 diagram Methods 0.000 description 2
- 238000005516 engineering process Methods 0.000 description 2
- 238000004590 computer program Methods 0.000 description 1
- 230000002349 favourable effect Effects 0.000 description 1
- 230000006870 function Effects 0.000 description 1
- 230000000977 initiatory effect Effects 0.000 description 1
- 239000012120 mounting media Substances 0.000 description 1
- 230000003287 optical effect Effects 0.000 description 1
- 230000008707 rearrangement Effects 0.000 description 1
- 238000006467 substitution reaction Methods 0.000 description 1
Images
Classifications
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/12—Shortest path evaluation
- H04L45/122—Shortest path evaluation by minimising distances, e.g. by selecting a route with minimum of number of hops
-
- G—PHYSICS
- G16—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR SPECIFIC APPLICATION FIELDS
- G16Y—INFORMATION AND COMMUNICATION TECHNOLOGY SPECIALLY ADAPTED FOR THE INTERNET OF THINGS [IoT]
- G16Y10/00—Economic sectors
- G16Y10/75—Information technology; Communication
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L45/00—Routing or path finding of packets in data switching networks
- H04L45/12—Shortest path evaluation
- H04L45/126—Shortest path evaluation minimising geographical or physical path length
-
- H—ELECTRICITY
- H04—ELECTRIC COMMUNICATION TECHNIQUE
- H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
- H04L67/00—Network arrangements or protocols for supporting network services or applications
- H04L67/01—Protocols
- H04L67/12—Protocols specially adapted for proprietary or special-purpose networking environments, e.g. medical networks, sensor networks, networks in vehicles or remote metering networks
Landscapes
- Engineering & Computer Science (AREA)
- Signal Processing (AREA)
- Computer Networks & Wireless Communication (AREA)
- Computing Systems (AREA)
- Economics (AREA)
- General Business, Economics & Management (AREA)
- Business, Economics & Management (AREA)
- Development Economics (AREA)
- Accounting & Taxation (AREA)
- Health & Medical Sciences (AREA)
- General Health & Medical Sciences (AREA)
- Medical Informatics (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The embodiment of the application discloses a method and a device for distributing data messages of the Internet of things. According to the technical scheme provided by the embodiment of the application, the target equipment is set, the request information is sent out to establish communication connection with the target equipment, the shortest path between the target equipment and the target equipment is obtained, the shortest path is used as the target path for data distribution, and the data packets are distributed to the target equipment or are sequentially transmitted to the target equipment along the nodes of the target path according to the path length of the target path, so that the data are prevented from being transmitted by using the whole transmission network, the situation of transmission resource waste is avoided, each target path only transmits the corresponding data, and network congestion and data loss are avoided.
Description
Technical Field
The embodiment of the application relates to the technical field of data transmission of the Internet of things, in particular to a method, a device, equipment and a storage medium for distributing data messages of the Internet of things.
Background
With the rapid development of network communication technology, a favorable opportunity is provided for the advancement of the technology of the internet of Things (IoT), which is composed of many devices (such as sensors, smart phones, embedded systems, and the like) with heterogeneous features. In the internet of things, besides the work data of each device, there are also some internal control data, such as configuration parameter data, firmware update data, etc., that need to be transmitted to all devices in the intranet. The data transmission needs to occupy the whole network, and the nodes sending the data send the data to all the nodes in the network, so that the network is easily subjected to great problems, and the hidden troubles of network congestion and data loss exist.
Disclosure of Invention
The embodiment of the application provides a method, a device, equipment and a storage medium for distributing data messages of the Internet of things, so that the data distribution quality and efficiency of the Internet of things are improved, and network congestion and data loss are avoided.
In a first aspect, an embodiment of the present application provides a method for distributing data packets of an internet of things, including:
broadcasting request information for establishing connection with target equipment;
after response information of the target equipment to the request information is received, communication connection is established with the target equipment;
acquiring all paths between the target equipment and the target equipment, selecting the path with the shortest path length from all the paths as a target path, and acquiring node information of all transmission nodes in the target path;
when the path length of the target path is larger than a first threshold value, directly distributing the data packet to the target equipment;
when the path length of the target path is not greater than the first threshold, the data packet is transmitted to the target device along each node in the target path in sequence.
Further, sequentially transmitting the data packet to the target device along each node in the target path includes:
the initial position of the data is taken as a main node, and the corresponding data is packaged into a plurality of data packets;
transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node; the data packet comprises a data header, and the data header comprises node information of a target path;
and after receiving all the data packets, each level of child nodes transmit all the data packets to the next level of child nodes which correspond to the node information and are directly connected according to the node information until all the data packets are transmitted to the target equipment.
Further, sequentially transmitting the data packet to the target device along each node in the target path includes:
receiving a data transmission request of a next-level child node by taking the initial position of the data as a current node;
according to the data transmission request, packaging corresponding data into a plurality of data packets, and sequentially transmitting the data packets to a next-level child node which is directly connected with the current node in the target path; the data packet contains data identification information;
and when each level of child nodes receives the data packet and confirms the data packet as the data packet requested by the child nodes per se according to the data identification information, transmitting the data packet to the next level of child nodes until the data packet is transmitted to the target equipment.
Further, sequentially transmitting the data packet to the target device along each node in the target path includes:
packaging corresponding data into a plurality of data packets by taking the initial positions of the data packets as main nodes;
transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node;
receiving a receiving completion signal fed back by all levels of child nodes after receiving all the data packets;
and calculating the data transmission progress according to the receiving completion signals of all levels of the sub-nodes, counting the current data transmission time, establishing a cross-level transmission unicast connection with the target equipment when the data transmission progress is smaller than a second threshold and the data transmission time is larger than a third threshold, and sequentially sending all data packets to the target equipment.
Further, when the data transmission progress is greater than a second threshold or the data transmission duration is less than a third threshold, all data packets are continuously transmitted to the next-stage child node in the target path, which does not receive the data packets.
Further, after receiving response information of the target device to the request information, establishing a communication connection with the target device includes:
receiving response information of a plurality of pieces of Internet of things equipment to the request information, wherein the response information comprises identity information of the pieces of Internet of things equipment;
acquiring identity information of target equipment, and comparing whether the identity information of the Internet of things equipment is consistent with the identity information of the target equipment or not based on the identity information of the Internet of things equipment;
and selecting the Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, and establishing communication connection with the target equipment.
Further, the identity information comprises an equipment identification code and an equipment position symbol; selecting the Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, wherein the method comprises the following steps:
and selecting the Internet of things equipment with the equipment identification code and the equipment position symbol consistent with the equipment identification code and the equipment position symbol of the target equipment as the target equipment.
In a second aspect, an embodiment of the present application provides an internet of things data packet distribution device, including:
a connection request module: broadcasting request information for establishing a connection with a target device;
a connection establishment module: the system is used for establishing communication connection with the target equipment after receiving response information of the target equipment to the request information;
a path selection module: the method comprises the steps of acquiring all paths between the target equipment and the target equipment, selecting the path with the shortest path length from all the paths as a target path, and acquiring node information of all transmission nodes in the target path;
a first distribution module: the data packet is directly distributed to the target equipment when the path length of the target path is larger than a first threshold value;
a second distribution module: and the data packet is transmitted to the target device along each node in the target path in sequence when the path length of the target path is not larger than the first threshold value.
Further, in the second distribution module, sequentially transmitting the data packet to the target device along each node in the target path includes:
the initial position of the data is taken as a main node, and the corresponding data is packaged into a plurality of data packets;
transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node; the data packet comprises a data header, and the data header comprises node information of a target path;
and after receiving all the data packets, each level of child nodes transmit all the data packets to the next level of child nodes which correspond to the node information and are directly connected according to the node information until all the data packets are transmitted to the target equipment.
Further, in the second distribution module, sequentially transmitting the data packet to the target device along each node in the target path includes:
receiving a data transmission request of a next-level child node by taking the initial position of the data as a current node;
according to the data transmission request, packaging corresponding data into a plurality of data packets, and sequentially transmitting the data packets to a next-level child node which is directly connected with the current node in the target path; the data packet contains data identification information;
and when each level of child nodes receives the data packet and confirms the data packet as the data packet requested by the child nodes per se according to the data identification information, transmitting the data packet to the next level of child nodes until the data packet is transmitted to the target equipment.
Further, in the second distribution module, sequentially transmitting the data packet to the target device along each node in the target path includes:
packaging corresponding data into a plurality of data packets by taking the initial positions of the data packets as main nodes;
transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node;
receiving a receiving completion signal fed back by all levels of child nodes after receiving all the data packets;
and calculating the data transmission progress according to the receiving completion signals of all levels of the sub-nodes, counting the current data transmission time, establishing a cross-level transmission unicast connection with the target equipment when the data transmission progress is smaller than a second threshold and the data transmission time is larger than a third threshold, and sequentially sending all data packets to the target equipment.
Further, when the data transmission progress is greater than a second threshold or the data transmission duration is less than a third threshold, all data packets are continuously transmitted to the next-stage child node in the target path, which does not receive the data packets.
Further, the establishing a communication connection with the target device after receiving the response information of the target device to the request information in the connection establishing module includes:
receiving response information of a plurality of pieces of Internet of things equipment to the request information, wherein the response information comprises identity information of the pieces of Internet of things equipment;
acquiring identity information of target equipment, and comparing whether the identity information of the Internet of things equipment is consistent with the identity information of the target equipment or not based on the identity information of the Internet of things equipment;
and selecting the Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, and establishing communication connection with the target equipment.
Further, the identity information comprises an equipment identification code and an equipment position symbol; selecting the Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, wherein the method comprises the following steps:
and selecting the Internet of things equipment with the equipment identification code and the equipment position symbol consistent with the equipment identification code and the equipment position symbol of the target equipment as the target equipment.
In a third aspect, an embodiment of the present application provides a computer device, including: a memory and one or more processors;
the memory for storing one or more programs;
when the one or more programs are executed by the one or more processors, the one or more processors implement the internet of things data message distribution method according to the first aspect.
In a fourth aspect, embodiments of the present application provide a storage medium containing computer-executable instructions, which when executed by a computer processor, are configured to perform the internet of things data message distribution method according to the first aspect.
According to the embodiment of the application, the target device is set, only the request information is sent out to establish communication connection with the target device, the shortest path between the target device and the target device is obtained, the shortest path is used as the target path to distribute data, and the data packets are distributed to the target device or are sequentially transmitted to the target device along the nodes of the target path according to the path length of the target path, so that the data are prevented from being transmitted by using the whole transmission network, the situation that transmission resources are wasted does not exist, each target path only transmits the corresponding data, and network congestion and data loss are avoided.
Drawings
Fig. 1 is a flowchart of a data message distribution method for the internet of things according to an embodiment of the present application;
fig. 2 is a schematic structural diagram of an internet of things data message distribution device according to an embodiment of the present application;
fig. 3 is a schematic structural diagram of data packet distribution equipment of the internet of things according to an embodiment of the present application.
Detailed Description
In order to make the objects, technical solutions and advantages of the present application more apparent, specific embodiments of the present application will be described in detail with reference to the accompanying drawings. It is to be understood that the specific embodiments described herein are merely illustrative of the application and are not limiting of the application. It should be further noted that, for the convenience of description, only some but not all of the relevant portions of the present application are shown in the drawings. Before discussing exemplary embodiments in more detail, it should be noted that some exemplary embodiments are described as processes or methods depicted as flowcharts. Although a flowchart may describe the operations (or steps) as a sequential process, many of the operations can be performed in parallel, concurrently or simultaneously. In addition, the order of the operations may be re-arranged. The process may be terminated when its operations are completed, but may have additional steps not included in the figure. The processes may correspond to methods, functions, procedures, subroutines, and the like.
The embodiment of the application provides a method, a device, equipment and a storage medium for distributing data messages of the Internet of things. According to the embodiment of the application, the target device is set, only the request information is sent out to establish communication connection with the target device, the shortest path between the target device and the target device is obtained, the shortest path is used as the target path to distribute data, and the data packets are distributed to the target device or are sequentially transmitted to the target device along the nodes of the target path according to the path length of the target path, so that the data are prevented from being transmitted by using the whole transmission network, the situation that transmission resources are wasted does not exist, each target path only transmits the corresponding data, and network congestion and data loss are avoided.
The following are detailed below.
Fig. 1 is a flowchart of an internet of things data packet distribution method according to an embodiment of the present disclosure, where the internet of things data packet distribution method according to the embodiment of the present disclosure may be implemented by an internet of things data packet distribution device, and the internet of things data packet distribution device may be implemented in a hardware and/or software manner and integrated in a computer device.
The following description will be given taking an example in which an internet-of-things data message distribution apparatus executes an internet-of-things data message distribution method. Referring to fig. 1, the method for distributing data packets of the internet of things includes:
101: request information to establish a connection with a target device is broadcast.
The application can be applied to a server, an upper computer and any intelligent equipment. The smart device may be a desktop computer, a notebook, a tablet computer, a smart bracelet, a smart watch, and the like. And in the whole internet of things architecture, the internet of things architecture comprises a plurality of transmission nodes, and each transmission node can be a workstation, a network user, a personal computer, a server, a printer and other equipment connected with the network. Each workstation, server, terminal device, network device, etc. is a device with a unique network address for itself, and can be used as a transmission node. A plurality of network nodes are directly connected by communication lines to form a certain geometrical relationship, so that a network topology structure of the Internet of things is formed.
In the network topology of the internet of things, any one network node can be used as an initial node for initiating data transmission in the embodiment of the application. As one of the application scenarios, a user needs to perform fixed upgrade on part of nodes in a network topology of the internet of things. And selecting one node from the part of nodes as an initial node. Usually, the initial node is selected as the most central node among the partial nodes to facilitate transmission. The initial node can be selected according to a preset rule through an algorithm, or a node can be selected as the initial node by a user subjectively, and an upgrade file is written in the initial node. The upgrade file is data that needs to be transmitted and distributed continuously.
After the upgrade file is written in the initial node, the written upgrade file often also contains the identity information of the target device, and the initial node analyzes the written upgrade file to obtain the identity information of the target device. And starting to distribute the data of the payload in the upgrade file by the initial node. First the initial node broadcasts a request message to the target device,
102: and after receiving the response information of the target equipment to the request information, establishing communication connection with the target equipment.
After the initial node sends request information to at least one target device, the target device reacts to the request information if receiving the request information, and response information is fed back. The response information often carries its own identity information, including an equipment identification code.
And when the initial node receives the response information fed back by the target equipment, establishing communication connection with the target equipment with feedback. If there is no target device with feedback, no communication is established.
103: and acquiring all paths between the target equipment and the target equipment, selecting the path with the shortest path length from all the paths as a target path, and acquiring node information of all transmission nodes in the target path.
The shortest path often means a faster transmission rate, and therefore, in the embodiment of the present application, the path with the shortest path is selected as the target path.
104: and judging whether the length of the target path is greater than a first threshold value. In this embodiment, by comparing the target path length with the first threshold, when the path length of the target path is greater than the first threshold, the data packet is directly distributed to the target device; when the path length of the target path is less than the first threshold, the data packet is transmitted to the target device along each node in the target path in sequence.
The data packet is sequentially transmitted to the target device along each node in the target path, for example, the target path includes sequentially ordered node a, node b, node c, node d, and node e, where node a is an initial node, and node e is a last node. And sequentially transmitting the data to the target equipment along the sequence of the node a, the node b, the node c, the node d and the node e. The method specifically comprises the following steps: the initial position of the data is taken as a main node, namely the node a is taken as the main node, and the node b, the node c, the node d and the node e are taken as other child nodes. Encapsulating the corresponding data into a plurality of data packets; transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node; that is, the node a transmits the data packet to the node b, and then the node b transmits the data packet to the next-level child node, that is, the node c, and so on. The data packet comprises a data header, and the data header comprises node information of a target path; and after receiving all the data packets, each level of child nodes transmit all the data packets to the next level of child nodes which correspond to the node information and are directly connected according to the node information until all the data packets are transmitted to the target equipment.
In another aspect, sequentially transmitting a data packet to a destination device along each node in a destination path comprises: receiving a data transmission request of a next-level child node by taking the initial position of the data as a current node; according to the data transmission request, packaging corresponding data into a plurality of data packets, and sequentially transmitting the data packets to a next-level child node which is directly connected with the current node in the target path; the data packet contains data identification information; and when each level of child nodes receives the data packet and confirms the data packet as the data packet requested by the child nodes per se according to the data identification information, transmitting the data packet to the next level of child nodes until the data packet is transmitted to the target equipment. In this example, as each next-level child node, a data transmission request is sent to the previous-level child node, and the previous-level child node needs to send a data packet only when receiving the data transmission request, and a handshake session between the previous-level and next-level child nodes is added by one layer, so that transmission guarantee can be increased.
In still further aspects, sequentially transmitting the data packet to the destination device along each node in the destination path comprises: packaging corresponding data into a plurality of data packets by taking the initial positions of the data packets as main nodes; transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node; receiving a receiving completion signal fed back by all levels of child nodes after receiving all the data packets; and calculating the data transmission progress according to the receiving completion signals of all levels of the sub-nodes, counting the current data transmission time, establishing a cross-level transmission unicast connection with the target equipment when the data transmission progress is smaller than a second threshold and the data transmission time is larger than a third threshold, and sequentially sending all data packets to the target equipment.
In this example, as the child node of the next stage, each time all the data packets are received, the reception completion signal is fed back. And the data transmission speed can be calculated according to the time of receiving the receiving completion signal and the time of sending the data packet by the initial node.
Furthermore, when the data transmission progress is greater than the second threshold or the data transmission duration is less than the third threshold, all data packets are continuously transmitted to the next-stage child node in the target path, which does not receive the data packets.
In this embodiment of the present application, after receiving response information of the target device to the request information, establishing a communication connection with the target device includes: receiving response information of a plurality of pieces of Internet of things equipment to the request information, wherein the response information comprises identity information of the pieces of Internet of things equipment; acquiring identity information of target equipment, and comparing whether the identity information of the Internet of things equipment is consistent with the identity information of the target equipment or not based on the identity information of the Internet of things equipment; and selecting the Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, and establishing communication connection with the target equipment.
As a preferred embodiment, in the present application, the identity information includes an equipment identification code and an equipment location identifier; selecting the Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, wherein the method comprises the following steps: and selecting the Internet of things equipment with the equipment identification code and the equipment position symbol consistent with the equipment identification code and the equipment position symbol of the target equipment as the target equipment.
As shown in fig. 2, an embodiment of the present application further provides an internet of things data packet distribution device, which includes a connection request module 201, a connection establishment module 202, a path selection module 203, a first distribution module 204, and a second distribution module 205. The connection request module 201 is used to broadcast request information for establishing connection with a target device. The connection establishing module 202 is configured to establish a communication connection with the target device after receiving the response information of the target device to the request information. The path selection module 203 is configured to acquire all paths between the target device and the target device, select a path with the shortest path length from all paths as a target path, and acquire node information of all transmission nodes in the target path. The first distribution module 204 is configured to directly distribute the data packet to the target device when the path length of the target path is greater than the first threshold. The second distribution module 205 is configured to sequentially transmit the data packet to the target device along each node in the target path when the path length of the target path is not greater than the first threshold.
In the connection establishing module 202, after receiving the response information of the target device to the request information, establishing a communication connection with the target device includes: receiving response information of a plurality of pieces of Internet of things equipment to the request information, wherein the response information comprises identity information of the pieces of Internet of things equipment; acquiring identity information of target equipment, and comparing whether the identity information of the Internet of things equipment is consistent with the identity information of the target equipment or not based on the identity information of the Internet of things equipment; and selecting the Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, and establishing communication connection with the target equipment.
In the embodiment of the application, the identity information comprises an equipment identification code and an equipment position symbol; selecting the Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, wherein the method comprises the following steps: and selecting the Internet of things equipment with the equipment identification code and the equipment position symbol consistent with the equipment identification code and the equipment position symbol of the target equipment as the target equipment.
Specifically, in the second distribution module 205, sequentially transmitting the data packet to the target device along each node in the target path includes: the initial position of the data is taken as a main node, and the corresponding data is packaged into a plurality of data packets; transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node; the data packet comprises a data header, and the data header comprises node information of a target path; and after receiving all the data packets, each level of child nodes transmit all the data packets to the next level of child nodes which correspond to the node information and are directly connected according to the node information until all the data packets are transmitted to the target equipment.
In another embodiment, the transmitting the data packet to the destination device in the second distribution module 205 in sequence along each node in the destination path includes: receiving a data transmission request of a next-level child node by taking the initial position of the data as a current node; according to the data transmission request, packaging corresponding data into a plurality of data packets, and sequentially transmitting the data packets to a next-level child node which is directly connected with the current node in the target path; the data packet contains data identification information; and when each level of child nodes receives the data packet and confirms the data packet as the data packet requested by the child nodes per se according to the data identification information, transmitting the data packet to the next level of child nodes until the data packet is transmitted to the target equipment.
The second distribution module 205 sequentially transmits the data packet to the target device along each node in the target path, and may further include: packaging corresponding data into a plurality of data packets by taking the initial positions of the data packets as main nodes; transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node; receiving a receiving completion signal fed back by all levels of child nodes after receiving all the data packets; and calculating the data transmission progress according to the receiving completion signals of all levels of the sub-nodes, counting the current data transmission time, establishing a cross-level transmission unicast connection with the target equipment when the data transmission progress is smaller than a second threshold and the data transmission time is larger than a third threshold, and sequentially sending all data packets to the target equipment.
And when the data transmission progress is greater than a second threshold or the data transmission duration is less than a third threshold, continuously transmitting all data packets to the next-stage child node which does not receive the data packets in the target path.
As shown in fig. 3, an embodiment of the present application further provides a computer device, including: a memory 301 and one or more processors 302; the memory 301 is used for storing one or more programs; when executed by the one or more processors 302, the one or more programs cause the one or more processors to implement a method for routing internet of things based data transmission as described herein.
Embodiments of the present application further provide a storage medium containing computer-executable instructions, which when executed by a computer processor, are configured to perform the method for routing based on data transmission of the internet of things according to the foregoing embodiments, where the method for routing based on data transmission of the internet of things includes: receiving a transmission path selection instruction input by a user through a terminal, wherein the transmission path selection instruction carries transmission path configuration information and target node information; acquiring all paths between a terminal and a target node and transmission data of each path; calculating the transmission quality parameter of each path according to the transmission data and a preset algorithm; and selecting a path matched with the transmission path configuration information according to the transmission quality parameters, or selecting a path matched with the transmission path configuration information according to the transmission quality parameters and the transmission data.
Storage medium-any of various types of memory devices or storage devices. The term "storage medium" is intended to include: mounting media such as CD-ROM, floppy disk, or tape devices; computer system memory or random access memory such as DRAM, DDR RAM, SRAM, EDO RAM, Lanbas (Rambus) RAM, etc.; non-volatile memory such as flash memory, magnetic media (e.g., hard disk or optical storage); registers or other similar types of memory elements, etc. The storage medium may also include other types of memory or combinations thereof. In addition, the storage medium may be located in a first computer system in which the program is executed, or may be located in a different second computer system connected to the first computer system through a network (such as the internet). The second computer system may provide program instructions to the first computer for execution. The term "storage medium" may include two or more storage media that may reside in different locations, such as in different computer systems that are connected by a network. The storage medium may store program instructions (e.g., embodied as a computer program) that are executable by one or more processors.
Of course, the storage medium containing the computer-executable instructions provided in the embodiments of the present application is not limited to the method for selecting a path based on data transmission in the internet of things as described above, and may also perform related operations in the method for selecting a path based on data transmission in the internet of things as provided in any embodiment of the present application.
The routing device, the device, and the storage medium based on internet of things data transmission provided in the foregoing embodiments may execute the routing method based on internet of things data transmission provided in any embodiment of the present application, and reference may be made to the routing method based on internet of things data transmission provided in any embodiment of the present application without detailed technical details described in the foregoing embodiments.
The foregoing is considered as illustrative of the preferred embodiments of the invention and the technical principles employed. The present application is not limited to the particular embodiments described herein, but is capable of various obvious changes, rearrangements and substitutions as will now become apparent to those skilled in the art without departing from the scope of the invention. Therefore, although the present application has been described in more detail with reference to the above embodiments, the present application is not limited to the above embodiments, and may include other equivalent embodiments without departing from the spirit of the present application, and the scope of the present application is determined by the scope of the claims.
Claims (9)
1. A method for distributing data messages of the Internet of things is characterized by comprising the following steps:
broadcasting request information for establishing connection with target equipment;
receiving response information of a plurality of pieces of Internet of things equipment to the request information, wherein the response information comprises identity information of the pieces of Internet of things equipment; acquiring identity information of target equipment, and comparing whether the identity information of the Internet of things equipment is consistent with the identity information of the target equipment or not based on the identity information of the Internet of things equipment; selecting Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, and establishing communication connection with the target equipment;
acquiring all paths between the target equipment and the target equipment, selecting the path with the shortest path length from all the paths as a target path, and acquiring node information of all transmission nodes in the target path;
when the path length of the target path is larger than a first threshold value, directly distributing the data packet to the target equipment;
when the path length of the target path is not greater than the first threshold, the data packet is transmitted to the target device along each node in the target path in sequence.
2. The internet of things data message distribution method according to claim 1, wherein the step of sequentially transmitting the data packets to the target device along each node in the target path comprises:
the initial position of the data is taken as a main node, and the corresponding data is packaged into a plurality of data packets;
transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node; the data packet comprises a data header, and the data header comprises node information of a target path;
and after receiving all the data packets, each level of child nodes transmit all the data packets to the next level of child nodes which correspond to the node information and are directly connected according to the node information until all the data packets are transmitted to the target equipment.
3. The internet of things data message distribution method according to claim 1, wherein the step of sequentially transmitting the data packets to the target device along each node in the target path comprises:
receiving a data transmission request of a next-level child node by taking the initial position of the data as a current node;
according to the data transmission request, packaging corresponding data into a plurality of data packets, and sequentially transmitting the data packets to a next-level child node which is directly connected with the current node in the target path; the data packet contains data identification information;
and when each level of child nodes receives the data packet and confirms the data packet as the data packet requested by the child nodes per se according to the data identification information, transmitting the data packet to the next level of child nodes until the data packet is transmitted to the target equipment.
4. The internet of things data message distribution method according to claim 1, wherein the step of sequentially transmitting the data packets to the target device along each node in the target path comprises:
packaging corresponding data into a plurality of data packets by taking the initial positions of the data packets as main nodes;
transmitting all data packets to the next-level child node in the target path, which is directly connected with the main node;
receiving a receiving completion signal fed back by all levels of child nodes after receiving all the data packets;
and calculating the data transmission progress according to the receiving completion signals of all levels of the sub-nodes, counting the current data transmission time, establishing a cross-level transmission unicast connection with the target equipment when the data transmission progress is smaller than a second threshold and the data transmission time is larger than a third threshold, and sequentially sending all data packets to the target equipment.
5. The internet of things data message distribution method according to claim 4, wherein when the data transmission progress is greater than a second threshold or the data transmission duration is less than a third threshold, all data packets are continuously transmitted to the next-stage child node in the target path, which does not receive the data packets.
6. The internet of things data message distribution method according to claim 1, wherein the identity information includes an equipment identification code and an equipment location symbol; selecting the Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, wherein the method comprises the following steps:
and selecting the Internet of things equipment with the equipment identification code and the equipment position symbol consistent with the equipment identification code and the equipment position symbol of the target equipment as the target equipment.
7. An internet of things data message distribution device is characterized by comprising:
a connection request module: broadcasting request information for establishing a connection with a target device;
a connection establishment module: the request information sending unit is used for sending request information to a plurality of devices of the Internet of things, and the request information comprises identity information of the devices of the Internet of things; acquiring identity information of target equipment, and comparing whether the identity information of the Internet of things equipment is consistent with the identity information of the target equipment or not based on the identity information of the Internet of things equipment; selecting Internet of things equipment with identity information consistent with that of the target equipment as the target equipment, and establishing communication connection with the target equipment;
a path selection module: the method comprises the steps of acquiring all paths between the target equipment and the target equipment, selecting the path with the shortest path length from all the paths as a target path, and acquiring node information of all transmission nodes in the target path;
a first distribution module: the data packet is directly distributed to the target equipment when the path length of the target path is larger than a first threshold value;
a second distribution module: and the data packet is transmitted to the target device along each node in the target path in sequence when the path length of the target path is not larger than the first threshold value.
8. An internet of things data message distribution device, comprising: a memory and one or more processors;
the memory for storing one or more programs;
when executed by the one or more processors, cause the one or more processors to implement the internet of things data message distribution method of any of claims 1-6.
9. A storage medium containing computer-executable instructions for performing the internet of things data message distribution method of any of claims 1-6 when executed by a computer processor.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110050564.6A CN112367259B (en) | 2021-01-15 | 2021-01-15 | Internet of things data message distribution method and device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202110050564.6A CN112367259B (en) | 2021-01-15 | 2021-01-15 | Internet of things data message distribution method and device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN112367259A CN112367259A (en) | 2021-02-12 |
| CN112367259B true CN112367259B (en) | 2021-04-16 |
Family
ID=74535006
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202110050564.6A Active CN112367259B (en) | 2021-01-15 | 2021-01-15 | Internet of things data message distribution method and device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN112367259B (en) |
Families Citing this family (4)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN113395135B (en) * | 2021-05-06 | 2023-03-14 | 埃森智能科技（深圳）有限公司 | Data communication method, device and computer readable storage medium |
| CN113422818B (en) * | 2021-06-18 | 2022-10-25 | 重庆紫光华山智安科技有限公司 | Data cascade transmission method, system and node equipment |
| CN113703364A (en) * | 2021-08-25 | 2021-11-26 | 京东方科技集团股份有限公司 | Data transmission method, device and medium |
| CN114070873B (en) * | 2021-11-09 | 2025-02-14 | 浙江大华技术股份有限公司 | Device linkage method and device in Internet of Things network, storage medium and electronic device |
Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN111343093A (en) * | 2020-02-28 | 2020-06-26 | 腾讯科技（深圳）有限公司 | Service data transmission method and device |
| US10749790B2 (en) * | 2019-01-15 | 2020-08-18 | Cisco Technology, Inc. | Multicast-based content distribution for IoT networks using bit index explicit replication (BIER) |
Family Cites Families (3)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN100591054C (en) * | 2008-02-22 | 2010-02-17 | 浙江树人大学 | A Hierarchical Energy Consumption Balance Method for Wireless Sensor Networks |
| JP4609547B2 (en) * | 2008-08-14 | 2011-01-12 | ソニー株式会社 | Wireless communication apparatus, communication system, communication control method, and program |
| US9967884B2 (en) * | 2015-11-10 | 2018-05-08 | Netgear, Inc. | Dedicated backhaul for whole home coverage |
-
2021
- 2021-01-15 CN CN202110050564.6A patent/CN112367259B/en active Active
Patent Citations (2)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| US10749790B2 (en) * | 2019-01-15 | 2020-08-18 | Cisco Technology, Inc. | Multicast-based content distribution for IoT networks using bit index explicit replication (BIER) |
| CN111343093A (en) * | 2020-02-28 | 2020-06-26 | 腾讯科技（深圳）有限公司 | Service data transmission method and device |
Also Published As
| Publication number | Publication date |
|---|---|
| CN112367259A (en) | 2021-02-12 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN112367259B (en) | Internet of things data message distribution method and device | |
| US4423414A (en) | System and method for name-lookup in a local area network data communication system | |
| US4430651A (en) | Expandable and contractible local area network system | |
| US4410889A (en) | System and method for synchronizing variable-length messages in a local area network data communication system | |
| US11445428B2 (en) | Method and device for setting up route path | |
| US11843412B2 (en) | Electronic device for performing ranging by using ultra wide band communication and operating method thereof | |
| JP2004336716A (en) | Path MTU discovery system and method in ad hoc networks | |
| CN114710549B (en) | A dynamic management method, system and business node for network cards in a container platform | |
| CN114125940A (en) | Data message sending method, processing method, device, equipment and data message | |
| US8208401B2 (en) | Method of managing address spaces of incommunicable nodes in ZigBee network | |
| US9160676B2 (en) | Apparatus and method for multi-hop routing decision and looping prevention | |
| WO2024067687A1 (en) | Information transmission method, first communication node, second communication node, and storage medium | |
| US9055522B2 (en) | Method, device, and system for selecting route discovery | |
| US9009248B2 (en) | Apparatus and method of performing discovery based on priority level in distributed network, and method of determining discovery back-off time | |
| EP3020163B1 (en) | Interworking between first protocol entity of stream reservation protocol and second protocol entity of routing protocol | |
| CN117896041A (en) | Message transmission method, device and readable storage medium based on industrial Internet | |
| US20230198648A1 (en) | Time synchronization method, device and apparatus, and storage medium | |
| CN112437458B (en) | Data transmission method, device, communication equipment and medium | |
| CN116366700A (en) | A command transmission method, device, equipment and medium | |
| CN112055083B (en) | Request processing method and device, electronic equipment and medium | |
| CN111464442B (en) | Method and device for routing data packet | |
| CN109067666B (en) | Message transmission method and device | |
| CN115134786A (en) | Bluetooth connection blocking method, device, equipment and storage medium | |
| CN115022224B (en) | A method, device and equipment for processing session establishment | |
| CN118175566B (en) | Link detection method, device, equipment and readable storage medium |
Legal Events
| Date | Code | Title | Description |
|---|---|---|---|
| PB01 | Publication | ||
| PB01 | Publication | ||
| SE01 | Entry into force of request for substantive examination | ||
| SE01 | Entry into force of request for substantive examination | ||
| GR01 | Patent grant | ||
| GR01 | Patent grant |