CN-122001846-A - Message hierarchical notification method, system, equipment, medium and product

CN122001846ACN 122001846 ACN122001846 ACN 122001846ACN-122001846-A

Abstract

The invention discloses a message grading notification method, a system, equipment, a medium and a product, which belong to the technical field of communication, wherein the method comprises the steps of acquiring the running state of each processing unit for a first service message with service priority smaller than a preset grade, calculating to obtain a first evaluation value, and dynamically adjusting the acquisition parameters of the processing units according to the first evaluation value; the method comprises the steps of determining the actual parameters of the processing unit in the first window, calculating to obtain a second evaluation value based on the actual parameters and the acquired parameters, controlling the proxy unit to conduct hierarchical regulation and control on the processing unit according to the second evaluation value, and when the service priority is greater than or equal to a second service message of a preset level, controlling the proxy unit to send the message notification of the second service message to the processing unit through a target channel.

Inventors

XIE SHANYI
ZHANG KAI
ZHOU GANG
CHEN YUZE
YANG QIANG
ZHANG JUNQUAN

Assignees

广东电网有限责任公司电力科学研究院

Dates

Publication Date: 20260508
Application Date: 20260210

Claims (10)

1. A method for hierarchical messaging notification comprising: When a message sending unit sends a first service message to a message proxy unit, acquiring running state data of each message processing unit, calculating a first evaluation value of the message processing unit in real time according to the running state data, and dynamically adjusting message acquisition parameters of the message processing unit according to the first evaluation value; Controlling the message processing unit to send a message acquisition request to the message proxy unit based on the message acquisition parameters, determining actual acquisition parameters of the message processing unit in a first preset time window, dynamically calculating to obtain a second evaluation value of the message processing unit based on the actual acquisition parameters and the message acquisition parameters, determining a target regulation scheme of the message proxy unit to the message processing unit according to the second evaluation value and a preset hierarchical regulation strategy, and sending a message notification of the first service message to the message processing unit based on the target regulation scheme; When the message sending unit sends a second service message to the message proxy unit, the message proxy unit is controlled to send a message notification of the second service message to the message processing unit through a target channel, wherein the service priority of the first service message is smaller than that of the second service message.
2. The message hierarchical notification method according to claim 1, wherein the operation state data includes historical operation data and real-time operation data within a second preset time window, and the first evaluation value of the message processing unit is calculated in real time according to the operation state data, specifically: for each evaluation index, carrying out standardization processing on the real-time operation data according to the historical operation data corresponding to each evaluation index to obtain a standard value at each moment; Performing linear regression analysis on each standard value to obtain a trend prediction factor corresponding to each evaluation index; Acquiring a trend weight factor, determining a weight coefficient corresponding to the evaluation index according to the priority of the power service, weighting each standard value, the trend weight factor and the trend prediction factor according to the weight coefficient at each moment, and fusing the weighted result of each evaluation index to obtain a first initial evaluation value corresponding to each moment; And carrying out normalization processing on each first initial evaluation value to obtain the first evaluation value.
3. The message classification notification method according to claim 2, wherein the standardized processing is performed on the real-time operation data according to the historical operation data corresponding to each evaluation index to obtain standard values at each time, specifically: calculating the historical operation data corresponding to each evaluation index to obtain an average value and a standard deviation; And carrying out standardized calculation on the real-time operation data by a Z-score method according to the average value and the standard deviation to obtain the standard value corresponding to the evaluation index.
4. The message hierarchical notification method according to claim 1, wherein the message acquisition parameters include an acquisition period and a corresponding message amount acquired each time, and the message acquisition parameters of the message processing unit are dynamically adjusted according to the first evaluation value, specifically: When the first evaluation value is larger than a preset acceleration threshold value, the message processing unit is controlled to add a message acquisition request to the message proxy unit at the current moment, or a first coefficient is obtained by dynamic calculation according to the difference value between the first evaluation value and the acceleration threshold value, and the acquisition period is adjusted according to the first coefficient to obtain an adjusted message acquisition parameter; And when the first evaluation value is smaller than a preset throttling threshold value, dynamically calculating to obtain a second coefficient according to the difference value between the first evaluation value and the throttling threshold value, adjusting the acquisition period based on the second coefficient, and adjusting the message quantity based on the first evaluation value to obtain an adjusted message acquisition parameter.
5. The message hierarchical notification method according to claim 4, wherein the actual acquisition parameters include a first number and a second number, and the second evaluation value of the message processing unit is dynamically calculated based on the actual acquisition parameters and the message acquisition parameters, specifically: Acquiring a second initial evaluation value; dynamically updating the second initial evaluation value based on a preset matching rule to obtain the second evaluation value, wherein the preset matching rule comprises, If the message agent unit is monitored to have the message acquisition request in the acquisition period, successful matching is performed, and the second initial evaluation value is dynamically increased according to the first number of successful matching in the first preset time window; if the fact that the information agent unit does not have the actual acquisition parameters in the acquisition period is monitored, the matching is failed, and the second initial evaluation value is dynamically reduced according to the second number of the matching failures in the first preset time window.
6. The method for notifying message classification according to claim 1, wherein determining a target regulation scheme of the message proxy unit to the message processing unit according to the second evaluation value and a preset classification regulation policy, and sending a message notification of the first service message to the message processing unit based on the target regulation scheme specifically comprises: When the second evaluation value is smaller than a preset first threshold value and larger than or equal to a preset second threshold value, controlling the message proxy unit to pause sending a message arrival notification to the message processing unit, wherein the first threshold value is larger than the second threshold value; and when the second evaluation value is smaller than the second threshold value, controlling the message proxy unit to pause sending a message arrival notification to the message processing units, sequencing all the message processing units according to the second evaluation values of all the message processing units to obtain a processing sequence, and adjusting the processing priority of the message acquisition request according to the processing sequence.
7. The message hierarchical notification system is characterized by comprising a parameter adjusting module, a behavior sensing module and a hierarchical regulation and control module; The parameter adjusting module is used for acquiring the running state data of each message processing unit when the message sending unit sends a first service message to the message proxy unit, calculating in real time according to the running state data to obtain a first evaluation value of the message processing unit, and dynamically adjusting the message acquisition parameters of the message processing unit according to the first evaluation value; The behavior perception module is used for controlling the message processing unit to send a message acquisition request to the message proxy unit based on the message acquisition parameters, determining actual acquisition parameters of the message processing unit in a first preset time window, dynamically calculating to obtain a second evaluation value of the message processing unit based on the actual acquisition parameters and the message acquisition parameters, determining a target regulation scheme of the message proxy unit to the message processing unit according to the second evaluation value and a preset hierarchical regulation strategy, and sending a message notification of the first service message to the message processing unit based on the target regulation scheme; The hierarchical regulation and control module is used for controlling the message proxy unit to send the message notification of the second service message to the message processing unit through the target channel when the message sending unit sends the second service message to the message proxy unit, wherein the service priority of the first service message is smaller than that of the second service message.
8. A terminal device comprising a processor, a memory and a computer program stored in the memory and configured to be executed by the processor, the processor implementing the message ranking notification method according to any of claims 1-6 when the computer program is executed by the processor.
9. A computer readable storage medium comprising a stored computer program, wherein the computer program, when run, controls a device on which the computer readable storage medium resides to perform the message ranking notification method of any of claims 1-6.
10. A computer program product comprising computer instructions which, when executed by a processor, implement the steps in the message ranking notification method of any of claims 1 to 6.

