CN116136818A - Method, device, equipment and medium for health inspection of message queue - Google Patents

Abstract

The disclosure provides a health inspection method, a device, equipment and a medium for a message queue, which can be applied to the technical field of computers and the technical field of artificial intelligence. The health inspection method for the message queue comprises the following steps: acquiring a patrol task deployed in a patrol platform, wherein the patrol task is configured with a preset execution frequency; acquiring list information of a server provided with a message queue from a configuration management platform, wherein the server in the list information is pre-deployed with a checking script containing message queue indexes; and carrying out inspection on the message queue of the server in the list information according to the message queue index according to the preset execution frequency of the inspection task and the inspection script, so as to obtain a health inspection result.

Description

Method, device, equipment and medium for health inspection of message queue

technical field

The present disclosure relates to the fields of computer technology and artificial intelligence technology, and more specifically, to a health inspection method, device, device and medium for message queues.

Background technique

In recent years, the scale of data center servers has shown explosive growth. Among them, the fastest growing number is mainly concentrated on servers using cheap X86 open platform systems, and MQ (Message Queue, message queue) servers have also surged accordingly.

In the process of implementing the disclosed concept, the inventors found that there are at least the following problems in related technologies: some abnormal indicators of message queues in the MQ server will cause abnormalities on the entire business application side, resulting in inevitable asset losses. In related technologies, the message queue indicators in the MQ server are generally checked manually. This manual inspection method has the problems of low inspection efficiency and inability to cope with large-scale server inspections.

Contents of the invention

In view of this, the present disclosure provides a health inspection method, device, device and medium for message queues.

One aspect of the present disclosure provides a health inspection method for message queues, including:

Obtain the inspection tasks deployed in the inspection platform, and the above inspection tasks are configured with a preset execution frequency;

Obtaining list information of servers configured with message queues from the configuration management platform, wherein the servers in the above list information are pre-deployed with check scripts containing message queue indicators; and

According to the preset execution frequency of the above-mentioned inspection task and the above-mentioned inspection script, the message queue of the server in the above-mentioned list information is inspected according to the above-mentioned message queue index, and the health inspection result is obtained.

According to an embodiment of the present disclosure, the above-mentioned message queue indicators include a first-type indicator and a second-type indicator, and the above-mentioned first-type indicator represents an indicator of an abnormal information transmission of the message queue of the server in the above-mentioned list information caused by a wrong operation of the user. The second type of index represents the necessary index for the message queue of the server in the above list information to transmit information normally.

According to an embodiment of the present disclosure, according to the preset execution frequency of the above-mentioned inspection task and the above-mentioned inspection script, the message queue of the server in the above-mentioned list information is inspected according to the above-mentioned message queue index, and the health inspection results obtained include:

Obtain the log information of the server in the above list information;

According to the above log information, the index value of the first type of index of the server’s message queue in the above list information is obtained, wherein the index value of the above first type of index includes the number of times the client’s user password is entered incorrectly, the user’s current status, and the user’s last The time when a wrong password is entered once;

According to the index value of the above-mentioned first type of index, the above-mentioned health inspection result is obtained.

According to an embodiment of the present disclosure, according to the preset execution frequency of the above-mentioned inspection task and the above-mentioned inspection script, the message queue of the server in the above-mentioned list information is inspected according to the above-mentioned message queue index, and the health inspection results obtained include:

Obtain the configuration file of the server in the above list information;

Comparing the configuration information in the above configuration file with the index value of the second type of index above to obtain a comparison result, wherein the index value of the second type of index above includes at least one of the following: the transmission control protocol of the server in the above list information Whether it is set to a long link, when the receiving server receives a channel connection request and the process related to the channel exists, whether the receiving server uses the method of establishing a new channel, whether the number of seconds for the new incoming process to wait for the old process to end is equal to the preset value and whether the above-mentioned server's setting for self-testing using a new channel is turned on;

According to the above comparison results, the above health inspection results are obtained.

According to an embodiment of the present disclosure, the above check script containing message queue indicators is pre-deployed in the server in the above list information according to the following steps:

Write an initial check script that includes message queue metrics based on business requirements;

Script release of the above-mentioned initial inspection script through the script management platform;

Perform a functional test on the above-mentioned initial check script, and obtain the above-mentioned check script that passes the functional test;

Submit the above check script to the script library;

The above checking script in the above script library is deployed to the server in the above list information according to the predetermined time through the script management platform.

According to an embodiment of the present disclosure, it also includes:

Return the above-mentioned health inspection results to the above-mentioned inspection platform;

The above-mentioned health degree inspection results are stored in the inspection result database.

According to an embodiment of the present disclosure, it also includes:

Locate servers with abnormal indicators according to the above health inspection results;

According to the above-mentioned servers with abnormal indicators and the results of the health inspection, the above-mentioned servers with abnormal indicators are processed.

Another aspect of the present disclosure provides a health inspection device for message queues, including:

The inspection task acquisition module is used to obtain the inspection tasks deployed in the inspection platform, and the above inspection tasks are configured with a preset execution frequency;

The server information obtaining module is used to obtain the list information of the servers configured with message queues from the configuration management platform, wherein the servers in the above list information are pre-deployed with check scripts containing message queue indicators; and

The inspection result obtaining module is configured to inspect the message queue of the server in the list information according to the preset execution frequency of the inspection task and the inspection script, and obtain the health inspection result.

Another aspect of the present disclosure provides an electronic device, including: one or more processors; a memory for storing one or more instructions, wherein, when the one or more instructions are executed by the one or more processors, such that One or more processors implement the methods described above.

Another aspect of the present disclosure provides a computer-readable storage medium, storing computer-executable instructions, which, when executed by a processor, cause the processor to implement the above method.

Another aspect of the present disclosure provides a computer program product comprising computer-executable instructions for implementing the method as described above when executed.

