CN115348322B

CN115348322B - Data processing method, networking equipment and computer readable storage medium

Info

Publication number: CN115348322B
Application number: CN202210812240.6A
Authority: CN
Inventors: 王祥红
Original assignee: Shenzhen Jiuzhou Electric Appliance Co Ltd
Current assignee: Shenzhen Jiuzhou Electric Appliance Co Ltd
Priority date: 2022-07-11
Filing date: 2022-07-11
Publication date: 2023-07-18
Anticipated expiration: 2042-07-11
Also published as: CN115348322A

Abstract

The invention discloses a data processing method, networking equipment and a computer readable storage medium, wherein the data processing method is applied to a main equipment in each networking equipment of a networking system, and the data processing method comprises the following steps: when a scheduling request sent by equipment to be scheduled is received, determining first target equipment from all networking equipment; and sending the equipment information of the first target equipment to the equipment to be scheduled, so that the equipment to be scheduled can send the received first service data to the first target equipment according to the equipment information, and after the first target equipment processes the first service data to obtain a first processing result, the first processing result is sent to the equipment to be scheduled. The invention realizes the balanced consumption of the computational power resources of each networking device of the networking system, thereby improving the stability of the networking system.

Description

Data processing method, networking equipment and computer readable storage medium

Technical Field

The present invention relates to the field of data processing control technologies, and in particular, to a data processing method, a networking device, and a computer readable storage medium.

Background

With the development of technology, network construction technology capable of meeting various complex environments and project requirements is widely used. In a networking system processing the same service type, the service data volume processed by each networking device is different, so that the computing power resource consumption of each device in the networking system is different. The amount of service data received by partial packet network equipment in the networking system is small, and the networking equipment consumes less computational power resources; and a part of networking equipment receives a large amount of service data, so that the computing power resources of the networking equipment are consumed in a large amount, the networking equipment may overload the processing data, the computing power resources may be exhausted, and the networking system is unstable.

The foregoing is provided merely for the purpose of facilitating understanding of the technical solutions of the present invention and is not intended to represent an admission that the foregoing is prior art.

Disclosure of Invention

The invention mainly aims to provide a data processing method, networking equipment and a computer readable storage medium, and aims to solve the technical problem of unbalanced consumption of computing power resources of all networking equipment in a networking system.

In order to achieve the above object, the present invention provides a data processing method applied to a master device in each networking device of a networking system, the data processing method comprising the steps of:

When a scheduling request sent by equipment to be scheduled is received, determining first target equipment from each networking equipment, wherein the occupied resource value of the first target equipment is smaller than a preset first threshold value or is the minimum value in the occupied resource values of the networking equipment in the networking system, and the equipment to be scheduled is slave equipment with the occupied resource value of the networking equipment in the networking system larger than a preset second threshold value;

and sending the equipment information of the first target equipment to the equipment to be scheduled, so that the equipment to be scheduled sends the received first service data to the first target equipment according to the equipment information, so that the first target equipment processes the first service data to obtain a first processing result, and then sends the first processing result to the equipment to be scheduled.

Optionally, the data processing method further includes:

when the occupied resource value of the main equipment is determined to be larger than the second threshold value, determining a second target equipment from the networking equipment, wherein the occupied resource value of the second target equipment is smaller than the first threshold value or is the minimum value in the occupied resource values of the networking equipment in the networking system;

And sending the received second service data to the second target device so that the second target device can process the second service data to obtain a second processing result and then send the second processing result to the main device.

Optionally, before the step of determining the second target device from each networking device, the method further includes:

detecting whether the occupied resource value of the master device is larger than the second threshold value;

when the occupied resource value of the main equipment is not larger than the second threshold value, processing the second service data;

and when the occupied resource value of the master device is determined to be larger than the second threshold value, executing the step of determining a second target device from the networking devices.

Optionally, before the step of determining the first target device from each networking device, the method further includes:

calculating the occupied resource value of the master equipment and acquiring the occupied resource value of the slave equipment;

after the step of determining the first target device from each networking device, the method further comprises:

and adjusting the occupied resource value of the first target device to be the maximum value of the occupied resource values of the networking devices in the networking system.

Optionally, the step of calculating the occupied resource value of the master device includes:

acquiring average time delay, packet loss rate, signal strength value of the main equipment and a first preset weight group corresponding to the service type of the networking system;

the average time delay, the packet loss rate and the signal strength value are weighted and summed by using each first weight value contained in the first weight value group to obtain a communication link quality value of the main equipment;

acquiring a memory utilization rate, an input/output resource utilization rate and a processor resource utilization rate of the main equipment, and a second weight group corresponding to the service type;

and carrying out weighted summation processing on the memory utilization rate, the input and output resource utilization rate, the processor resource utilization rate and the communication link quality value by using each second weight value contained in the second weight value group to obtain the occupied resource value of the main equipment.

In order to achieve the above object, the present invention further provides a data processing method, which is applied to any target slave device in each networking device of a networking system, the data processing method including the steps of:

when the occupied resource value of the target slave device is determined to be larger than a preset first threshold value, sending a scheduling request to a master device in each networking device, so that after the master device receives the scheduling request, determining a target device from each networking device, and sending device information of the target device to the target slave device, wherein the occupied resource value of the target device is smaller than a preset second threshold value or is the minimum value in the occupied resource values of the networking devices in the networking system;

When the equipment information is received, the received business data to be processed is sent to the target equipment according to the equipment information, so that the target equipment processes the business data to be processed to obtain a business processing result, and then the business processing result is sent to the target slave equipment.

