CN110213120B - A pressure measurement method, device and terminal equipment for message middleware - Google Patents

Abstract

The present invention is applicable to the field of communication technology, and provides a pressure measurement method, device and terminal equipment for middleware. The consumption messages are continuously accumulated, and after a preset time period, the running state of the message middleware is monitored, and if the running state of the message middleware is abnormal, it is determined that the performance of the message middleware is abnormal. In the present invention, the communication connection with the consumer terminal is disconnected in the process of producing and consuming information, the concurrent number of the producer terminal is increased, the consumption messages are continuously accumulated, and the running state of the message middleware can be monitored, so as to determine that the message middleware is consuming The running status in the case of message accumulation, to determine whether the message middleware is faulty, to ensure that the message middleware can run continuously and stably during the production and consumption process and avoid unnecessary losses.

Description

A pressure measurement method, device and terminal equipment for message middleware

technical field

The invention belongs to the field of communication technologies, and in particular relates to a pressure measurement method, device and terminal equipment for message middleware.

Background technique

Recently, message middleware has gradually become a core component inside the computer industry system.

The existing daily stress testing methods for message middleware generally focus on the load performance of message middleware under normal circumstances. However, in reality, some abnormal scenarios may occur in actual business services, and abnormal scenarios may cause message middleware The existing pressure measurement methods cannot detect the above exceptions, and the message middleware cannot run continuously and stably, causing some unnecessary losses.

SUMMARY OF THE INVENTION

In view of this, the embodiments of the present invention provide a pressure measurement method, device and terminal equipment for message middleware, so as to solve the problem that the pressure measurement method in the prior art cannot detect the abnormality of the message middleware, and the message middleware cannot be continuously stabilized. operation, causing unnecessary losses.

A first aspect of the embodiments of the present invention provides a pressure measurement method for message middleware, including:

In the process of producing and consuming information, the communication connection with the consumer terminal is disconnected, the concurrent number of the producer terminal is increased, and the consumption information is continuously accumulated;

After a preset time period, monitor the running status of the message middleware;

If the running state of the message middleware is abnormal, it is determined that the performance of the message middleware is abnormal.

Optionally, the method further includes:

Repeatedly performing the steps of disconnecting the communication connection with the consumer terminal during the process of producing and consuming information, increasing the concurrent number of the producer terminal, making the consumption messages continue to accumulate, and opening the communication connection with the consumer terminal;

After a preset time period, monitor the running state of the message middleware and the running state of the consumer terminal;

If the running state of the message middleware is a normal state and the running state of the consumer terminal is an abnormal state, it is determined that the performance of the consumer terminal is abnormal.

Optionally, after monitoring the running state of the message middleware after the preset time period, the method further includes:

If the running state of the message middleware is a normal state, disconnect the communication connection with the master node;

Get the running status of the slave node;

If the running state of the slave node is an abnormal state, it is determined that the performance of the slave node is abnormal.

Optionally, after obtaining the running status of the slave node, it includes:

Repeat the steps of disconnecting the communication connection with the master node to obtain the running status of the slave node;

Open the communication connection with the master node, and obtain the operation state of the master node after opening and the operation state of the slave node after opening;

If the operating state of the master node after being turned on and the operating state of the slave node after turning on are both normal states, it is determined that the switching of the master node and the slave node is normal.

Optionally, after monitoring the running state of the message middleware after the preset time period, the method further includes:

If the running state of the message middleware is a normal state, disconnect the communication connection with the slave node;

Get the running status of the master node;

If the running state of the master node is an abnormal state, it is determined that the master node is abnormal in stress resistance.

A second aspect of the embodiments of the present invention provides a pressure measurement device for message middleware, including:

The first switching module is used for disconnecting the communication connection with the consumer terminal in the process of producing and consuming information, increasing the concurrent number of the producer terminal, and making the consumption messages continue to accumulate;

a first monitoring module, configured to monitor the running state of the message middleware after a preset time period;

The first judgment module is configured to judge that the performance of the message middleware is abnormal if the running state of the message middleware is abnormal.

A third aspect of the embodiments of the present invention provides a terminal device, including: a memory, a processor, and a computer program stored in the memory and executable on the processor, where the processor executes the computer program When implementing the steps of the above method.

A fourth aspect of the embodiments of the present invention provides a computer-readable storage medium, where the computer-readable storage medium stores a computer program, and when the computer program is executed by a processor, the steps of the above method are implemented.