According to the embodiment of the present disclosure, by acquiring the inspection task deployed in the inspection platform, the inspection task is configured with a preset execution frequency, and the business type to be detected included in the inspection task and the business type to be detected are obtained. Related preset execution frequency, and then according to the service type to be detected, obtain the list information of the servers with message queues related to the service type to be detected from the configuration management platform, wherein, the servers in the list information are pre-deployed with messages containing The check script of the queue index, set the server with the message queue as the MQ server, and then according to the preset execution frequency and check script of the inspection task, inspect the message queue of the MQ server in the list information according to the message queue index, and obtain the health Inspection results, realize automatic inspection of the message queue indicators of the MQ server's message queue in the list information according to the preset execution frequency and inspection script of the inspection task, and obtain whether the message queue of the MQ server in the list information is abnormal The detection results of the indicators improve the efficiency of the inspection of the message queue indicators of the message queues of the MQ server in the list information, and realize the rapid inspection of the message queue indicators of the message queues of the large-scale MQ servers. An abnormal message queue was found in the server's message queue.

Description of drawings

The above and other objects, features and advantages of the present disclosure will be more clearly described through the following description of the embodiments of the present disclosure with reference to the accompanying drawings, in which:

FIG. 1 schematically shows an exemplary system architecture to which a health inspection method for a message queue can be applied according to an embodiment of the present disclosure;

FIG. 2 schematically shows a flow chart of a method for health inspection of a message queue according to an embodiment of the present disclosure;

Fig. 3 schematically shows a message queue indicator according to an embodiment of the present disclosure;

Fig. 4 schematically shows a flow chart of deploying a check script on a server according to an embodiment of the present disclosure;

FIG. 5 schematically shows a flow chart of a method for health inspection of a message queue according to another embodiment of the present disclosure;

Fig. 6 schematically shows a block diagram of a health inspection device for a message queue according to an embodiment of the present disclosure;

Fig. 7 schematically shows a block diagram of a computer system suitable for implementing the method described above according to an embodiment of the present disclosure.

Detailed ways

Hereinafter, embodiments of the present disclosure will be described with reference to the drawings. It should be understood, however, that these descriptions are exemplary only, and are not intended to limit the scope of the present disclosure. In the following detailed description, for purposes of explanation, numerous specific details are set forth in order to provide a thorough understanding of the embodiments of the present disclosure. It may be evident, however, that one or more embodiments may be practiced without these specific details. Also, in the following description, descriptions of well-known structures and techniques are omitted to avoid unnecessarily obscuring the concept of the present disclosure.

The terminology used herein is for the purpose of describing particular embodiments only, and is not intended to be limiting of the present disclosure. The terms "comprising", "comprising", etc. used herein indicate the presence of stated features, steps, operations and/or components, but do not exclude the presence or addition of one or more other features, steps, operations or components.

All terms (including technical and scientific terms) used herein have the meaning commonly understood by one of ordinary skill in the art, unless otherwise defined. It should be noted that the terms used herein should be interpreted to have a meaning consistent with the context of this specification, and not be interpreted in an idealized or overly rigid manner.

Where expressions such as "at least one of A, B, and C, etc." are used, they should generally be interpreted as those skilled in the art would normally understand the expression (for example, "having A, B, and C A system of at least one of "shall include, but not be limited to, systems with A alone, B alone, C alone, A and B, A and C, B and C, and/or A, B, C, etc. ). Where expressions such as "at least one of A, B, or C, etc." are used, they should generally be interpreted as those skilled in the art would normally understand the expression (for example, "having A, B, or C A system of at least one of "shall include, but not be limited to, systems with A alone, B alone, C alone, A and B, A and C, B and C, and/or A, B, C, etc. ).

In the technical solution of the present disclosure, the acquisition, storage and application of the user's personal information involved are in compliance with relevant laws and regulations, necessary confidentiality measures have been adopted, and they do not violate public order and good customs.

Some abnormal indicators of the message queue in the MQ server will cause abnormalities on the entire business application side, resulting in inevitable asset losses. In related technologies, the message queue indicators in the MQ server are generally checked manually. This manual inspection method has the problems of low inspection efficiency and inability to cope with large-scale server inspections.

In order to at least partly solve the technical problems in related technologies, embodiments of the present disclosure provide a method, device, device and medium for health inspection of message queues, which can be applied in the fields of computer technology and artificial intelligence technology. The health inspection method for message queues includes: obtaining inspection tasks deployed on the inspection platform, where the inspection tasks are configured with a preset execution frequency; obtaining list information of servers configured with message queues from the configuration management platform , wherein, the servers in the list information are pre-deployed with check scripts containing message queue indicators; and according to the preset execution frequency and check scripts of the inspection tasks, the message queues of the servers in the list information are inspected according to the message queue indicators, Get the health inspection results.

Fig. 1 schematically shows an exemplary system architecture to which a health inspection method for a message queue can be applied according to an embodiment of the present disclosure. It should be noted that, what is shown in FIG. 1 is only an example of the system architecture to which the embodiments of the present disclosure can be applied, so as to help those skilled in the art understand the technical content of the present disclosure, but it does not mean that the embodiments of the present disclosure cannot be used in other device, system, environment or scenario.

As shown in FIG. 1 , a system architecture 100 according to this embodiment may include a first terminal device 101 , a second terminal device 102 , a third terminal device 103 , a network 104 and a server 105 . The network 104 is used as a medium for providing communication links among the first terminal device 101 , the second terminal device 102 , the third terminal device 103 and the server 105 . Network 104 may include various connection types, such as wired and/or wireless communication links, among others.

A user can use at least one of the first terminal device 101 , the second terminal device 102 , and the third terminal device 103 to interact with the server 105 through the network 104 to receive or send messages and the like. Various communication client applications can be installed on the first terminal device 101, the second terminal device 102, and the third terminal device 103, such as shopping applications, web browser applications, search applications, instant messaging tools, email clients, and / or social platform software, etc. (examples only).

The first terminal device 101, the second terminal device 102, and the third terminal device 103 may be various electronic devices with display screens and supporting web browsing, including but not limited to smart phones, tablet computers, laptop computers and desktop computers etc.

The server 105 may be a server that provides various services, such as a background management server that supports websites browsed by users using the first terminal device 101 , the second terminal device 102 , and the third terminal device 103 (just an example). The background management server can analyze and process received data such as user requests, and feed back processing results (such as webpages, information, or data obtained or generated according to user requests) to the terminal device.

