一种消息处理方法和装置.pdf

(19)中华人民共和国国家知识产权局(12)发明专利申请(10)申请公布号CN113535420A(43)申请公布日2021.10.22(21)申请号202010312442.5(22)申请日2020.04.20(71)申请人北京沃东天骏信息技术有限公司地址100176北京市北京经济技术开发区科创十一街18号院2号楼4层A402室申请人北京京东世纪贸易有限公司(72)发明人丰泽王晓成(74)专利代理机构中原信达知识产权代理有限责任公司11219代理人张效荣王志远(51)Int.Cl.G06F9/54(2006.01)权利要求书1页说明书10页附图5页(54)发明名称一种消息处理方法和装置(57)摘要本发明公开了一种消息处理方法和装置，涉及计算机技术领域。该方法的一具体实施方式包括：拉取消息队列中的消息；将消息存储至存储设备，并构建消息存储表，以记录消息的消息信息；根据定制方案和消息信息从存储设备中拉取相应消息进行处理。该实施方式将消息的拉取逻辑和处理逻辑解耦，提高了消息处理效率，降低了处理设备的负载率，降低了消息队列中的消息积压量，同时实现了对消息的定制处理。CN113535420ACN113535420A权利要求书1/1页1.一种消息处理方法，其特征在于，包括：拉取消息队列中的消息；将所述消息存储至存储设备，并构建消息存储表，以记录所述消息的消息信息；根据定制方案和所述消息信息从所述存储设备中拉取相应消息进行处理。2.根据权利要求1所述的消息处理方法，其特征在于，所述消息信息包括下列中的一种或多种：消息编号、消息状态、消息优先级、消息类型和消息日期。3.根据权利要求1所述的消息处理方法，其特征在于，在所述将所述消息存储至存储设备的步骤之前，所述消息处理方法还包括：将所述消息的消息状态设置为未处理。4.根据权利要求1所述的消息处理方法，其特征在于，所述定制方案包括：根据消息优先级、消息类型或消息日期进行处理。5.根据权利要求4所述的消息处理方法，其特征在于，所述根据定制方案和所述消息信息从所述存储设备中拉取相应消息进行处理的步骤包括：根据所述定制方案、每次处理数量以及所述消息信息从所述存储设备中拉取相应消息进行处理。6.根据权利要求1所述的消息处理方法，其特征在于，在所述根据定制方案和所述消息信息从所述存储设备中拉取相应消息进行处理的步骤之后，所述消息处理方法还包括：根据处理结果对相应消息的消息状态进行更新。7.根据权利要求6所述的消息处理方法，其特征在于，所述处理结果包括处理完成和处理失败，在所述根据处理结果对相应的消息的状态进行更新的步骤之前，所述消息处理方法还包括：在任一消息处理失败的次数达到失败阈值的情况下，确定该消息对应的处理结果为处理失败。8.根据权利要求7所述的消息处理方法，其特征在于，在处理结果为处理失败的情况下，所述消息处理方法还包括：生成警示信息，所述警示信息用于记录处理结果为处理失败的消息。9.根据权利要求7所述的消息处理方法，其特征在于，所述消息处理方法还包括：根据时间阈值删除所述存储设备中消息状态为处理完成的消息。10.一种消息处理装置，其特征在于，包括：消息拉取模块，用于拉取消息队列中的消息；存储模块，用于将所述消息存储至存储设备，并构建消息存储表，以记录所述消息的消息信息；处理模块，用于根据定制方案和所述消息信息从所述存储设备中拉取相应消息进行处理。11.一种电子设备，其特征在于，包括：一个或多个处理器；存储装置，用于存储一个或多个程序，当所述一个或多个程序被所述一个或多个处理器执行，使得所述一个或多个处理器实现如权利要求1-9中任一所述的方法。12.一种计算机可读介质，其上存储有计算机程序，其特征在于，所述程序被处理器执行时实现如权利要求1-9中任一所述的方法。2CN113535420A说明书1/10页一种消息处理方法和装置技术领域[0001]本发明涉及计算机技术领域，尤其涉及一种消息处理方法和装置。背景技术[0002]随着计算机业务的飞速发展，越来越多的业务消息需要消费处理。现有技术中主要是通过push(接收)或pull(拉取)方式获取消息，然后直接进行消费。[0003]在实现本发明过程中，发明人发现现有技术中至少存在如下问题：[0004]无论是push方式还是pull方式，消息的接收/拉取逻辑和消费逻辑之间高度耦合，当消息量较大时，处理设备负载较大，消息处理效率低，消息队列中的消息积压量大，消息处理的失败率和重复率较大，且无法实现对消息的定制消费处理。发明内容[0005]有鉴于此，本发明实施例提供一种消息处理方法和装置，能够将消息的接收逻辑和处理逻辑解耦，提高消息处理效率，降低处理设备的负载率，降低消息队列中的消息积压量，同时实现了对消息的定制处理。[0006]为实现上述目的，根据本发明实施