Optionally, before the step of sending the scheduling request to the master device in each networking device, the method further includes:

detecting whether the occupied resource value of the target slave device is larger than the first threshold value;

when the occupied resource value of the target slave device is not larger than the first threshold value, processing the received service data to be processed;

and when the occupied resource value of the target slave device is determined to be larger than the first threshold value, executing the step of sending the scheduling request to the master device in each networking device.

calculating the occupied resource value of the target slave device;

and sending the occupied resource value of the target slave device to the master device.

To achieve the above object, the present invention also provides a data processing apparatus including:

A determining module 10, configured to determine, when a scheduling request sent by a device to be scheduled is received, a first target device from each networking device, where an occupied resource value of the first target device is smaller than a preset first threshold or is a minimum value in occupied resource values of the networking devices in the networking system, and the device to be scheduled is a slave device in which the occupied resource value of the networking devices in the networking system is greater than a preset second threshold;

and the sending module 20 is configured to send the device information of the first target device to the device to be scheduled, so that the device to be scheduled sends the received first service data to the first target device according to the device information, so that the first target device processes the first service data to obtain a first processing result, and then sends the first processing result to the device to be scheduled.

In order to achieve the above object, the present invention further provides a networking device, including: the system comprises a memory, a processor and a data processing program stored on the memory and capable of running on the processor, wherein the data processing program realizes the steps of the data processing method when being executed by the processor.

In addition, to achieve the above object, the present invention also proposes a computer-readable storage medium having stored thereon a data processing program which, when executed by a processor, implements the steps of the data processing method as described above.

In the invention, when a main device receives a scheduling request sent by a device to be scheduled, a first target device is determined from each networking device, wherein the occupied resource value of the first target device is smaller than a preset first threshold value or is the minimum value in the occupied resource values of the networking devices in a networking system, the device to be scheduled is a slave device with the occupied resource value of the networking devices in the networking system larger than a preset second threshold value, the main device sends the device information of the first target device to the device to be scheduled, the device to be scheduled sends the received first service data to the first target device according to the device information, and after the first target device processes the first service data to obtain a first processing result, the first processing result is sent to the device to be scheduled. The invention realizes the balanced consumption of the computational power resources of each networking device of the networking system, thereby improving the stability of the networking system.

Drawings

FIG. 1 is a flow chart of a first embodiment of a data processing method according to the present invention;

FIG. 2 is a timing diagram of an embodiment of a data processing method according to the present invention;

FIG. 3 is a timing diagram illustrating an embodiment of a data processing method according to the present invention;

FIG. 4 is a schematic diagram of functional blocks of an embodiment of a data processing apparatus according to the present invention;

fig. 5 is a schematic structural diagram of a networking device of a hardware running environment according to an embodiment of the present invention.

The achievement of the objects, functional features and advantages of the present invention will be further described with reference to the accompanying drawings, in conjunction with the embodiments.

Detailed Description

It should be understood that the specific embodiments described herein are for purposes of illustration only and are not intended to limit the scope of the invention.

An embodiment of the present invention provides a data processing method, and referring to fig. 1, fig. 1 is a schematic flow chart of a first embodiment of a data processing method of the present invention. It should be noted that although a logical order is depicted in the flowchart, in some cases the steps depicted or described may be performed in a different order than presented herein. In this embodiment, the data processing method is applied to a master device in each networking device of the networking system, where the master device may be a device such as a personal computer, a smart phone, a server, and the like, and in this embodiment, the data processing method includes:

Step S10, when a scheduling request sent by equipment to be scheduled is received, determining a first target equipment from each networking equipment, wherein the occupied resource value of the first target equipment is smaller than a preset first threshold value or is the minimum value in the occupied resource values of the networking equipment in the networking system, and the equipment to be scheduled is slave equipment with the occupied resource value of the networking equipment in the networking system larger than a preset second threshold value;

the networking technology, that is, the network construction technology, may construct different devices in the same network, hereinafter, a networking system obtained by networking is referred to as a networking system, and each device of the networking is referred to as a networking device. The networking system may be various systems such as internet of things networking, neural network networking, etc., which are not limited herein. There are various networking modes, for example, WI-FI (WIreless-FIdelity) may be networked through WIreless bridging or easy Mesh (simple Mesh), and bluetooth may be ad hoc through Mesh (Mesh), which is not limited herein.

The networking devices that connect to the various networking devices, and the networking devices that connect to the network or cloud are referred to as the master devices (also referred to as parent devices, gateway devices) of the networking system. The master device may be preconfigured by a technician during the networking process, or may be obtained according to a networking structure or a networking manner during the networking, which is not limited herein. Each networking device connected to the master device in the networking system is referred to as a slave device (may also be referred to as a child device), and it is understood that the master device and the slave device may be devices such as a personal computer, a smart phone, and a server, which are not limited herein.

The amount of service data received by each networking device in the networking system varies, and thus resources consumed by the networking devices for processing service data (hereinafter, referred to as computing resources for convenience of description) also vary. The amount of service data received by the partial networking equipment is small, and the networking equipment consumes less computational resources; and a part of networking equipment receives a large amount of service data, so that the networking equipment consumes more computational resources, the networking equipment can overload to process the service data, and the computational resources of the networking equipment can be exhausted, thereby causing unstable networking system.

In this embodiment, a data processing method is provided, where a master device schedules service data of slave devices, so that each slave device can process the service data, and balance consumption of computing power resources of each slave device, thereby improving stability of a networking system.