In the embodiment of the present invention, the communication connection with the consumer terminal is disconnected in the process of producing and consuming information, the concurrent number of the producer terminal is increased, the consumption messages are continuously accumulated, and the running status of the message middleware can be monitored, so that the message middleware can be determined. In the running state of the accumulation of consumption messages, it is judged whether the message middleware is faulty, so as to ensure that the message middleware can run continuously and stably during the production and consumption process and avoid unnecessary losses.

Description of drawings

In order to explain the technical solutions in the embodiments of the present invention more clearly, the following briefly introduces the accompanying drawings that need to be used in the description of the embodiments or the prior art. Obviously, the drawings in the following description are only for the present invention. In some embodiments, for those of ordinary skill in the art, other drawings can also be obtained according to these drawings without any creative effort.

FIG. 1 is a schematic flowchart of a pressure measurement method for message middleware according to Embodiment 1 of the present invention;

FIG. 2 is a schematic flowchart of a pressure measurement method for message middleware according to Embodiment 2 of the present invention;

3 is a schematic flowchart of a pressure measurement method for message middleware according to Embodiment 3 of the present invention;

FIG. 4 is a schematic structural diagram of a pressure measurement device for message middleware according to Embodiment 4 of the present invention;

FIG. 5 is a schematic diagram of a terminal device according to Embodiment 5 of the present invention.

Detailed ways

In order for those skilled in the art to better understand the solutions of the present invention, the technical solutions in the embodiments of the present invention will be clearly described below with reference to the accompanying drawings in the embodiments of the present invention. Obviously, the described embodiments are of the present invention. Some examples, but not all examples. Based on the embodiments of the present invention, all other embodiments obtained by persons of ordinary skill in the art without creative efforts shall fall within the protection scope of the present invention.

The term "comprising" and any variations thereof in the description and claims of the present invention and the above drawings are intended to cover non-exclusive inclusions. For example, a process, method or system, product or device comprising a series of steps or units is not limited to the listed steps or units, but optionally also includes unlisted steps or units, or optionally also includes Other steps or units inherent in these processes, methods, products or devices. Also, the terms "first," "second," and "third," etc. are used to distinguish between different objects, rather than to describe a particular order.

In order to illustrate the technical solutions of the present invention, the following specific embodiments are used for description.

Example 1

As shown in FIG. 1 , this embodiment provides a pressure measurement method for message middleware, which can be applied to, for example, a mobile phone, a PC, a tablet computer, or other terminal devices including message middleware. The pressure measurement method for message middleware provided in this embodiment includes:

S101. In the process of producing and consuming information, the communication connection with the consumer terminal is disconnected, the concurrent number of the producer terminal is increased, and the consumption information is continuously accumulated.

In a specific application, the method can be applied to a terminal device containing any message middleware, such as ActiveMQ, RobbitMQ, kafka, redis and other message middleware. In the process of producing and consuming information in a normal state, the message middleware disconnects the communication connection with the consumer terminal, increases the concurrent number of the producer terminal, and keeps the consumption messages accumulating.

S102. After a preset time period, monitor the running state of the message middleware.

In a specific application, after a preset time period elapses, the running state of the message middleware is monitored. The running status of the message middleware includes: the running status of the message middleware, the service communication status and the server resource usage status. The preset time period can be specifically set according to the actual situation, for example, it can be set to 5s.

S103. If the running state of the message middleware is abnormal, determine that the performance of the message middleware is abnormal.

In a specific application, if the message middleware runs abnormally, the service communication is abnormal, or the server resource usage is abnormal, it is determined that the performance of the message middleware is abnormal.

In this embodiment, during the process of producing and consuming information, the communication connection with the consumer terminal is disconnected, the concurrent number of the producer terminal is increased, the consumption messages are continuously accumulated, and the running status of the message middleware can be monitored, so as to determine whether the message middleware is in the The running status in the case of accumulation of consumption messages, to determine whether the message middleware is faulty, to ensure that the message middleware can run continuously and stably during the production and consumption process and avoid unnecessary losses.

Embodiment 2

As shown in FIG. 2 , this embodiment is a further description of the method steps in the first embodiment. In this embodiment, the method further includes:

S104. Repeat the steps of disconnecting the communication connection with the consumer terminal during the process of producing and consuming information, increasing the concurrent number of the producer terminal, making the consumption messages continue to accumulate, and opening the communication connection with the consumer terminal .

