基于Redis的消息处理方法、装置、系统、服务器和介质.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN114116247A(43)申请公布日2022.03.01(21)申请号202110359735.3(22)申请日2021.04.02(71)申请人北京京东拓先科技有限公司地址100176北京市大兴区经济技术开发区科创十一街18号院1号楼7层701室(72)发明人郭思聪迟彪(74)专利代理机构北京英赛嘉华知识产权代理有限责任公司11204代理人王达佐马晓亚(51)Int.Cl.G06F9/54(2006.01)G06F16/22(2019.01)G06F16/2455(2019.01)G06F16/2457(2019.01)权利要求书2页说明书10页附图5页(54)发明名称基于Redis的消息处理方法、装置、系统、服务器和介质(57)摘要本公开的实施例公开了基于Redis的消息处理方法、装置、系统、服务器和介质。该方法的一具体实施方式包括：响应于接收到延迟消息任务，将接收该延迟消息任务的延迟队列集合确定为目标延迟队列集合，其中，该目标延迟队列集合包括从预设的至少两个延迟队列集合中选取的与该延迟消息任务相匹配的延迟队列集合；从与该目标延迟队列集合相匹配的进程集合中选取目标进程；通过该目标进程在该目标延迟队列中查询待处理的延迟消息任务；将该待处理的延迟消息任务发送至预设的消息消费队列。该实施方式减少了延迟队列集合中的信息堆积，避免了消息处理效率的明显降低，提升了整个系统的效率和可靠性。CN114116247ACN114116247A权利要求书1/2页1.一种基于Redis的消息处理方法，包括：响应于接收到延迟消息任务，将接收所述延迟消息任务的延迟队列集合确定为目标延迟队列集合，其中，所述目标延迟队列集合包括从预设的至少两个延迟队列集合中选取的与所述延迟消息任务相匹配的延迟队列集合；从与所述目标延迟队列集合相匹配的进程集合中选取目标进程；通过所述目标进程在所述目标延迟队列中查询待处理的延迟消息任务；将所述待处理的延迟消息任务发送至预设的消息消费队列。2.根据权利要求1所述的方法，其中，所述延迟队列集合中的延迟消息任务对应有用于表征延迟处理时间的延迟时间分数；以及所述通过所述目标进程在所述目标延迟队列中查询待处理的延迟消息任务，包括：执行以下查询步骤：从所述目标延迟队列集合中选取最小的延迟时间分数作为目标分数；响应于确定所述目标分数所指示的时间不晚于当前时间戳所指示的时间，将所述目标分数对应的延迟消息任务确定为所述待处理的延迟消息任务。3.根据权利要求2所述的方法，其中，所述通过所述目标进程在所述目标延迟队列中查询待处理的延迟消息任务，还包括：响应于确定所述目标分数所指示的时间晚于当前时间戳所指示的时间，休眠预设时间后继续执行所述查询步骤。4.根据权利要求1‑3之一所述的方法，其中，所述目标进程包括基于Zookeeper选举得到的临时节点。5.一种基于Redis的消息处理装置，包括：确定单元，被配置成响应于接收到延迟消息任务，将接收所述延迟消息任务的延迟队列集合确定为目标延迟队列集合，其中，所述目标延迟队列集合包括从预设的至少两个延迟队列集合中选取的与所述延迟消息任务相匹配的延迟队列集合；选取单元，被配置成从与所述目标延迟队列集合相匹配的进程集合中选取目标进程；查询单元，被配置成通过所述目标进程在所述目标延迟队列中查询待处理的延迟消息任务；发送单元，被配置成将所述待处理的延迟消息任务发送至预设的消息消费队列。6.一种基于Redis的消息处理系统，包括：生产者，被配置成获取预设的至少两个延迟队列集合的信息；根据所述信息，从所述至少两个延迟队列集合中选取目标延迟队列集合；将所生产的延迟消息任务存入所述目标延迟队列集合；消息处理端，被配置成执行如权利要求1‑4之一所述的方法；消费者，被配置成从所述消息消费队列中选取待处理的延迟消息任务；处理所选取的待处理的延迟消息任务。7.根据权利要求6所述的系统，其中，所述至少两个延迟队列集合中包括对应于同一个键的两个延迟队列集合。8.根据权利要求6或7所述的系统，其中，所述至少两个延迟队列集合的信息包括键；以及2CN114116247A权利要求书2/2页所述生产者被进一步配置成：确定所述至少两个延迟队列集合的键对应的哈希值；将所述键对应的哈希值分配至预设的哈希环上；采用与生成所述键对应的哈希值一致的方式确定所生产的延迟消息任务对应的哈希值；将所述延迟消息任务对应的哈希值映射至所述哈希环；根据所述延迟消息任务对应的哈希值映射至所述哈希环的位置与所述键对应的哈希值分配至预设的哈希环的位置之间的相对关系，选取目标延迟队列集合。9.一种服务器，包括：一个或多个处理器；存储装置，其上存储有一个或多个程序；当所述一个或多个程序被所述一个或