[go: up one dir, main page]
More Web Proxy on the site http://driver.im/

WO2016091003A1 - 一种实现业务协同调度的方法、计算单板及存储介质 - Google Patents

一种实现业务协同调度的方法、计算单板及存储介质 Download PDF

Info

Publication number
WO2016091003A1
WO2016091003A1 PCT/CN2015/091675 CN2015091675W WO2016091003A1 WO 2016091003 A1 WO2016091003 A1 WO 2016091003A1 CN 2015091675 W CN2015091675 W CN 2015091675W WO 2016091003 A1 WO2016091003 A1 WO 2016091003A1
Authority
WO
WIPO (PCT)
Prior art keywords
cpu utilization
board
communication board
communication
cpu
Prior art date
Application number
PCT/CN2015/091675
Other languages
English (en)
French (fr)
Inventor
叶斐
李盛
蔡鸿鹏
Original Assignee
中兴通讯股份有限公司
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by 中兴通讯股份有限公司 filed Critical 中兴通讯股份有限公司
Publication of WO2016091003A1 publication Critical patent/WO2016091003A1/zh

Links

Images

Definitions

  • the present invention relates to data processing technologies in the field of optical communications, and in particular, to a method for implementing service collaborative scheduling, a computing board, and a computer storage medium.
  • each communication board is independent of each other, and each communication board is only responsible for processing its own signal.
  • the CPU utilization exceeds 90% when the data processing capability of a communication board is overloaded due to the limitation of the operation speed of the central processing unit (CPU).
  • the communication board receives network management. If the configuration command is sent, the communication board may not be able to respond to the received configuration command in time. This may cause the communication interface of the communication device to be blocked or the configuration operation to fail. Other communication boards may process the information. The amount of data is small, and CPU utilization is low, resulting in waste of resources.
  • the embodiments of the present invention provide a method for implementing service collaborative scheduling, a computing board, and a computer storage medium, which can implement coordinated scheduling of data to be processed between communication boards and improve resource utilization.
  • An embodiment of the present invention provides a method for implementing service collaborative scheduling, which is applied to a computing board, and the method includes:
  • the acquired CPU utilization information is stored in the form of a CPU utilization form according to a preset storage condition
  • the first communication board is a communication board with an overloaded CPU utilization
  • the received data to be processed is sent to the second communication board.
  • the method further includes:
  • the method before the sending the to-be-processed data to the second communication board, the method further includes:
  • the acquiring CPU utilization information of the communication board includes:
  • the CPU utilization information of the communication board except the communication board is obtained by receiving the broadcast message; the communication board is one of the communication boards.
  • the acquiring CPU utilization information of the communication board includes:
  • the CPU utilization information of the communication board is obtained by receiving a broadcast message.
  • the CPU utilization form includes at least the following combination of form items: a board subrack number, a board slot number, a CPU utilization, and whether a threshold is exceeded.
  • the preset storage condition includes storing CPU utilization information of the N pieces of communication boards with the lowest CPU utilization ranking among the communication boards; wherein N is a positive integer greater than or equal to 2. number.
  • the storing the obtained CPU utilization information in the form of a CPU utilization form includes:
  • the CPU utilization form is sorted according to the CPU utilization
  • the communication board is determined according to the CPU utilization information. Whether the CPU utilization exceeds the threshold;
  • the sorted CPU utilization form is updated according to the CPU utilization information, and the updated CPU utilization form is reordered.
  • the CPU utilization information is determined according to the CPU utilization information. Whether the CPU utilization of the communication board exceeds the threshold;
  • the CPU in the sorted CPU utilization form is replaced by the CPU utilization information of the communication board. Update the sorted CPU utilization form in the manner of the CPU usage information corresponding to the highest utilization communication board, and reorder the updated CPU utilization form. sequence.
  • the embodiment of the present invention further provides a computer storage medium, wherein the computer storage medium stores computer executable instructions, and the computer executable instructions are configured to perform the method for implementing service collaborative scheduling according to the embodiment of the present invention.
  • the embodiment of the present invention further provides a computing board, where the computing board includes an acquiring module, a storage module, a first receiving module, a selecting module, and a first sending module;
  • the acquiring module is configured to obtain CPU utilization information of the communication board.
  • the storage module is configured to store the acquired CPU utilization information in the form of a CPU utilization form according to a preset storage condition
  • the first receiving module is configured to receive data to be processed sent by the first communication board;
  • the first communication board is a communication board with overloaded CPU usage;
  • the selecting module is configured to select a second communication board in the saved CPU utilization form according to a preset screening condition
  • the first sending module is configured to send the received data to be processed to the second communication board.
  • the computing board further includes a second receiving module and a forwarding module
  • the second receiving module is configured to receive a processing result of the feedback of the second communication board
  • the forwarding module is configured to forward the processing result to the first communication board.
  • the computing board further includes a second sending module and a third receiving module
  • the second sending module is configured to send a processing request to the second communications board
  • the third receiving module is configured to receive a processing request response fed back by the second communication board.
  • the acquisition module includes a monitoring unit and an acquisition unit, where
  • the monitoring unit is configured to periodically monitor CPU utilization information of the communication board
  • the acquiring unit is configured to acquire CPU utilization information of other communication boards except the communication board by receiving a broadcast message.
  • the acquiring module is configured to obtain the CPU utilization information of the communication board by receiving a broadcast message.
  • the CPU utilization form includes at least the following combination of form items: a board subrack number, a board slot number, a CPU utilization, and whether a threshold is exceeded.
  • the preset storage condition includes storing CPU utilization information of the N pieces of communication boards with the lowest CPU utilization ranking among the communication boards; wherein N is a positive integer greater than or equal to 2.
  • the storage module includes an initialization unit, a storage unit, a counting unit, a sorting unit, a matching unit, a determining unit, and an updating unit, where
  • the initialization unit is configured to initialize each form item in the CPU utilization form
  • the storage unit is configured to save the CPU utilization information of the obtained communication board one by one in the CPU utilization form;
  • the counting unit is configured to count the communication boards corresponding to the CPU utilization information stored in the CPU utilization form;
  • the sorting unit is configured to sort the CPU utilization form according to CPU utilization when the number of communication boards recorded by the counting unit is N, and is also used to re-update the updated CPU utilization form. Sort
  • the matching unit is configured to: when the CPU usage information of the N+1th communication board is obtained, the board subrack number and the board slot number in the CPU utilization information and the sorted CPU Matching comparison of corresponding form items in the utilization form;
  • the determining unit is configured to be a board subrack number and a board in the CPU utilization information.
  • the slot number matches the corresponding form item in the sorted CPU utilization form, determining whether the CPU utilization of the communication board exceeds a threshold according to the CPU utilization information;
  • the updating unit is configured to update the sorted CPU utilization form according to the CPU utilization information when the CPU utilization of the communication board does not exceed a threshold.
  • the storage module further includes a comparison unit
  • the determining unit is further configured to use, according to the CPU, when the board subrack number and the board slot number in the CPU utilization information do not match the corresponding form items in the sorted CPU utilization form. Rate information determines whether the CPU utilization of the communication board exceeds a threshold;
  • the comparing unit is configured to compare the CPU utilization of the communication board with the CPU utilization saved in the sorted CPU utilization form when the CPU utilization of the communication board does not exceed the threshold;
  • the updating unit is further configured to replace, by using the CPU utilization information of the communication board, that the CPU utilization of the communication board is lower than the CPU usage saved in the sorted CPU utilization form. Updates the sorted CPU utilization form and reorders the updated CPU utilization form by sorting the CPU utilization information corresponding to the communication board with the highest CPU utilization in the sorted CPU utilization form.
  • the method for implementing service collaborative scheduling, the computing board, and the computer storage medium acquires CPU utilization information of the communication board; and stores the acquired CPU utilization in the form of a CPU utilization form according to preset storage conditions. Rate information; receiving the to-be-processed data sent by the first communication board, where the first communication board is a communication board with an overloaded CPU usage; selecting the second in the saved CPU utilization form according to a preset screening condition
  • the communication board sends the received data to be processed to the second communication board.
  • the coordinated scheduling of the amount of data to be processed between the communication boards can be realized, and the resource utilization rate can be improved.
  • the communication interface blocking or the configuration operation failure caused by the overload of the data processing capability of a certain communication board can be effectively avoided. problem.
  • FIG. 1 is a schematic flowchart 1 of a method for implementing service collaborative scheduling according to an embodiment of the present invention
  • FIG. 2 is a schematic structural diagram of a communication message between communication boards according to an embodiment of the present invention.
  • FIG. 3 is a schematic flowchart of storing CPU acquisition information obtained in the form of a CPU utilization form according to an embodiment of the present invention
  • FIG. 4 is a schematic structural diagram of a CPU utilization form in an initialization manner according to an embodiment of the present invention.
  • FIG. 5 is a schematic structural diagram of a composition of a sorted CPU utilization form according to an embodiment of the present invention.
  • FIG. 6 is a schematic flowchart 2 of a method for implementing service collaborative scheduling according to an embodiment of the present invention.
  • FIG. 7 is a schematic flowchart diagram of a method for implementing service collaborative scheduling according to an application example of the present invention.
  • FIG. 8 is a schematic diagram of CPU utilization of each communication board obtained in the application example shown in FIG. 7 according to the present invention.
  • FIG. 9 is a sorted CPU utilization form in the application example shown in FIG. 7 according to the present invention.
  • FIG. 10 is a schematic structural diagram 1 of a structural structure of a computing board according to an embodiment of the present invention.
  • FIG. 11 is a second schematic structural diagram of a computing board according to an embodiment of the present invention.
  • FIG. 12 is a schematic structural diagram of a component of an acquiring module according to an embodiment of the present invention.
  • FIG. 13 is a schematic structural diagram of a storage module according to an embodiment of the present invention.
  • the CPU utilization information of the communication board is obtained; the acquired CPU utilization information is stored in the form of a CPU utilization form according to the preset storage condition; and the to-be-processed data sent by the first communication board is received.
  • the first communication board is a communication board with an overloaded CPU usage; the second communication board is selected in the saved CPU utilization form according to a preset screening condition; and the received pending data is sent to the The second communication board is described.
  • the CPU utilization information of the communication board includes the board subrack number, the board slot number, the CPU utilization rate, and whether the threshold value is exceeded.
  • FIG. 1 is a schematic flowchart 1 of a method for implementing service collaborative scheduling according to an embodiment of the present invention, which is applied to a computing board.
  • a method for implementing service collaborative scheduling according to an embodiment of the present invention includes:
  • Step S101 Obtain CPU utilization information of the communication board.
  • the obtaining the CPU utilization information of the communication board includes: periodically monitoring the CPU utilization information of the communication board; and acquiring the broadcast message by receiving the broadcast message.
  • the CPU utilization information of the communication board is obtained, including:
  • the CPU utilization information of the communication board is obtained by receiving a broadcast message.
  • the message structure corresponding to the broadcast message may adopt a communication message structure between communication boards.
  • the communication message structure between the communication boards includes a “message header” and a “message body”; wherein the “message header” includes the following content:
  • Inter-board communication version used to identify the software version of the computing board
  • Length of the information body used to identify the length of the message body
  • Destination address is 0xAABB format, AA is the board subrack number, and BB is the board slot number.
  • Source address is 0xAABB format, AA is the board subrack number, and BB is the board slot number.
  • message type is used to distinguish the packet type, including a broadcast message packet, a processing request message, a processing request response message, a processing result feedback message, a to-be-processed data transmission message, and the like; Processing the request response message includes processing the request response message and processing the request rejection Absolute message.
  • Step S102 Store the acquired CPU utilization information in the form of a CPU utilization form according to a preset storage condition.
  • the CPU utilization form includes at least the following combination of form items: a board subrack number, a board slot number, a CPU utilization, and whether a threshold is exceeded.
  • the preset storage condition includes storing CPU utilization information of the N pieces of communication boards with the lowest CPU utilization ranking among the communication boards; wherein N is a positive integer greater than or equal to 2.
  • the N value is 3, that is, the preset storage condition includes storing CPU utilization information of the three communication boards with the lowest CPU utilization ranking among the communication boards.
  • the storing the obtained CPU utilization information in the form of a CPU utilization form includes:
  • Step S1021 Initializing each form item in the CPU utilization form
  • Step S1022 The CPU utilization information of the obtained communication board is saved in the CPU utilization form one by one;
  • Step S1023 When the CPU utilization information of the N communication boards is filled in the CPU utilization form, the CPU utilization form is sorted according to the CPU utilization;
  • the sorting the CPU utilization form may include sorting the forms according to CPU utilization from low to high; and may also sorting the forms according to CPU utilization from high to low.
  • Step S1024 When the CPU utilization information of the N+1th communication board is obtained, The board subrack number and board slot number in the CPU usage information are compared with the corresponding form items in the sorted CPU utilization form.
  • steps S1025a to S1025b are performed; when the CPU utilizes If the board subrack number and the board slot number in the rate information do not match the corresponding form items in the sorted CPU utilization form, perform steps S1026a to S1026c;
  • Step S1025a determining, according to the CPU utilization information, whether the CPU utilization of the communication board exceeds a threshold
  • Step S1025b When the CPU utilization of the communication board does not exceed the threshold, the sorted CPU utilization form is updated according to the CPU utilization information, and the updated CPU utilization form is reordered.
  • Step S1026a determining, according to the CPU utilization information, whether the CPU utilization of the communication board exceeds a threshold
  • Step S1026b When the CPU utilization of the communication board does not exceed the threshold, compare the CPU utilization of the communication board with the CPU utilization saved in the sorted CPU utilization form;
  • Step S1026c When the CPU utilization of the communication board is lower than the CPU usage saved in the sorted CPU utilization form, the sorted CPU utilization is replaced by the CPU utilization information of the communication board. CPU corresponding to the communication board with the highest CPU utilization in the form The utilization information updates the sorted CPU utilization form and reorders the updated CPU utilization form.
  • the steps S1022 to S1026 in the foregoing step S102 are cyclically executed. You can ensure that the CPU utilization information is stored in the CPU usage table.
  • the CPU usage information such as the board subrack number, board slot number, CPU utilization, and whether the threshold is exceeded is the lowest.
  • Step S103 Receive data to be processed sent by the first communication board; the first communication board is a communication board with overloaded CPU usage;
  • the first communication board sends a processing request message to the computing board when the CPU usage of the first communication board is overloaded in the entire rack.
  • the message structure of the request message is as shown in FIG. 2, wherein the “message body” contains data to be processed. In this way, after the computing board receives the data to be processed sent by the first communication board, the subsequent step S104 can be performed.
  • Step S104 Select a second communication board in the saved CPU utilization form according to the preset screening condition.
  • the preset filter condition is usually a communication board corresponding to the form item with the lowest CPU utilization in the saved CPU utilization form; correspondingly, the calculation board is filtered in the saved CPU utilization form.
  • the communication board corresponding to the form with the lowest CPU utilization is used as the second communication board.
  • Step S105 Send the received data to be processed to the second communication board.
  • calculation board sends the party that processes the request message.
  • the data is sent to the second communication board.
  • the message structure of the processing request message is as shown in FIG. 2, wherein the “message body” contains data to be processed.
  • the second communication board after receiving the data to be processed, performs a corresponding processing operation on the data to be processed by the CPU, to obtain a corresponding processing result, and feeds back the processing to the computing board. result.
  • the method for implementing service collaborative scheduling in the embodiment of the present invention may further include:
  • Step S106 Receive the processing result of the feedback of the second communication board, and forward the processing result to the first communication board.
  • the computing board receives the processing result of the feedback of the second communication board, and sends the to-be-processed data to the second communication board by sending the processing result feedback message to the first communication board.
  • the message structure of the processing result feedback message is as shown in FIG. 2, wherein the “message body” includes a processing result.
  • the method for implementing the service collaborative scheduling according to the embodiment of the present invention can realize the coordinated scheduling of the data to be processed between the communication boards, and improve the resource utilization rate. At the same time, the data processing of a certain communication board is effectively avoided. The communication interface is blocked due to capacity overload or the configuration operation fails.
  • the embodiment of the present invention further provides a computer storage medium, wherein the computer storage medium stores computer executable instructions, and the computer executable instructions are configured to perform the method for implementing service collaborative scheduling according to the embodiment of the present invention.
  • FIG. 6 is a schematic flowchart of a method for implementing service collaborative scheduling according to an embodiment of the present invention, which is applied to a computing board. As shown in FIG. 6, the method for implementing service collaborative scheduling according to an embodiment of the present invention includes:
  • Step S101 Obtain CPU utilization information of the communication board.
  • the CPU that acquires the communication board includes: periodically monitoring the CPU usage information of the communication board; and obtaining the CPU utilization information of the communication board except the communication board by receiving the broadcast message; wherein the communication board is It is one of the communication boards.
  • the CPU utilization information of the communication board is obtained, including:
  • the CPU utilization information of the communication board is obtained by receiving a broadcast message.
  • the message structure corresponding to the broadcast message may adopt a communication message structure between communication boards.
  • the communication message structure between the communication boards includes a “message header” and a “message body”; wherein the “message header” includes the following content:
  • Inter-board communication version used to identify the software version of the computing board
  • Length of the information body used to identify the length of the message body
  • Destination address is 0xAABB format, AA is the board subrack number, and BB is the board slot number.
  • Source address is 0xAABB format, AA is the board subrack number, and BB is the board slot number.
  • message type is used to distinguish the packet type, including a broadcast message packet, a processing request message, a processing request response message, a processing result feedback message, a to-be-processed data transmission message, and the like; Processing the request response message includes processing the request response message and processing the request rejection message.
  • Step S102 Store the acquired CPU utilization information in the form of a CPU utilization form according to a preset storage condition.
  • the CPU utilization form includes at least the following combination of form items: a board subrack number, a board slot number, a CPU utilization, and whether a threshold is exceeded.
  • the preset storage condition includes storing CPU utilization information of the N pieces of communication boards with the lowest CPU utilization ranking among the communication boards; wherein N is a positive integer greater than or equal to 2.
  • step S102 is similar to the implementation process of step S102 in the first embodiment of the present invention, and therefore will not be described again.
  • Step S103 Receive data to be processed sent by the first communication board; the first communication board is a communication board with overloaded CPU usage;
  • the first communication board sends a processing request message to the computing board when the CPU usage of the first communication board is overloaded in the entire rack.
  • the message structure of the request message is as shown in FIG. 2, wherein the “message body” contains data to be processed. In this way, after the computing board receives the data to be processed sent by the first communication board, the subsequent step S104 can be performed.
  • Step S104 Select a second communication board in the saved CPU utilization form according to the preset screening condition.
  • the preset filter condition is usually a communication board corresponding to the form item with the lowest CPU utilization in the saved CPU utilization form; correspondingly, the calculation board is filtered in the saved CPU utilization form.
  • the communication board corresponding to the form with the lowest CPU utilization is used as the second communication board.
  • Step S201 Send a processing request to the second communication board.
  • the computing board sends the processing request message to the second communication board by sending a processing request message; further, when the second communication board receives the When the request is processed, the processing request response of the accepting or rejecting type is fed back to the computing board by processing the request response message.
  • the message structure of the processing request message is as shown in FIG. 2, wherein the “message body” may be null information; the message structure of the processing request response message is as shown in FIG. 2, where the The "message" can contain accept or reject information.
  • Step S202 Receive a processing request response fed back by the second communication board.
  • the computing board receives the processing request response fed back by the second communication board; when the processing request response is a receiving type processing request response, the subsequent step S105 is continued.
  • the third communication board is The communication board corresponding to the form item with the lowest CPU utilization in the sorted CPU utilization form. Then, the third communication board is used as the second communication board, and steps S201 to S202 are continued.
  • Step S105 Send the received data to be processed to the second communication board.
  • the computing board sends the data to be processed to the second communication board by sending a processing request message; the message structure of the processing request message is as shown in FIG. 2 , where The "message body" contains the data to be processed.
  • the second communication board after receiving the data to be processed, performs a corresponding processing operation on the data to be processed by the CPU, to obtain a corresponding processing result, and feeds back the processing to the computing board. result.
  • Step S106 Receive the processing result of the feedback of the second communication board, and forward the processing result to the first communication board.
  • the computing board receives the processing result of the feedback of the second communication board, and sends the to-be-processed data to the second communication board by sending the processing result feedback message to the first communication board.
  • the message structure of the processing result feedback message is as shown in FIG. 2, wherein the “message body” includes a processing result.
  • the method for implementing the service collaborative scheduling according to the embodiment of the present invention can realize the coordinated scheduling of the data to be processed between the communication boards, and improve the resource utilization rate. At the same time, the data processing of a certain communication board is effectively avoided. The communication interface is blocked due to capacity overload or the configuration operation fails.
  • the method for implementing the service collaborative scheduling by calculating the board according to the first and second embodiments of the present invention can also assist the routing board to complete the complicated route collaborative scheduling process by using the computing board. .
  • the embodiment of the present invention further provides a computer storage medium, wherein the computer storage medium stores computer executable instructions, and the computer executable instructions are configured to perform the method for implementing service collaborative scheduling according to the embodiment of the present invention.
  • FIG. 7 is a schematic flowchart of a method for implementing service collaborative scheduling according to an application example of the present invention, which is applied to a computing board, where the computing board is attached to the communication board A, and the communication board A is the communication unit.
  • the method for implementing service collaborative scheduling according to an application example of the present invention includes:
  • Step S301 The communication board A collects related service data such as performance and alarm; performs data processing on the collected related service data to obtain a data processing result; and reports the data processing result to the network manager.
  • related service data such as performance and alarm
  • the data collection configuration task module of the communication board A can collect related performance data, such as performance and alarms, from the underlying hardware through the software and hardware communication interface; and transmit the collected related service data to the data processing task module;
  • the data processing task module performs data processing on the related service data, where the data processing includes analysis of alarm filtering, performance comparison and the like, and determining performance and alarm related data to be reported according to the analysis result;
  • the data processing task is The determined performance and alarm related data to be reported are transmitted to the data reporting configuration task module as a data processing result; and the data processing configuration task module reports the data processing result to the network manager through the backplane communication interface.
  • Step S302 The communication board A obtains a configuration command from the network manager; parses the configuration command to obtain a configuration parameter; and configures the configuration parameter into a specific hardware through a communication interface.
  • the number of the communication board A is The configuration task module obtains the configuration command delivered by the network manager through the backplane communication interface, where the configuration command carries the configuration parameter; the data reporting configuration task module transmits the configuration command to the data processing task module; the data processing task The module parses the configuration command, obtains the configuration parameters, and transmits the obtained configuration parameters to the data collection configuration task module; the data collection configuration task module configures the configuration parameters into the specific hardware through the software and hardware communication interfaces.
  • steps S301 and S302 is not limited.
  • Step S303 The computing board attached to the communication board A obtains CPU utilization information of each communication board.
  • the computing board periodically monitors the CPU utilization information of the communication board, and obtains other communication boards except the communication board A, including the communication boards B and C, by receiving the broadcast message. And the CPU utilization information of D; wherein, as shown in FIG. 8, the CPU utilization rates in the CPU utilization information of each communication board A, B, C, and D acquired are 91%, 55%, and 70, respectively. % and 60%.
  • Step S304 Store the acquired CPU utilization information in the form of a CPU utilization form according to the preset storage condition.
  • the sorted CPU utilization form stored in step S102 in the first or second embodiment of the present invention is as shown in FIG. 9.
  • Step S305 Receive data to be processed sent by the communication board A.
  • the communication board A sends the unprocessed data to be processed to the calculation board.
  • Step S306 The second communication board B is selected in the saved CPU utilization form according to the preset filter condition.
  • the preset filter condition is usually the lowest CPU utilization form item in the saved CPU utilization form. Corresponding communication board.
  • step S306 the calculation board is saved in the saved CPU as shown in FIG.
  • the second communication board B is selected in the usage form.
  • Step S307 The calculation board sends the received data to be processed to the second communication board B;
  • Step S308 Receive the processing result fed back by the second communication board B, and forward the processing result to the first communication board A.
  • the embodiment of the invention further provides a computer storage medium, wherein the computer storage medium stores computer executable instructions, and the computer executable instructions are used to execute the method for implementing service collaborative scheduling according to the embodiment of the invention.
  • FIG. 10 is a schematic diagram of a composition of a computing board according to an embodiment of the present invention.
  • the computing board includes: an obtaining module 401, a storage module 402, a first receiving module 403, a selecting module 404, and a first sending module 405;
  • the obtaining module 401 is configured to obtain CPU utilization information of the communication board.
  • the storage module 402 is configured to store the acquired CPU utilization information in the form of a CPU utilization form according to a preset storage condition.
  • the CPU utilization form includes at least the following combination of form items: a board subrack number, a board slot number, a CPU utilization, and whether a threshold is exceeded.
  • the preset storage condition includes storing CPU utilization information of the N pieces of communication boards with the lowest CPU utilization ranking among the communication boards; where N is a positive integer greater than or equal to 2.
  • the first receiving module 403 is configured to receive data to be processed sent by the first communication board; the first communication board is a communication board with overloaded CPU usage;
  • the selecting module 404 is configured to select the second communication board in the saved CPU utilization form according to the preset screening condition
  • the first sending module 405 is configured to send the received data to be processed to the second communications board.
  • the computing board further includes a second receiving module 406 and a forwarding module 407;
  • the second receiving module 406 is configured to receive a processing result of the feedback of the second communication board
  • the forwarding module 407 is configured to forward the processing result to the first communication board.
  • the computing board further includes a second sending module 408 and a third receiving module 409;
  • the second sending module 408 is configured to send a processing request to the second communications board.
  • the third receiving module 409 is configured to receive a processing request response fed back by the second communication board.
  • the acquiring module 401 when the computing board is attached to the communication board, the acquiring module 401 includes a monitoring unit 4011 and an obtaining unit 4012, where the communication board is the One of the communication boards; among them,
  • the monitoring unit 4011 is configured to periodically monitor CPU utilization information of the communication board
  • the obtaining unit 4012 is configured to obtain CPU utilization information of other communication boards except the communication board by receiving a broadcast message.
  • the storage module 402 includes an initialization unit 4021, a storage unit 4022, a counting unit 4023, a sorting unit 4024, a matching unit 4025, a determining unit 4026, and an updating unit 4027;
  • the initializing unit 4021 is configured to initialize each form item in the CPU utilization form
  • the storage unit 4022 is configured to save the CPU utilization information of the obtained communication board one by one in the CPU utilization form.
  • the counting unit 4023 is configured to count the communication boards corresponding to the CPU utilization information stored in the CPU utilization form;
  • the sorting unit 4024 is configured to be the number of communication boards recorded by the counting unit 4023. When there are N, the CPU utilization form is sorted according to CPU utilization; and is also used to reorder the updated CPU utilization form;
  • the matching unit 4025 is configured to: when the CPU utilization information of the N+1th communication board is obtained, the board subrack number and the board slot number in the CPU utilization information are sorted. Matching comparison of corresponding form items in the CPU utilization form;
  • the determining unit 4026 is configured to use the CPU according to the CPU when the board subrack number and the board slot number in the CPU utilization information match the corresponding form items in the sorted CPU utilization form. Rate information determines whether the CPU utilization of the communication board exceeds a threshold;
  • the updating unit 4027 is configured to update the sorted CPU utilization form according to the CPU utilization information when the CPU utilization of the communication board does not exceed the threshold.
  • the storage module further includes a comparison unit 4028;
  • the determining unit 4026 is further configured to: when the board subrack number and the board slot number in the CPU utilization information do not match the corresponding form items in the sorted CPU utilization form, according to the CPU The usage information determines whether the CPU usage of the communication board exceeds a threshold;
  • the comparing unit 4028 is configured to compare the CPU utilization of the communication board with the CPU utilization saved in the sorted CPU utilization form when the CPU utilization of the communication board does not exceed the threshold. ;
  • the updating unit 4027 is further configured to replace, by using the CPU utilization information of the communication board, when the CPU usage of the communication board is lower than the CPU usage saved in the sorted CPU utilization form. Update the sorted CPU utilization form and reorder the updated CPU utilization form in the same way as the CPU utilization information of the communication board with the highest CPU utilization in the sorted CPU utilization form.
  • Each module in the computing board provided by the embodiment of the present invention, and the unit included in the module may be implemented by calculating a processor in the board, or may be implemented by using a specific logic circuit; For example, in practical applications, it can be a Central Processing Unit (CPU), a Micro Processor Unit (MPU), a Digital Signal Processor (DSP), or a Field Programmable Gate Array (Field).
  • CPU Central Processing Unit
  • MPU Micro Processor Unit
  • DSP Digital Signal Processor
  • FPGA Field Programmable Gate Array
  • the counting unit can also be implemented by a counter in the computing board
  • the storage unit can also be implemented by a memory in the computing board.
  • embodiments of the present invention can be provided as a method, system, or computer program product. Accordingly, the present invention can take the form of a hardware embodiment, a software embodiment, or a combination of software and hardware. Moreover, the invention can take the form of a computer program product embodied on one or more computer-usable storage media (including but not limited to disk storage and optical storage, etc.) including computer usable program code.
  • the computer program instructions can also be stored in a computer readable memory that can direct a computer or other programmable data processing device to operate in a particular manner, such that the instructions stored in the computer readable memory produce an article of manufacture comprising the instruction device.
  • the apparatus implements the functions specified in one or more blocks of a flow or a flow and/or block diagram of the flowchart.
  • These computer program instructions can also be loaded onto a computer or other programmable data processing device such that A series of operational steps are performed on a computer or other programmable device to produce computer-implemented processing such that instructions executed on a computer or other programmable device are provided for implementing one or more processes and/or block diagrams in the flowchart The steps of a function specified in a box or multiple boxes.
  • the board calculates the CPU utilization information of the communication board, and stores the acquired CPU utilization information in the form of a CPU utilization form according to the preset storage condition;
  • the data communication board sends the data to be processed, and the first communication board is a communication board with an overloaded CPU usage; the second communication board is selected in the saved CPU utilization form according to the preset screening condition;
  • the received data to be processed is sent to the second communication board.
  • the coordinated scheduling of the amount of data to be processed between the communication boards can be realized, and the resource utilization rate can be improved.
  • the communication interface blocking or the configuration operation failure caused by the overload of the data processing capability of a certain communication board can be effectively avoided. problem.