It should be noted that, generally, the health inspection method for message queues provided by the embodiments of the present disclosure may be executed by the server 105 . Correspondingly, the health inspection device for message queues provided by the embodiments of the present disclosure can generally be set in the server 105 . The health inspection method for message queues provided by the embodiments of the present disclosure may also be implemented by an A server or server cluster executes. Correspondingly, the health inspection system for message queues provided by the embodiments of the present disclosure may also be set different from the server 105 and be able to communicate with the first terminal device 101, the second terminal device 102, the third terminal device 103 and/or Server 105 communicates with a server or server cluster.

Alternatively, the health inspection method for message queues provided by the embodiments of the present disclosure may also be executed by the first terminal device 101, the second terminal device 102, or the third terminal device 103, or may also be executed by an Other terminal devices of the terminal device 101, the second terminal device 102 or the third terminal device 103 execute. Correspondingly, the health inspection device for message queues provided by the embodiments of the present disclosure may also be set in the first terminal device 101, the second terminal device 102, or the third terminal device 103, or be set in a device different from the first terminal device. In other terminal devices of the device 101, the second terminal device 102 or the third terminal device 103.

It should be understood that the numbers of terminal devices, networks and servers in Fig. 1 are only illustrative. According to the implementation needs, there can be any number of terminal devices, networks and servers.

Fig. 2 schematically shows a flowchart of a health inspection method for a message queue according to an embodiment of the present disclosure.

As shown in Fig. 2, the method includes operations S201-S203.

In operation S201, the inspection task deployed on the inspection platform is obtained, and the inspection task is configured with a preset execution frequency.

According to an embodiment of the present disclosure, the inspection task represents a task of detecting a message queue of a specified MQ server.

According to the embodiment of the present disclosure, the patrol task can be deployed for the MQ servers corresponding to all business types. At this time, the same preset execution frequency can be configured for all MQ servers, and the same preset execution can be performed for all MQ servers. Frequency inspections.

According to the embodiments of the present disclosure, patrol tasks can also be deployed respectively for the MQ servers corresponding to multiple service types respectively. At this time, the preset execution frequencies can be respectively configured for the MQ servers corresponding to the multiple service types, and for the MQ servers corresponding to the multiple service types. The MQ servers corresponding to multiple business types perform inspections at their respective preset execution frequencies.

According to an embodiment of the present disclosure, different preset execution frequencies may be set according to the importance of the business.

According to the embodiment of the present disclosure, the preset execution frequency may be, for example, once a day or once a minute. The embodiment of the present disclosure does not limit the execution frequency, which may be selected according to actual conditions.

In operation S202, the list information of servers configured with message queues is obtained from the configuration management platform, wherein the servers in the list information are pre-deployed with check scripts containing message queue indicators.

According to an embodiment of the present disclosure, a configuration management platform (Configuration Management Database, CMDB) represents a platform that can manage cross-platform servers in batches.

According to an embodiment of the present disclosure, the CMDB may record service type information, cluster information related to each service type, MQ server information related to each service type, etc., wherein the MQ server information may include the MQ server IP address.

According to an embodiment of the present disclosure, the message queue index represents an index for ensuring normal transmission of information by the message queue.

According to an embodiment of the present disclosure, the list information of the server represents an information table including the MQ server to be inspected, and the servers included in the list information of the server may be all MQ servers under the configuration management platform, or may be related to a certain type of business The associated MQ server.

According to the embodiment of the present disclosure, according to the information of the service type to be detected configured in the inspection task, the list information of the servers configured with message queues related to the service type to be detected can be obtained from the configuration management platform.

According to the embodiment of the present disclosure, in the default state of the inspection task, the service type to be detected may not be configured, and at this time, the MQ server related to all service types is patrolled by default.

In operation S203, according to the preset execution frequency of the inspection task and the inspection script, the message queue of the server in the list information is inspected according to the message queue index, and a health inspection result is obtained.

According to an embodiment of the present disclosure, the health inspection result may include the detected health status and abnormal status of each MQ server.

According to the embodiment of the present disclosure, according to the preset execution frequency of the inspection task and the inspection script, the message queue index of the server's message queue in the list information can be inspected to obtain whether there is an abnormality in the server's message queue in the list information the result of.

According to the embodiment of the present disclosure, by acquiring the inspection task deployed in the inspection platform, the inspection task is configured with a preset execution frequency, and the business type to be detected included in the inspection task and the business type to be detected are obtained. Related preset execution frequency, and then according to the service type to be detected, obtain the list information of the servers with message queues related to the service type to be detected from the configuration management platform, wherein, the servers in the list information are pre-deployed with messages containing The check script of the queue index, set the server with the message queue as the MQ server, and then according to the preset execution frequency and check script of the inspection task, inspect the message queue of the MQ server in the list information according to the message queue index, and obtain the health Inspection results, realize automatic inspection of the message queue indicators of the MQ server's message queue in the list information according to the preset execution frequency and inspection script of the inspection task, and obtain whether the message queue of the MQ server in the list information is abnormal The detection results of the indicators improve the efficiency of the inspection of the message queue indicators of the message queues of the MQ server in the list information, and realize the rapid inspection of the message queue indicators of the message queues of the large-scale MQ servers. An abnormal message queue was found in the server's message queue.

According to an embodiment of the present disclosure, the message queue indicators include a first-type indicator and a second-type indicator. The first-type indicator represents an indicator of an abnormal information transmission of the server’s message queue in the list information caused by a user’s wrong operation, and the second-type The index represents the necessary index for the message queue of the server in the list information to transmit information normally.

According to the embodiment of the present disclosure, according to the first type of indicators in the message queue indicators, the influence of the user's wrong operation on the message queue of the MQ server in the list information can be monitored, and according to the second type of indicators in the message queue indicators, the list information can be monitored Whether the necessary indicators of the message queue of the MQ server in the list are enabled, the first type of indicators and the second type of indicators in the message queue indicators guarantee the health status of the message queue of the MQ server in the list information from different aspects.

According to the embodiment of the present disclosure, according to the preset execution frequency of the inspection task and the inspection script, the message queue of the server in the list information is inspected according to the message queue index, and the health inspection results obtained include:

