CN115277711A - Device scheduling method and device - Google Patents

Abstract

The scheme provided by the application determines the attribution of the equipment through the equipment identification mark of the equipment to be scheduled, determines the optimal scheduling area according to the attribution of the equipment, filters the servers in the target area, eliminates part of servers with running states which do not meet requirements, determines the target server with the most appropriate load state from the rest servers by using a weighted minimum connection algorithm, achieves the effect of distributing the servers for the equipment to be scheduled in a self-adaptive mode, and solves the technical problem of low scheduling efficiency of the existing equipment scheduling method.

Description

A device scheduling method and device

technical field

The present application relates to the technical field of the Internet of Things, and in particular to a device scheduling method and device.

Background technique

With the development of the Internet of Things technology, more and more devices produced by various manufacturers are connected to long-term connection services, and the server of a single node is far from meeting the needs of device connections, which leads to resource scheduling for many devices. demand.

The scheduling process of the IoT device refers to that after the device is connected to the Internet, a server is allocated to the device by calling the corresponding scheduling interface to process the request of the device. The current method of device scheduling is mostly regional, and some business personalized Scheduling methods, so that the implementation of these scheduling methods generally needs to specify the scheduling area and service type in advance, which leads to the technical problem of low scheduling efficiency of the existing equipment scheduling methods.

Contents of the invention

The present application provides an equipment scheduling method and device, which are used to solve the technical problem of low scheduling efficiency of the existing equipment scheduling method.

In order to solve the above technical problems, first, the first aspect of the present application provides a device scheduling method, including:

In response to the scheduling request message sent by the device, extracting the device identification contained in the scheduling request message;

Determine the attribution of the device according to the device identification, and then determine the target area according to the attribution of the device;

According to the operation status of each server in the target area, filter the servers whose operation status does not meet the requirements in the target area;

Based on the remaining servers after filtering, the target server is determined from the remaining servers through a weighted minimum connection algorithm, so as to perform device scheduling based on the target server.

Preferably, when the number of the target servers is multiple, based on the remaining servers after filtering, through the weighted minimum connection algorithm, after determining the target servers from the remaining servers, it also includes:

A target server is determined from multiple target servers by a random polling algorithm.

Preferably, the determining the attribution of the device according to the identification of the device, and then determining the target area according to the attribution of the device specifically includes:

According to the device IP in the device identification, determine the IP attribution of the device, and then determine the target area according to the IP attribution of the device.

Preferably, according to the running status of each server in the target area, filtering the servers whose running status does not meet the requirements in the target area specifically includes:

According to the running status of each server in the target area, the servers in the target area whose load value is higher than a preset load threshold or in an offline state are filtered.

Preferably, after extracting the device identification contained in the scheduling request message, the method further includes:

According to the device identification, match the specified scheduling policy of the device identification, if the matching is successful, perform device scheduling according to the specified scheduling policy, if the matching is unsuccessful, determine the device according to the device identification The attribution of the device, and then determine the target area according to the attribution of the device.

At the same time, the second aspect of the present application provides an equipment scheduling device, including:

a scheduling request response unit, configured to respond to the scheduling request message sent by the device, and extract the device identification contained in the scheduling request message;

A device area determining unit, configured to determine the attribution of the device according to the device identification, and then determine the target area according to the attribution of the device;

a server filtering unit, configured to filter servers whose operating status does not meet requirements in the target area according to the operating status of each server in the target area;

The target server determining unit is configured to determine a target server from the remaining servers based on the remaining servers after filtering through a weighted minimum connection algorithm, so as to perform device scheduling based on the target servers.

Preferably, when the number of the target servers is multiple, based on the remaining servers after filtering, through the weighted minimum connection algorithm, after determining the target servers from the remaining servers, it also includes:

The target server secondary determination unit is used to determine a target server from multiple target servers through a random polling algorithm.

Preferably, the device area determination unit is specifically configured to:

According to the device IP in the device identification, determine the IP attribution of the device, and then determine the target area according to the IP attribution of the device.

Preferably, the server filtering unit is specifically used for:

According to the running status of each server in the target area, the servers in the target area whose load value is higher than a preset load threshold or in an offline state are filtered.

Preferably, it also includes:

A specified scheduling strategy matching unit, configured to match the specified scheduling strategy of the device identifier according to the device identifier, if the matching is successful, perform device scheduling according to the specified scheduling strategy, and if the matching is unsuccessful, then perform device scheduling according to the described Identify the device, determine the attribution of the device, and then determine the target area according to the attribution of the device.

It can be seen from the above technical solutions that the embodiments of the present application have the following advantages:

The solution provided by this application determines the attribution of the device through the device identification of the device to be scheduled, and then determines the best scheduling area according to the attribution of the device, filters the servers in the target area, and excludes some operating states For servers that do not meet the requirements, use the weighted minimum connection algorithm to determine the target server with the most suitable load status from the remaining servers, so as to realize the effect of adaptively allocating servers for the equipment to be scheduled, and solve the low scheduling efficiency of the existing equipment scheduling method technical problems.

Description of drawings

In order to more clearly illustrate the technical solutions in the embodiments of the present application or the prior art, the following will briefly introduce the drawings that need to be used in the description of the embodiments or the prior art. Obviously, the accompanying drawings in the following description are only These are some embodiments of the present application. Those skilled in the art can also obtain other drawings based on these drawings without any creative effort.

FIG. 1 is a schematic diagram of a system architecture of a device scheduling method provided in the present application.

Fig. 2 is a schematic flowchart of an embodiment of a device scheduling method provided by the present application.

Fig. 3 is a schematic flowchart of another embodiment of a device scheduling method provided by the present application.

FIG. 4 is a schematic structural diagram of an embodiment of an apparatus for scheduling equipment provided by the present application.

Detailed ways

The embodiment of the present application provides an equipment scheduling method and device, which are used to solve the technical problem of low scheduling efficiency of the existing equipment scheduling method.

In order to make the purpose, features and advantages of the present application more obvious and understandable, the technical solutions in the embodiments of the present application will be clearly and completely described below in conjunction with the drawings in the embodiments of the present application. Obviously, the following The described embodiments are only some of the embodiments of the present application, but not all of them. Based on the embodiments in this application, all other embodiments obtained by persons of ordinary skill in the art without making creative efforts belong to the scope of protection of this application.

As shown in Figure 1, the system structure involved in the device scheduling method provided by this application includes two parts: the device long-connection service part and the scheduling service part, wherein the device long-connection service part is used to control the connection transaction of the server. The reporting module is set to report the current node information of the server to the scheduling service at regular intervals. The server node information includes but not limited to internal network IP, public network IP, the number of connections of the server’s current long-term connection port, and the current basic information of the server. etc. Among them, the basic information includes but is not limited to: cpu usage rate, memory usage rate, network bandwidth usage rate, disk usage rate, online status; the scheduling service saves the information reported by the server to execute subsequent scheduling strategies, namely The device scheduling method provided by this application.

The above is the overall framework of the device scheduling method provided by the present application at the system level, and the following content is a detailed description of an embodiment of the device scheduling method provided by the present application.

Please refer to Figure 2, the embodiment of the present application provides a device scheduling method, including:

Step 101. In response to the scheduling request message sent by the device, extract the device identification contained in the scheduling request message.

It should be noted that after the manufacturer's equipment is connected to the network, the equipment sends a scheduling request message to the scheduling service by calling the corresponding scheduling interface. After receiving the scheduling request message sent by the device, the scheduling service extracts the device identification contained in the scheduling request message. The device identification includes but not limited to device number and device IP.

Step 102: Determine the attribution of the device according to the identification of the device, and then determine the target area according to the attribution of the device.

