分布式系统中顺序消息的处理方法、设备、介质及产品

本申请提供了一种分布式系统中顺序消息的处理方法、设备、介质及产品，属于计算机技术领域。所述方法包括：将生产者发送的消息写入多个节点的多个主题消息队列中；从多个节点对应的多个主题消息队列中，分别拉取位于每个主题消息队列的队列头部的消息，得到多个节点上多个主题的头部消息，每个主题的头部消息均携带在相应节点上的落盘时间戳；按照落盘时间戳由小到大的顺序，对多个节点上的头部消息在同一主题下进行排序，得到多个节点上的头部消息在每种主题下的排序结果；基于多个节点上的头部消息在每种主题下的排序结果，将在每个主题下落盘最早的头部消息推送给消费者。本申请能够保证每个主题的消息的消费顺序。