Specifically, in this embodiment, the calculation power resource value that each networking device has used is referred to as an occupied resource value. A threshold value of the occupied resource value of the networking device (hereinafter referred to as a first threshold value to show distinction) is preset, and when the occupied resource value of the networking device is smaller than the first threshold value, it is determined that the consumption of the computational power resource of the networking device is less.

A threshold value of an occupied resource value of the networking device (hereinafter referred to as a second threshold value to show distinction) is preset, and when the occupied resource value of the networking device is greater than the second threshold value, it is determined that the computing power resource of the networking device is more consumed.

In a specific embodiment, the first threshold and the second threshold may be determined according to experience of a technician, or may be obtained through testing, which is not limited herein. In a specific embodiment, the values of the first threshold and the second threshold may be the same or different. Further, in an embodiment, in a process of working the networking system, the values of the first threshold and the second threshold may be adjusted according to actual requirements.

When receiving a scheduling request transmitted by a device to be scheduled, the master device determines a networking device (hereinafter referred to as a first target device to show distinction) for scheduling from among the individual networking devices. In a specific embodiment, the first target device may be a networking device with a minimum occupied resource value in the networking system, or may be any networking device with an occupied resource value smaller than a first threshold, which is not limited herein.

Step S20, sending the device information of the first target device to the device to be scheduled, so that the device to be scheduled sends the received first service data to the first target device according to the device information, so that the first target device processes the first service data to obtain a first processing result, and then sends the first processing result to the device to be scheduled.

And after the main equipment determines the first target equipment, the equipment information of the first target equipment is sent to the equipment to be scheduled.

After receiving the device information, the device to be scheduled transmits the received service data (hereinafter referred to as first service data to show distinction) to the first target device according to the device information. After receiving the first service data, the first target device processes the first service data to obtain a processing result (hereinafter referred to as a first processing result to show distinction), and sends the first processing result to the device to be scheduled.

Specifically, in an embodiment, the device to be scheduled may send a scheduling request after receiving the first service data each time, and the master device determines the first target device after receiving the scheduling request, where the device to be scheduled sends the first service data to the first target device, in other words, each time the device to be scheduled receives a set of first service data, the master device determines a first target device correspondingly, and the first target devices corresponding to the first service data received by the device to be scheduled at different moments may be the same or different; in another embodiment, the device to be scheduled may send a scheduling application to the master device after determining that the value of the occupied resource of the device to be scheduled is greater than the second threshold, and the master device determines the first target device after receiving the scheduling request, where the device to be scheduled sends the first service data to the first target device. The setting can be specifically performed according to actual demands, and is not limited herein.

Further, in a specific embodiment, when the device to be scheduled sends a scheduling application to the master device after determining that the value of the occupied resource of the device to be scheduled is greater than the second threshold, the scheduling device may resend the scheduling request to replace the first target device. In this embodiment, the device to be scheduled may send a scheduling request according to a certain period, or may determine whether to send the scheduling request according to the occupied resource value of the first target device after obtaining the occupied resource value of the first target device, so that the master device may determine the first target device again; or the main device may send an instruction to the device to be scheduled according to the condition of the occupied resource value of each networking device, and the scheduling device sends the scheduling request again after receiving the instruction, which is not limited herein.

Further, after receiving the first processing result, the device to be scheduled sends the first processing result to a service data end for sending the first service data.

In this embodiment, when the master device receives a scheduling request sent by a device to be scheduled, a first target device is determined from each networking device, where an occupied resource value of the first target device is smaller than a preset first threshold or is a minimum value in occupied resource values of networking devices in a networking system, the device to be scheduled is a slave device in each networking device of the networking system, the master device sends device information of the first target device to the device to be scheduled, the device to be scheduled sends the received first service data to the first target device according to the device information, and after the first target device processes the first service data to obtain a first processing result, the first processing result is sent to the device to be scheduled. According to the method and the device, the first business data received by the slave equipment with high consumption of the computational resources are sent to the first target equipment with low consumption of the computational resources for processing, so that the computational resources of all networking equipment are consumed in an equalizing mode, the consumption of the computational resources of the networking equipment is avoided, and the stability of a networking system is improved.

Further, based on the above first embodiment, a second embodiment of the data processing method of the present invention is provided, and in this embodiment, before the step S10, the method further includes:

step S30, calculating the occupied resource value of the master device and acquiring the occupied resource value of the slave device;

in this embodiment, the master device obtains the occupied resource value of each networking device, so that the master device determines the first target device.

Specifically, in this embodiment, the master device calculates an occupied resource value of the master device, and obtains the occupied resource value of each slave device.

In a specific embodiment, the occupied resource value of the slave device may be calculated by the slave device, and the master device obtains a calculation result; or after the master device obtains the related data for calculating the occupied resource value of the slave device, the master device calculates the occupied resource value of the slave device.

Specifically, in an embodiment, the master device may actively acquire related data for calculating the occupied resource value or the occupied resource value of the slave device, for example, the master device may query the occupied resource value of the slave device according to a certain period; in another embodiment, the slave device may also calculate the related data of the occupied resource value or the occupied resource value of the slave device, for example, when the slave device receives the first service data, and send the data of calculating the occupied resource value to the master device, which is not limited herein.

Further, after the master device obtains the occupied resource value of each networking device, the occupied resource value of each networking device is recorded, and the specific form of the recording is not limited.

Further, in an embodiment, after the master device obtains the occupied resource values of each networking device, the occupied resource values of the networking devices may be recorded in a queue. Further, in a specific embodiment, the occupied resource values in the queue may be arranged according to a certain order, for example, the occupied resource values of the networking devices may be arranged from small to large.

