有效

基于滑动窗口的消息消费方法、装置、设备及存储介质

彭勇、尹全军、王鹏、胡越、赵栋、曾俊杰、曾云秀、刘吉元、杨硕、杨伟、杨金华
中国人民解放军国防科技大学

摘要

本申请涉及一种基于滑动窗口的消息消费方法、装置、设备及存储介质。所述方法包括:在消息生产者和消息消费者之间部署消息中间件,构建第一滑动窗口和第二滑动窗口记录消息中间件中的待发送消息、发送中消息和消息中间件是否接收到已确认消费消息,并分别构建第一位图表和第二位图表存储滑动窗口记录的信息,在消息中间件上同步滑动第一滑动窗口与第二滑动窗口,并当第二滑动窗口记录到消息中间件接收到已确认消费消息时,将已确认消费消息的最小位移存储至本地磁盘中,直至消息中间件发布的所有消息消费完成。本方法通过采用位图与滑动窗口结合的机制,大幅降低消息消费所需的内存,加快消息消费进度,满足海量消息的处理需求。

暂无引用专利