Message scheduling method and system and related components

Abstract

The invention discloses a message scheduling method and system and a related component. The method comprises the following steps: continuously receiving messages of a message producer; executing the following operations on the same group of messages: numbering all the messages in an increased order according to a logical order to determine the sequence number of each message, and initializing and assigning an executable sequence number as the sequence number of the first message; the following operations are repeatedly executed until all the messages are executed: whether a target message exists or not is judged, and the target message is specifically a message of which the sequence serial number is the same as the current executable serial number; and if yes, executing the target message, and adding one to the current executable serial number. According to the method, the same group of messages are numbered according to the logic sequence, the sequence serial numbers and the executable serial numbers are compared, and only the messages corresponding to the executable serial numbers are executed, so that the problem that the message sequence of a message producer is disordered is avoided, the message execution sequence is clear, the sequence disorder of a consumer is avoided, and the user experience is improved. And smooth completion of the group of messages is ensured.

Description

technical field [0001] The invention relates to the field of message queue processing, in particular to a message scheduling method, system and related components. Background technique [0002] When currently processing messages, in some application scenarios, due to network delays or differences in the logic execution speed of code blocks, the messages in the message queue cannot be processed in the logical order of the messages, and there are multiple messages in the consumer group. Each consumer has the opportunity to execute the message, which also prevents the message from being executed in a normal logical order. Once the message is not executed in the order, it will cause the flow of the message group to be disordered and stuck. It is difficult to guarantee that all The successful completion of the message. [0003] Therefore, how to provide a solution to the above technical problems is a problem that those skilled in the art need to solve. Contents of the inventio...

AI Technical Summary

Problems solved by technology

[0002] When currently processing messages, in some application scenarios, due to network delays or differences in the logic execution speed of code blocks, the messages in the message queue cannot be processed in the logical order of the messages, and there are multiple messages in the consumer group. Each consumer has the opportunity to execute the message, which also prevents the message from being executed in a normal logical order. Once the message is not executed in the order, it will cause the flow of the message group to be disordered and stuck. It is difficult to guarantee that all successful completion of the message

Images