After step S10, further includes:

and step S40, adjusting the occupied resource value of the first target equipment to be the maximum value of the occupied resource values of the networking equipment in the networking system.

In this embodiment, after the first target device is determined, the occupied resource value of the first target device is adjusted to be the maximum value of the occupied resource values of the networking devices in the networking system based on the occupied resource values of the networking devices recorded by the master device. When the main equipment performs next scheduling, the first target equipment for scheduling is determined according to the adjusted occupied resource values of the networking equipment recorded by the main equipment, so that the condition that the first target equipment is selected for scheduling for multiple times to cause the exhaustion of the computing power resources of the first target equipment is avoided, and the stability of a computing power system is improved.

Further, in an embodiment, the step of calculating the occupied resource value of the master device in step S30 includes:

step S301, obtaining average time delay, packet loss rate, signal intensity value of the main equipment and a first weight group preset corresponding to the service type of the networking system;

in this embodiment, the occupied resource value of the master device may be calculated according to the communication link quality value, the memory utilization, the input/output utilization, and the processor resource utilization of the master device.

And acquiring the average time delay, the packet loss rate and the signal strength value of the main equipment. The average time delay is the average time delay of the equipment accessing the network, and the packet loss rate is the ratio of the number of lost data packets in the data transmission process to the transmitted data. In a specific embodiment, the average delay and the packet loss rate may be obtained by using a certain number of packets from PING (Packet Internet Groper, internet packet explorer), and the signal strength value may be obtained by testing a measurement program configured in the device, and the specific process is not described herein.

A weight set (hereinafter referred to as a first weight set to show distinction) for calculating a communication link quality value preset corresponding to a traffic type of the networking system is acquired. The first weight group includes three weights (hereinafter referred to as first weights for distinguishing), and each first weight corresponds to the average delay, the packet loss rate and the signal strength value of the master device one by one.

In a specific embodiment, each first weight in the first weight group may be adjusted according to an actual requirement. For example, when the networking system is a wired network domain, the weight corresponding to the signal strength value may be set to 0; when the networking system is a wireless network domain, different weights can be set correspondingly according to different service types, which is not limited herein.

Step S302, carrying out weighted summation processing on the average time delay, the packet loss rate and the signal intensity value by using each first weight value contained in the first weight value group to obtain a communication link quality value of the main equipment;

and carrying out weighted summation processing on the average time delay, the packet loss rate and the signal strength value of the main equipment by using each first weight value contained in the first weight value group to obtain the communication link quality value of the main equipment.

It can be appreciated that the main device processes the same first service data, the greater the communication link quality value, the worse the signal quality; the smaller the communication link quality value, the better the signal quality.

Further, in a specific embodiment, since the magnitude difference between the packet loss rate value and the average delay value and the signal strength value is larger, the average delay value may be divided by 1000, and the signal strength value may be divided by 100, and then weighted summation is performed, so that the obtained communication link quality value result is more accurate.

Step S303, obtaining the memory utilization rate, the input/output resource utilization rate, the processor resource utilization rate of the main equipment and a second weight set preset corresponding to the service type;

and acquiring the memory utilization rate, the input/output resource utilization rate and the processor resource utilization rate of the main equipment. Memory utilization is the ratio of the space already used by memory in a device to the total space. Processor resource utilization is the ratio of used processor resources to total processor resources. The input/output resource utilization is the ratio of resources used in the process of writing data and outputting data by the device to the total resources. In a specific embodiment, the memory utilization rate, the input/output resource utilization rate, and the processor resource utilization rate may be obtained through a measurement program configured in the master device, which will not be described herein.

And acquiring a weight group (hereinafter referred to as a second weight group for showing distinction) corresponding to the service type and used for calculating the occupied resource value of the networking equipment, wherein the second weight group comprises four weights (hereinafter referred to as second weight for showing distinction), and the second weights contained in the second weight group are respectively in one-to-one correspondence with the memory utilization rate, the input/output resource utilization rate, the processor resource utilization rate and the communication link quality value.

In a specific embodiment, the second weight sets corresponding to different service types are different, for example, when the networking system is used for processing the storage service, the second weight corresponding to the memory occupancy rate in the second weight set is higher and the second weight corresponding to the quality value of the communication link is lower compared with when the networking system processes other service types. The setting may be specifically performed according to the actually processed service, which is not limited herein. Further, in an embodiment, during the working process of each networking device of the networking system, each second weight included in the second weight group may be adjusted according to the actual requirement.

And step S304, carrying out weighted summation processing on the memory utilization rate, the input/output resource utilization rate, the processor resource utilization rate and the communication link quality value by using each second weight value contained in the second weight value group to obtain the occupied resource value of the main equipment.

Specifically, each second weight value included in the second weight value group is used for carrying out weighted summation processing on the memory utilization rate, the input/output resource utilization rate, the processor resource utilization rate and the communication link quality value to obtain the occupied resource value of the main equipment.

Further, in an embodiment, when the networking system is a wired network, the signal strength indication of the master device has a smaller influence on the transmission rate, and the weight corresponding to the signal strength indication may be adjusted to 0 or calculated without using the signal strength value. The setting can be specifically performed according to actual demands, and is not limited herein.

In this embodiment, the master device obtains the occupied resource value of each networking device, so as to determine the first target device from each networking device. After the first target device is determined, the first device occupation resource value of the first target device is adjusted to be the maximum value in the occupation resource values of all networking devices, so that the first target device cannot be selected for scheduling when the main device performs scheduling next time, and the condition that the computing power resources of the first target device are exhausted due to the fact that the first target device is selected for processing the first service data for many times is avoided, and therefore stability of a computing power system is improved.