In a specific application, the operation of step S101 in the above-mentioned first embodiment is repeated, and the communication connection with the consumer terminal is opened.

S105. After a preset time period, monitor the running state of the message middleware and the running state of the consumer terminal;

In a specific application, after a preset time period, the running status of the message middleware and the consumer terminal is monitored. The running state of the consumer terminal is to detect whether the consumer terminal has repeated consumption.

S106. If the running state of the message middleware is a normal state and the running state of the consumer terminal is an abnormal state, determine that the performance of the consumer terminal is abnormal.

In a specific application, if the running state of the message middleware is in a normal state and the running state of the consumer terminal is in an abnormal state, it is determined that the consumer terminal will have a performance abnormality when consuming messages accumulate.

In one implementation, after the step S102, it further includes:

S107, if the running state of the message middleware is a normal state, disconnect the communication connection with the master node;

S108, obtain the running status of the slave node;

S109. If the running state of the slave node is an abnormal state, determine that the performance of the slave node is abnormal.

In a specific application, when the message middleware is running normally, the communication connection with the master node is cut off, and the running status of the slave node can be observed (such as observing whether the slave node can run normally, whether an error occurs, whether the service communication is normal, the server Whether the resource usage is normal), if the running state of the slave node is abnormal, it is determined that the slave node will have abnormal performance when the consumption messages are accumulated and the communication of the master node is cut off. On the contrary, it is determined that the performance of the slave node is normal when the consumption messages are accumulated and the communication of the master node is cut off.

In one embodiment, after the step S108, it further includes:

Repeat the steps of disconnecting the communication connection with the master node to obtain the running status of the slave node;

Open the communication connection with the master node, and obtain the operation state of the master node after opening and the operation state of the slave node after opening;

If the operating state of the master node after being turned on and the operating state of the slave node after turning on are both normal states, it is determined that the switching of the master node and the slave node is normal.

In a specific application, the above steps S107 to 108 are repeated, the communication connection with the master node is reopened, and the running status of the master node and the running status of the slave node (for example, after the master node is switched) are obtained after the master node is turned on , observe whether the master node is running normally, whether the slave node is running normally, whether the above-mentioned consumption messages are normally produced, whether the above-mentioned consumption messages are normally consumed, whether the server resource usage status is normal, etc.), if the master node is turned on, the running status of the master node and After the master node is turned on, if the running states of the slave nodes are all normal, it is determined that the switching between the master node and the slave node is normal.

In this embodiment, during the production and consumption process, the communication with the master node and/or the slave node is switched multiple times under different circumstances, so as to determine the pressure resistance and operating status of the slave node and the master node under different circumstances, In order to ensure the continuous and stable operation of the master node and the slave node, and provide more guarantees for the production system business.

Embodiment 3

As shown in FIG. 3 , this embodiment is a further description of the method steps in the first embodiment. In this embodiment, after the step S102, it further includes:

S201. If the running state of the message middleware is a normal state, disconnect the communication connection with the slave node.

In a specific application, in the process of producing and consuming information, the communication connection with the consumer terminal is disconnected, the concurrent number of the producer terminal is increased, and the consumption messages are continuously accumulated. After a preset time period, the operation of the message middleware is monitored. If the status is normal, the communication connection with the slave node is disconnected.

S202. Obtain the running status of the master node.

S203. If the running state of the master node is an abnormal state, determine that the master node is abnormal in compression resistance.

In a specific application, if the status of the master node is abnormal after cutting off the communication connection with the slave node (for example, the master node is running abnormally, the service communication is abnormal, or the server resource usage status is abnormal), it is determined that the master node cannot resist High load pressure, that is, the main node is abnormally resistant to pressure. On the contrary, it is determined that the master node can withstand the high load pressure and operate normally, that is, the master node is under normal pressure.

In this embodiment, when the consumption messages are accumulated, the communication connection with the slave node is cut off, and the running state of the master node is judged in the above-mentioned situation, so as to determine the high load resistance of the master node, so as to ensure the performance of the master node and make the consumption Messages are produced and consumed normally.

It should be understood that the size of the sequence numbers of the steps in the above embodiments does not mean the sequence of execution, and the execution sequence of each process should be determined by its functions and internal logic, and should not constitute any limitation to the implementation process of the embodiments of the present invention.

Embodiment 4

As shown in FIG. 4 , this embodiment provides a pressure measurement apparatus 100 for message middleware, which is used to execute the method steps in the first embodiment. The pressure measurement device 100 for message middleware provided in this embodiment includes:

The first switching module 101 is used for disconnecting the communication connection with the consumer terminal in the process of producing and consuming information, increasing the concurrent number of the producer terminal, and making the consumption messages continue to accumulate;

a first monitoring module 102, configured to monitor the running state of the message middleware after a preset time period;

The first judgment module 103 is configured to judge that the performance of the message middleware is abnormal if the running state of the message middleware is abnormal.

In one embodiment, the apparatus 100 further includes:

The opening module is used for repeatedly executing the process of producing and consuming information, disconnecting the communication connection with the consumer terminal, increasing the concurrent number of the producer terminal, making the consumption messages continue to accumulate steps, and opening the communication connection with the consumer terminal communication connection;

a second monitoring module, configured to monitor the running state of the message middleware and the running state of the consumer terminal after a preset time period;

The second judgment module is configured to judge that the performance of the consumer terminal is abnormal if the running state of the message middleware is a normal state and the running state of the consumer terminal is an abnormal state.

In one embodiment, the apparatus 100 further includes:

a second switching module, configured to disconnect the communication connection with the master node if the operating state of the message middleware is a normal state;

The first obtaining module is used to obtain the running status of the slave node;

The third judging module is configured to judge that the performance of the slave node is abnormal if the running state of the slave node is an abnormal state.

In one embodiment, the apparatus 100 includes:

a fourth judging module, used for repeating the steps of disconnecting the communication connection with the master node and acquiring the running state of the slave node;

a second acquiring module, configured to open a communication connection with the master node, and acquire the running state of the master node after opening and the running state of the slave node after opening;

A fifth judging module, configured to judge that the switching of the master node and the slave node is normal if the operating state of the master node after turning on and the operating state of the slave node after turning on are both normal states.

In one embodiment, the apparatus 100 further includes:

a third switching module, configured to disconnect the communication connection with the slave node if the running state of the message middleware is a normal state;

The third acquisition module is used to acquire the running status of the master node;

The sixth judgment module is used for judging that the master node is abnormal under pressure if the running state of the master node is abnormal

In this embodiment, during the process of producing and consuming information, the communication connection with the consumer terminal is disconnected, the concurrent number of the producer terminal is increased, the consumption messages are continuously accumulated, and the running status of the message middleware can be monitored, so as to determine whether the message middleware is in the The running status in the case of accumulation of consumption messages, to determine whether the message middleware is faulty, to ensure that the message middleware can run continuously and stably during the production and consumption process and avoid unnecessary losses.

Embodiment 5

FIG. 5 is a schematic diagram of a terminal device provided in this embodiment. As shown in FIG. 5 , the terminal device 5 in this embodiment includes: a processor 50 , a memory 51 , and a computer program 52 stored in the memory 51 and executable on the processor 50 , such as a message middleware test program. When the processor 50 executes the computer program 52 , the steps in the above-mentioned embodiments of the pressure measurement method for each message middleware are implemented, for example, steps S101 to S103 shown in FIG. 1 . Alternatively, when the processor 50 executes the computer program 52, the functions of the modules/units in each of the foregoing apparatus embodiments, such as the functions of the modules 101 to 103 shown in FIG. 4, are implemented.

Exemplarily, the computer program 52 can be divided into one or more modules/units, and the one or more modules/units are stored in the memory 51 and executed by the processor 50 to complete the this invention. The one or more modules/units may be a series of computer program instruction segments capable of performing specific functions, and the instruction segments are used to describe the execution process of the computer program 52 in the terminal device 5 . For example, the computer program 52 can be divided into a first switching module, a first monitoring module and a first judgment module, and the specific functions of each module are as follows:

The first switching module is used for disconnecting the communication connection with the consumer terminal in the process of producing and consuming information, increasing the concurrent number of the producer terminal, and making the consumption messages continue to accumulate;

a first monitoring module, configured to monitor the running state of the message middleware after a preset time period;

The first judgment module is configured to judge that the performance of the message middleware is abnormal if the running state of the message middleware is abnormal.

The terminal device 5 may be a computing device such as a desktop computer, a notebook, a palmtop computer, and a cloud server. The terminal device may include, but is not limited to, the processor 50 and the memory 51 . Those skilled in the art can understand that FIG. 5 is only an example of the terminal device 5, and does not constitute a limitation on the terminal device 5. It may include more or less components than the one shown, or combine some components, or different components For example, the terminal device may further include an input and output device, a network access device, a bus, and the like.

