-
公开(公告)号:CN114428685A
公开(公告)日:2022-05-03
申请号:CN202011180135.2
申请日:2020-10-29
Applicant: 中移动信息技术有限公司 , 中国移动通信集团有限公司
IPC: G06F9/54
Abstract: 本申请实施例提供了一种数据处理的方法、装置、设备及计算机存储介质,方法包括:接收消息的调用请求,根据消息的调用请求,从分布式缓存中获取消息对应的消息队列的延迟时长,以及消息对应的第一预设时长,当消息队列的延迟时长大于或者等于第一预设时长时,消息队列对应的线程级消费器将消息移出消息队列,可动态调整消息队列的大小,确定在第一预设时长内消息队列中消息的调用数量。在调用消息的同时,根据消息队列的大小确定消息的调用数量,不需要等待缓存刷新才能对消息的调用数量进行统计,避免了对消息的调用数量进行二次累计,实时性强,减少了计算资源消耗。