Further, based on the first embodiment, a third embodiment of the data processing method of the present invention is provided, where in the present embodiment, the data processing method further includes:

step S50, when the occupied resource value of the main equipment is determined to be larger than the second threshold value, determining a second target equipment from the networking equipment, wherein the occupied resource value of the second target equipment is the first threshold value or the minimum value in the occupied resource values of the networking equipment in the networking system;

In this embodiment, when it is determined that the occupied resource value of the master device is greater than the second threshold, it is determined that the power resource consumption of the master device is relatively high, and at this time, the master device may schedule the received service data (hereinafter referred to as the second service data to indicate distinction) to other networking devices, so that it may be avoided that the power resource of the master device is exhausted due to overload processing of the service data by the master device, thereby improving stability of the networking system.

Specifically, in the present embodiment, when it is determined that the occupied resource value of the master device is greater than the second threshold value, the master device determines a networking device (hereinafter referred to as a second target device to show distinction) for processing the second service data from among the respective networking devices. In a specific embodiment, the second target device may be a networking device with a minimum occupied resource value in the networking system, or may be any networking device with an occupied resource value smaller than a first threshold, which is not limited herein. The specific reference may be made to step S10 in the first embodiment, and details are not described here.

Step S60, sending the received second service data to the second target device, so that the second target device processes the second service data to obtain a second processing result, and then sending the second processing result to the master device.

And after the second target device is determined, the main device sends the received second service data to the second target device. After receiving the second service data, the second target device processes the second service data to obtain a processing result (hereinafter referred to as a second processing result to show distinction), and sends the second processing result to the master device.

Specifically, in an embodiment, the master device may determine the second target device after receiving the second service data, where in this embodiment, the master device may be the same as or different from the second target device corresponding to the received second service data; in another embodiment, the master device may determine the second target device after determining that the value of the self-occupied resource is greater than the second threshold, where in this embodiment, multiple sets of first service data received by the master device at different times may be the same corresponding first target device. In particular, the present invention is not limited thereto.

Further, in a specific embodiment, when the master device determines the second target device after determining that the own occupied resource value is greater than the second threshold value, the second target device may be replaced. In this embodiment, the master device may redetermine the second target device according to a certain period; or determining whether the second target device needs to be redetermined according to the condition of the occupied resource value of each networking device, and in particular, the method is not limited herein.

Further, after receiving the second processing result, the master device sends the second processing result to a service data sending end which sends the second service data.

When the occupied resource value of the main device is determined to be larger than the second threshold, the main device determines a second target device from each networking device, and sends the received second data service to the second target device, so that the situation that the computing power resource of the main device is exhausted due to overload processing of service data of the main device can be avoided, and the stability of the networking system is improved.

Further, in an embodiment, before step S30, the method further includes:

step S70, detecting whether the occupied resource value of the main equipment is larger than the second threshold value;

in this embodiment, whether the occupied resource value of the master device is greater than a second threshold is detected, so as to determine whether the master device needs to schedule the received second service data.

Step S80, when the occupied resource value of the main equipment is not larger than the second threshold value, processing the second service data;

and when the occupied resource value of the main equipment is not larger than the second threshold value, the computing power resource consumption of the main equipment is less, and the main equipment can process the second service data. Further, the master device sends the processing result obtained by processing the second service data to a service data sending end for sending the second service data.

In a specific embodiment, when the occupied resource value of the master device is not greater than the second threshold, the second service data received by the master device may be service data sent by a device to be scheduled, or may be service data sent by a device outside the networking system, which is not limited herein.

And step S90, when the occupied resource value of the master device is determined to be larger than the second threshold value, executing the step of determining a second target device from the networking devices.

When the occupied resource value of the main device is determined to be greater than the second threshold, it is determined that the computing power resource consumption of the main device is relatively high, at this time, the main device may determine a second target device from each networking device, and schedule the second service data to the second target device, and the specific scheduling process may refer to steps S50 to S60, which are not described herein.

Further, in an embodiment, before determining the second target device from each networking device, the master device calculates an occupied resource value of the master device, and obtains the occupied resource value of each slave device. The master device records the occupied resource value of each device, and after the second target device is determined, the occupied resource value of the second target device is adjusted to be the maximum value in the occupied resource values of each networking device. The main equipment performs next scheduling according to the adjusted occupied resource values of the networking equipment, so that the second target equipment cannot be selected when the main equipment performs next scheduling, and the condition that the second target equipment is selected for processing service data for many times to cause the exhaustion of the computing power resources of the second target equipment is avoided, thereby improving the stability of a computing power system. The specific implementation may refer to the second embodiment, and will not be described herein.

Further, in an embodiment, referring to fig. 2, the specific procedure of data processing may be:

the master calculates its own occupancy resource value (i.e., the master's occupancy resource value).

The master device periodically queries the occupied resource value of the slave device, and the specific process may be: the master device starts a service application program for inquiring occupied resource values, the slave device starts a client application program for inquiring occupied resource values, the master device initiates a request for inquiring occupied resource values to all the slave devices on the network, the slave devices calculate occupied resource values (namely occupied resource values of the slave devices) and send the occupied resource values to the master device through the client application program, after receiving the occupied resource values of all the slave devices, the master device sorts the occupied resource values of all the slave devices in order from small to large, and the master device maintains the occupied resource value sorting queue. (i.e. the master device obtains the occupied resource values of the slave devices and maintains a queue in which the occupied resource values of the networking devices are ordered in order from small to large)

The master device sets the value of the resources occupied by node 2 to a maximum value. (i.e., the master device adjusts the occupied resource value of the second target device to the maximum value among the occupied resource values of the networking devices of the networking system)

When the master device receives the service data, if the occupied resource value of the master device exceeds the threshold value, the master device is overloaded, and the service data needs to be balanced to other networking devices for processing. The master device selects the slave device 2 with the minimum value from the occupied resource value sorting queue for scheduling. The master device adjusts the occupied resource value of slave device 2 to the maximum value in the occupied resource value ordering queue. (i.e., when the value of the occupied resource of the master device is greater than the second threshold value, the master device determines a second target device from among the respective networking devices)

The slave device 2 receives the service data, processes the service data to obtain a service data processing result, and the slave device 2 sends the service data processing result to the master device. (namely, the second target device processes the received second service data to obtain a second service result, and sends the second service result to the main device)

In this embodiment, when it is determined that the occupied resource value of the master device is greater than the second threshold, the master device determines a second target device from each networking device, and sends the second data service to the second target device, so as to avoid exhaustion of computing resources of the master device caused by overload processing of service data by the master device, thereby improving stability of the networking system.

Further, based on the first/second/third embodiments described above, a fourth embodiment of the data processing method of the present invention is provided, in this embodiment, the data processing method is applied to any target slave device in each networking device of the networking system, where the target slave device may be a device such as a personal computer, a smart phone, a server, etc., and in this embodiment, the data processing method includes, without limitation:

step A10, when the occupied resource value of the target slave device is determined to be greater than a preset first threshold value, sending a scheduling request to a master device in each networking device, so that after the master device receives the scheduling request, determining a target device from each networking device, and sending device information of the target device to the target slave device, wherein the occupied resource value of the target device is smaller than a preset second threshold value or is the minimum value in the occupied resource values of the networking devices in the networking system;

in this embodiment, a first threshold and a second threshold of the occupied resource value of the networking device are preset, and in a specific implementation manner, specific values of the first threshold and the second threshold may refer to step S10 in the first embodiment, which is not described herein in detail.

When the occupied resource value of the target slave device is larger than a preset first threshold value, determining that the computational power resource consumption of the target slave device is more, and at the moment, sending a scheduling request to the master device to request the master device to schedule service data (hereinafter referred to as service data to be processed for distinguishing) received by the target slave device.

After receiving the scheduling request, the master device determines networking devices (hereinafter referred to as target devices for distinguishing) for processing the service data to be processed from the networking devices, and sends the device information of the target devices to the device to be scheduled. In a specific embodiment, the target device may be a networking device with a minimum occupied resource value in the networking system, or any networking device with an occupied resource value smaller than a second threshold, which is not limited herein. The specific reference may be made to step S10 in the first embodiment, and details are not described here.

And step A20, when the equipment information is received, the received business data to be processed is sent to the target equipment according to the equipment information, so that the target equipment processes the business data to be processed to obtain a business processing result, and then the business processing result is sent to the target slave equipment.

And when the target slave device receives the device information sent by the master device, sending the service data to be processed to the target device according to the device information.

After receiving the service data to be processed, the target device processes the service data to be processed to obtain a processing result (hereinafter referred to as a service processing result to show distinction). And the target equipment sends the service processing result to the target slave equipment.

In a specific embodiment, the target slave device may send the scheduling request after receiving the service data to be processed, or may send the scheduling request after determining that the occupied resource value of the target slave device is greater than the first threshold, which may refer to step S10 to step S20 in the first embodiment, and will not be described herein.

Further, after receiving the service processing result, the target slave device sends the service processing result to a service data sending end for sending the service data to be processed.

Further, in an embodiment, before step a10, the method further includes

Step A30, detecting whether the occupied resource value of the target slave device is larger than the first threshold value;

in this embodiment, whether the scheduling request master needs to be sent is determined by detecting whether the occupied resource value of the target slave is greater than a first threshold, so as to request the master to schedule the service data to be processed.

Step A40, when the occupied resource value of the target slave device is not larger than the first threshold value, processing the received service data to be processed;

and when the occupied resource value of the target slave device is not larger than the first threshold value, and the consumption of the computational power resources of the target slave device is less, the target slave device processes the received business data to be processed. Further, the target slave device sends the processing result to a service data sending end which sends the service data to be processed.

In a specific embodiment, when the occupied resource value of the target slave device is not greater than the first threshold, the to-be-processed service data received by the target slave device may be service data sent by a device to be scheduled (i.e. a networking device with an occupied resource value greater than the second threshold), or may be service data sent by a device outside the networking system, which is not limited herein.

And step A50, when the occupied resource value of the target slave device is determined to be larger than the first threshold value, executing the step of sending the scheduling request to the master device in each networking device.

And when the occupied resource value of the target slave device is determined to be larger than the second threshold value, determining that the computational power resource of the target slave device is more consumed, and at the moment, the target slave device can send a scheduling request to the master device. The specific process may refer to steps a10 to a20 in this embodiment, and will not be described here.

Further, in an embodiment, before step a30, the method further includes:

step A60, calculating the occupied resource value of the target slave device;

and step A70, transmitting the occupied resource value of the target slave device to the master device.

The target slave device may be a master device that transmits data for calculating the occupied resource value, and the master device calculates the occupied resource value of the target slave device according to the received data; or the target slave device calculates to obtain the occupied resource value of the target slave device, and sends the occupied resource value of the target slave device to the master device.

Specifically, in this embodiment, after the target slave device calculates its own occupied resource value, the occupied resource value of the target slave device is sent to the master device.

In a specific embodiment, calculating the occupied resource value of the target slave device may be after receiving the service data to be processed; or according to a certain period; the occupied resource value of the target slave device may also be calculated after the master device performs the query, and in this embodiment, the method is not limited, and may be set according to actual requirements. The specific calculation method may refer to step S301 to step S304 in the second embodiment, which is not described herein.

In a specific embodiment, the sending of the occupied resource value of the target slave device to the master device may be sending the occupied resource value of the target slave device when the master device queries; or the occupied resource value of the target slave device may be sent to the master device after the occupied resource value of the target slave device is obtained through each calculation, which is not limited herein.

Further, in an embodiment, the target slave device may send data for calculating the occupied resource value to the master device, so that the master device calculates the occupied resource value of the target slave device.

Specifically, in this embodiment, the target slave device acquires a first data set for calculating a quality value of the communication link, where the first data set includes an average delay, a packet loss rate, and a signal strength value of the target slave device. The specific reference may be made to step S301 in the second embodiment, which is not described herein.

The target slave device transmits the first data set to the master device. After receiving the first data set, the master device obtains a first weight set which corresponds to the service type of the networking system and is preset for calculating the quality value of the communication link. The first weight group includes three weights (hereinafter referred to as first weights for distinguishing), and each first weight corresponds to the average delay, the packet loss rate and the signal strength value one by one. And the master device uses each first weight value contained in the first weight value group to carry out weighted summation processing on each data (namely average time delay, packet loss rate and signal strength value) in the first data group so as to obtain the communication link quality value of the target slave device. Specific reference may be made to step S301 to step S302 in the second embodiment, and details are not described here.

The target slave device obtains a second data set for calculating the occupied resource value, where the second data set includes the memory utilization rate, the input/output resource utilization rate, and the processor resource utilization rate of the target slave device, and the details of step S303 in the second embodiment may be referred to, which will not be described herein.

The target slave device sends the second data set to the master device. After receiving the second data set, the master device obtains a second weight set, which is preset corresponding to the service type and used for calculating the occupied resource value, wherein the second weight set comprises four weights (hereinafter referred to as second weights for distinguishing), and each second weight corresponds to the memory utilization rate, the input/output resource utilization rate, the processor resource utilization rate and the communication link quality value one by one. And the master device performs weighted summation processing on each data (namely, memory utilization rate, input/output resource utilization rate and processor resource utilization rate) and the communication link quality value contained in the second data group by using each second weight value contained in the second weight value group to obtain the occupied resource value of the target slave device. The specific process may refer to step S303 to step S304 in the second embodiment, which is not described herein.

Further, in an embodiment, after the target slave device calculates the own occupied resource value, the occupied resource value of the target slave device is sent to the master device, and referring to fig. 3, a specific process of data processing may be:

The master device periodically queries the occupied resource value of the slave device, and the specific process may be: the master device starts a service application program for inquiring the occupied resource value, the slave device starts a client application program for inquiring the occupied resource value, the master device initiates a request for inquiring the occupied resource value to all the slave devices on the network, the slave device calculates the occupied resource value, and the occupied resource value is sent to the master device through the client application program. (i.e., the target slave calculates its own occupancy resource value and transmits the occupancy resource value of the target slave to the master)

After receiving the occupied resource values of all the slave devices, the master device sorts the occupied resource values of all the slave devices in order from small to large, and maintains the occupied resource value sorting queue. (i.e. the master device sorts the occupied resource values of the networking devices in order from small to large)

When the slave device 1 receives the service data, if the occupied resource value of the slave device 1 exceeds the threshold value, the slave device 1 is overloaded, and the service data needs to be balanced to other networking devices for processing. The slave device 1 initiates a scheduling request to the master device, and the master device selects the slave device 2 with the minimum value from the occupied resource value sequencing queue to schedule. The master device adjusts the occupied resource value of slave device 2 to the maximum value in the occupied resource value ordering queue. ( I.e. when the occupied resource value of the target slave device is larger than the first threshold value, a scheduling request is sent to the master device. The master device determines target devices from all networking devices )

The master device sets the value of the resources occupied by node 2 to a maximum value. (i.e., the master device adjusts the occupied resource value of the target device to the maximum value among the occupied resource values of the respective networking devices of the networking system)

The slave device 2 receives the service data, processes the service data to obtain a service data processing result, and the slave device 2 sends the service data processing result to the slave device 1. (namely, the target equipment processes the received business data to be processed to obtain business processing results, and sends the business results to the target slave equipment)

In this embodiment, when it is determined that the occupied resource value of the target slave device is greater than a preset first threshold, the target slave device sends a scheduling request to a master device in each networking device, so that after the master device receives the scheduling request, the target device is determined from each networking device, device information of the target device is sent to the target slave device, when the target slave device receives the device information, the received service data to be processed is sent to the target device according to the device information, so that the target device processes the service data to be processed to obtain a service processing result, and then the service processing result is sent to the target slave device. According to the method and the device for processing the business data, the business data to be processed, which are received by the target slave devices with large consumption of the computing resources, are sent to the target devices with small consumption of the computing resources for processing, so that the computing resources of all networking devices are consumed in an equalizing mode, the consumption of the computing resources of the slave devices is avoided, and the stability of the networking system is improved.

The present invention also provides a data processing apparatus, referring to fig. 4, comprising:

Further, the determining module 10 is further configured to:

The sending module 20 is further configured to send the received second service data to the second target device, so that the second target device processes the second service data to obtain a second processing result, and then send the second processing result to the master device.

Further, the data processing device further comprises a detection module, wherein the detection module is used for:

the data processing device also comprises a processing module, wherein the processing module is used for

Further, the data processing apparatus further includes an acquisition module, where the acquisition module is configured to:

the data processing device further comprises an adjustment module for:

Further, the acquisition module is further configured to:

Further, the determining module 10 is further configured to:

The sending module 20 is further configured to:

Further, the detection module is further configured to:

the processing module is further configured to:

Further, the acquisition module is further configured to:

calculating the occupied resource value of the target slave device;

the sending module 20 is further configured to:

The embodiments of the data processing apparatus according to the present invention may refer to the embodiments of the data processing method according to the present invention, and will not be described herein.

An embodiment of the present invention provides a networking device, referring to fig. 5, where the networking device may include: a processor 1001, such as a central processing unit (Central Processing Unit, CPU), a communication bus 1002, a user interface 1003, a network interface 1004, a memory 1005. Wherein the communication bus 1002 is used to enable connected communication between these components. The user interface 1003 may include a Display, an input unit such as a Keyboard (Keyboard), and the optional user interface 1003 may further include a standard wired interface, a wireless interface. The network interface 1004 may optionally include a standard wired interface, a WIreless interface (e.g., a WIreless-FIdelity (WI-FI) interface). The Memory 1005 may be a high-speed random access Memory (Random Access Memory, RAM) Memory or a stable nonvolatile Memory (NVM), such as a disk Memory. The memory 1005 may also optionally be a storage device separate from the processor 1001 described above.

Those skilled in the art will appreciate that the structure shown in fig. 5 is not limiting of the networking device and may include more or fewer components than shown, or certain components may be combined, or a different arrangement of components.

As shown in fig. 5, an operating system, a data storage module, a network communication module, a user interface module, and a data processing program may be included in a memory 1005 as one type of computer-readable storage medium.

In the networking device shown in fig. 5, the network interface 1004 is mainly used for data communication with other devices; the user interface 1003 is mainly used for data interaction with a user; the processor 1001 and the memory 1005 in the networking device of the present invention may be disposed in the networking device, where the networking device invokes a data processing program stored in the memory 1005 through the processor 1001, and executes the steps of the data processing method provided in the embodiment of the present invention.

The embodiments of the networking device of the present invention may refer to the embodiments of the data processing method of the present invention, and will not be described herein.

Furthermore, the embodiment of the present invention also proposes a computer-readable storage medium having stored thereon a data processing program which, when executed by a processor, implements the steps of the data processing method as described above.

Embodiments of the computer readable storage medium according to the present invention may refer to embodiments of the data processing method according to the present invention, and will not be described herein.

It should be noted that, in this document, the terms "comprises," "comprising," or any other variation thereof, are intended to cover a non-exclusive inclusion, such that a process, method, article, or system that comprises a list of elements does not include only those elements but may include other elements not expressly listed or inherent to such process, method, article, or system. Without further limitation, an element defined by the phrase "comprising one … …" does not exclude the presence of other like elements in a process, method, article, or system that comprises the element.

The foregoing embodiment numbers of the present invention are merely for the purpose of description, and do not represent the advantages or disadvantages of the embodiments.

From the above description of the embodiments, it will be clear to those skilled in the art that the above-described embodiment method may be implemented by means of software plus a necessary general hardware platform, but of course may also be implemented by means of hardware, but in many cases the former is a preferred embodiment. Based on such understanding, the technical solution of the present invention may be embodied essentially or in a part contributing to the prior art in the form of a software product stored in a computer readable storage medium (e.g. ROM/RAM, magnetic disk, optical disk) as described above, comprising instructions for causing a terminal device (which may be a mobile phone, a computer, a server, or a network device, etc.) to perform the method according to the embodiments of the present invention.

The foregoing description is only of the preferred embodiments of the present invention, and is not intended to limit the scope of the invention, but rather is intended to cover any equivalents of the structures or equivalent processes disclosed herein or in the alternative, which may be employed directly or indirectly in other related arts.

Claims

1. A data processing method, wherein the data processing method is applied to a master device in each networking device of a networking system, the data processing method comprising the steps of:

2. The data processing method according to claim 1, wherein the data processing method further comprises:

3. The data processing method of claim 2, wherein prior to the step of determining the second target device from each of the networking devices, further comprising:

4. The data processing method of claim 1, wherein prior to the step of determining the first target device from each of the networking devices, further comprising:

5. The data processing method of claim 4, wherein the step of calculating the occupied resource value of the master device comprises:

6. A data processing method, wherein the data processing method is applied to any one target slave device among each networking device of a networking system, the data processing method comprising the steps of:

7. The data processing method of claim 6, wherein prior to the step of sending the scheduling request to the master device in each of the networking devices, further comprising:

8. The data processing method according to claim 6 or 7, wherein before the step of sending the scheduling request to the master device in each of the networking devices, further comprising:

calculating the occupied resource value of the target slave device;

9. A networking device, characterized in that the networking device comprises: memory, a processor and a data processing program stored on the memory and executable on the processor, the data processing program being configured to implement the steps of the data processing method according to any one of claims 1 to 8.

10. A computer-readable storage medium, on which a data processing program is stored, which, when executed by a processor, implements the steps of the data processing method according to any one of claims 1 to 8.