摘要
本申请公开了一种消息处理方法、计算机设备、存储介质及程序产品,涉及消息处理技术领域,消息处理方法包括:获取多个优先级队列中的待处理消息的消息超期时间,将消息超期时间小于或者等于当前时间的待处理消息添加至执行队列中;基于执行队列的历史队列深度、执行队列的当前队列深度、多个优先级队列的当前队列深度以及多个优先级队列的权重配置信息计算多个优先级队列的消息处理配额;从各优先级队列中选取满足消息处理配额要求的待处理消息,响应于将满足消息处理配额要求的待处理消息添加至执行队列完成,从执行队列中取出待处理消息并发送至处理节点进行处理。解决相关技术中消息调度粗放的技术问题,达到提高消息调度可靠性的技术效果。
技术关键词
队列
配额
更新消息
表征系统
计算机设备
系统资源利用率
判断系统
消息序列号
关系
入口
可读存储介质
存储计算机程序
节点
查询系统
计算机程序产品
偏差
算法
资源分配
处理器