CN112596893B - Monitoring method and system for multi-node edge computing device - Google Patents
Monitoring method and system for multi-node edge computing device Download PDFInfo
- Publication number
- CN112596893B CN112596893B CN202011319531.9A CN202011319531A CN112596893B CN 112596893 B CN112596893 B CN 112596893B CN 202011319531 A CN202011319531 A CN 202011319531A CN 112596893 B CN112596893 B CN 112596893B
- Authority
- CN
- China
- Prior art keywords
- node server
- slave node
- data
- servers
- command
- 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 37
- 238000012544 monitoring process Methods 0.000 title claims abstract description 25
- 238000012545 processing Methods 0.000 claims abstract description 119
- 230000005540 biological transmission Effects 0.000 claims abstract description 54
- 230000003993 interaction Effects 0.000 claims abstract description 33
- 238000004364 calculation method Methods 0.000 claims abstract description 26
- 238000004458 analytical method Methods 0.000 claims abstract description 12
- 230000003044 adaptive effect Effects 0.000 claims description 19
- 238000004891 communication Methods 0.000 claims description 8
- 238000012856 packing Methods 0.000 claims description 4
- 230000006837 decompression Effects 0.000 claims description 3
- 230000009286 beneficial effect Effects 0.000 description 9
- 238000012986 modification Methods 0.000 description 3
- 230000004048 modification Effects 0.000 description 3
- 238000010586 diagram Methods 0.000 description 2
- 230000007547 defect Effects 0.000 description 1
- 238000005516 engineering process Methods 0.000 description 1
- 230000002349 favourable effect Effects 0.000 description 1
- 230000001360 synchronised effect Effects 0.000 description 1
Images
Classifications
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/50—Allocation of resources, e.g. of the central processing unit [CPU]
- G06F9/5005—Allocation of resources, e.g. of the central processing unit [CPU] to service a request
- G06F9/5027—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals
- G06F9/5044—Allocation of resources, e.g. of the central processing unit [CPU] to service a request the resource being a machine, e.g. CPUs, Servers, Terminals considering hardware capabilities
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F9/00—Arrangements for program control, e.g. control units
- G06F9/06—Arrangements for program control, e.g. control units using stored programs, i.e. using an internal store of processing equipment to receive or retain programs
- G06F9/46—Multiprogramming arrangements
- G06F9/54—Interprogram communication
- G06F9/546—Message passing systems or structures, e.g. queues
-
- G—PHYSICS
- G06—COMPUTING; CALCULATING OR COUNTING
- G06F—ELECTRIC DIGITAL DATA PROCESSING
- G06F2209/00—Indexing scheme relating to G06F9/00
- G06F2209/50—Indexing scheme relating to G06F9/50
- G06F2209/502—Proximity
Landscapes
- Engineering & Computer Science (AREA)
- Software Systems (AREA)
- Theoretical Computer Science (AREA)
- Physics & Mathematics (AREA)
- General Engineering & Computer Science (AREA)
- General Physics & Mathematics (AREA)
- Data Exchanges In Wide-Area Networks (AREA)
Abstract
The present invention provides a monitoring method and system for a multi-node edge computing device, which selects one of servers satisfying a specific data processing capability condition as a master node server and the rest as slave node servers from a plurality of servers, the slave node server receives and retains the command packet from the master node server adaptively according to the address information of the slave node server, and then performs data interaction operation between the slave node server and the master node server according to the analysis processing result of the command packet to complete the corresponding data calculation task, it makes corresponding command instruction to slave node server by determining master node server, and uses address information as command receiving and retaining basis, therefore, the transmission efficiency and the transmission accuracy of the command packet are greatly improved, the reliability of the multi-task processing is furthest improved, and the condition of task processing conflict is avoided.
Description
Technical Field
The present invention relates to the field of computer data processing technology, and more particularly, to a monitoring method and system for a multi-node edge computing device.
Background
The distributed computer system comprises a plurality of autonomous computer nodes which are mutually communicated and connected, and is widely applied to different data processing scenes due to the characteristics of high computing speed and capability of performing multi-task synchronous processing. In the distributed computer system, all the autonomous computer nodes are equal in position in the system, and there is no primary-secondary score, which makes the probability that all the autonomous computer nodes are allocated to the corresponding computing tasks identical, thus resulting in that the distributed computer system needs to spend corresponding time and computing power to decide to allocate the computing task to a specific autonomous computer node in the process of performing distributed task computing processing, which is not favorable for improving the computing efficiency of the distributed computer system and is easy to cause the situation that different autonomous computer nodes generate computing conflicts.
Disclosure of Invention
Aiming at the defects in the prior art, the invention provides a monitoring method and a monitoring system for multi-node edge computing equipment, which are characterized in that data processing state information corresponding to a plurality of servers is obtained, the servers are distinguished and determined to be a main node server and a plurality of slave node servers according to the data processing state information, target address information of a command from the main node server is identified, and the target address information is compared with the address information of the slave node servers, so that whether the slave node server receives the command packet is determined, the slave node server receiving the command is indicated to analyze the command packet, and adaptive data interaction operation is carried out with the main node server according to the result of analysis processing; it can be seen that the monitoring method and system for multi-node edge computing device selects one server satisfying specific data processing capacity condition from several servers as a main node server and the rest servers as slave node servers, the slave node server receives and retains the command packet from the master node server adaptively according to the address information of the slave node server, and then performs data interaction operation between the slave node server and the master node server according to the analysis processing result of the command packet to complete the corresponding data calculation task, it makes corresponding command instruction to slave node server by determining master node server, and uses address information as command receiving and retaining basis, therefore, the transmission efficiency and the transmission accuracy of the command packet are greatly improved, the reliability of the multi-task processing is furthest improved, and the condition of task processing conflict is avoided.
The invention provides a monitoring method for multi-node edge computing equipment, which is characterized by comprising the following steps:
step S1, acquiring data processing state information corresponding to a plurality of servers, and determining the plurality of servers as a master node server and a plurality of slave node servers according to the data processing state information;
step S2, recognizing target address information of the command from the master node server, and comparing the target address information with address information of the slave node server itself, thereby determining whether to instruct the slave node server to receive the command packet;
step S3, instructing the slave node server that received the command to perform parsing on the command packet, so as to perform adaptive data interaction operation with the master node server according to the result of the parsing;
further, in step S1, the acquiring data processing state information corresponding to a plurality of servers, and determining the plurality of servers as a master node server and a plurality of slave node servers according to the data processing state information specifically includes:
step S101, acquiring data calculation speed, data transmission speed and data transmission distortion degree corresponding to each of a plurality of servers, and taking the data calculation speed, the data transmission speed and the data transmission distortion degree as the data processing state information;
step S102, determining a data processing quality value corresponding to each server according to the data calculation speed, the data transmission speed and the data transmission distortion;
step S103, according to the magnitude of the data processing quality value, determining the server with the maximum data processing quality value as a master node server, and determining the rest servers as slave node servers;
further, in the step S2, identifying the target address information of the command packet from the master node server, and comparing the target address information with the address information of the slave node server itself, so as to determine whether to indicate that the slave node server receives the command packet specifically includes:
step S201, identifying and obtaining target address information corresponding to a target server to which the command packet needs to be sent from the command from the master node server, and simultaneously obtaining MAC address information or IP address information of all slave node servers;
step S202, comparing the target address information with MAC address information or IP address information of all slave node servers, thereby indicating that the slave node servers with the MAC address information or the IP address information consistent with the target address information keep the received command packets, and indicating other slave node servers to discard the received command packets;
further, in step S3, instructing the slave node server that receives the command packet to perform parsing on the command packet, so that performing adaptive data interaction with the master node server according to a result of the parsing specifically includes:
step S301A, instruct the slave node server which receives and retains the command packet to decompress the command packet and identify the command type, so as to determine whether the command packet contains instructions belonging to the control instruction or the query instruction;
step S302A, if it is determined that the instruction included in the command packet belongs to a control instruction, returning a message of successful instruction execution to the master node server after the slave node server successfully executes the control instruction;
step S303A, if it is determined that the instruction included in the command packet belongs to the query instruction, packing and returning the data obtained by the query to the master node server after the slave node server successfully executes the query instruction, and instructing the master node server to process and display the packed and returned data;
further, in step S3, instructing the slave node server that receives the command packet to perform parsing on the command packet, so as to perform adaptive data interaction with the master node server according to a result of the parsing, specifically includes instructing the slave node server that receives the command packet to perform parsing on the command packet, so as to determine a data processing quality value of each slave node server, and transmitting the data packet of the master node server to the slave node server according to the IP address of the slave node server, so as to implement the data interaction, which is specifically:
in step S301B, the operation state information of each slave node server is acquired, and the data processing quality value Q of the slave node server is determined according to the following formula (1):
in the above formula (1), N represents the total number of slave node servers, and N is greater than or equal to 2, t represents a preset unit time, and is an integer multiple of 1min, μt+1Represents the data bit quantity, mu, accumulatively processed by the slave node server within time t +1tRepresents the amount of data bits, Cul (μ) cumulatively processed from the node server over time tt+1,μt) Representing the difference between the data bit amounts cumulatively processed from the node server at time t +1 and at time t, Bt+1Representing the amount of data bits transmitted cumulatively from the node server during time t +1, BtRepresents the amount of data bits, Tra (B), transmitted cumulatively from the node server over time tt+1,Bt) Represents the difference between the data bit quantity transmitted cumulatively from the node server at time t +1 and at time t, Sim (B)t+1,Bt) The sum of data bit quantities which are transmitted from the node server in the time t +1 and the time t in an accumulated mode is represented;
step S302B, selecting the slave node server with the highest data processing quality value Q to perform data interaction with the master node server, and determining the parameter value R returned by the selected slave node server after the selected slave node server receives the data packet from the master node server according to the following formula (2):
in the above formula (2), N represents the total number of slave node servers, and N is greater than or equal to 2, QmaxRepresents the highest value of the data processing quality of each slave node server, x represents the total number of data packets sent by the master node server and is greater than or equal to 2, P0Indicating the communication distance, P, of the selected slave node server from the master node servern-1Indicating otherwise than said selected slave node serverMaximum value of communication distances between other slave node servers and the master node server, D1Indicating the amount of data bits of the first data packet sent by the primary node server, Dx-1Indicating the amount of data bits, Sim (P), of the x-1 th packet sent by the master node server0,Pn-1) Represents P0And Pn-1The difference between them;
step S303B, determining whether the parameter value R is less than 1, if so, determining that the selected slave node server completely processes the data packet from the master node server, otherwise, determining that the selected slave node server does not completely process the data packet from the master node server.
The invention also provides a monitoring system for the multi-node edge computing equipment, which is characterized by comprising a main control unit and a plurality of servers; wherein,
the main control unit is used for acquiring data processing state information corresponding to the plurality of servers and distinguishing and determining the plurality of servers into a main node server and a plurality of slave node servers according to the data processing state information;
the master control unit is further configured to identify target address information of a command from the master node server, and compare the target address information with address information of the slave node server itself, thereby determining whether to indicate the slave node server to receive the command packet;
the master control unit is further used for indicating the slave node server receiving the command to analyze the command packet, so that adaptive data interaction operation is performed with the master node server according to the result of the analysis;
further, the main control unit obtains data processing state information corresponding to the plurality of servers, and according to the data processing state information, the plurality of servers are distinguished and determined to be a master node server and a plurality of slave node servers specifically comprising
Acquiring data calculation speed, data transmission speed and data transmission distortion degree corresponding to each of the plurality of servers, and taking the data calculation speed, the data transmission speed and the data transmission distortion degree as the data processing state information;
determining a data processing quality value corresponding to each server according to the data calculation speed, the data transmission speed and the data transmission distortion;
determining the server with the maximum data processing quality value as a master node server and determining the rest servers as slave node servers according to the data processing quality value;
further, the identifying, by the master control unit, target address information of a command from the master node server, and comparing the target address information with address information of the slave node server itself, so as to determine whether to indicate that the slave node server receives the command packet specifically includes:
identifying and obtaining target address information corresponding to a target server to which the command packet needs to be sent from the command from the master node server, and simultaneously obtaining MAC address information or IP address information of all slave node servers;
comparing the target address information with MAC address information or IP address information of all slave node servers, thereby indicating that the slave node servers with the MAC address information or the IP address information consistent with the target address information keep the received command packets and indicating other slave node servers to discard the received command packets;
further, the instructing, by the master control unit, the slave node server that receives the command to perform parsing on the command packet, so that performing adaptive data interaction with the master node server according to a result of the parsing specifically includes:
instructing a slave node server receiving and reserving the command packet to perform decompression processing and command type identification processing on the command packet, so as to determine whether an instruction contained in the command packet belongs to a control instruction or a query instruction;
if the command included in the command packet is determined to belong to a control command, after the slave node server successfully executes the control command, returning a message of successful execution of the command to the master node server;
and if the command packet is determined to belong to the query command, packing and returning the data obtained by query to the master node server after the slave node server successfully executes the query command, and indicating the master node server to process and display the packed and returned data.
Compared with the prior art, the monitoring method and the monitoring system for the multi-node edge computing device have the advantages that the data processing state information corresponding to the plurality of servers is obtained, the plurality of servers are distinguished and determined to be the master node server and the plurality of slave node servers according to the data processing state information, the target address information of the command from the master node server is identified, the target address information is compared with the address information of the slave node servers, whether the slave node servers are indicated to receive the command packet is determined, the slave node servers receiving the command are indicated to analyze the command packet, and accordingly adaptive data interaction operation is conducted with the master node server according to the analysis result; it can be seen that the monitoring method and system for multi-node edge computing device selects one server satisfying specific data processing capacity condition from several servers as a main node server and the rest servers as slave node servers, the slave node server receives and retains the command packet from the master node server adaptively according to the address information of the slave node server, and then performs data interaction operation between the slave node server and the master node server according to the analysis processing result of the command packet to complete the corresponding data calculation task, it makes corresponding command instruction to slave node server by determining master node server, and uses address information as command receiving and retaining basis, therefore, the transmission efficiency and the transmission accuracy of the command packet are greatly improved, the reliability of the multi-task processing is furthest improved, and the condition of task processing conflict is avoided.
Additional features and advantages of the invention will be set forth in the description which follows, and in part will be obvious from the description, or may be learned by practice of the invention. The objectives and other advantages of the invention will be realized and attained by the structure particularly pointed out in the written description and claims hereof as well as the appended drawings.
The technical solution of the present invention is further described in detail by the accompanying drawings and embodiments.
Drawings
In order to more clearly illustrate the embodiments of the present invention or the technical solutions in the prior art, the drawings used in the description of the embodiments or the prior art will be briefly described below, it is obvious that the drawings in the following description are only some embodiments of the present invention, and for those skilled in the art, other drawings can be obtained according to the drawings without creative efforts.
FIG. 1 is a flow chart illustrating a monitoring method for a multi-node edge computing device according to the present invention.
FIG. 2 is a schematic structural diagram of a monitoring system for a multi-node edge computing device according to the present invention.
Detailed Description
The technical solutions in the embodiments of the present invention will be clearly and completely described below with reference to the drawings in the embodiments of the present invention, and it is obvious that the described embodiments are only a part of the embodiments of the present invention, and not all of the embodiments. All other embodiments, which can be derived by a person skilled in the art from the embodiments given herein without making any creative effort, shall fall within the protection scope of the present invention.
Fig. 1 is a schematic flowchart of a monitoring method for a multi-node edge computing device according to an embodiment of the present invention. The monitoring method for the multi-node edge computing equipment comprises the following steps:
step S1, acquiring data processing status information corresponding to a plurality of servers, and determining the servers as a master node server and a plurality of slave node servers according to the data processing status information;
step S2, recognizing the target address information of the command from the master node server, and comparing the target address information with the address information of the slave node server itself, thereby determining whether to indicate the slave node server to receive the command packet;
and step S3, instructing the slave node server receiving the command to perform parsing processing on the command packet, so as to perform adaptive data interaction operation with the master node server according to the result of the parsing processing.
The beneficial effects of the above technical scheme are that: the monitoring method for the multi-node edge computing equipment selects one server meeting a specific data processing capacity condition from a plurality of servers as a main node server and the rest servers as slave node servers, the slave node server receives and retains the command packet from the master node server adaptively according to the address information of the slave node server, and then performs data interaction operation between the slave node server and the master node server according to the analysis processing result of the command packet to complete the corresponding data calculation task, it makes corresponding command instruction to slave node server by determining master node server, and uses address information as command receiving and retaining basis, therefore, the transmission efficiency and the transmission accuracy of the command packet are greatly improved, the reliability of the multi-task processing is furthest improved, and the condition of task processing conflict is avoided.
Preferably, in step S1, the acquiring data processing status information corresponding to a plurality of servers, and determining a plurality of servers as a master node server and a plurality of slave node servers according to the data processing status information specifically includes:
step S101, acquiring data calculation speed, data transmission speed and data transmission distortion degree corresponding to a plurality of servers, and using the data calculation speed, the data transmission speed and the data transmission distortion degree as data processing state information;
step S102, determining a data processing quality value corresponding to each server according to the data calculation speed, the data transmission speed and the data transmission distortion;
in step S103, according to the magnitude of the data processing quality value, the server having the largest data processing quality value is determined as the master node server, and the remaining servers are determined as slave node servers.
The beneficial effects of the above technical scheme are that: because the data processing states of different servers are different, the data processing quality value corresponding to each server is determined according to the data calculation speed, the data transmission speed and the data transmission distortion, and the server with the optimal data processing performance can be selected from all the servers as the main node server, so that the data processing efficiency of the multi-node edge computing device is improved.
Preferably, in the step S2, identifying the target address information of the command packet from the master node server, and comparing the target address information with the address information of the slave node server itself, so as to determine whether to indicate that the slave node server receives the command packet specifically includes:
step S201, identifying and obtaining target address information corresponding to a target server to which the command packet needs to be sent from the command from the master node server, and simultaneously obtaining MAC address information or IP address information of all slave node servers;
step S202, comparing the destination address information with the MAC address information or IP address information of all the slave node servers, so as to instruct the slave node servers where the MAC address information or the IP address information is consistent with the destination address information to retain the received command packet, and instruct other slave node servers to discard the received command packet.
The beneficial effects of the above technical scheme are that: the slave node service parent is subjected to address matching through MAC address information or IP address information of the slave node server, so that the command packet can be received and reserved by the unique slave node server, and the condition that the command packet is received by mistake is avoided.
Preferably, in step S3, instructing the slave node server that receives the command packet to perform parsing processing on the command packet, so that performing adaptive data interaction with the master node server according to the result of the parsing processing specifically includes:
step S301, instruct the slave node server which receives and retains the command packet to decompress the command packet and identify the command type, so as to determine whether the command included in the command packet belongs to the control command or the query command;
step S302, if the command included in the command packet is determined to belong to a control command, after the slave node server successfully executes the control command, returning a message of successful command execution to the master node server;
step S303, if it is determined that the instruction included in the command packet belongs to the query instruction, after the slave node server successfully executes the query instruction, the slave node server packages and returns the queried data to the master node server, and instructs the master node server to process and display the packaged and returned data.
The beneficial effects of the above technical scheme are that: by distinguishing and identifying the control instruction and the query instruction for the command packet, the slave node server can pertinently process the command packet, so that the slave node server can effectively process the command packet.
Preferably, in step S3, instructing the slave node server that received the command packet to perform parsing on the command packet, so that according to the result of the parsing, performing adaptive data interaction with the master node server specifically includes instructing the slave node server that received the command packet to perform parsing on the command packet, so as to determine a data processing quality value of each slave node server, and transmitting the data packet of the master node server to the slave node server according to the IP address of the slave node server, so as to implement the data interaction, which is specifically:
in step S301B, the operation state information of each slave node server is acquired, and the data processing quality value Q of the slave node server is determined according to the following formula (1):
in the above formula (1), N represents the total number of slave node servers, and N is greater than or equal to 2, t represents a preset unit time, and is an integer multiple of 1min, μt+1Represents the data bit quantity, mu, accumulatively processed by the slave node server within time t +1tRepresents the amount of data bits, Cul (μ) cumulatively processed from the node server over time tt+1,μt) Representing the difference between the data bit amounts cumulatively processed from the node server at time t +1 and at time t, Bt+1Representing the amount of data bits transmitted cumulatively from the node server during time t +1, BtRepresents the amount of data bits, Tra (B), transmitted cumulatively from the node server over time tt+1,Bt) Represents the difference between the data bit quantity transmitted cumulatively from the node server at time t +1 and at time t, Sim (B)t+1,Bt) The sum of data bit quantities which are transmitted from the node server in the time t +1 and the time t in an accumulated mode is represented;
step S302B, selecting the slave node server with the highest data processing quality value Q to perform data interaction with the master node server, and determining the parameter value R returned by the selected slave node server after the selected slave node server receives the data packet from the master node server according to the following formula (2):
in the above formula (2), N represents the total number of slave node servers, and N is greater than or equal to 2, QmaxRepresents the highest value of the data processing quality of each slave node server, x represents the total number of data packets sent by the master node server and is greater than or equal to 2, P0Indicating the communication distance, P, of the selected slave node server from the master node servern-1A maximum value representing a communication distance between the slave node servers other than the selected slave node server and the master node server, D1Indicating the amount of data bits of the first data packet sent by the master node server, Dx-1Indicating the master node serviceData bit quantity of x-1 data packet sent by the device, Sim (P)0,Pn-1) Represents P0And Pn-1The difference between them;
step S303B, determining whether the parameter value R is less than 1, if so, determining that the selected slave node server completely processes the data packet from the master node server, otherwise, determining that the selected slave node server does not completely process the data packet from the master node server.
The beneficial effects of the above technical scheme are that: the process can utilize the current optimal server to process data to the maximum extent, thereby greatly improving the transmission efficiency and transmission accuracy of the command packet and improving the reliability of multi-task processing to the maximum extent.
Fig. 2 is a schematic structural diagram of a monitoring system for a multi-node edge computing device according to an embodiment of the present invention. The monitoring system for the multi-node edge computing equipment comprises a main control unit and a plurality of servers; wherein,
the main control unit is used for acquiring data processing state information corresponding to a plurality of servers and distinguishing and determining the servers into a main node server and a plurality of slave node servers according to the data processing state information;
the master control unit is also used for identifying target address information of the command from the master node server and comparing the target address information with the address information of the slave node server, so as to determine whether the slave node server is indicated to receive the command packet;
the master control unit is also used for indicating the slave node server receiving the command to analyze the command packet, so as to perform adaptive data interaction operation with the master node server according to the result of the analysis processing.
The beneficial effects of the above technical scheme are that: the monitoring system for a multi-node edge computing device selects one of a plurality of servers that satisfies a specific data processing capability condition as a master node server and the remaining servers as slave node servers, the slave node server receives and retains the command packet from the master node server adaptively according to the address information of the slave node server, and then performs data interaction operation between the slave node server and the master node server according to the analysis processing result of the command packet to complete the corresponding data calculation task, it makes corresponding command instruction to slave node server by determining master node server, and uses address information as command receiving and retaining basis, therefore, the transmission efficiency and the transmission accuracy of the command packet are greatly improved, the reliability of the multi-task processing is furthest improved, and the condition of task processing conflict is avoided.
Preferably, the main control unit obtains data processing status information corresponding to the plurality of servers, and determines the plurality of servers as a master node server and a plurality of slave node servers according to the data processing status information by distinguishing the plurality of servers, wherein the master node server and the plurality of slave node servers specifically include
Acquiring data calculation speed, data transmission speed and data transmission distortion degree corresponding to each of the servers, and taking the data calculation speed, the data transmission speed and the data transmission distortion degree as the data processing state information;
determining a data processing quality value corresponding to each server according to the data calculation speed, the data transmission speed and the data transmission distortion;
and determining the server with the maximum data processing quality value as the master node server and the rest servers as slave node servers according to the size of the data processing quality value.
The beneficial effects of the above technical scheme are that: because the data processing states of different servers are different, the data processing quality value corresponding to each server is determined according to the data calculation speed, the data transmission speed and the data transmission distortion, and the server with the optimal data processing performance can be selected from all the servers as the main node server, so that the data processing efficiency of the multi-node edge computing device is improved.
Preferably, the identifying, by the master control unit, target address information of the command from the master node server, and comparing the target address information with address information of the slave node server itself, so as to determine whether to indicate that the slave node server receives the command packet specifically includes:
identifying and obtaining target address information corresponding to a target server to which the command packet needs to be sent from the command from the master node server, and simultaneously obtaining MAC address information or IP address information of all slave node servers;
and comparing the target address information with the MAC address information or the IP address information of all the slave node servers, thereby indicating that the slave node servers with the MAC address information or the IP address information consistent with the target address information keep the received command packet and indicating other slave node servers to discard the received command packet.
The beneficial effects of the above technical scheme are that: the slave node service parent is subjected to address matching through MAC address information or IP address information of the slave node server, so that the command packet can be received and reserved by the unique slave node server, and the condition that the command packet is received by mistake is avoided.
Preferably, the instructing, by the master control unit, the slave node server that receives the command to perform parsing on the command packet, so that performing adaptive data interaction with the master node server according to a result of the parsing specifically includes:
instructing the slave node server which receives and retains the command packet to perform decompression processing and command type identification processing on the command packet, thereby determining whether the command packet contains an instruction belonging to a control instruction or a query instruction;
if the command contained in the command packet is determined to belong to the control command, after the slave node server successfully executes the control command, returning a message of successful execution of the command to the master node server;
if the command packet is determined to belong to the query command, after the slave node server successfully executes the query command, the slave node server packs and returns the data obtained by query to the master node server, and instructs the master node server to process and display the packed and returned data.
The beneficial effects of the above technical scheme are that: by distinguishing and identifying the control instruction and the query instruction for the command packet, the slave node server can pertinently process the command packet, so that the slave node server can effectively process the command packet.
As can be seen from the content of the foregoing embodiment, by obtaining data processing state information corresponding to a plurality of servers, and according to the data processing state information, determining the plurality of servers as a master node server and a plurality of slave node servers in a differentiated manner, identifying target address information of a command from the master node server, and comparing the target address information with address information of the slave node server itself, it is determined whether to instruct the slave node server to receive the command packet, and then instruct the slave node server that receives the command to perform parsing on the command packet, so as to perform adaptive data interaction operation with the master node server according to a result of the parsing; it can be seen that the monitoring method and system for multi-node edge computing device selects one server satisfying specific data processing capacity condition from several servers as a main node server and the rest servers as slave node servers, the slave node server receives and retains the command packet from the master node server adaptively according to the address information of the slave node server, and then performs data interaction operation between the slave node server and the master node server according to the analysis processing result of the command packet to complete the corresponding data calculation task, it makes corresponding command instruction to slave node server by determining master node server, and uses address information as command receiving and retaining basis, therefore, the transmission efficiency and the transmission accuracy of the command packet are greatly improved, the reliability of the multi-task processing is furthest improved, and the condition of task processing conflict is avoided.
It will be apparent to those skilled in the art that various changes and modifications may be made in the present invention without departing from the spirit and scope of the invention. Thus, if such modifications and variations of the present invention fall within the scope of the claims of the present invention and their equivalents, the present invention is also intended to include such modifications and variations.
Claims (4)
1. A monitoring method for a multi-node edge computing device, comprising the steps of:
step S1, acquiring data processing state information corresponding to a plurality of servers, and determining the plurality of servers as a master node server and a plurality of slave node servers according to the data processing state information;
step S2, recognizing target address information of the command from the master node server, and comparing the target address information with address information of the slave node server itself, thereby determining whether to instruct the slave node server to receive the command packet;
step S3, instructing the slave node server that received the command to perform parsing on the command packet, so as to perform adaptive data interaction operation with the master node server according to the result of the parsing;
in step S1, the acquiring data processing state information corresponding to a plurality of servers, and determining the plurality of servers as a master node server and a plurality of slave node servers according to the data processing state information specifically includes:
step S101, acquiring data calculation speed, data transmission speed and data transmission distortion degree corresponding to each of a plurality of servers, and taking the data calculation speed, the data transmission speed and the data transmission distortion degree as the data processing state information;
step S102, determining a data processing quality value corresponding to each server according to the data calculation speed, the data transmission speed and the data transmission distortion;
step S103, according to the magnitude of the data processing quality value, determining the server with the maximum data processing quality value as a master node server, and determining the rest servers as slave node servers;
wherein, in the step S2, identifying the target address information of the command packet from the master node server, and comparing the target address information with the address information of the slave node server itself, so as to determine whether to indicate that the slave node server receives the command packet specifically includes:
step S201, identifying and obtaining target address information corresponding to a target server to which the command packet needs to be sent from the command from the master node server, and simultaneously obtaining MAC address information or IP address information of all slave node servers;
step S202, comparing the target address information with MAC address information or IP address information of all slave node servers, thereby indicating that the slave node servers with the MAC address information or the IP address information consistent with the target address information keep the received command packets, and indicating other slave node servers to discard the received command packets; in step S3, instructing the slave node server that received the command packet to perform parsing on the command packet, so as to perform adaptive data interaction with the master node server according to a result of the parsing, specifically includes instructing the slave node server that received the command packet to perform parsing on the command packet, so as to determine a data processing quality value of each slave node server, and transmitting the data packet of the master node server to the slave node server according to an IP address of the slave node server, so as to implement the data interaction, which is specifically:
in step S301B, the operation state information of each slave node server is acquired, and the data processing quality value Q of the slave node server is determined according to the following formula (1):
in the above formula (1), N represents the total number of slave node servers, and N is greater than or equal to 2, t represents a preset unit time, and is an integer multiple of 1min, μt+1Represents the data bit quantity, mu, accumulatively processed by the slave node server within time t +1tRepresents the amount of data bits, Cul (μ) cumulatively processed from the node server over time tt+1,μt) Representing the difference between the data bit amounts cumulatively processed from the node server at time t +1 and at time t, Bt+1Representing the amount of data bits transmitted cumulatively from the node server during time t +1, BtRepresents the amount of data bits, Tra (B), transmitted cumulatively from the node server over time tt+1,Bt) Represents the difference between the data bit quantity transmitted cumulatively from the node server at time t +1 and at time t, Sim (B)t+1,Bt) The sum of data bit quantities which are transmitted from the node server in the time t +1 and the time t in an accumulated mode is represented;
step S302B, selecting the slave node server with the highest data processing quality value Q to perform data interaction with the master node server, and determining the parameter value R returned by the selected slave node server after the selected slave node server receives the data packet from the master node server according to the following formula (2):
in the above formula (2), N represents the total number of slave node servers, and N is greater than or equal to 2, QmaxRepresents the highest value of the data processing quality of each slave node server, x represents the total number of data packets sent by the master node server and is greater than or equal to 2, P0Indicating the communication distance, P, of the selected slave node server from the master node servern-1A maximum value representing a communication distance between the other slave node servers except the selected slave node server and the master node server, D1Indicating the amount of data bits of the first data packet sent by the primary node server, Dx-1Indicating the amount of data bits, Sim (P), of the x-1 th packet sent by the master node server0,Pn-1) Represents P0And Pn-1The difference between them;
step S303B, determining whether the parameter value R is less than 1, if so, determining that the selected slave node server completely processes the data packet from the master node server, otherwise, determining that the selected slave node server does not completely process the data packet from the master node server.
2. A monitoring method for a multi-node edge computing device as recited in claim 1, wherein: in step S3, instructing the slave node server that receives the command packet to perform parsing on the command packet, so that performing adaptive data interaction with the master node server according to a result of the parsing specifically includes:
step S301A, instruct the slave node server which receives and retains the command packet to decompress the command packet and identify the command type, so as to determine whether the command packet contains instructions belonging to the control instruction or the query instruction;
step S302A, if it is determined that the instruction included in the command packet belongs to a control instruction, returning a message of successful instruction execution to the master node server after the slave node server successfully executes the control instruction;
step S303A, if it is determined that the instruction included in the command packet belongs to the query instruction, after the slave node server successfully executes the query instruction, packing and returning the data obtained by the query to the master node server, and instructing the master node server to process and display the packed and returned data.
3. A monitoring system for a multi-node edge computing device, comprising a master control unit and a plurality of servers; wherein,
the main control unit is used for acquiring data processing state information corresponding to the plurality of servers and distinguishing and determining the plurality of servers into a main node server and a plurality of slave node servers according to the data processing state information;
the master control unit is further configured to identify target address information of a command from the master node server, and compare the target address information with address information of the slave node server itself, thereby determining whether to indicate the slave node server to receive the command packet;
the master control unit is further used for indicating the slave node server receiving the command to analyze the command packet, so that adaptive data interaction operation is performed with the master node server according to the result of the analysis;
the main control unit obtains data processing state information corresponding to the servers, and distinguishes and determines the servers to be a main node server and a plurality of slave node servers according to the data processing state information
Acquiring data calculation speed, data transmission speed and data transmission distortion degree corresponding to each of the plurality of servers, and taking the data calculation speed, the data transmission speed and the data transmission distortion degree as the data processing state information;
determining a data processing quality value corresponding to each server according to the data calculation speed, the data transmission speed and the data transmission distortion;
determining the server with the maximum data processing quality value as a master node server and determining the rest servers as slave node servers according to the data processing quality value;
wherein the identifying, by the master control unit, target address information of a command from the master node server, and comparing the target address information with address information of the slave node server itself, so as to determine whether to indicate that the slave node server receives the command packet specifically includes:
identifying and obtaining target address information corresponding to a target server to which the command packet needs to be sent from the command from the master node server, and simultaneously obtaining MAC address information or IP address information of all slave node servers;
comparing the target address information with MAC address information or IP address information of all slave node servers, thereby indicating that the slave node servers with the MAC address information or the IP address information consistent with the target address information keep the received command packets and indicating other slave node servers to discard the received command packets;
the instructing the slave node server that receives the command packet to perform parsing on the command packet, so as to perform adaptive data interaction with the master node server according to a result of the parsing, specifically includes instructing the slave node server that receives the command packet to perform parsing on the command packet, so as to determine a data processing quality value of each slave node server, and transmitting the data packet of the master node server to the slave node server according to an IP address of the slave node server, so as to implement the data interaction, and specifically includes:
in step S301B, the operation state information of each slave node server is acquired, and the data processing quality value Q of the slave node server is determined according to the following formula (1):
in the above formula (1), N represents the total number of slave node servers, and N is greater than or equal to 2, t represents a preset unit time, and is an integer multiple of 1min, μt+1Represents the data bit quantity, mu, accumulatively processed by the slave node server within time t +1tRepresents the amount of data bits, Cul (μ) cumulatively processed from the node server over time tt+1,μt) Representing the difference between the data bit amounts cumulatively processed from the node server at time t +1 and at time t, Bt+1Representing the amount of data bits transmitted cumulatively from the node server during time t +1, BtRepresents the amount of data bits, Tra (B), transmitted cumulatively from the node server over time tt+1,Bt) Represents the difference between the data bit quantity transmitted cumulatively from the node server at time t +1 and at time t, Sim (B)t+1,Bt) The sum of data bit quantities which are transmitted from the node server in the time t +1 and the time t in an accumulated mode is represented;
step S302B, selecting the slave node server with the highest data processing quality value Q to perform data interaction with the master node server, and determining the parameter value R returned by the selected slave node server after the selected slave node server receives the data packet from the master node server according to the following formula (2):
in the above formula (2), N represents the total number of slave node servers, and N is greater than or equal to 2, QmaxRepresents the highest value of the data processing quality of each slave node server, x represents the total number of data packets sent by the master node server and is greater than or equal to 2, P0Indicating the communication distance, P, of the selected slave node server from the master node servern-1A maximum value representing a communication distance between the other slave node servers except the selected slave node server and the master node server, D1Indicating the amount of data bits of the first data packet sent by the primary node server, Dx-1Indicating the amount of data bits, Sim (P), of the x-1 th packet sent by the master node server0,Pn-1) Represents P0And Pn-1The difference between them;
step S303B, determining whether the parameter value R is less than 1, if so, determining that the selected slave node server completely processes the data packet from the master node server, otherwise, determining that the selected slave node server does not completely process the data packet from the master node server.
4. The monitoring system for a multi-node edge computing device of claim 3, wherein: the main control unit instructs the slave node server receiving the command to analyze the command packet, so that performing adaptive data interaction with the master node server according to the result of the analysis specifically includes:
instructing a slave node server receiving and reserving the command packet to perform decompression processing and command type identification processing on the command packet, so as to determine whether an instruction contained in the command packet belongs to a control instruction or a query instruction;
if the command included in the command packet is determined to belong to a control command, after the slave node server successfully executes the control command, returning a message of successful execution of the command to the master node server; and if the command packet is determined to belong to the query command, packing and returning the data obtained by query to the master node server after the slave node server successfully executes the query command, and indicating the master node server to process and display the packed and returned data.
Priority Applications (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011319531.9A CN112596893B (en) | 2020-11-23 | 2020-11-23 | Monitoring method and system for multi-node edge computing device |
Applications Claiming Priority (1)
| Application Number | Priority Date | Filing Date | Title |
|---|---|---|---|
| CN202011319531.9A CN112596893B (en) | 2020-11-23 | 2020-11-23 | Monitoring method and system for multi-node edge computing device |
Publications (2)
| Publication Number | Publication Date |
|---|---|
| CN112596893A CN112596893A (en) | 2021-04-02 |
| CN112596893B true CN112596893B (en) | 2021-10-08 |
Family
ID=75184191
Family Applications (1)
| Application Number | Title | Priority Date | Filing Date |
|---|---|---|---|
| CN202011319531.9A Active CN112596893B (en) | 2020-11-23 | 2020-11-23 | Monitoring method and system for multi-node edge computing device |
Country Status (1)
| Country | Link |
|---|---|
| CN (1) | CN112596893B (en) |
Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102591917A (en) * | 2011-12-16 | 2012-07-18 | 华为技术有限公司 | Data processing method and system and related device |
| CN102957568A (en) * | 2012-11-21 | 2013-03-06 | 浪潮电子信息产业股份有限公司 | Monitoring management method of multi-node server |
| CN106331098A (en) * | 2016-08-23 | 2017-01-11 | 东方网力科技股份有限公司 | Server cluster system |
| US9760114B1 (en) * | 2014-01-03 | 2017-09-12 | Juniper Networks, Inc. | Systems and methods for improving clock synchronization between master and slave devices |
| CN108769118A (en) * | 2018-04-23 | 2018-11-06 | 网宿科技股份有限公司 | The choosing method and device of host node in a kind of distributed system |
| CN111221632A (en) * | 2019-10-15 | 2020-06-02 | 中国平安财产保险股份有限公司 | Distributed parallel task scheduling method and device, computer equipment and storage medium |
-
2020
- 2020-11-23 CN CN202011319531.9A patent/CN112596893B/en active Active
Patent Citations (6)
| Publication number | Priority date | Publication date | Assignee | Title |
|---|---|---|---|---|
| CN102591917A (en) * | 2011-12-16 | 2012-07-18 | 华为技术有限公司 | Data processing method and system and related device |
| CN102957568A (en) * | 2012-11-21 | 2013-03-06 | 浪潮电子信息产业股份有限公司 | Monitoring management method of multi-node server |
| US9760114B1 (en) * | 2014-01-03 | 2017-09-12 | Juniper Networks, Inc. | Systems and methods for improving clock synchronization between master and slave devices |
| CN106331098A (en) * | 2016-08-23 | 2017-01-11 | 东方网力科技股份有限公司 | Server cluster system |
| CN108769118A (en) * | 2018-04-23 | 2018-11-06 | 网宿科技股份有限公司 | The choosing method and device of host node in a kind of distributed system |
| CN111221632A (en) * | 2019-10-15 | 2020-06-02 | 中国平安财产保险股份有限公司 | Distributed parallel task scheduling method and device, computer equipment and storage medium |
Also Published As
| Publication number | Publication date |
|---|---|
| CN112596893A (en) | 2021-04-02 |
Similar Documents
| Publication | Publication Date | Title |
|---|---|---|
| CN107786440B (en) | Method and device for forwarding data message | |
| CN109729602B (en) | Link data processing method and device and computer storage medium | |
| CN112202623B (en) | Data processing method and device | |
| CN115037700B (en) | Complex network data packet transmission method, system, terminal and storage medium | |
| US20230037783A1 (en) | Resource scheduling method and related apparatus | |
| CN115858160A (en) | Remote direct memory access virtualization resource allocation method and device and storage medium | |
| CN103888364A (en) | Message shunting method and device | |
| CN105721612A (en) | Data transmission method and device | |
| CN103441931B (en) | A kind of file transmitting method and device | |
| CN106209680B (en) | Information processing apparatus and information processing method | |
| CN116233018A (en) | Message processing method and device, electronic equipment and storage medium | |
| CN113259490B (en) | Multi-level node network data transmission method based on UDP transmission protocol | |
| CN112596893B (en) | Monitoring method and system for multi-node edge computing device | |
| CN111294316B (en) | Network isolation method and device based on user mode protocol stack virtual router | |
| US9876805B2 (en) | Apparatus and method for transmitting and receiving messages | |
| KR101794200B1 (en) | Method for transmitting and receiving protocol packet using packet processor based LINUX in distributed packet transport network | |
| US7653070B2 (en) | Method and system for supporting efficient and cache-friendly TCP session lookup operations based on canonicalization tags | |
| CN113765805B (en) | Calling-based communication method, device, storage medium and equipment | |
| CN111240867A (en) | Information communication system and method | |
| CN118509399B (en) | Message processing method and device, electronic equipment and storage medium | |
| CN112737884B (en) | Method for forwarding data and detecting network performance and related device | |
| CN113132233B (en) | Data processing method, software defined network controller and data processing system | |
| CN115118473B (en) | Data processing method, device, equipment and storage medium | |
| US12058774B2 (en) | Data processing method, data processing apparatus, electronic device and computer readable storage medium | |
| CN116801308A (en) | Data processing method, data processing device, electronic equipment and 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 |