Obtain the log information of the server in the list information;

According to the log information, the index value of the first type of index of the server's message queue in the list information is obtained, where the index value of the first type of index includes the number of times the client's user password is entered incorrectly, the current status of the user, and the last time the user entered an error password time;

According to the index value of the first type of index, the health inspection result is obtained.

According to an embodiment of the present disclosure, the log information represents text information recording all activities related to the MQ server in the list information.

According to an embodiment of the present disclosure, the log information may include information about operations performed by the user related to the message queue of the MQ server. Therefore, through the log information, the number of password input errors of the user related to the message queue of the MQ server, the user The current state of , and the last time the user entered an incorrect password.

According to the embodiment of the present disclosure, when the current state of the user, the time when the user entered the wrong password for the last time, and the number of times the user entered the wrong password is greater than or equal to the predetermined number of times obtained through the index value of the first type of index, the MQ in the list information is considered The server's message queue has abnormal indicators.

According to the embodiment of the present disclosure, when the user's password input error is greater than or equal to the predetermined number of times, the message queue of the MQ server in the list information can be made unavailable to ensure the security of the client's information in the MQ server. Therefore, When it is detected that the log information includes the number of times the user entered wrong passwords greater than or equal to the threshold number of times, it is necessary to enable the MQ server in the list information based on the number of wrong passwords entered, the current status of the user, and the time when the user entered the wrong password last time. Message queue, so that the message queue of the MQ server in the list information can be used normally after processing.

According to the embodiments of the present disclosure, for example, when the user's password input error times is greater than or equal to 3, the message queue of the MQ server in the list information may be made unavailable. Then, according to the current status of the user and the time when the user entered the wrong password for the last time, set the time threshold for the normal use of the message queue of the MQ server in the list information, for example, one day. When the time threshold is reached, the list information will be opened normally The message queue of the MQ server in the list information, so that the message queue of the MQ server in the list information can be used normally.

According to an embodiment of the present disclosure, by obtaining the log information of the server in the list information, that is, the MQ server, and then according to the log information, the index value of the first type of index of the message queue of the MQ server in the list information is obtained, wherein the first type The index value of the index includes the number of wrong password input of the client, the current status of the user, and the time when the user entered the wrong password for the last time. According to the index value of the first type of index, the health inspection result is obtained, and the MQ server in the list information The index value of the first type of index of the message queue is automatically inspected, and the influence of the user's wrong operation on the message queue of the MQ server in the list information is discovered in time, so that the subsequent users can be included according to the index value of the first type of index The number of wrong passwords entered, the current status of the user, and the time when the user entered the wrong password for the last time open the message queue of the MQ server in the list information in time, so that the message queue of the MQ server in the list information can be used normally.

According to the embodiment of the present disclosure, according to the preset execution frequency of the inspection task and the inspection script, the message queue of the server in the list information is inspected according to the message queue index, and the health inspection results obtained include:

Obtain the configuration file of the server in the manifest information;

The configuration information in the configuration file is compared with the index value of the second type of index to obtain the comparison result, wherein the index value of the second type of index includes at least one of the following: whether the transmission control protocol of the server in the list information is set to long Link, when the receiver server receives a channel connection request and the process related to the channel exists, whether the receiver server adopts to establish a new channel, whether the number of seconds for the new process to wait for the old process to end is equal to the preset value, and the server’s Whether the setting of using a new channel for self-test is enabled;

According to the comparison result, the health inspection result is obtained.

According to an embodiment of the present disclosure, a configuration file represents a file recording all configurations of an MQ server in manifest information.

According to the embodiment of the present disclosure, the preset value of the number of seconds for the new process to wait for the end of the old process can be, for example, 30s, 40s, 1min, etc. The embodiment of the present disclosure does not limit the specific preset value, which can be selected according to the actual situation .

According to an embodiment of the present disclosure, when the configuration information in the configuration file is consistent with the index value of the second type of index, it is considered that the message queue of the MQ server in the list information is in a healthy state, and the configuration information in the configuration file is consistent with the second type of index value. If any of the index values of the second type of index is inconsistent, it is considered that the message queue of the MQ server in the list information is in an abnormal state.

According to an embodiment of the present disclosure, whether the transmission control protocol (Transmission Control Protocol, TCP) of the MQ server in the detection list information is set to a long link can be, for example, the mechanism keepAlive for checking the dead connection of the MQ server in the detection list information Whether to set to YES. When keepAlive is set to YES, TCP is set as a long connection. At this time, use the TCP/IP of the operating system to monitor whether the channel of the message queue of the other server connected to the channel corresponding to the message queue of the MQ server is available. If If it is not set, the channel connection corresponding to the message queue will be reset, making the transmission information of the message queue abnormal.

According to an embodiment of the present disclosure, when the receiver server, that is, the MQ server, receives a channel connection request and the process related to the channel exists, whether the receiver MQ server uses to establish a new channel can be, for example: Detect the receiver MQ When the server receives the request to establish a channel connection and the process related to the channel exists, whether the channel attribute AdoptNewMCA of the message queue of the receiving MQ server is set to ALL. When AdoptNewMCA is set to ALL, when the receiving MQ server receives a channel connection request and the process related to the channel exists, the receiving MQ server adopts to establish a new channel.

According to an embodiment of the present disclosure, detecting whether the number of seconds that a new process waits for an old process to end is equal to a preset value may be, for example: detecting whether the value of AdoptNewMCATimeOut that a new channel related to a message queue waits for an old channel to end is equal to a preset value. In the case that the value of AdoptNewMCATimeOut is equal to the preset value, it can ensure that the message queue transmits information normally.

According to an embodiment of the present disclosure, whether the check server, that is, whether the MQ server self-testing setting for adopting a new channel is enabled, for example, may be: checking whether the setting AdoptNewMCACheck for adopting a new channel for self-testing related to the message queue of the MQ server is enabled Whether it is set to ALL, when AdoptNewMCACheck is set to ALL, the setting of adopting new channel for self-test is enabled, which can ensure the normal transmission of information in the message queue.

