消息处理方法和处理系统.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN111953506A(43)申请公布日2020.11.17(21)申请号201910408040.2(22)申请日2019.05.15(71)申请人北京沃东天骏信息技术有限公司地址100176北京市大兴区北京经济技术开发区科创十一街18号院2号楼4层A402室(72)发明人张开涛王杰颖邹子靖林本兴田子玉杨嗦(74)专利代理机构北京成创同维知识产权代理有限公司11449代理人蔡纯高青(51)Int.Cl.H04L12/24(2006.01)H04L12/863(2013.01)权利要求书2页说明书7页附图3页(54)发明名称消息处理方法和处理系统(57)摘要本发明实施例提供一种消息处理方法和处理系统，该方法包括：获取处理发生故障的目标队列消息；获取存储频率，且该存储频率小于业务消息队列的消息处理速率；基于存储频率向业务消息队列存储目标队列消息，且业务消息队列同时接收用户发送的新消息；根据业务消息队列中消息的存储顺序进行消息处理。本发明解决了队列消息发生处理故障后新消息积压的技术问题。CN111953506ACN111953506A权利要求书1/2页1.一种消息处理方法，其特征在于，包括：获取处理发生故障的目标队列消息；获取存储频率，所述存储频率小于业务消息队列的消息处理速率；基于所述存储频率向所述业务消息队列存储所述目标队列消息，且所述业务消息队列同时接收用户发送的新消息；根据所述业务消息队列中消息的存储顺序进行消息处理。2.根据权利要求1所述的处理方法，其特征在于，获取存储频率，包括：获取用户发送的新消息和所述目标队列消息之间的处理比例；根据所述处理速率和所述处理比例，确定所述存储频率。3.根据权利要求1所述的处理方法，其特征在于，在获取处理发生故障的目标队列消息之前，所述方法还包括：将所述目标队列消息存储在旁路消息队列中；获取处理发生故障的目标队列消息，包括：从所述旁路消息队列中获取所述目标队列消息。4.根据权利要求3所述的处理方法，其特征在于，所述目标队列消息包括需要重新处理的队列消息，所述旁路消息队列包括容灾消息队列；将所述目标队列消息存储在旁路消息队列中，包括：在所述业务消息队列接收用户发送的新消息时，向所述容灾消息队列中写入所述新消息，以使所述旁路消息队列存储有所述目标队列消息。5.根据权利要求4所述的处理方法，其特征在于，向所述容灾消息队列中写入所述新消息，包括：在所述容灾消息队列中，将所述新消息写入当前容灾队列，其中，所述当前容灾队列为和当前时段所对应的容灾队列；以及，所述容灾消息队列中包括多个容灾队列，每个所述容灾队列对应一个时段且根据所对应时段命名。6.根据权利要求5所述的处理方法，其特征在于，所述容灾队列的配置容量为消息写入极限速率的时段均值。7.根据权利要求3所述的处理方法，其特征在于，所述目标队列消息包括积压的队列消息，所述旁路消息队列包括积压消息队列，将所述目标队列消息存储在旁路消息队列中，包括：在所述业务消息队列中的消息积压数量大于预设阈值的情况下，将所述业务消息队列转化为所述积压消息队列，以使积压消息被所述积压消息队列存储；以及，配置供消息处理使用的新业务消息队列。8.一种消息处理系统，其特征在于，包括：第一获取模块，用于获取处理发生故障的目标队列消息；第二获取模块，用于获取存储频率，所述存储频率小于业务消息队列的消息处理速率；第一存储模块，用于基于所述存储频率向所述业务消息队列存储所述目标队列消息，且所述业务消息队列同时接收用户发送的新消息；2CN111953506A权利要求书2/2页处理模块，用于根据所述业务消息队列中消息的存储顺序进行消息处理。9.根据权利要求8所述的处理系统，其特征在于，所述第二获取模块用于：获取用户发送的新消息和所述目标队列消息之间的处理比例；根据所述处理速率和所述处理比例，确定所述存储频率。10.根据权利要求8所述的处理系统，其特征在于，还包括：第二存储模块，其中，所述第二存储模块，用于在获取处理发生故障的目标队列消息之前，将所述目标队列消息存储在旁路消息队列中；所述第一获取模块，用于从所述旁路消息队列中获取所述目标队列消息。11.根据权利要求10所述的处理系统，其特征在于，所述目标队列消息包括需要重新处理的队列消息，所述旁路消息队列包括容灾消息队列，所述第二存储模块用于：在所述业务消息队列接收用户发送的新消息时，向所述容灾消息队列中写入所述新消息，以使所述旁路消息队列存储有所述目标队列消息。12.根据权利要求11所述的处理系统，其特征在于，所述第二存储模块用于：在所述容灾消息队列中，将所述新消息写入当前容灾队列，其中，所述当前容灾队列为和当前时段所对应的容灾队列；以及，所述容灾消息队列中包括