The so-called processor 50 may be a central processing unit (Central Processing Unit, CPU), and may also be other general-purpose processors, digital signal processors (Digital Signal Processors, DSP), application specific integrated circuits (Application Specific Integrated Circuit, ASIC), Off-the-shelf programmable gate array (Field-Programmable Gate Array, FPGA) or other programmable logic devices, discrete gate or transistor logic devices, discrete hardware components, and the like. A general purpose processor may be a microprocessor or the processor may be any conventional processor or the like.

The memory 51 may be an internal storage unit of the terminal device 5 , such as a hard disk or a memory of the terminal device 5 . The memory 51 may also be an external storage device of the terminal device 5, such as a plug-in hard disk, a smart memory card (Smart Media Card, SMC), a secure digital card (Secure Digital, SD card) equipped on the terminal device 5. ), Flash Card, etc. Further, the memory 51 may also include both an internal storage unit of the terminal device 5 and an external storage device. The memory 51 is used for storing the computer program and other programs and data required by the terminal device. The memory 51 can also be used to temporarily store data that has been output or will be output.

Those skilled in the art can clearly understand that, for the convenience and simplicity of description, only the division of the above-mentioned functional units and modules is used as an example. Module completion, that is, dividing the internal structure of the device into different functional units or modules to complete all or part of the functions described above. Each functional unit and module in the embodiment may be integrated in one processing unit, or each unit may exist physically alone, or two or more units may be integrated into one unit, and the above-mentioned integrated units may adopt hardware. It can also be realized in the form of software functional units. In addition, the specific names of the functional units and modules are only for the convenience of distinguishing from each other, and are not used to limit the protection scope of the present application. For the specific working processes of the units and modules in the above-mentioned system, reference may be made to the corresponding processes in the foregoing method embodiments, which will not be repeated here.

In the foregoing embodiments, the description of each embodiment has its own emphasis. For parts that are not described or described in detail in a certain embodiment, reference may be made to the relevant descriptions of other embodiments.

Those of ordinary skill in the art can realize that the units and algorithm steps of each example described in conjunction with the embodiments disclosed herein can be implemented in electronic hardware, or a combination of computer software and electronic hardware. Whether these functions are performed in hardware or software depends on the specific application and design constraints of the technical solution. Skilled artisans may implement the described functionality using different methods for each particular application, but such implementations should not be considered beyond the scope of the present invention.

In the embodiments provided by the present invention, it should be understood that the disclosed apparatus/terminal device and method may be implemented in other manners. For example, the apparatus/terminal device embodiments described above are only illustrative. For example, the division of the modules or units is only a logical function division. In actual implementation, there may be other division methods, such as multiple units. Or components may be combined or may be integrated into another system, or some features may be omitted, or not implemented. On the other hand, the shown or discussed mutual coupling or direct coupling or communication connection may be through some interfaces, indirect coupling or communication connection of devices or units, and may be in electrical, mechanical or other forms.

The units described as separate components may or may not be physically separated, and components displayed as units may or may not be physical units, that is, may be located in one place, or may be distributed to multiple network units. Some or all of the units may be selected according to actual needs to achieve the purpose of the solution in this embodiment.

In addition, each functional unit in each embodiment of the present invention may be integrated into one processing unit, or each unit may exist physically alone, or two or more units may be integrated into one unit. The above-mentioned integrated units may be implemented in the form of hardware, or may be implemented in the form of software functional units.

The integrated modules/units, if implemented in the form of software functional units and sold or used as independent products, may be stored in a computer-readable storage medium. Based on this understanding, the present invention can implement all or part of the processes in the methods of the above embodiments, and can also be completed by instructing relevant hardware through a computer program, and the computer program can be stored in a computer-readable storage medium. When the program is executed by the processor, the steps of the foregoing method embodiments can be implemented. Wherein, the computer program includes computer program code, and the computer program code may be in the form of source code, object code, executable file or some intermediate form, and the like. The computer-readable medium may include: any entity or device capable of carrying the computer program code, a recording medium, a U disk, a removable hard disk, a magnetic disk, an optical disk, a computer memory, a read-only memory (ROM, Read-Only Memory) , Random Access Memory (RAM, Random Access Memory), electric carrier signal, telecommunication signal and software distribution medium, etc. It should be noted that the content contained in the computer-readable media may be appropriately increased or decreased according to the requirements of legislation and patent practice in the jurisdiction, for example, in some jurisdictions, according to legislation and patent practice, the computer-readable media Electric carrier signals and telecommunication signals are not included.