According to the embodiment of the present disclosure, by obtaining the configuration file of the server in the list information, that is, the MQ server, and then comparing the configuration information in the configuration file with the index value of the second type of index, the comparison result is obtained, and according to the comparison result, the health The result of the inspection is to realize the automatic inspection of the index values of the second-type indicators of the message queue of the MQ server in the list information, and to find out in time whether the necessary indicators of the message queue of the MQ server in the list information are enabled. According to the health inspection It turns out that if the necessary indicator of the message queue of the MQ server in the list information is not enabled, the message queue indicator can be enabled in time, so that the message queue of the MQ server in the list information can be used normally.

Fig. 3 schematically shows message queue indicators according to an embodiment of the present disclosure.

As shown in FIG. 3 , the message queue indicator 300 includes a first-type indicator 310 and a second-type indicator 320 . The index values corresponding to the first type of index 310 include the number of times 311 of user password input errors, the user's current status 312 and the time 313 of the user's last input error password. The index value corresponding to the second type of index 320 includes whether the transmission control protocol of the server in the list information, that is, the MQ server, is set to a long link 321, and whether the receiver server, that is, the MQ server, receives a channel connection request and there are processes related to the channel. Under the situation, whether the receiver MQ server adopts to establish new channel 322, whether the second number that the new incoming process waits for the old process to finish is equal to the preset value 323 and whether the MQ server promptly adopts the setting of new channel to carry out self-test to open 324.

As shown in Figure 3, according to the first type of indicators 310 in the message queue indicators, the influence of the user's wrong operation on the message queue of the server in the list information can be monitored, and according to the second type of indicators 320 in the message queue indicators, the list information can be monitored Whether the necessary indicators of the server's message queue in the message queue are enabled, the first type of indicators 310 and the second type of indicators 320 in the message queue indicators ensure the health status of the server's message queue in the list information from different aspects.

According to an embodiment of the present disclosure, the check script containing the message queue indicator is pre-deployed in the server in the inventory information according to the following steps:

Write an initial check script that includes message queue metrics based on business requirements;

Script release of the initial inspection script through the script management platform;

Perform a functional test on the initial check script to obtain a check script that passes the functional test;

Submit the check script to the script repository;

Deploy the inspection scripts in the script library to the servers in the inventory information according to the scheduled time through the script management platform.

According to an embodiment of the present disclosure, performing a functional test on the initial inspection script includes testing the encoding format, output format, and adaptability of the initial script, so as to ensure the correctness of the inspection script obtained according to the initial inspection script.

According to an embodiment of the present disclosure, performing a functional test on the initial inspection script includes testing the encoding format, output format, and adaptability of the initial script, so as to ensure the correctness of the inspection script obtained according to the initial inspection script.

According to an embodiment of the present disclosure, the predetermined time may be a period of time when the user performs few operations on the message queue of the server in the list information, and the predetermined time may be, for example, 12 am, 1 am or 2 am in the morning, etc., the present disclosure The embodiment does not limit the specific predetermined time, which can be selected according to the actual situation.

Fig. 4 schematically shows a flow chart of deploying a check script to a server according to an embodiment of the present disclosure.

As shown in Figure 4, in step 410, the operation and maintenance personnel write an initial check script containing message queue indicators according to business requirements. In step 420, the script management platform publishes the script for the initial check script. Carry out the function test, obtain the check script that passes the function test, in step 440, submit the check script to the script library, and in step 450, deploy the check script in the script library to the server in the list information according to the scheduled time through the script management platform. In the MQ server.

According to an embodiment of the present disclosure, by writing an initial inspection script containing message queue indicators according to business requirements, an initial inspection script containing message queue indicators related to each business is obtained, and then the initial inspection script is published through the script management platform, Perform a functional test on the initial check script, obtain a check script that passes the functional test, obtain a check script that can perform message queue indicator detection on the message queue of the server in the business-related list information, and then submit the check script that passes the functional test to Script library, so that the message queue indicators of the server in the business-related list information, that is, the message queue of the MQ server, can be automatically inspected based on the inspection script that has passed the functional test.

According to an embodiment of the present disclosure, the above health inspection method for message queues further includes:

Return the health inspection results to the inspection platform;

Store the health inspection result in the inspection result database.

According to an embodiment of the present disclosure, the inspection result database may be, for example, a relational database Mysql database, which realizes rapid recording of health inspection results and retrieval of health inspection results.

According to the embodiment of the present disclosure, the health degree inspection result is returned to the inspection platform, and the health degree inspection result is stored in the inspection result database, so that the health inspection result database can be used to record and save the health degree inspection result. If there are many problems in the message queue of the server in the list information, that is, the MQ server, you can query the health inspection result according to the inspection result database, and then check the messages of the MQ server in the list information in which the problem occurs in the order of storage. queue for processing.

According to an embodiment of the present disclosure, the above health inspection method for message queues further includes:

Locate servers with abnormal indicators based on health inspection results;

According to the servers with abnormal indicators and the health inspection results, the servers with abnormal indicators are processed.

According to the embodiment of the present disclosure, by locating the server with abnormal indicators, that is, the MQ server, according to the health inspection results, and then processing the MQ servers with abnormal indicators according to the MQ servers with abnormal indicators and the health inspection results, to achieve Automatically locate the MQ server with abnormal indicators, and process the MQ server with abnormal indicators, and improve the processing efficiency of MQ servers with abnormal indicators.

According to the embodiment of the present disclosure, processing the MQ server with abnormal indicators includes sending the MQ server with abnormal indicators to the relevant operation and maintenance personnel through email and warning the server with abnormal indicators through the monitoring system to remind the relevant operation and maintenance personnel Timely handle MQ servers with abnormal indicators.

Fig. 5 schematically shows a flowchart of a method for health inspection of a message queue according to another embodiment of the present disclosure.

As shown in Figure 5, the operation and maintenance personnel deploy inspection tasks on the inspection platform in advance, and then configure the inspection task execution frequency for the inspection task, that is, the preset execution frequency.