Then, use the device identification obtained in step 101 to query the attribution information of the device, and then, after determining the attribution of the device, determine the target area according to the attribution, so as to filter out the information used to communicate with the device in the target area. The target server to establish a persistent connection.

Step 103, according to the running status of each server in the target area, filter the servers whose running status does not meet the requirements in the target area.

Then, based on the target area determined in step 102, the servers in the target area are screened, the servers whose operating status does not meet the requirements are filtered, and the subsequent steps are continued according to the remaining servers after filtering, wherein the operating status of the server It can be determined according to the node information reported by each server, and will not be repeated here.

Step 104, based on the remaining servers after filtering, determine the target server from the remaining servers through the weighted least connection algorithm, so as to perform device scheduling based on the target server.

It should be noted that the weighted least-connection scheduling (Weighted Least-Connection Scheduling) algorithm is a superset of the least-connection scheduling, and each server uses a corresponding weight to represent its processing performance. The default weight of the server is 1, and the system administrator can dynamically set the weight of the server. The weighted least connection scheduling makes the number of established connections of the server proportional to its weight as much as possible when scheduling new connections.

Then, based on the remaining servers after filtering, the target server with the best current running state is determined from the remaining servers through the weighted minimum connection algorithm, so as to complete the task of device scheduling based on the target server.

The solution provided by the embodiment of this application determines the attribution of the device through the device identification of the device to be dispatched, and then determines the best dispatching area according to the attribution of the device, filters the servers in the target area, and excludes some of the operating states that do not meet the requirements. The required server, and then use the weighted minimum connection algorithm to determine the target server with the most suitable load status from the remaining servers, so as to realize the effect of adaptively allocating servers for the equipment to be scheduled, and solve the problem of low scheduling efficiency of the existing equipment scheduling method question.

The above content is the detailed description of the first embodiment of the device scheduling method provided by the present application, and the following is the detailed description of the second embodiment of the device scheduling method provided by the present application.

Please refer to Figure 3. Based on the content of the device scheduling method provided in the previous embodiment, a device scheduling method provided in this embodiment includes:

Further, step 101 mentioned in the first embodiment may further include:

Step 1001, according to the device identification, match the specified scheduling policy of the device identification, if the match is successful, then perform equipment scheduling according to the specified scheduling policy, if the match is unsuccessful, determine the attribution of the device according to the device identification, and then according to the attribution to determine the target area.

It should be noted that after the device identification is extracted, it can be judged whether the device identification has a corresponding specified scheduling strategy based on the extracted device identification through matching methods. If the matching is successful, the matched A scheduling strategy is specified to schedule the device, for example, according to the specified scheduling strategy, a specific server or any server in the specified area is assigned as a target server to the device sending the scheduling request message. If the matching is unsuccessful, go to step 102.

Further, the step 102 mentioned in the first embodiment specifically includes:

According to the device IP in the device identification, determine the IP attribution of the device, and then determine the target area according to the IP attribution of the device.

It should be noted that, according to the device IP in the device identification, the IP attribution corresponding to the device IP is determined through the IP attribution query method, and then the target area is determined according to the IP attribution of the device.

Further, the step 103 mentioned in the first embodiment specifically includes: specifically includes:

According to the running status of each server in the target area, the server in the target area whose load value is higher than the preset load threshold or is offline is filtered.

Filter the servers in the target area, and filter the servers whose load value is higher than the preset load threshold or offline in the target area to eliminate overloaded and offline servers, so as to obtain the remaining load values that are normal and online server, wherein the load value mentioned in this embodiment can be calculated according to a preset formula based on information such as cpu usage rate, memory usage rate, disk usage rate, network bandwidth usage rate reported by the server, and the calculation method includes But not limited to: the weighted sum of each usage rate, the product of each usage rate, the maximum or average value of each usage rate, etc., and other existing load calculation methods may also be used.

Further, when there are multiple target servers, based on the remaining servers after filtering, through the weighted minimum connection algorithm, after determining the target server from the remaining servers, it also includes:

Step 1002: Determine a target server from multiple target servers through a random polling algorithm.

The above content is a detailed description of another embodiment of a device scheduling method provided in the present application, and the following is a detailed description of an embodiment of a device scheduling device provided in the present application.

Please refer to Figure 4, the third embodiment of the present application provides an equipment scheduling device, including:

The scheduling request response unit 201 is configured to extract the device identification contained in the scheduling request message in response to the scheduling request message sent by the device;

The device area determining unit 202 is configured to determine the attribution of the device according to the device identification, and then determine the target area according to the attribution of the device;

The server filtering unit 203 is configured to filter the servers in the target area whose operating status does not meet the requirements according to the operating status of each server in the target area;

The target server determining unit 204 is configured to determine a target server from the remaining servers based on the remaining servers after filtering through a weighted minimum connection algorithm, so as to perform device scheduling based on the target servers.

Further, when there are multiple target servers, based on the remaining servers after filtering, through the weighted minimum connection algorithm, after determining the target server from the remaining servers, it also includes:

The target server secondary determination unit 2002 is configured to determine a target server from multiple target servers through a random polling algorithm.

Further, the device area determining unit 202 is specifically used for:

According to the device IP in the device identification, determine the IP attribution of the device, and then determine the target area according to the IP attribution of the device.

Further, the server filtering unit 203 is specifically used for:

According to the running status of each server in the target area, the server in the target area whose load value is higher than the preset load threshold or is offline is filtered.

Further, it also includes:

The specified scheduling strategy matching unit 2001 is used to match the specified scheduling strategy of the device identification according to the device identification, if the matching is successful, then perform equipment scheduling according to the specified scheduling strategy, and if the matching is unsuccessful, then according to the device identification, determine the scheduling strategy of the device Attribution, and then determine the target area according to the attribution of the device.

Those skilled in the art can clearly understand that for the convenience and brevity of the description, the specific working process of the terminals, devices and units described above can refer to the corresponding process in the foregoing method embodiments, which will not be repeated here.

In the several embodiments provided in this application, it should be understood that the disclosed devices and methods may be implemented in other ways. For example, the device embodiments described above are only illustrative. For example, the division of the units is only a logical function division. In actual implementation, there may be other division methods. For example, multiple units or components can be combined or May be integrated into another system, or some features may be ignored, or not implemented. In another point, the mutual coupling or direct coupling or communication connection shown or discussed may be through some interfaces, and the indirect coupling or communication connection of devices or units may be in electrical, mechanical or other forms.

The terms "first", "second", "third", "fourth", etc. (if any) in the description of the present application and the above drawings are used to distinguish similar objects and not necessarily to describe specific sequence or sequence. It is to be understood that the data so used are interchangeable under appropriate circumstances such that the embodiments of the application described herein, for example, can be practiced in sequences other than those illustrated or described herein. Furthermore, the terms "comprising" and "having", as well as any variations thereof, are intended to cover a non-exclusive inclusion, for example, a process, method, system, product or device comprising a sequence of steps or elements is not necessarily limited to the expressly listed instead, may include other steps or elements not explicitly listed or inherent to the process, method, product or apparatus.

The units described as separate components may or may not be physically separated, and the components shown as units may or may not be physical units, that is, they may be located in one place, or may be distributed to multiple network units. Part or all of the units can be selected according to actual needs to achieve the purpose of the solution of this embodiment.

In addition, each functional unit in each embodiment of the present invention may be integrated into one processing unit, each unit may exist separately physically, or two or more units may be integrated into one unit. The above-mentioned integrated units can be implemented in the form of hardware or in the form of software functional units.

If the integrated unit is realized in the form of a software function unit and sold or used as an independent product, it can be stored in a computer-readable storage medium. Based on this understanding, the essence of the technical solution of the present invention or the part that contributes to the prior art or all or part of the technical solution can be embodied in the form of a software product, and the computer software product is stored in a storage medium , including several instructions to make a computer device (which may be a personal computer, a server, or a network device, etc.) execute all or part of the steps of the method described in each embodiment of the present invention. The aforementioned storage medium includes: U disk, mobile hard disk, read-only memory (ROM, Read-OnlyMemory), random access memory (RAM, Random Access Memory), magnetic disk or optical disk and other media that can store program codes.

