Monitoring fault processing method, monitoring fault processing device, storage medium and electronic equipment

Abstract

The invention discloses a monitoring fault processing method, a monitoring fault processing device, a storage medium and electronic equipment, and relates to the technical field of data communication.The monitoring fault processing method is applied to a system including a message queue and a message consumption side. The monitoring fault processing method comprises the steps of: decoupling a message monitor from a message processing application at the message consumption side; monitoring the message queue, and, if the fact that an abnormal message queue exists in the message queue is monitored, notifying the abnormal message queue to a monitoring manager at the message consumption side through a predetermined channel; determining the message monitor corresponding to the abnormal messagequeue as the target monitor by the monitor manager; and, detecting the target monitor, so that the target monitor is restarted in a condition that the fault of the target monitor is detected. By meansof the monitoring fault processing method, the monitoring fault processing device, the storage medium and the electronic equipment disclosed by the invention, the problem that the message queue is abnormal due to the fault of the monitor can be solved; and furthermore, high-cohesion and low-coupling design requirements can be realized by decoupling between the monitor and the message processing application.

Description

technical field [0001] The present invention relates to the technical field of data communication, in particular to a monitoring fault processing method, a monitoring fault processing device, a storage medium and electronic equipment. Background technique [0002] With the development of social informatization, data interaction between various business systems is becoming more and more frequent. At present, RabbitMQ (a data communication method) is often used between various business systems to realize data interaction. Specifically, first, the message producer (Producer) can send the message to the message exchange (Exchange); then, the message exchange can distribute the message to each queue (Queue) bound to the message exchange; in addition, the message consumer (Consumer ) can monitor the queue through the monitor, and after the message in the queue is monitored and processed by the message consumer, the message consumer can feed back the callback (Callback) to the que...

AI Technical Summary

Problems solved by technology

[0003] However, on the one hand, there is currently a problem that the length of messages in the queue is too high due to the downtime of the listener; on the other hand, for the message consumer, the coupling degree between the listener and the message processing application that specifically processes the message is high , when performing code maintenance on listeners or message processing applications or during project iterations, developers modifying a certain code may cause errors in the entire system, which does not meet the design requirements of high cohesion and low coupling

Images