As shown in Figure 5, in step 510, the inspection task deployed in the inspection platform is obtained, and the preset execution frequency configured in the inspection task is obtained, and in step 520, the configuration management platform CMDB obtains the The server is the list information of the MQ server, and according to the preset execution frequency and inspection script of the inspection task, the message queue of the MQ server in the list information is inspected according to the message queue index, and the health inspection result is obtained. In step 530, The health inspection result is stored in the Mysql database. In step 540, the health inspection result is extracted from the Mysql database. In step 550, the MQ server with abnormal indicators is located according to the health inspection result. In step 560, the abnormal The MQ server processing of the indicators includes sending the MQ servers with abnormal indicators to the relevant operation and maintenance personnel by email and warning the MQ servers with abnormal indicators through the monitoring system, and reminding the relevant operation and maintenance personnel to timely monitor the MQ servers with abnormal indicators. deal with.

According to the embodiment of the present disclosure, by executing the health inspection method for the message queue in steps 510 to 560, it can be realized that the message queue of the MQ server in the list information can be checked according to the preset execution frequency and inspection script of the inspection task. The message queue indicators are automatically inspected, and the detection results of whether there are abnormal indicators in the message queue of the MQ server in the list information are obtained, and the efficiency of the inspection of the message queue indicators of the message queue of the MQ server in the list information is improved, and the rapid detection is realized. Check the message queue indicators of the message queue of the large-scale MQ server, find abnormal message queues in the message queue of the large-scale MQ server in time, and send the MQ server with abnormal indicators to the relevant operation and maintenance personnel and Through the monitoring system, the MQ server with abnormal indicators will be warned, and the relevant operation and maintenance personnel will be reminded to deal with the MQ server with abnormal indicators in time.

It should be noted that, unless the operations shown in the flow charts in the embodiments of the present disclosure clearly indicate that there is a sequence of execution between different operations, or that there is a sequence of execution of different operations in terms of technical implementation, otherwise, multiple operations The order of execution can be in no particular order, and multiple operations can also be executed at the same time.

Fig. 6 schematically shows a block diagram of a health inspection device for a message queue according to an embodiment of the present disclosure.

As shown in FIG. 6 , a health inspection device 600 for message queues includes an inspection task acquisition module 610 , a server information acquisition module 620 and an inspection result acquisition module 630 .

The inspection task acquiring module 610 is configured to acquire the inspection tasks deployed in the inspection platform, where the inspection tasks are configured with a preset execution frequency.

The server information obtaining module 620 is configured to obtain list information of servers configured with message queues from the configuration management platform, wherein the servers in the list information are pre-deployed with check scripts containing message queue indicators.

The inspection result obtaining module 630 is configured to inspect the message queue of the server in the list information according to the preset execution frequency and inspection script of the inspection task, and obtain the health inspection result.

According to an embodiment of the present disclosure, the message queue indicators include a first-type indicator and a second-type indicator. The first-type indicator represents an indicator of an abnormal information transmission of the server’s message queue in the list information caused by a user’s wrong operation, and the second-type The index represents the necessary index for the message queue of the server in the list information to transmit information normally.

According to an embodiment of the present disclosure, the inspection result obtaining module includes a log information obtaining submodule, a first index value obtaining submodule, and a first inspection result obtaining submodule.

The log information obtaining submodule is used to obtain the log information of the server in the list information.

The first index value obtaining sub-module is used to obtain the index value of the first type of index of the message queue of the server in the list information according to the log information, wherein the index value of the first type of index includes the number of times the user password is entered incorrectly at the client, The current status of the user and the last time the user entered an incorrect password.

The inspection result first obtaining sub-module is used to obtain the health inspection result according to the index value of the first type of index.

According to an embodiment of the present disclosure, the inspection result obtaining module includes a configuration file obtaining submodule, a comparison result obtaining submodule and a second inspection result obtaining submodule.

The configuration file acquisition submodule is used to obtain the configuration file of the server in the manifest information.

The comparison result obtaining sub-module is used to compare the configuration information in the configuration file with the index value of the second type of index to obtain the comparison result, wherein the index value of the second type of index includes at least one of the following: the server in the list information Whether the transmission control protocol is set to a long link, when the receiving server receives a channel connection request and the process related to the channel exists, whether the receiving server uses the establishment of a new channel, the number of seconds for the new incoming process to wait for the old process to end Whether it is equal to the preset value and whether the setting of server self-test for adopting a new channel is turned on.

The inspection result second obtaining sub-module is used to obtain the health inspection result according to the comparison result.

According to an embodiment of the present disclosure, the check script containing the message queue indicator is pre-deployed in the server in the inventory information according to the following steps:

Write an initial check script that includes message queue metrics based on business requirements;

Script release of the initial inspection script through the script management platform;

Perform a functional test on the initial check script to obtain a check script that passes the functional test;

Submit the check script to the script repository;

Deploy the inspection scripts in the script library to the servers in the inventory information according to the scheduled time through the script management platform.

According to an embodiment of the present disclosure, the health inspection device for message queues further includes an inspection result return module and an inspection result storage module.

The inspection result return module is used to return the health inspection result to the inspection platform.

The inspection result storage module is used to store the health inspection result in the inspection result database.

According to an embodiment of the present disclosure, the health inspection device for message queues further includes a server location module and a processing module.

The server location module is used to locate servers with abnormal indicators according to the health inspection results.

The processing module is used to process the servers with abnormal indicators according to the servers with abnormal indicators and the health inspection results.

Modules, sub-modules, units, any multiple of sub-units according to the embodiments of the present disclosure, or at least part of the functions of any multiple of them may be implemented in one module. Any one or more of modules, submodules, units, and subunits according to the embodiments of the present disclosure may be implemented by being divided into multiple modules. Any one or more of modules, submodules, units, and subunits according to embodiments of the present disclosure may be at least partially implemented as hardware circuits, such as field programmable gate arrays (FPGAs), programmable logic arrays (PLAs), system-on-chip, system-on-substrate, system-on-package, application-specific integrated circuit (ASIC), or hardware or firmware that may be implemented by any other reasonable means of integrating or packaging circuits, or in a combination of software, hardware, and firmware Any one of these implementations or an appropriate combination of any of them. Alternatively, one or more of the modules, submodules, units, and subunits according to the embodiments of the present disclosure may be at least partially implemented as computer program modules, and when the computer program modules are executed, corresponding functions may be performed.

