百安居信息技术(上海)有限公司张林获国家专利权
买专利卖专利找龙图腾,真高效! 查专利查商标用IPTOP,全免费!专利年费监控用IP管家,真方便!
龙图腾网获悉百安居信息技术(上海)有限公司申请的专利一种自适应延时消息数据处理方法、装置、介质及设备获国家发明授权专利权,本发明授权专利权由国家知识产权局授予,授权公告号为:CN114968615B 。
龙图腾网通过国家知识产权局官网在2025-11-11发布的发明授权授权公告中获悉:该发明授权的专利申请号/专利号为:202210415439.5,技术领域涉及:G06F9/54;该发明授权一种自适应延时消息数据处理方法、装置、介质及设备是由张林;刘汉中设计研发完成,并于2022-04-20向国家知识产权局提交的专利申请。
本一种自适应延时消息数据处理方法、装置、介质及设备在说明书摘要公布了:本发明提供一种自适应延时消息数据处理方法、装置、介质及设备。所述方法包括:S11、获取消息数据,将所述消息数据加入预写式日志中并通过调度服务判断所述消息数据的延时时间是否超过时间轮最大缓存时间,若是,则进入S12,若否,则进步S13;S12、筛选预写式日志中延时消息数据,构建延时日志文件与索引文件,将所述延时消息数据写入所述延时日志文件;S13、将所述延时消息数据按照延迟时间懒加载到时间轮;S14、将所述时间轮中到期的消息数据转发消费队列并接收消息数据发送结果;S15、根据所述消息数据发送结果进行数据处理:若发送成功,将所述消息数据及消息数据的索引写入调度日志;若发送失败,则在所述调度日志检索发送失败的消息数据并重新加载到所述时间轮中。本发明实现了实现了支持定义任意时延的业务需求和支持延迟消息宕机或超时重试的场景,解决了现有问题中延时消息的排序和存储问题。
本发明授权一种自适应延时消息数据处理方法、装置、介质及设备在权利要求书中公布了:1.一种自适应延时消息数据处理方法,其特征在于,包括: S11、获取消息数据,将所述消息数据加入预写式日志中并通过调度服务判断所述消息数据的延时时间是否超过时间轮最大缓存时间,若是,则进入S12,若否,则进步S13; S12、筛选预写式日志中延时消息数据,构建延时日志文件与索引文件,将所述延时消息数据写入所述延时日志文件; S13、将所述延时消息数据按照延迟时间懒加载到时间轮; 计算所述延时消息数据的截止发送时间deadline,所述截止发送时间deadline=当前时间+消息延时时间-时间轮启动时时间; 计算所述延时消息数据在所述时间轮中位置,所述延时消息数据在所述时间轮中位置为:对截止发送时间deadline%时间轮长度wheelLength进行hash取模; 将所述延时消息数据以链表的方式存储在所述时间轮对应位置的槽位上,其中,所述链表结构为闭环双向链表; 计算第一延时消息数据与第二延时消息数据之间延时时间差是否为所述时间轮wheelLength*时间轮刻度tickDuration,通过所述时间差判断所述第一延时消息数据与所述第二延时消息数据在所述时间轮中位置是否冲突,若冲突,则创建第二时间轮,将所述第二延时消息数据懒加载进第二时间轮中,其中所述第二时间轮时间轮刻度tickDuration为第一时间轮刻度tickDuration的六十分之一; S14、将所述时间轮中到期的消息数据转发消费队列并接收消息数据发送结果; S15、根据所述消息数据发送结果进行数据处理:若发送成功,将所述消息数据及消息数据的索引写入调度日志;若发送失败,则在所述调度日志检索发送失败的消息数据并重新加载到所述时间轮中。
如需购买、转让、实施、许可或投资类似专利技术,可联系本专利的申请人或专利权人百安居信息技术(上海)有限公司,其通讯地址为:200120 上海市浦东新区银霄路393号百安居浦东商务大楼;或者联系龙图腾网官方客服,联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。
以上内容由龙图腾AI智能生成。
1、本报告根据公开、合法渠道获得相关数据和信息,力求客观、公正,但并不保证数据的最终完整性和准确性。
2、报告中的分析和结论仅反映本公司于发布本报告当日的职业理解,仅供参考使用,不能作为本公司承担任何法律责任的依据或者凭证。

皖公网安备 34010402703815号
请提出您的宝贵建议,有机会获取IP积分或其他奖励