Landscapes

  • Debugging And Monitoring (AREA)
  • Mobile Radio Communication Systems (AREA)
  • Hardware Redundancy (AREA)

Abstract

本发明实施例提供一种实现业务协同调度的方法、计算单板及计算机存储介质，所述方法包括：获取通信单板的CPU利用率信息；根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；接收第一通信单板发送的待处理数据；所述第一通信单板为CPU利用率超负荷的通信单板；根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；将所接收的待处理数据发送给所述第二通信单板。

Description

一种实现业务协同调度的方法、计算单板及存储介质 技术领域
本发明涉及光通信领域中的数据处理技术，尤其涉及一种实现业务协同调度的方法、计算单板及计算机存储介质。
背景技术
随着光通信的不断发展，通信设备的业务速率不断提高，对通信设备中通信单板的处理能力提出更高的要求。在目前的通信设备中，各通信单板之间相互独立，每块通信单板只负责处理自身的信号。由于受到自身中央处理器(Central Processing Unit，CPU)对应运算速度的限制，当某块通信单板的数据处理能力超负荷时，CPU利用率超过90％，若所述通信单板收到网络管理器下发的一些配置命令，则所述通信单板很有可能无法及时对所接收的配置命令作出响应，这样将导致通信设备的通信接口阻塞或者配置操作失败；而其他通信单板可能处理的数据量小，CPU利用率偏低，从而造成资源浪费。
发明内容
本发明实施例提供一种实现业务协同调度的方法、计算单板及计算机存储介质，能够实现各通信单板之间待处理数据量的协同调度，提高资源利用率。
本发明实施例的技术方案是这样实现的：
本发明实施例提供一种实现业务协同调度的方法，应用于计算单板，该方法包括：
获取通信单板的CPU利用率信息；
根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；
接收第一通信单板发送的待处理数据；所述第一通信单板为CPU利用率超负荷的通信单板；
根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；
将所接收的待处理数据发送给所述第二通信单板。
上述方案中，所述方法还包括：
接收所述第二通信单板反馈的处理结果，并向所述第一通信单板转发所述处理结果。
上述方案中，在所述将所接收的待处理数据发送给所述第二通信单板之前，所述方法还包括：
向所述第二通信单板发送处理请求；
接收所述第二通信单板反馈的处理请求响应。
上述方案中，当所述计算单板附着于本通信单板时，所述获取通信单板的CPU利用率信息，包括：
定时监测本通信单板CPU利用率信息；
通过接收广播消息的方式获取除本通信单板之外的其他通信单板的CPU利用率信息；所述本通信单板为所述各通信单板之一。
上述方案中，当所述计算单板不附着于任一通信单板时，所述获取通信单板的CPU利用率信息，包括：
通过接收广播消息的方式获取通信单板的CPU利用率信息。
上述方案中，所述CPU利用率表单至少包括如下表单项组合：单板子架号、单板槽位号、CPU利用率、以及是否超过阈值。
上述方案中，所述预设存储条件包括存储各通信单板中CPU利用率排序最低的N块通信单板的CPU利用率信息；其中，N为大于等于2的正整 数。
上述方案中，所述以CPU利用率表单的形式存储所获取的CPU利用率信息，包括：
初始化CPU利用率表单中的各个表单项；
逐一将获取的通信单板的CPU利用率信息保存在所述CPU利用率表单中；
当所述CPU利用率表单中存满N个通信单板的CPU利用率信息时，依据CPU利用率对所述CPU利用率表单进行排序；
当获取到第N+1个通信单板的CPU利用率信息时，将所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项进行匹配比较；
当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项相匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
当所述通信单板的CPU利用率未超过阈值时，根据所述CPU利用率信息更新已排序的CPU利用率表单，并对更新后的CPU利用率表单重新排序。
上述方案中，当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项不匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
当所述通信单板的CPU利用率未超过阈值时，将所述通信单板的CPU利用率与已排序的CPU利用率表单中所保存的CPU利用率进行比较；
当所述通信单板的CPU利用率低于已排序的CPU利用率表单中所保存的CPU利用率时，则通过所述通信单板的CPU利用率信息替换已排序的CPU利用率表单中CPU利用率最高的通信单板对应的CPU利用率信息的方式更新已排序的CPU利用率表单，并对更新后的CPU利用率表单重新排 序。
本发明实施例还提供一种计算机存储介质，所述计算机存储介质中存储有计算机可执行指令，所述计算机可执行指令配置为执行本发明实施例所述实现业务协同调度的方法。
本发明实施例还提供一种计算单板，所述计算单板包括获取模块、存储模块、第一接收模块、选取模块、以及第一发送模块；
所述获取模块，配置为获取通信单板的CPU利用率信息；
所述存储模块，配置为根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；
所述第一接收模块，配置为接收第一通信单板发送的待处理数据；所述第一通信单板为CPU利用率超负荷的通信单板；
所述选取模块，配置为根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；
所述第一发送模块，配置为将所接收的待处理数据发送给所述第二通信单板。
上述方案中，所述计算单板还包括第二接收模块和转发模块；
所述第二接收模块，配置为接收所述第二通信单板反馈的处理结果；以及
所述转发模块，配置为向所述第一通信单板转发所述处理结果。
上述方案中，所述计算单板还包括第二发送模块和第三接收模块；其中，
所述第二发送模块，配置为向所述第二通信单板发送处理请求；
所述第三接收模块，配置为接收所述第二通信单板反馈的处理请求响应。
上述方案中，当所述计算单板附着于本通信单板时，所述本通信单板 为所述各通信单板之一，所述获取模块包括监测单元和获取单元，其中，
所述监测单元，配置为定时监测本通信单板CPU利用率信息；
所述获取单元，配置为通过接收广播消息的方式获取除本通信单板之外的其他通信单板的CPU利用率信息。
上述方案中，当所述计算单板不附着于任一通信单板时，所述获取模块配置为，通过接收广播消息的方式获取通信单板的CPU利用率信息。
上述方案中，所述CPU利用率表单至少包括如下表单项组合：单板子架号、单板槽位号、CPU利用率、以及是否超过阈值。
上述方案中，所述预设存储条件包括存储各通信单板中CPU利用率排序最低的N块通信单板的CPU利用率信息；其中，N为大于等于2的正整数。
上述方案中，所述存储模块包括初始化单元、存储单元、计数单元、排序单元、匹配单元、确定单元和更新单元；其中，
所述初始化单元，配置为初始化CPU利用率表单中的各个表单项；
所述存储单元，配置为逐一将获取的通信单板的CPU利用率信息保存在所述CPU利用率表单中；
所述计数单元，配置为对所述CPU利用率表单中所存储的CPU利用率信息对应的通信单板进行计数；
所述排序单元，配置为当所述计数单元所记录的通信单板数为N个时，依据CPU利用率对所述CPU利用率表单进行排序；还用于对更新后的CPU利用率表单重新排序；
所述匹配单元，配置为当获取到第N+1个通信单板的CPU利用率信息时，将所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项进行匹配比较；
所述确定单元，配置为当所述CPU利用率信息中的单板子架号和单板 槽位号与已排序的CPU利用率表单中的对应表单项相匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
所述更新单元，配置为当所述通信单板的CPU利用率未超过阈值时，根据所述CPU利用率信息更新已排序的CPU利用率表单。
上述方案中，所述存储模块还包括比较单元；其中，
所述确定单元，还配置为当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项不匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
所述比较单元，配置为当所述通信单板的CPU利用率未超过阈值时，将所述通信单板的CPU利用率与已排序的CPU利用率表单中所保存的CPU利用率进行比较；
所述更新单元，还配置为当所述通信单板的CPU利用率低于已排序的CPU利用率表单中所保存的CPU利用率时，则通过所述通信单板的CPU利用率信息替换已排序的CPU利用率表单中CPU利用率最高的通信单板对应的CPU利用率信息的方式更新已排序的CPU利用率表单，并对更新后的CPU利用率表单重新排序。
本发明实施例所提供的实现业务协同调度的方法、计算单板及计算机存储介质，获取通信单板的CPU利用率信息；根据预设存储条件以CPU利用率表单的形式存储所获取的CPU利用率信息；接收第一通信单板发送的待处理数据，所述第一通信单板为CPU利用率超负荷的通信单板；根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；将所接收的待处理数据发送给所述第二通信单板。如此，能够实现各通信单板之间待处理数据量的协同调度，提高资源利用率；同时，有效避免因某块通信单板的数据处理能力超负荷所导致的通信接口阻塞或者配置操作失败的问题。
附图说明
图1为本发明实施例实现业务协同调度的方法的流程示意图一；
图2为本发明实施例通信单板间的通信消息结构示意图；
图3为本发明实施例以CPU利用率表单的形式存储所获取的CPU利用率信息的流程示意图；
图4为本发明实施例初始化时CPU利用率表单在组成结构示意图；
图5为本发明实施例已排序的CPU利用率表单的组成结构示意图；
图6为本发明实施例实现业务协同调度的方法的流程示意图二；
图7为本发明一应用实例实现业务协同调度的方法的流程示意图；
图8为本发明如图7所示应用实例中所获取的各通信单板的CPU利用率示意图；
图9为本发明如图7所示应用实例中已排序的CPU利用率表单；
图10为本发明实施例计算单板的组成结构示意图一；
图11为本发明实施例计算单板的组成结构示意图二；
图12为本发明实施例所述获取模块的组成结构示意图；
图13为本发明实施例所述存储模块的组成结构示意图。
具体实施方式
在本发明实施例中，获取通信单板的CPU利用率信息；根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；接收第一通信单板发送的待处理数据，所述第一通信单板为CPU利用率超负荷的通信单板；根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；将所接收的待处理数据发送给所述第二通信单板。
这里，所述通信单板的CPU利用率信息包括单板子架号、单板槽位号、CPU利用率、以及是否超过阈值等。
下面结合附图及具体实施例对本发明再作进一步详细的说明。
实施例一
图1为本发明实施例实现业务协同调度的方法的流程示意图一，应用于计算单板，如图1所示，本发明实施例实现业务协同调度的方法包括：
步骤S101：获取通信单板的CPU利用率信息；
这里，当所述计算单板附着于本通信单板时，所述获取通信单板的CPU利用率信息，包括：定时监测本通信单板CPU利用率信息；通过接收广播消息的方式获取除本通信单板之外的其他通信单板的CPU利用率信息；其中，所述本通信单板为所述各通信单板之一。
这里，当所述计算单板不附着于任一通信单板时，即在整个机架中插入一块计算单板，此时，所述获取通信单板的CPU利用率信息，包括：
通过接收广播消息的方式获取通信单板的CPU利用率信息。
需要说明的是，在本发明实施例中，所述广播消息所对应的消息结构可以采用通信单板间的通信消息结构。
具体地，如图2所示，所述通信单板间的通信消息结构包括“报文头”和“报文体”两部分；其中，所述“报文头”包含如下内容：
1)板间通信版本：用于标识所述计算单板的软件版本；
2)信息体长度：用于标识报文体长度；
3)校验和：存放整个报文数据相加结果，用于接收端进行校验；
4)目的地址：目的地址为0xAABB格式，AA代表单板子架号，BB代表单板槽位号；
5)源地址：源地址为0xAABB格式，AA代表单板子架号，BB代表单板槽位号；
6)消息类型：消息类型用于区分该报文类型，包括广播消息报文、处理请求报文、处理请求响应报文、处理结果反馈报文、待处理数据发送报文等；其中，所述处理请求响应报文包括处理请求应答报文和处理请求拒 绝报文。
步骤S102：根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；
其中，所述CPU利用率表单至少包括如下表单项组合：单板子架号、单板槽位号、CPU利用率、以及是否超过阈值。
这里，所述预设存储条件包括存储各通信单板中CPU利用率排序最低的N块通信单板的CPU利用率信息；其中，N为大于等于2的正整数。
在一实施例中，如图3所示，以N取值为3，即所述预设存储条件包括存储各通信单板中CPU利用率排序最低的3块通信单板的CPU利用率信息为例，所述以CPU利用率表单的形式存储所获取的CPU利用率信息，包括：
步骤S1021：初始化CPU利用率表单中的各个表单项；
具体地，如图4所示，在初始化过程中，将所述CPU利用率表单中的所有表单项全部设置为默认字符“null(空)”。
步骤S1022：逐一将获取的通信单板的CPU利用率信息保存在所述CPU利用率表单中；
步骤S1023：当所述CPU利用率表单中存满N个通信单板的CPU利用率信息时，依据CPU利用率对所述CPU利用率表单进行排序；
具体地，如图5所示，以N取值为3为例，当所述CPU利用率表单中存满3个通信单板的CPU利用率信息时，依据CPU利用率对所述CPU利用率表单进行排序后，所得到的已排序的CPU利用率表单的组成结构如图5所示。
这里，所述对所述CPU利用率表单进行排序可以包括按照CPU利用率从低到高排序表单；也可以包括按照CPU利用率从高到低排序表单。
步骤S1024：当获取到第N+1个通信单板的CPU利用率信息时，将所 述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项进行匹配比较；
这里，当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项相匹配时，执行步骤S1025a～S1025b；当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项不匹配时，执行步骤S1026a～S1026c；
步骤S1025a：根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
步骤S1025b：当所述通信单板的CPU利用率未超过阈值时，根据所述CPU利用率信息更新已排序的CPU利用率表单，并对更新后的CPU利用率表单重新排序。
这里，需要补充说明的是，当所述通信单板的CPU利用率超过阈值时，则直接删除已排序的CPU利用率表单中已保存的所述通信单板的CPU利用率信息，将所对应的表单项设置为默认字符“null”。
步骤S1026a：根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
步骤S1026b：当所述通信单板的CPU利用率未超过阈值时，将所述通信单板的CPU利用率与已排序的CPU利用率表单中所保存的CPU利用率进行比较；
这里，需要补充说明的是，当所述通信单板的CPU利用率超过阈值时，则舍弃所获取的第N+1个通信单板的CPU利用率信息，不对已排序的CPU利用率表单作任何处理。
步骤S1026c：当所述通信单板的CPU利用率低于已排序的CPU利用率表单中所保存的CPU利用率时，则通过所述通信单板的CPU利用率信息替换已排序的CPU利用率表单中CPU利用率最高的通信单板对应的CPU 利用率信息的方式更新已排序的CPU利用率表单，并对更新后的CPU利用率表单重新排序。
这里，需要补充说明的是，当所述通信单板的CPU利用率不低于已排序的CPU利用率表单中所保存的CPU利用率时，则舍弃所获取的第N+1个通信单板的CPU利用率信息，不对已排序的CPU利用率表单作任何处理。
如此，在后续计算单板接收到的除已处理的N+1块通信单板之外的其他任一通信单板的CPU利用率信息时，循环执行前述步骤S102中的步骤S1022至步骤S1026，得以保证CPU利用率表单中保存有CPU利用率最低的N块通信单板的单板子架号、单板槽位号、CPU利用率、以及是否超过阈值等CPU利用率信息。
步骤S103：接收第一通信单板发送的待处理数据；所述第一通信单板为CPU利用率超负荷的通信单板；
这里，需要补充说明的是，当整个机架中存在第一通信单板的CPU利用率超负荷时，所述第一通信单板会向所述计算单板发送处理请求报文，所述处理请求报文的消息结构如图2所示，其中，所述“报文体”中包含有待处理数据。这样，当所述计算单板接收第一通信单板发送的待处理数据后，即可执行后续步骤S104。
步骤S104：根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；
这里，所述预设筛选条件通常为已保存的CPU利用率表单中CPU利用率最低的表单项所对应的通信单板；相应地，所述计算单板在已保存的CPU利用率表单中筛选出CPU利用率最低的表单项所对应的通信单板，作为第二通信单板。
步骤S105：将所接收的待处理数据发送给所述第二通信单板。
这里，需要补充说明的是，所述计算单板通过发送处理请求报文的方 式向第二通信单板发送待处理数据；所述处理请求报文的消息结构如图2所示，其中，所述“报文体”中包含有待处理数据。
相应地，当所述第二通信单板接收到所述待处理数据后，通过自身的CPU对待处理数据执行相应的处理操作，以获得相应的处理结果并向所述计算单板反馈所述处理结果。
在一实施例中，本发明实施例所述实现业务协同调度的方法还可以包括：
步骤S106：接收所述第二通信单板反馈的处理结果，并向所述第一通信单板转发所述处理结果。
具体地，所述计算单板接收所述第二通信单板反馈的处理结果，并通过向所述第一通信单板发送处理结果反馈报文的方式向第二通信单板发送待处理数据；所述处理结果反馈报文的消息结构如图2所示，其中，所述“报文体”中包含有处理结果。
如此，通过本发明实施例所述实现业务协同调度的方法，能够实现各通信单板之间待处理数据量的协同调度，提高资源利用率；同时，有效避免因某块通信单板的数据处理能力超负荷所导致的通信接口阻塞或者配置操作失败的问题。
本发明实施例还提供一种计算机存储介质，所述计算机存储介质中存储有计算机可执行指令，所述计算机可执行指令配置为执行本发明实施例所述实现业务协同调度的方法。
实施例二
图6为本发明实施例实现业务协同调度的方法的流程示意图二，应用于计算单板，如图6所示，本发明实施例实现业务协同调度的方法包括：
步骤S101：获取通信单板的CPU利用率信息；
这里，当所述计算单板附着于本通信单板时，所述获取通信单板的CPU 利用率信息，包括：定时监测本通信单板CPU利用率信息；通过接收广播消息的方式获取除本通信单板之外的其他通信单板的CPU利用率信息；其中，所述本通信单板为所述各通信单板之一。
这里，当所述计算单板不附着于任一通信单板时，即在整个机架中插入一块计算单板，此时，所述获取通信单板的CPU利用率信息，包括：
通过接收广播消息的方式获取通信单板的CPU利用率信息。
需要说明的是，在本发明实施例中，所述广播消息所对应的消息结构可以采用通信单板间的通信消息结构。
具体地，如图2所示，所述通信单板间的通信消息结构包括“报文头”和“报文体”两部分；其中，所述“报文头”包含如下内容：
1)板间通信版本：用于标识所述计算单板的软件版本；
2)信息体长度：用于标识报文体长度；
3)校验和：存放整个报文数据相加结果，用于接收端进行校验；
4)目的地址：目的地址为0xAABB格式，AA代表单板子架号，BB代表单板槽位号；
5)源地址：源地址为0xAABB格式，AA代表单板子架号，BB代表单板槽位号；
6)消息类型：消息类型用于区分该报文类型，包括广播消息报文、处理请求报文、处理请求响应报文、处理结果反馈报文、待处理数据发送报文等；其中，所述处理请求响应报文包括处理请求应答报文和处理请求拒绝报文。
步骤S102：根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；
其中，所述CPU利用率表单至少包括如下表单项组合：单板子架号、单板槽位号、CPU利用率、以及是否超过阈值。
这里，所述预设存储条件包括存储各通信单板中CPU利用率排序最低的N块通信单板的CPU利用率信息；其中，N为大于等于2的正整数。
在本发明实施例中，步骤S102的具体实现过程与本发明实施例一中步骤S102的实现过程相类似，因此不再赘述。
步骤S103：接收第一通信单板发送的待处理数据；所述第一通信单板为CPU利用率超负荷的通信单板；
这里，需要补充说明的是，当整个机架中存在第一通信单板的CPU利用率超负荷时，所述第一通信单板会向所述计算单板发送处理请求报文，所述处理请求报文的消息结构如图2所示，其中，所述“报文体”中包含有待处理数据。这样，当所述计算单板接收第一通信单板发送的待处理数据后，即可执行后续步骤S104。
步骤S104：根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；
这里，所述预设筛选条件通常为已保存的CPU利用率表单中CPU利用率最低的表单项所对应的通信单板；相应地，所述计算单板在已保存的CPU利用率表单中筛选出CPU利用率最低的表单项所对应的通信单板，作为第二通信单板。
步骤S201：向所述第二通信单板发送处理请求；
这里，需要补充说明的是，所述计算单板会通过发送处理请求报文的方式向第二通信单板发送所述处理请求报文；进一步地，当所述第二通信单板接收到所述处理请求时，会通过处理请求响应报文的方式向所述计算单板反馈接受或拒绝类型的处理请求响应。其中，所述处理请求报文的消息结构如图2所示，其中，所述“报文体”可以为空信息；所述处理请求响应报文的消息结构如图2所示，其中，所述“报文体”可以包含接受或拒绝信息。
步骤S202：接收所述第二通信单板反馈的处理请求响应。
这里，所述计算单板接收所述第二通信单板反馈的处理请求响应；当所述处理请求响应为接受类型的处理请求响应时，继续执行后续步骤S105。
这里，需要补充说明的是，当所述处理请求响应为拒绝类型的处理请求响应时，所述计算单板可以根据预设规则重新选取第三通信单板；所述第三通信单板为已排序的CPU利用率表单中CPU利用率次低的表单项所对应的通信单板。之后，将所述第三通信单板作为第二通信单板，继续执行步骤S201～S202。
步骤S105：将所接收的待处理数据发送给所述第二通信单板；
这里，需要补充说明的是，所述计算单板通过发送处理请求报文的方式向第二通信单板发送待处理数据；所述处理请求报文的消息结构如图2所示，其中，所述“报文体”中包含有待处理数据。
相应地，当所述第二通信单板接收到所述待处理数据后，通过自身的CPU对待处理数据执行相应的处理操作，以获得相应的处理结果并向所述计算单板反馈所述处理结果。
步骤S106：接收所述第二通信单板反馈的处理结果，并向所述第一通信单板转发所述处理结果。
具体地，所述计算单板接收所述第二通信单板反馈的处理结果，并通过向所述第一通信单板发送处理结果反馈报文的方式向第二通信单板发送待处理数据；所述处理结果反馈报文的消息结构如图2所示，其中，所述“报文体”中包含有处理结果。
如此，通过本发明实施例所述实现业务协同调度的方法，能够实现各通信单板之间待处理数据量的协同调度，提高资源利用率；同时，有效避免因某块通信单板的数据处理能力超负荷所导致的通信接口阻塞或者配置操作失败的问题。
需要补充说明的是，通过本发明实施例一和二所述的通过计算单板实现业务协同调度的方法，本领域技术人员还可以通过所述计算单板协助路由板完成复杂的路由协同调度过程。
本发明实施例还提供一种计算机存储介质，所述计算机存储介质中存储有计算机可执行指令，所述计算机可执行指令配置为执行本发明实施例所述实现业务协同调度的方法。
实施例三
图7为本发明一应用实例实现业务协同调度的方法的流程示意图，应用于计算单板，所述计算单板附着于本通信单板A，所述本通信单板A为所述各通信单板之一，如图7所示，本发明一应用实例实现业务协同调度的方法包括：
步骤S301：本通信单板A采集性能、告警等相关业务数据；对所采集的相关业务数据进行数据处理，得到数据处理结果；向网络管理器上报数据处理结果。
具体地，本通信单板A的数据采集配置任务模块能够通过软、硬件通信接口将从底层硬件采集的性能、告警等相关业务数据；将所采集的相关业务数据传送至数据处理任务模块；所述数据处理任务模块对所述相关业务数据进行数据处理，所述数据处理包括告警过滤、性能越限比较等分析，以及根据分析结果决定待上报的性能、告警相关数据；所述数据处理任务将所述确定的待上报的性能、告警相关数据作为数据处理结果传送至数据上报配置任务模块；再由所述数据上报配置任务模块将所述数据处理结果通过背板通信接口上报给网络管理器。
步骤S302：本通信单板A从网络管理器获取配置命令；解析所述配置命令，获得配置参数；将所述配置参数通过通信接口配置到具体硬件中。
具体地，当本通信单板A需要对硬件进行配置时，本通信单板A的数 据上报配置任务模块通过背板通信接口获取网络管理器下发的配置命令，所述配置命令中携带有配置参数；数据上报配置任务模块将所述配置命令传送给数据处理任务模块；数据处理任务模块对配置命令进行解析，获得配置参数，并将所获得的配置参数传送至数据采集配置任务模块；数据采集配置任务模块将所述配置参数通过软、硬件通信接口配置到具体硬件中。
这里，在本发明实施例中，步骤S301和S302的执行顺序不限。
步骤S303：当本通信单板A中附着的计算单板获取各通信单板的CPU利用率信息；
具体地，所述计算单板定时监测到本通信单板CPU利用率信息；同时，通过接收广播消息的方式获取除本通信单板A之外的其他通信单板，包括通信单板B、C、以及D的CPU利用率信息；其中，如图8所示，所获取的各通信单板A、B、C和D的CPU利用率信息中的CPU利用率分别为91％、55％、70％和60％。
步骤S304：根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；
具体地，通过本发明实施例一或二中步骤S102所存储的已排序的CPU利用率表单如图9所示。
步骤S305：接收本通信单板A发送的待处理数据；
这里，需要说明的是，由于本通信单板A的CPU利用率达到91％，超过阈值90％，因此本通信单板A会将未处理完的待处理数据发送至计算单板。
步骤S306：根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板B；其中，所述预设筛选条件通常为已保存的CPU利用率表单中CPU利用率最低的表单项所对应的通信单板。
这里，通过步骤S306，所述计算单板在已保存的如图8所示的CPU利 用率表单中选取出第二通信单板B。
步骤S307：计算单板将所接收的待处理数据发送给所述第二通信单板B；
步骤S308：接收所述第二通信单板B反馈的处理结果，并向所述第一通信单板A转发所述处理结果。
本发明实施例还提供一种计算机存储介质，所述计算机存储介质中存储有计算机可执行指令，所述计算机可执行指令用于执行本发明实施例所述实现业务协同调度的方法。
实施例四
图10为本发明实施例计算单板的组成结构示意图一，所述计算单板包括：获取模块401、存储模块402、第一接收模块403、选取模块404以及第一发送模块405；其中，
所述获取模块401，配置为获取通信单板的CPU利用率信息；
所述存储模块402，配置为根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；
其中，所述CPU利用率表单至少包括如下表单项组合：单板子架号、单板槽位号、CPU利用率、以及是否超过阈值。
其中，所述预设存储条件包括存储各通信单板中CPU利用率排序最低的N块通信单板的CPU利用率信息；其中，N为大于等于2的正整数。
所述第一接收模块403，配置为接收第一通信单板发送的待处理数据；所述第一通信单板为CPU利用率超负荷的通信单板；
所述选取模块404，配置为根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；
所述第一发送模块405，配置为将所接收的待处理数据发送给所述第二通信单板。
在一实施例中，如图10所示，所述计算单板还包括第二接收模块406和转发模块407；
所述第二接收模块406，配置为接收所述第二通信单板反馈的处理结果；以及
所述转发模块407，配置为向所述第一通信单板转发所述处理结果。
在一实施例中，如图11所示，所述计算单板还包括第二发送模块408和第三接收模块409；其中，
所述第二发送模块408，配置为向所述第二通信单板发送处理请求；
所述第三接收模块409，配置为接收所述第二通信单板反馈的处理请求响应。
在一实施例中，如图12所示，当所述计算单板附着于本通信单板时，所述获取模块401包括监测单元4011和获取单元4012，所述本通信单板为所述各通信单板之一；其中，
所述监测单元4011，配置为定时监测本通信单板CPU利用率信息；
所述获取单元4012，配置为通过接收广播消息的方式获取除本通信单板之外的其他通信单板的CPU利用率信息。
在一实施例中，如图13所示，所述存储模块402包括初始化单元4021、存储单元4022、计数单元4023、排序单元4024、匹配单元4025、确定单元4026和更新单元4027；其中，
所述初始化单元4021，配置为初始化CPU利用率表单中的各个表单项；
所述存储单元4022，配置为逐一将获取的通信单板的CPU利用率信息保存在所述CPU利用率表单中；
所述计数单元4023，配置为对所述CPU利用率表单中所存储的CPU利用率信息对应的通信单板进行计数；
所述排序单元4024，配置为当所述计数单元4023所记录的通信单板数 为N个时，依据CPU利用率对所述CPU利用率表单进行排序；还用于对更新后的CPU利用率表单重新排序；
所述匹配单元4025，配置为当获取到第N+1个通信单板的CPU利用率信息时，将所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项进行匹配比较；
所述确定单元4026，配置为当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项相匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
所述更新单元4027，配置为当所述通信单板的CPU利用率未超过阈值时，根据所述CPU利用率信息更新已排序的CPU利用率表单。
在一实施例中，如图13所示，所述存储模块还包括比较单元4028；其中，
所述确定单元4026，还配置为当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项不匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
所述比较单元4028，配置为当所述通信单板的CPU利用率未超过阈值时，将所述通信单板的CPU利用率与已排序的CPU利用率表单中所保存的CPU利用率进行比较；
所述更新单元4027，还配置为当所述通信单板的CPU利用率低于已排序的CPU利用率表单中所保存的CPU利用率时，则通过所述通信单板的CPU利用率信息替换已排序的CPU利用率表单中CPU利用率最高的通信单板对应的CPU利用率信息的方式更新已排序的CPU利用率表单，并对更新后的CPU利用率表单重新排序。
本发明实施例中提供的计算单板中的各模块，及模块各自包括的单元均可以通过计算单板中的处理器实现，也可以通过具体的逻辑电路实现； 比如，在实际应用中，可由中央处理器(Central Processing Unit，CPU)、微处理器(Micro Processor Unit，MPU)、数字信号处理器(Digital Signal Processor，DSP)、或现场可编程门阵列(Field Programmable Gate Array，FPGA)等实现；另外，所述计数单元也可由计算单板中的计数器实现；所述存储单元也可由计算单板中的存储器实现。
本发明实施例所记载的技术方案之间，在不冲突的情况下，可以任意组合。
本领域内的技术人员应明白，本发明的实施例可提供为方法、系统、或计算机程序产品。因此，本发明可采用硬件实施例、软件实施例、或结合软件和硬件方面的实施例的形式。而且，本发明可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器和光学存储器等)上实施的计算机程序产品的形式。
本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使 得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
以上所述，仅为本发明的具体实施方式，但本发明的保护范围并不局限于此，任何熟悉本技术领域的技术人员在本发明揭露的技术范围内，可轻易想到变化或替换，都应涵盖在本发明的保护范围之内。
工业实用性
本发明实施例所述实现业务协同调度的方法，计算单板获取通信单板的CPU利用率信息；根据预设存储条件以CPU利用率表单的形式存储所获取的CPU利用率信息；接收第一通信单板发送的待处理数据，所述第一通信单板为CPU利用率超负荷的通信单板；根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；将所接收的待处理数据发送给所述第二通信单板。如此，能够实现各通信单板之间待处理数据量的协同调度，提高资源利用率；同时，有效避免因某块通信单板的数据处理能力超负荷所导致的通信接口阻塞或者配置操作失败的问题。

