Message processing method, device, electronic device and readable storage medium

Abstract

An embodiment of the present invention provides a message processing method, device, electronic device, and readable storage medium, wherein the method includes: receiving the first message sent by the production server, and storing the first message in the same business type as the first message In the corresponding message queue, M first messages are obtained from the message queue, each first message is written into the first memory buffer queue corresponding to the first target service identifier by using M first threads, The first target service address associated with the business identifier, using N second threads to read N first messages in the first memory buffer queue, and sending N first request messages to the target server corresponding to the first target service address, The N first messages are processed by invoking the service corresponding to the target server N times. Thereby, a faster reading operation can be realized, to a certain extent, the backlog of messages in the message queue can be avoided, and the consumption efficiency of messages in the message queue can be improved.

Description

technical field [0001] The invention relates to the technical field of data processing, in particular to a message processing method, device, electronic equipment and a readable storage medium. Background technique [0002] Because the system based on the microservice architecture is easy to develop and maintain, it has been applied to the development of larger projects. At the same time, in order to realize the coupling between microservices, asynchronous message processing, current limiting and peak shaving and other functions, the production and consumption mode is usually applied. [0003] The production and consumption mode is specifically: the server that publishes the message (production server) publishes the message to the message queue (MQ, Message Queue) in the production server cluster, a message queue is a buffer, and the server that consumes the message (consumer server) reads the Take out the message and process the message. After processing a message, continu...

AI Technical Summary

Problems solved by technology

[0004] However, when a large number of messages remain in the message queue for some reason (for example, the consumer server takes a long time to process the message), in this case, the production server must pause and wait (that is, block the producer thread), thereby affecting the message Consumption efficiency of messages in the queue

Images