CN-122001563-A - Hierarchical monitoring method and system for block chain system and electronic equipment

CN122001563ACN 122001563 ACN122001563 ACN 122001563ACN-122001563-A

Abstract

The embodiment of the disclosure provides a hierarchical monitoring method, a hierarchical monitoring system, electronic equipment and a readable medium for a blockchain system. The layering monitoring method comprises the steps that an edge monitoring subsystem collects edge monitoring data, edge warning information is generated based on an edge warning strategy, the edge monitoring data are processed to generate first aggregation monitoring data, the aggregation monitoring subsystem collects first aggregation monitoring data and second aggregation monitoring data, the aggregation warning information is generated based on the aggregation warning strategy, the first aggregation monitoring data and the second aggregation monitoring data are processed to generate first global monitoring data, the global monitoring subsystem collects the first global monitoring data and the second global monitoring data, and global warning information is generated based on the global warning strategy, wherein the second global monitoring data comprise global fault data of global monitoring nodes. By constructing a hierarchical monitoring system corresponding to blockchain management responsibilities, efficient monitoring of the blockchain system can be achieved.

Inventors

ZHAO XINPENG
CHEN QINGJIE
CHEN XUANHUI
TAN QIWEN
MAO KAI

Assignees

中国人民银行数字货币研究所

Dates

Publication Date: 20260508
Application Date: 20251218

Claims (10)

1. A hierarchical monitoring method for a blockchain system is characterized by being applied to a hierarchical monitoring system, wherein the hierarchical monitoring system comprises an edge monitoring subsystem, an aggregation monitoring subsystem and a global monitoring subsystem, the blockchain system comprises an edge monitoring node, an aggregation monitoring node and a global monitoring node, and the method comprises the following steps: The edge monitoring subsystem collects edge monitoring data, generates edge warning information based on an edge warning strategy, and processes the edge monitoring data to generate first aggregate monitoring data, wherein the edge monitoring data comprises edge fault data of the edge monitoring nodes; the aggregation monitoring subsystem collects the first aggregation monitoring data and the second aggregation monitoring data, generates aggregation alarm information based on an aggregation alarm strategy, and processes the first aggregation monitoring data and the second aggregation monitoring data to generate first global monitoring data, wherein the second aggregation monitoring data comprises aggregation fault data of the aggregation monitoring nodes; The global monitoring subsystem collects the first global monitoring data and the second global monitoring data, and generates global alarm information based on a global alarm strategy, wherein the second global monitoring data comprises global fault data of the global monitoring node.
2. The method of claim 1, wherein processing the edge monitoring data to generate first aggregate monitoring data comprises: Preprocessing, desensitizing, filtering and compressing the collected edge monitoring data to generate the first aggregate monitoring data, and sending the first aggregate monitoring data to the aggregate monitoring subsystem, and/or, And filtering and compressing the collected edge fault data of the edge monitoring nodes to generate first aggregation monitoring data, and broadcasting the first aggregation monitoring data to the blockchain system through a heartbeat broadcasting component of the edge monitoring nodes so that the aggregation monitoring subsystem monitors and obtains the first aggregation monitoring data through the aggregation monitoring nodes.
3. The method according to claim 1 or 2, wherein said processing said first aggregate monitor data and said second aggregate monitor data to generate first global monitor data comprises: Summarizing, desensitizing, filtering and compressing the collected first and second aggregate monitor data to generate the first global monitor data, and sending the first global monitor data to the global monitor subsystem, and/or, And filtering and compressing the collected first aggregation monitoring data and the aggregation fault data of the aggregation monitoring nodes to generate first global monitoring data, broadcasting the first global monitoring data to the blockchain system through a heartbeat broadcasting component of the aggregation monitoring nodes, and enabling the global monitoring subsystem to monitor and acquire the first global monitoring data through the global monitoring nodes.
4. The method of claim 1, wherein the first aggregate monitoring data further comprises an edge monitoring subsystem identification or an edge monitoring node identification, the method further comprising: The aggregation monitoring subsystem is used for collecting the first aggregation monitoring data and the second aggregation monitoring data, screening the first aggregation monitoring data based on the edge monitoring subsystem identification or the edge monitoring node identification, generating aggregation alarm information based on the screened first aggregation monitoring data, and processing the screened first aggregation monitoring data and the screened second aggregation monitoring data to generate the first global monitoring data.
5. The method of claim 4, wherein screening the first aggregate monitor data based on the edge monitor subsystem identification or the edge monitor node identification comprises: and establishing a corresponding relation between the edge monitoring subsystem identification and the aggregation monitoring subsystem identification or between the edge monitoring node identification and the aggregation monitoring node identification, and screening the first aggregation monitoring data based on the corresponding relation.
6. The method of claim 4, wherein screening the first aggregate monitor data based on the edge monitor subsystem identification or the edge monitor node identification comprises: And establishing an allocation algorithm between the edge monitoring subsystem identification and the aggregation monitoring subsystem identification or between the edge monitoring node identification and the aggregation monitoring node identification, broadcasting algorithm dependent parameters in the blockchain system, and screening the first aggregation monitoring data based on the allocation algorithm and the algorithm dependent parameters.
7. The method of claim 6, wherein the algorithm dependent parameters include the aggregate monitoring node number and a monitoring replication factor.
8. The block chain system-oriented hierarchical monitoring system is characterized by comprising an edge monitoring subsystem, an aggregation monitoring subsystem and a global monitoring subsystem, wherein the block chain system comprises edge monitoring nodes, aggregation monitoring nodes and global monitoring nodes, and the block chain system comprises the following components: The edge monitoring subsystem is configured to collect edge monitoring data, generate edge warning information based on an edge warning strategy, and process the edge monitoring data to generate first aggregate monitoring data, wherein the edge monitoring data comprises edge fault data of the edge monitoring nodes; The aggregation monitoring subsystem is configured to collect the first aggregation monitoring data and the second aggregation monitoring data, generate aggregation alarm information based on an aggregation alarm strategy, and process the first aggregation monitoring data and the second aggregation monitoring data to generate first global monitoring data, wherein the second aggregation monitoring data comprises aggregation fault data of the aggregation monitoring node; the global monitoring subsystem is configured to collect the first global monitoring data and the second global monitoring data, and generate global alarm information based on a global alarm strategy, wherein the second global monitoring data comprises global fault data of the global monitoring node.
9. An electronic device, comprising: One or more processors; Storage means for storing one or more programs, The one or more programs, when executed by the one or more processors, cause the one or more processors to implement the methods of claims 1-7.
10. A computer readable medium, on which a computer program is stored, characterized in that the program, when being executed by a processor, implements the method according to claims 1-7.

