消息处理方法、装置、电子设备及消息处理系统.pdf

(19)国家知识产权局(12)发明专利申请(10)申请公布号CN115801718A(43)申请公布日2023.03.14(21)申请号202211258553.8(22)申请日2022.10.14(71)申请人北京沃东天骏信息技术有限公司地址100176北京市北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人丰泽王晓成(74)专利代理机构北京清亦华知识产权代理事务所(普通合伙)11201专利代理师张润(51)Int.Cl.H04L51/18(2022.01)H04L67/10(2022.01)权利要求书2页说明书12页附图6页(54)发明名称消息处理方法、装置、电子设备及消息处理系统(57)摘要本申请提出一种消息处理方法、装置、电子设备及消息处理系统，涉及计算机技术领域，其中，方法应用于消息处理节点，方法包括：获取所述消息处理节点所处理的第一消息主题中消息的处理状态信息；在确定所述处理状态信息满足第一预设条件的情况下，将所述第一消息主题中的消息转发至多个第二消息主题；并行对多个所述第二消息主题中的消息进行处理。由此，可以在消息处理节点数量固定的情况下，高效利用机器配置资源，从而机器成本消耗低，机器配置资源的利用率高，且由于消息处理节点可以并行对多个第二消息主题中的消息进行处理，从而能够实现快速处理消息，保证消息的时效性。CN115801718ACN115801718A权利要求书1/2页1.一种消息处理方法，其特征在于，应用于消息处理节点，所述方法包括：获取所述消息处理节点所处理的第一消息主题中消息的处理状态信息；在确定所述处理状态信息满足第一预设条件的情况下，将所述第一消息主题中的消息转发至多个第二消息主题；并行对多个所述第二消息主题中的消息进行处理。2.根据权利要求1所述的方法，其特征在于，所述处理状态信息，包括消息积压量；所述在确定所述处理状态信息满足第一预设条件的情况下，将所述第一消息主题中的消息转发至多个第二消息主题，包括：在确定所述消息积压量大于第一预设阈值的情况下，将所述第一消息主题中的消息转发至多个第二消息主题。3.根据权利要求2所述的方法，其特征在于，所述将所述第一消息主题中的消息转发至多个第二消息主题，包括：以预设时间间隔，从所述第一消息主题中获取预设数量的消息；将每次获取的所述预设数量的消息，随机转发至多个所述第二消息主题中的任意一个第二消息主题。4.根据权利要求1所述的方法，其特征在于，所述并行对多个所述第二消息主题中的消息进行处理，包括：通过各所述第二消息主题对应的拉取消息线程，并行从对应的第二消息主题中拉取消息；并行对从各所述第二消息主题中拉取的消息进行处理。5.根据权利要求1‑4任一项所述的方法，其特征在于，所述方法还包括：在确定所述处理状态信息满足第二预设条件的情况下，停止将所述第一消息主题中的消息转发至多个所述第二消息主题，并对所述第一消息主题中的消息进行处理。6.根据权利要求5所述的方法，其特征在于，所述处理状态信息，包括消息积压量以及预设时间段内的消息转发量；所述在确定所述处理状态信息满足第二预设条件的情况下，停止将所述第一消息主题中的消息转发至多个所述第二消息主题，包括：在确定所述消息积压量不大于所述第一预设阈值，且所述预设时间段内的消息转发量小于第二预设阈值的情况下，停止将所述第一消息主题中的消息转发至多个所述第二消息主题。7.一种消息处理装置，其特征在于，应用于消息处理节点，所述装置包括：获取模块，用于获取所述消息处理节点所处理的第一消息主题中消息的处理状态信息；转发模块，用于在确定所述处理状态信息满足第一预设条件的情况下，将所述第一消息主题中的消息转发至多个第二消息主题；第一处理模块，用于并行对多个所述第二消息主题中的消息进行处理。8.根据权利要求7所述的装置，其特征在于，所述处理状态信息，包括消息积压量；所述转发模块，包括：转发单元，用于在确定所述消息积压量大于第一预设阈值的情况下，将所述第一消息2CN115801718A权利要求书2/2页主题中的消息转发至多个第二消息主题。9.根据权利要求8所述的装置，其特征在于，所述转发单元，包括：获取子单元，用于以预设时间间隔，从所述第一消息主题中获取预设数量的消息；转发子单元，用于将每次获取的所述预设数量的消息，随机转发至多个所述第二消息主题中的任意一个第二消息主题。10.根据权利要求7所述的装置，其特征在于，所述第一处理模块，包括：拉取单元，用于通过各所述第二消息主题对应的拉取消息线程，并行从对应的第二消息主题中拉取消息；第一处理单元，用于并行对从各所述第二消息主题中拉取的消息进行处理。11.根据权利要求7‑10任一项所述的装置，其特征在于，所述装置还包括：第二处理模块，用于在确定所述处