Claims (19)

  1. 一种实现业务协同调度的方法，应用于计算单板，所述方法包括：
    获取通信单板的中央处理器CPU利用率信息；
    根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；
    接收第一通信单板发送的待处理数据；所述第一通信单板为CPU利用率超负荷的通信单板；
    根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；
    将所接收的待处理数据发送给所述第二通信单板。
  2. 根据权利要求1所述的方法，其中，所述方法还包括：
    接收所述第二通信单板反馈的处理结果，并向所述第一通信单板转发所述处理结果。
  3. 根据权利要求1或2所述的方法，其中，在所述将所接收的待处理数据发送给所述第二通信单板之前，所述方法还包括：
    向所述第二通信单板发送处理请求；
    接收所述第二通信单板反馈的处理请求响应。
  4. 根据权利要求3所述的方法，其中，当所述计算单板附着于本通信单板时，所述获取通信单板的CPU利用率信息，包括：
    定时监测本通信单板CPU利用率信息；
    通过接收广播消息的方式获取除本通信单板之外的其他通信单板的CPU利用率信息；所述本通信单板为所述各通信单板之一。
  5. 根据权利要求3所述的方法，其中，当所述计算单板不附着于任一通信单板时，所述获取通信单板的CPU利用率信息，包括：
    通过接收广播消息的方式获取通信单板的CPU利用率信息。
  6. 根据权利要求3所述的方法，其中，所述CPU利用率表单至少包 括如下表单项组合：单板子架号、单板槽位号、CPU利用率、以及是否超过阈值。
  7. 根据权利要求3所述的方法，其中，所述预设存储条件包括存储各通信单板中CPU利用率排序最低的N块通信单板的CPU利用率信息；其中，N为大于等于2的正整数。
  8. 根据权利要求7所述的方法，其中，所述以CPU利用率表单的形式存储所获取的CPU利用率信息，包括：
    初始化CPU利用率表单中的各个表单项；
    逐一将获取的通信单板的CPU利用率信息保存在所述CPU利用率表单中；
    当所述CPU利用率表单中存满N个通信单板的CPU利用率信息时，依据CPU利用率对所述CPU利用率表单进行排序；
    当获取到第N+1个通信单板的CPU利用率信息时，将所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项进行匹配比较；
    当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项相匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
    当所述通信单板的CPU利用率未超过阈值时，根据所述CPU利用率信息更新已排序的CPU利用率表单，并对更新后的CPU利用率表单重新排序。
  9. 根据权利要求8所述的方法，其中，当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项不匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
    当所述通信单板的CPU利用率未超过阈值时，将所述通信单板的CPU 利用率与已排序的CPU利用率表单中所保存的CPU利用率进行比较；
    当所述通信单板的CPU利用率低于已排序的CPU利用率表单中所保存的CPU利用率时，则通过所述通信单板的CPU利用率信息替换已排序的CPU利用率表单中CPU利用率最高的通信单板对应的CPU利用率信息的方式更新已排序的CPU利用率表单，并对更新后的CPU利用率表单重新排序。
  10. 一种计算单板，所述计算单板包括获取模块、存储模块、第一接收模块、选取模块、以及第一发送模块；
    所述获取模块，配置为获取通信单板的中央处理器CPU利用率信息；
    所述存储模块，配置为根据预设存储条件，以CPU利用率表单的形式存储所获取的CPU利用率信息；
    所述第一接收模块，配置为接收第一通信单板发送的待处理数据；所述第一通信单板为CPU利用率超负荷的通信单板；
    所述选取模块，配置为根据预设筛选条件在已保存的CPU利用率表单中选取第二通信单板；
    所述第一发送模块，配置为将所接收的待处理数据发送给所述第二通信单板。
  11. 根据权利要求10所述的计算单板，其中，所述计算单板还包括第二接收模块和转发模块；
    所述第二接收模块，配置为接收所述第二通信单板反馈的处理结果；
    所述转发模块，配置为向所述第一通信单板转发所述处理结果。
  12. 根据权利要求10或11所述的计算单板，其中，所述计算单板还包括第二发送模块和第三接收模块；
    所述第二发送模块，配置为向所述第二通信单板发送处理请求；
    所述第三接收模块，配置为接收所述第二通信单板反馈的处理请求响 应。
  13. 根据权利要求12所述的计算单板，其中，当所述计算单板附着于本通信单板时，所述本通信单板为所述各通信单板之一，所述获取模块包括监测单元和获取单元；
    所述监测单元，配置为定时监测本通信单板CPU利用率信息；
    所述获取单元，配置为通过接收广播消息的方式获取除本通信单板之外的其他通信单板的CPU利用率信息。
  14. 根据权利要求12所述的计算单板，其中，当所述计算单板不附着于任一通信单板时，所述获取模块配置为，
    通过接收广播消息的方式获取通信单板的CPU利用率信息。
  15. 根据权利要求12所述的计算单板，其中，所述CPU利用率表单至少包括如下表单项组合：单板子架号、单板槽位号、CPU利用率、以及是否超过阈值。
  16. 根据权利要求12所述的计算单板，其中，所述预设存储条件包括存储各通信单板中CPU利用率排序最低的N块通信单板的CPU利用率信息；其中，N为大于等于2的正整数。
  17. 根据权利要求16所述的计算单板，其中，所述存储模块包括初始化单元、存储单元、计数单元、排序单元、匹配单元、确定单元和更新单元；
    所述初始化单元，配置为初始化CPU利用率表单中的各个表单项；
    所述存储单元，配置为逐一将获取的通信单板的CPU利用率信息保存在所述CPU利用率表单中；
    所述计数单元，配置为对所述CPU利用率表单中所存储的CPU利用率信息对应的通信单板进行计数；
    所述排序单元，配置为当所述计数单元所记录的通信单板数为N个时， 依据CPU利用率对所述CPU利用率表单进行排序；还用于对更新后的CPU利用率表单重新排序；
    所述匹配单元，配置为当获取到第N+1个通信单板的CPU利用率信息时，将所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项进行匹配比较；
    所述确定单元，配置为当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项相匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
    所述更新单元，配置为当所述通信单板的CPU利用率未超过阈值时，根据所述CPU利用率信息更新已排序的CPU利用率表单。
  18. 根据权利要求17所述的计算单板，其中，所述存储模块还包括比较单元；
    所述确定单元，还配置为当所述CPU利用率信息中的单板子架号和单板槽位号与已排序的CPU利用率表单中的对应表单项不匹配时，根据所述CPU利用率信息确定所述通信单板的CPU利用率是否超过阈值；
    所述比较单元，配置为当所述通信单板的CPU利用率未超过阈值时，将所述通信单板的CPU利用率与已排序的CPU利用率表单中所保存的CPU利用率进行比较；
    所述更新单元，还配置为当所述通信单板的CPU利用率低于已排序的CPU利用率表单中所保存的CPU利用率时，则通过所述通信单板的CPU利用率信息替换已排序的CPU利用率表单中CPU利用率最高的通信单板对应的CPU利用率信息的方式更新已排序的CPU利用率表单，并对更新后的CPU利用率表单重新排序。
  19. 一种计算机存储介质，所述计算机存储介质中存储有计算机可执行指令，所述计算机可执行指令用于执行权利要求1至9任一项所述实现 业务协同调度的方法。