Description

Hierarchical monitoring method and system for block chain system and electronic equipment Technical Field The disclosure relates to the technical field of blockchain systems, in particular to a hierarchical monitoring method, a hierarchical monitoring system, electronic equipment and a readable medium for a blockchain system. Background With the widespread use of blockchain technology, the number of alliance chains and public chain systems co-established across jurisdictions, multi-service principals has shown explosive growth. The system has large node scale and complex network topology, and has higher requirement on the monitoring of the running state. However, when dealing with a blockchain scenario with cross-domain synergy, the conventional monitoring architecture has significant underadaptation, and core problems include: the method comprises the steps of (1) converging all node data to a central server in a traditional monitoring architecture, wherein the data transmission delay is high and single-point fault risks are obvious, 2) the fault detection relies on central analysis, local abnormal quick response is difficult to realize, 3) redundant data (such as normal state data) occupy a large amount of bandwidth and storage space, so that resource waste is caused, 4) under the legal limit of data cross-border flow, scheme implementation is possibly limited, illegal transmission of sensitive service data is caused, and 5) a monitoring system cannot meet monitoring requirements under complex treatment responsibilities. Therefore, the traditional monitoring architecture cannot form a systematic cross-domain cooperative mechanism, cannot systematically solve the cooperative problem among data isolation, intelligent desensitization and low-bandwidth transmission, and cannot meet the actual requirement of deep fusion of blockchain management responsibilities and monitoring strategies. Disclosure of Invention The embodiment of the disclosure provides a hierarchical monitoring method, a hierarchical monitoring system, an electronic device and a readable medium for a blockchain system, which are used for realizing the efficient monitoring of the blockchain system by constructing a hierarchical monitoring system corresponding to blockchain monitoring management responsibilities, further realizing the dynamic adjustment of an alarm strategy and a monitoring range, improving the adaptability of the blockchain system monitoring, improving the monitoring efficiency, enhancing the instantaneity, reducing the resource consumption and protecting sensitive data. In order to achieve the technical purpose, the embodiment of the disclosure adopts the following technical scheme: In a first aspect, an embodiment of the present disclosure provides a hierarchical monitoring method for a blockchain system, where the method is applied to a hierarchical monitoring system, the hierarchical monitoring system includes an edge monitoring subsystem, an aggregation monitoring subsystem, and a global monitoring subsystem, and the blockchain system includes an edge monitoring node, an aggregation monitoring node, and a global monitoring node, and the method includes: The edge monitoring subsystem collects edge monitoring data, generates edge warning information based on an edge warning strategy, and processes the edge monitoring data to generate first aggregate monitoring data, wherein the edge monitoring data comprises edge fault data of edge monitoring nodes; the aggregation monitoring subsystem collects first aggregation monitoring data and second aggregation monitoring data, generates aggregation alarm information based on an aggregation alarm strategy, and processes the first aggregation monitoring data and the second aggregation monitoring data to generate first global monitoring data, wherein the second aggregation monitoring data comprises aggregation fault data of aggregation monitoring nodes; The global monitoring subsystem collects first global monitoring data and second global monitoring data, and generates global alarm information based on a global alarm strategy, wherein the second global monitoring data comprises global fault data of a global monitoring node. In some possible embodiments, processing the edge monitoring data to generate first aggregate monitoring data includes: preprocessing, desensitizing, filtering and compressing the collected edge monitoring data to generate first aggregate monitoring data, and sending the first aggregate monitoring data to an aggregate monitoring subsystem, and/or, And filtering and compressing the collected edge fault data of the edge monitoring nodes to generate first aggregation monitoring data, and broadcasting the first aggregation monitoring data to the block chain system through a heartbeat broadcasting assembly of the edge monitoring nodes so that the aggregation monitoring subsystem monitors through the aggregation monitoring nodes to obtain the first aggregation monitoring d