Message consumption method and message system

Abstract

The invention discloses a message consumption method and a message system, and the method comprises the steps: setting N message storage queues and message consumption queues in one-to-one correspondence at a message consumption server and a message storage server respectively, storing the messages in a message storage queue according to a preset queue storage sequence and the marks of the messages by the message distribution server, and consuming the messages from a message consumption queue according to a preset queue consumption sequence and the marks of the messages by the message distribution server, therefore, the last message consumption and the current message consumption meet the requirement that the message consumption queues consume the messages according to the preset queue consumption sequence by taking the preset number as the unit, and the sequential performance when the messages are consumed is ensured. In addition, N message pulling processes are set in the message consumption server and pull the messages from the message storage server at the same time, so that compared with a single message pulling process, the message pulling efficiency and the message consumption efficiency and the message throughput in a high-concurrency scene are improved.

Description

technical field [0001] The invention relates to the field of message consumption, in particular to a message consumption method and a message system. Background technique [0002] In the field of message payment and the industrial field, after the message producer produces the message, the message distribution server will deliver the message produced by the message producer to the message storage server in a certain order, and the message storage server receives the messages delivered by the message distribution server. After the message is stored in the message storage queue of the message storage server in a certain order, when the message is consumed, the message pulling process in the message consumption server pulls the message from the message storage queue of the message storage server to the message storage server's Messages are consumed in the queue and consumed in a certain order, which is sequential consumption. In the existing technology, when sequential consump...

AI Technical Summary

Problems solved by technology

In the existing technology, when sequential consumption is realized, only one message storage queue is set up on the message consumption server and the message storage server, and only a single message pulling process is used on the message consumption server to pull messages from the message storage server. Under the circumstances, due to the slow speed of a single message pulling process from the message storage server, the consumption efficiency of messages in high concurrency scenarios is very low, which reduces the throughput of messages

Images