PCT/CN2015/091675 2014-12-08 2015-10-10 一种实现业务协同调度的方法、计算单板及存储介质 WO2016091003A1 (zh)

Applications Claiming Priority (2)

Application Number Priority Date Filing Date Title
CN201410742634.4A CN105743802B (zh) 2014-12-08 2014-12-08 一种实现业务协同调度的方法及计算单板
CN201410742634.4 2014-12-08

Publications (1)

Publication Number Publication Date
WO2016091003A1 true WO2016091003A1 (zh) 2016-06-16

Family

ID=56106639

Family Applications (1)

Application Number Title Priority Date Filing Date
PCT/CN2015/091675 WO2016091003A1 (zh) 2014-12-08 2015-10-10 一种实现业务协同调度的方法、计算单板及存储介质

Country Status (2)

Country Link
CN (1) CN105743802B (zh)
WO (1) WO2016091003A1 (zh)

Families Citing this family (2)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN110764922A (zh) * 2018-07-25 2020-02-07 中兴通讯股份有限公司 一种数据的处理方法、单板和计算机存储介质
CN116204327B (zh) * 2023-05-06 2023-08-01 阿里巴巴（中国）有限公司 分布式系统通信调度方法及分布式机器学习系统

Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2008225641A (ja) * 2007-03-09 2008-09-25 Nec Corp コンピュータシステム、割り込み制御方法及びプログラム
CN101741912A (zh) * 2009-12-30 2010-06-16 中兴通讯股份有限公司 一种处理计算任务的方法、网络设备及分布式网络系统
CN103108334A (zh) * 2011-11-10 2013-05-15 中兴通讯股份有限公司 一种射频拉远系统的系统负荷动态调整方法