Description

Message hierarchical notification method, system, equipment, medium and product Technical Field The present invention relates to the field of communications technologies, and in particular, to a method, a system, an apparatus, a medium, and a product for hierarchical notification of a message. Background In the electric power internet of things system, an electric power data acquisition and control unit is used as a message sending unit, and reliable and efficient communication is needed to be carried out between the electric power data acquisition and control unit and a back-end message processing unit through a message proxy unit (such as a message middleware). With the complexity of power services and the proliferation of data volumes, message broker units often face the problem of mismatch between the processing power of the message processing unit and the production speed of the message sending unit, especially when bursty traffic or processing unit resources are limited, with the problem of message backlog and processing delay. Currently, a message broker unit sets a fixed threshold for the message processing rate for each message processing unit and monitors its processing progress, and when it detects that the processing rate of a certain message processing unit is continuously below the threshold, the message broker unit exercises authority control over it, for example, reduces the priority of delivering new messages to it or temporarily stops pushing message notifications to it. However, when a certain message processing unit is subjected to authority management according to a fixed threshold, all messages flowing to the message processing unit, especially high-priority service messages, have the problem of being delayed or blocked, so that the reliability of the power system is reduced. Disclosure of Invention The invention provides a message grading notification method, a system, equipment, media and products, which can solve the problem of low reliability of a power system caused by the existing regulation and control mechanism based on a fixed processing rate threshold. The invention provides a message grading notification method, which comprises the following steps: When a message sending unit sends a first service message to a message proxy unit, acquiring running state data of each message processing unit, calculating a first evaluation value of the message processing unit in real time according to the running state data, and dynamically adjusting message acquisition parameters of the message processing unit according to the first evaluation value; Controlling the message processing unit to send a message acquisition request to the message proxy unit based on the message acquisition parameters, determining actual acquisition parameters of the message processing unit in a first preset time window, dynamically calculating to obtain a second evaluation value of the message processing unit based on the actual acquisition parameters and the message acquisition parameters, determining a target regulation scheme of the message proxy unit to the message processing unit according to the second evaluation value and a preset hierarchical regulation strategy, and sending a message notification of the first service message to the message processing unit based on the target regulation scheme; When the message sending unit sends a second service message to the message proxy unit, the message proxy unit is controlled to send a message notification of the second service message to the message processing unit through a target channel, wherein the service priority of the first service message is smaller than that of the second service message. The embodiment of the invention divides the messages into two types of processing according to service priority, namely, performing capacity assessment and self-adaptive adjustment on common messages, performing assessment and hierarchical regulation according to actual behaviors, sending notification on key messages directly through independent target channels, realizing real-time state of a precise response message processing unit and self-adaptive and intelligent management of flow, establishing a transmission channel independent of conventional regulation and control logic for the core service messages, guaranteeing the preferential delivery and accessibility of the core service messages under any system load, meeting the requirements of high-reliability service scenes such as electric power and the like, optimizing the processing throughput and resource utilization rate of the common messages, providing deterministic service guarantee for key services and realizing the unification of efficiency and safety under a unified architecture. Further, the operation state data includes historical operation data and real-time operation data in a second preset time window, and the first evaluation value of the message processing unit is obtained by real-time calculation accor