基于MQ框架确保消息队列消费顺序准确性的方法

摘要

本发明涉及基于MQ框架确保消息队列消费顺序准确性的方法，包括如下步骤：步骤一、先将消息消费产生的业务数据以发送Queue‑1、Queue‑2、....、Queue‑N的队列形式发送至生产者的业务服务端口，并对多组发送的业务数据进行分区处理，且由时间戳对业务数据的时间进行标记。通过步骤一到五，实现消息信息数据的分区队列划分和先进先出原则的顺序排序，保证在同一服务端口中的多个消息具有事务特性，使多个对列之间也可保证消息顺序性，能严格保证在集群和单机部署模式下的消息顺序性，以防消费失败，导致消息信息发生阻塞，同时也防止重复消费，再基于MQ框架采用FastDTW公式对各队列信息数据进行精准且全面的计算判断，提高较多消息队列的准确性。