Patent Citations (3)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
JP2008225641A (ja) * 2007-03-09 2008-09-25 Nec Corp コンピュータシステム、割り込み制御方法及びプログラム
CN101741912A (zh) * 2009-12-30 2010-06-16 中兴通讯股份有限公司 一种处理计算任务的方法、网络设备及分布式网络系统
CN103108334A (zh) * 2011-11-10 2013-05-15 中兴通讯股份有限公司 一种射频拉远系统的系统负荷动态调整方法

Also Published As

Publication number Publication date
CN105743802B (zh) 2020-02-14
CN105743802A (zh) 2016-07-06

Similar Documents

Publication Publication Date Title
US10915822B2 (en) Complex event processing method, apparatus, and system
US9967188B2 (en) Network traffic flow management using machine learning
US9888048B1 (en) Supporting millions of parallel light weight data streams in a distributed system
EP3281369B1 (en) Server load balancing
US9560119B2 (en) Elastic scale out policy service
CN105721535A (zh) 对服务功能链中的服务功能的并行处理
US20150222516A1 (en) Techniques Associated with Server Transaction Latency Information
CN111147403B (zh) 报文的处理方法及装置、存储介质和电子装置
CN111338787B (zh) 一种数据处理方法及装置、存储介质、电子装置
CN103607302A (zh) 故障信息上报方法、监控设备及管理设备
CN104618253A (zh) 一种动态变更的传输报文处理方法和装置
CN105379210B (zh) 一种数据流处理方法及装置
CN107547301A (zh) 一种主备设备倒换方法及装置
WO2016091003A1 (zh) 一种实现业务协同调度的方法、计算单板及存储介质
CN104052679A (zh) 网络流量的负载均衡方法和装置
CN110620722A (zh) 一种订单处理的方法和装置
CN114938376A (zh) 基于优先级处理数据的工业物联网及其控制方法
CN109684091A (zh) 一种任务处理方法及装置
US9535868B1 (en) Apparatus and method for network traffic classification and policy enforcement
US10560527B2 (en) Network service chains using hardware logic devices in an information handling system
JP2015207921A (ja) トラフィック情報収集システムおよび収集制御ノード
CN110209475B (zh) 数据采集方法及装置
CN103368862B (zh) 一种负载均衡调度方法和负载均衡调度装置
CN109033189B (zh) 链路结构日志的压缩方法、装置、服务器及可读存储介质
CN111708676A (zh) 实例集群的监控方法、装置和服务器

Legal Events

Date Code Title Description
121 Ep: the epo has been informed by wipo that ep was designated in this application

Ref document number: 15868221

Country of ref document: EP

Kind code of ref document: A1

NENP Non-entry into the national phase

Ref country code: DE

122 Ep: pct application non-entry in european phase

Ref document number: 15868221

Country of ref document: EP

Kind code of ref document: A1