As mentioned above, the above embodiments are only used to illustrate the technical solutions of the present application, and are not intended to limit them; although the present application has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that: it can still understand the foregoing The technical solutions described in each embodiment are modified, or some of the technical features are equivalently replaced; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the spirit and scope of the technical solutions of the various embodiments of the application.

Claims (10)

1. A device scheduling method, characterized in that, comprising: In response to the scheduling request message sent by the device, extracting the device identification contained in the scheduling request message; Determine the attribution of the device according to the device identification, and then determine the target area according to the attribution of the device; According to the operation status of each server in the target area, filter the servers whose operation status does not meet the requirements in the target area; Based on the remaining servers after filtering, the target server is determined from the remaining servers through a weighted minimum connection algorithm, so as to perform device scheduling based on the target server. 2. A device scheduling method according to claim 1, wherein when the number of the target servers is multiple, based on the remaining servers after filtering, through the weighted minimum connection algorithm, from the remaining servers After determining the target server also includes: A target server is determined from multiple target servers by a random polling algorithm. 3. A device scheduling method according to claim 1, wherein said determining the attribution of the device according to the identification of the device, and then determining the target area according to the attribution of the device specifically includes: According to the device IP in the device identification, determine the IP attribution of the device, and then determine the target area according to the IP attribution of the device. 4. A device scheduling method according to claim 1, characterized in that, according to the running status of each server in the target area, filtering the servers whose running status does not meet the requirements in the target area specifically includes : According to the running status of each server in the target area, the servers in the target area whose load value is higher than a preset load threshold or in an offline state are filtered. 5. A kind of device dispatching method according to claim 1, is characterized in that, after extracting the device identification mark that described dispatching request message contains, also comprises: According to the device identification, match the specified scheduling policy of the device identification, if the matching is successful, perform device scheduling according to the specified scheduling policy, if the matching is unsuccessful, determine the device according to the device identification The attribution of the device, and then determine the target area according to the attribution of the device. 6. An equipment scheduling device, characterized in that it comprises: a scheduling request response unit, configured to respond to the scheduling request message sent by the device, and extract the device identification contained in the scheduling request message; A device area determining unit, configured to determine the attribution of the device according to the device identification, and then determine the target area according to the attribution of the device; a server filtering unit, configured to filter servers whose operating status does not meet requirements in the target area according to the operating status of each server in the target area; The target server determining unit is configured to determine a target server from the remaining servers based on the remaining servers after filtering through a weighted minimum connection algorithm, so as to perform device scheduling based on the target servers. 7. A device scheduling device according to claim 6, wherein when the number of the target servers is multiple, based on the remaining servers after filtering, through the weighted minimum connection algorithm, from the remaining servers After determining the target server also includes: The target server secondary determination unit is used to determine a target server from multiple target servers through a random polling algorithm. 8. The equipment scheduling device according to claim 6, wherein the equipment area determining unit is specifically used for: According to the device IP in the device identification, determine the IP attribution of the device, and then determine the target area according to the IP attribution of the device. 9. A device scheduling device according to claim 6, wherein the server filtering unit is specifically used for: According to the running status of each server in the target area, the servers in the target area whose load value is higher than a preset load threshold or in an offline state are filtered. 10. A device scheduling device according to claim 6, further comprising: A specified scheduling strategy matching unit, configured to match the specified scheduling strategy of the device identifier according to the device identifier, if the matching is successful, perform device scheduling according to the specified scheduling strategy, and if the matching is unsuccessful, then perform device scheduling according to the described Identify the device, determine the attribution of the device, and then determine the target area according to the attribution of the device.

Images