The above-mentioned embodiments are only used to illustrate the technical solutions of the present invention, but not to limit them; although the present invention has been described in detail with reference to the foregoing embodiments, those of ordinary skill in the art should understand that: it is still possible to implement the foregoing implementations. The technical solutions described in the examples are modified, or some technical features thereof are equivalently replaced; and these modifications or replacements do not make the essence of the corresponding technical solutions deviate from the spirit and scope of the technical solutions of the embodiments of the present invention, and should be included in the within the protection scope of the present invention.

Claims (9)

1. A method for pressure measurement of message middleware, comprising:

in the process of producing the consumption information, the communication connection with the consumer terminal is disconnected, the concurrence number of the producer terminal is improved, and the consumption information is continuously accumulated;

after a preset time period, monitoring the running state of the message middleware;

if the running state of the message middleware is a normal state, disconnecting the communication connection with the slave node;

acquiring the running state of a main node;

if the running state of the main node is an abnormal state, judging that the main node is abnormal in pressure resistance;

and if the running state of the message middleware is abnormal, judging that the performance of the message middleware is abnormal.

2. The method of pressure testing of message middleware of claim 1, the method further comprising:

in the process of repeatedly executing the production consumption information, disconnecting the communication connection with the consumer terminal, improving the concurrency of the producer terminal, continuously accumulating the consumption information, and opening the communication connection with the consumer terminal;

after a preset time period, monitoring the running state of the message middleware and the running state of the consumer terminal;

and if the running state of the message middleware is a normal state and the running state of the consumer terminal is an abnormal state, judging that the performance of the consumer terminal is abnormal.

3. The method for pressure measurement of message middleware of claim 1, wherein after monitoring the operating state of the message middleware after a preset time period, further comprising:

if the running state of the message middleware is a normal state, disconnecting the communication connection with the main node;

acquiring the running state of a slave node;

and if the running state of the slave node is an abnormal state, judging that the performance of the slave node is abnormal.

4. The message middleware pressure measurement method as claimed in claim 3, wherein after acquiring the operation state of the slave node, the method comprises:

repeating the step of disconnecting the communication connection with the master node and acquiring the running state of the slave node;

starting communication connection with the main node, and acquiring the running state of the main node after starting and the running state of the slave node after starting;

and if the running state of the started master node and the running state of the started slave node are both normal states, judging that the master node and the slave node are switched normally.

5. A device for pressure measurement of message middleware, comprising:

the first switching module is used for disconnecting the communication connection with the consumer terminal in the process of producing the consumption information, so that the concurrency of the producer terminal is improved, and the consumption information is continuously accumulated;

the first monitoring module is used for monitoring the running state of the message middleware after a preset time period;

the third switching module is used for disconnecting the communication connection with the slave node if the running state of the message middleware is a normal state;

the third acquisition module is used for acquiring the running state of the main node;

the sixth judgment module is used for judging that the main node is abnormal in pressure resistance if the running state of the main node is abnormal;

and the first judgment module is used for judging that the performance of the message middleware is abnormal if the running state of the message middleware is abnormal.

6. The message middleware pressure measurement device as claimed in claim 5, further comprising:

the starting module is used for disconnecting the communication connection with the consumer terminal in the process of repeatedly executing the production consumption information, improving the concurrency of the producer terminal, continuously accumulating the consumption information, and starting the communication connection with the consumer terminal;

the second monitoring module is used for monitoring the running state of the message middleware and the running state of the consumer terminal after a preset time period;

and the second judgment module is used for judging that the performance of the consumer terminal is abnormal if the running state of the message middleware is a normal state and the running state of the consumer terminal is an abnormal state.

7. The message middleware pressure measurement device as claimed in claim 6, further comprising:

the second switching module is used for disconnecting the communication connection with the main node if the running state of the message middleware is a normal state;

the first acquisition module is used for acquiring the running state of the slave node;

and the third judging module is used for judging that the performance of the slave node is abnormal if the running state of the slave node is an abnormal state.

8. A terminal device comprising a memory, a processor and a computer program stored in the memory and executable on the processor, characterized in that the processor implements the steps of the method according to any of claims 1 to 4 when executing the computer program.

9. A computer-readable storage medium, in which a computer program is stored which, when being executed by a processor, carries out the steps of the method according to any one of claims 1 to 4.

Images