For example, any number of the inspection task acquisition module 610, the server information acquisition module 620, and the inspection result acquisition module 630 can be combined in one module/unit/subunit, or any one of the modules/units/subunits Can be split into multiple modules/units/subunits. Alternatively, at least part of the functions of one or more modules/units/subunits of these modules/units/subunits can be combined with at least part of the functions of other modules/units/subunits, and combined in one module/unit/subunit realized in. According to an embodiment of the present disclosure, at least one of the inspection task acquisition module 610, the server information acquisition module 620, and the inspection result acquisition module 630 may be at least partially implemented as a hardware circuit, such as a field programmable gate array (FPGA), programmable logic array (PLA), system-on-chip, system-on-substrate, system-on-package, application-specific integrated circuit (ASIC), or any other reasonable means of integrating or packaging circuits, such as hardware or firmware, may be implemented, Or it may be realized by any one of software, hardware and firmware, or by an appropriate combination of any of them. Alternatively, at least one of the inspection task acquisition module 610, the server information acquisition module 620, and the inspection result acquisition module 630 may be at least partially implemented as a computer program module, and when the computer program module is executed, corresponding functions may be performed .

It should be noted that the part of the health inspection device used for the message queue in the embodiment of the present disclosure corresponds to the part of the health inspection method used for the message queue in the embodiment of the present disclosure, and the health inspection method for the message queue For the description of the inspection device part, please refer to the part of the health inspection method for the message queue, which will not be repeated here.

Fig. 7 schematically shows a block diagram of a computer system suitable for implementing the method described above according to an embodiment of the present disclosure. The computer system shown in FIG. 7 is only an example, and should not limit the functions and scope of use of the embodiments of the present disclosure.

As shown in FIG. 7 , a computer system 700 according to an embodiment of the present disclosure includes a processor 701 that can be loaded into a random access memory (RAM) 703 according to a program stored in a read-only memory (ROM) 702 or loaded from a storage section 708 Various appropriate actions and processing are performed by the program. Processor 701 may include, for example, a general-purpose microprocessor (eg, a CPU), an instruction set processor and/or associated chipset and/or a special-purpose microprocessor (eg, an application-specific integrated circuit (ASIC)), and the like. Processor 701 may also include on-board memory for caching purposes. The processor 701 may include a single processing unit or multiple processing units for executing different actions of the method flow according to the embodiments of the present disclosure.

In the RAM 703, various programs and data necessary for the operation of the system 700 are stored. The processor 701 , ROM 702 , and RAM 703 are connected to each other via a bus 704 . The processor 701 executes the programs in the ROM 702 and/or the RAM 703 to perform various operations according to the method flow of the embodiment of the present disclosure. It should be noted that the program may also be stored in one or more memories other than the ROM 702 and the RAM 703 . The processor 701 may also perform various operations according to the method flow of the embodiments of the present disclosure by executing programs stored in the one or more memories.

According to an embodiment of the present disclosure, the system 700 may also include an input/output (I/O) interface 705 that is also connected to the bus 704 . System 700 may also include one or more of the following components connected to I/O interface 705: an input section 706 including a keyboard, mouse, etc.; etc.; a storage section 708 including a hard disk or the like; and a communication section 709 including a network interface card such as a LAN card, a modem, or the like. The communication section 709 performs communication processing via a network such as the Internet. A drive 710 is also connected to the I/O interface 705 as needed. A removable medium 711 such as a magnetic disk, optical disk, magneto-optical disk, semiconductor memory, etc. is mounted on the drive 710 as necessary so that a computer program read therefrom is installed into the storage section 708 as necessary.

According to the embodiments of the present disclosure, the method flow according to the embodiments of the present disclosure can be implemented as a computer software program. For example, the embodiments of the present disclosure include a computer program product, which includes a computer program carried on a computer-readable storage medium, where the computer program includes program codes for executing the methods shown in the flowcharts. In such an embodiment, the computer program may be downloaded and installed from a network via communication portion 709 and/or installed from removable media 711 . When the computer program is executed by the processor 701, the above-mentioned functions defined in the system of the embodiment of the present disclosure are executed. According to the embodiments of the present disclosure, the above-described systems, devices, devices, modules, units, etc. may be implemented by computer program modules.

The present disclosure also provides a computer-readable storage medium. The computer-readable storage medium may be included in the device/apparatus/system described in the above embodiments; it may also exist independently without being assembled into the device/system device/system. The above-mentioned computer-readable storage medium carries one or more programs, and when the above-mentioned one or more programs are executed, the method according to the embodiment of the present disclosure is realized.

According to an embodiment of the present disclosure, the computer-readable storage medium may be a non-volatile computer-readable storage medium. Examples may include, but are not limited to: portable computer diskettes, hard disks, random access memory (RAM), read-only memory (ROM), erasable programmable read-only memory (EPROM or flash memory), portable compact disk read-only memory (CD- ROM), optical storage devices, magnetic storage devices, or any suitable combination of the above. In the present disclosure, a computer-readable storage medium may be any tangible medium that contains or stores a program that can be used by or in conjunction with an instruction execution system, apparatus, or device.

For example, according to an embodiment of the present disclosure, a computer-readable storage medium may include one or more memories other than the above-described ROM 702 and/or RAM 703 and/or ROM 702 and RAM 703 .

Embodiments of the present disclosure also include a computer program product, which includes a computer program, and the computer program includes program codes for executing the method provided by the embodiments of the present disclosure. When the computer program product is run on an electronic device, the program The code is used to enable the electronic device to implement the health inspection method for the message queue provided by the embodiment of the present disclosure.

When the computer program is executed by the processor 701, the above-mentioned functions defined in the system/device of the embodiment of the present disclosure are executed. According to the embodiments of the present disclosure, the above-described systems, devices, modules, units, etc. may be implemented by computer program modules.

In one embodiment, the computer program may rely on tangible storage media such as optical storage devices and magnetic storage devices. In another embodiment, the computer program can also be transmitted and distributed in the form of a signal on a network medium, downloaded and installed through the communication part 709, and/or installed from the removable medium 711. The program code contained in the computer program can be transmitted by any appropriate network medium, including but not limited to: wireless, wired, etc., or any appropriate combination of the above.

