摘要
本发明公开了一种分布式延迟队列的方法及系统,属于云计算技术领域,延迟队列包括任务池、延迟等待队列、定时执行器、待执行队列,任务池中存放所有任务的元数据、需要进行异步处理的任务,是分布式延迟队列中的基本处理单元;延迟等待队列是一组以时间为维度的有序队列,用来存放需要进行延迟操作的任务;定时执行器负责实时的对延迟等待队列进行扫描,并将延迟时间大于当前时间的任务放入待执行队列中,以便执行后续流程;待执行队列存放经过定时执行器处理、已到达执行时间节点的任务,在待执行队列中存放任务的唯一标识,提供给后续业务处理模块进行消费。本发明能够实现可靠的消息传输,具有高可用特性,支持队列消息的指定删除。