According to the embodiments of the present disclosure, the program codes for executing the computer programs provided by the embodiments of the present disclosure can be written in any combination of one or more programming languages, specifically, high-level procedural and/or object-oriented programming language, and/or assembly/machine language to implement these computing programs. Programming languages include, but are not limited to, programming languages such as Java, C++, python, "C" or similar programming languages. The program code can execute entirely on the user computing device, partly on the user device, partly on the remote computing device, or entirely on the remote computing device or server. In cases involving a remote computing device, the remote computing device may be connected to the user computing device through any kind of network, including a local area network (LAN) or a wide area network (WAN), or may be connected to an external computing device (for example, using an Internet service provider). business to connect via the Internet).

The flowchart and block diagrams in the Figures illustrate the architecture, functionality, and operation of possible implementations of systems, methods and computer program products according to various embodiments of the present disclosure. In this regard, each block in a flowchart or block diagram may represent a module, program segment, or portion of code that includes one or more logical functions for implementing specified executable instructions. It should also be noted that, in some alternative implementations, the functions noted in the block may occur out of the order noted in the figures. For example, two blocks shown in succession may, in fact, be executed substantially concurrently, or they may sometimes be executed in the reverse order, depending upon the functionality involved. It should also be noted that each block in the block diagrams or flowchart illustrations, and combinations of blocks in the block diagrams or flowchart illustrations, can be implemented by a dedicated hardware-based system that performs the specified function or operation, or can be implemented by a A combination of dedicated hardware and computer instructions. Those skilled in the art can understand that various combinations and/or combinations can be made in the various embodiments of the present disclosure and/or the features described in the claims, even if such combinations or combinations are not explicitly recorded in the present disclosure. In particular, without departing from the spirit and teaching of the present disclosure, the various embodiments of the present disclosure and/or the features described in the claims can be combined and/or combined in various ways. All such combinations and/or combinations fall within the scope of the present disclosure.

The embodiments of the present disclosure have been described above. However, these examples are for illustrative purposes only and are not intended to limit the scope of the present disclosure. Although the various embodiments have been described separately above, this does not mean that the measures in the various embodiments cannot be advantageously used in combination. The scope of the present disclosure is defined by the appended claims and their equivalents. Various substitutions and modifications can be made by those skilled in the art without departing from the scope of the present disclosure, and these substitutions and modifications should all fall within the scope of the present disclosure.

Claims (11)

1. A health tour inspection method for a message queue, comprising:

acquiring a patrol task deployed in a patrol platform, wherein the patrol task is configured with a preset execution frequency;

acquiring list information of a server provided with a message queue from a configuration management platform, wherein the server in the list information is pre-deployed with a checking script containing a message queue index; and

and carrying out inspection on the message queue of the server in the list information according to the preset execution frequency of the inspection task and the inspection script and the message queue index to obtain a health inspection result.

2. The method of claim 1, wherein the message queue metrics include a first class of metrics that characterize metrics that cause abnormal information transmission of the message queues of the servers in the manifest information by a user's erroneous operation, and a second class of metrics that characterize metrics necessary for normal information transmission of the message queues of the servers in the manifest information.

3. The method of claim 2, wherein the performing inspection on the message queue of the server in the list information according to the message queue index according to the preset execution frequency of the inspection task and the inspection script, and obtaining a health inspection result includes:

acquiring log information of a server in the list information;

obtaining index values of first indexes of a message queue of a server in the list information according to the log information, wherein the index values of the first indexes comprise user password error transmission times of a client, the current state of a user and the last password error transmission time of the user;

and obtaining the health inspection result according to the index value of the first type index.

4. The method of claim 2, wherein the performing inspection on the message queue of the server in the list information according to the message queue index according to the preset execution frequency of the inspection task and the inspection script, and obtaining a health inspection result includes:

acquiring a configuration file of a server in the list information;

comparing the configuration information in the configuration file with the index values of the second type of indexes to obtain a comparison result, wherein the index values of the second type of indexes comprise at least one of the following: whether the transmission control protocol of the server in the list information is set to be long link, whether the receiver server adopts the establishment of a new channel, whether the number of seconds of the new process waiting for the end of the old process is equal to a preset value or not and whether the server starts the self-detection of the new channel when the receiver server receives the channel connection establishment request and the process related to the channel exists;

And obtaining the health inspection result according to the comparison result.

5. The method of claim 1, the inspection script containing message queue metrics is pre-deployed in a server in the manifest information according to the steps of:

writing an initial checking script containing the message queue index according to the service requirement;

script release is carried out on the initial inspection script through a script management platform;

performing functional test on the initial inspection script to obtain the inspection script passing the functional test;

submitting the checking script to a script library;

and deploying the checking script in the script library to a server in the list information according to preset time through a script management platform.

6. The method of claim 1, further comprising:

returning the health inspection result to the inspection platform;

and storing the health inspection result into an inspection result database.

7. The method of claim 1, further comprising:

positioning a server with abnormal indexes according to the health degree inspection result;

and processing the server with the abnormal index according to the server with the abnormal index and the health degree inspection result.

8. A health tour inspection device for a message queue, comprising:

the system comprises a patrol task acquisition module, a patrol task management module and a control module, wherein the patrol task acquisition module is used for acquiring patrol tasks deployed in a patrol platform, and the patrol tasks are configured with preset execution frequency;

the server information acquisition module is used for acquiring list information of the servers provided with the message queues from the configuration management platform, wherein the servers in the list information are pre-deployed with check scripts containing message queue indexes; and

and the inspection result obtaining module is used for inspecting the message queue of the server in the list information according to the message queue index and the preset execution frequency of the inspection task and the inspection script to obtain a health inspection result.

9. An electronic device, comprising:

one or more processors;

a memory for storing one or more instructions,

wherein the one or more instructions, when executed by the one or more processors, cause the one or more processors to implement the method of any of claims 1 to 7.

10. A computer readable storage medium having stored thereon executable instructions which when executed by a processor cause the processor to implement the method of any of claims 1 to 7.

11. A computer program product comprising computer executable instructions for implementing the method of any one of claims 1 to 7 when executed.

Images