(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211193676.8 (22)申请日 2022.09.28 (71)申请人 建信金融科技有限责任公司 地址 200120 上海市浦东 新区自由贸易试 验区银城路9 9号12层、 15层 (72)发明人 邵蔚　 (74)专利代理 机构 北京润平知识产权代理有限 公司 11283 专利代理师 高英英 (51)Int.Cl. G06F 9/54(2006.01) G06F 9/48(2006.01) G06F 16/2455(2019.01) (54)发明名称 消息的消费方法和装置、 机器可读存储介质 及处理器 (57)摘要 本申请实施例涉及任务调度技术领域， 具体 涉及一种消息的消费方法和装置、 机器可读存储 介质及处理器。 消费方法包括： 针对预设内存队 列中的待被消费的待消费消息， 依次执行以下内 容： 为当前待消费消息确定消费者； 从所述预设 内存队列中获取所述当前待消费消息； 以及将所 述当前待消费消息投递给所确定的消费者， 以对 所述当前待消费消息进行消费。 藉此， 实现了消 费消息。 权利要求书3页 说明书11页 附图3页 CN 115454679 A 2022.12.09 CN 115454679 A 1.一种消息的消费方法， 其特 征在于， 所述消费方法包括： 针对预设内存队列中的待被消费的待消费消息， 依次执 行以下内容： 为当前待消费消息确定消费者； 从所述预设内存队列中获取 所述当前待消费消息； 以及 将所述当前待消费消息投递给 所确定的消费者， 以对所述当前待消费消息进行消费。 2.根据权利要求1所述的消费方法， 其特征在于， 所述为当前待消费消息确定消费者包 括： 在所述当前待消费消息不存在消息组标识 的情况下， 根据第一预设规则， 从预设消费 者列表中为所述当前待消费消息 选择所述消费者； 和/或 在所述当前待消费消息存在所述消息组标识的情况 下， 执行以下内容： 判断预设对应关系表中是否有与所述当前待消费消息的消息组标识对应的所述消费 者， 其中， 所述预设对应关系表包括所述消息组标识与所述消费者的对应关系； 以及 在所述预设对应关系表中没有与所述当前待消费消息的消息组标识对应的所述消费 者的情况下， 根据第二预设规则， 从所述预设消费者列表中为所述当前待消费消息选择所 述消费者； 和/或 在所述预设对应关系表中有与所述当前待消费消息的消息组标识对应的所述消费者 的情况下， 所述预设对应关系中的与所述当前待消费消息的消息组标识对应的所述消费者 即为为所述当前待消费消息确定的所述消费者。 3.根据权利要求2所述的消费方法， 其特征在于， 在所述当前待消费消息存在所述消息 组标识的情况 下， 所述消费方法还 包括： 在将所述当前待消费消息投递给所确定的消费者后， 判断所述当前待消费消息是否存 在结束标识； 以及 在所述当前待消费消息存在所述结束标识的情况下， 在所述当前待消费消息被消费 后， 在所述预设对应关系表中删除所述当前待消费消息的消息组标识和所述消费者的对应 关系。 4.根据权利要求2所述的消费方法， 其特征在于， 在所述当前待消费消息存在所述消息 组标识但所述预设对应关系表中没有与所述当前待消费消息的消息组标识对应的所述消 费者的情况 下， 所述消费方法还 包括： 在所述预设对应关系中增加针对所述当前待消费消息的消息组标识的所述对应关系， 其中， 针对所述当前待消费消息的消息组标识的所述对应关系为所述当前待消费消息的消 息组标识与根据所述第二预设规则从所述预设消费者列表中为所述当前待消费消息选择 的所述消费者之间的对应关系。 5.根据权利要求1所述的消费方法， 其特征在于， 在将所述当前待消费消息投递给所确 定的消费者之前， 所述消费方法还 包括： 判断所确定的消费者是否处于空 闲状态； 以及 在所确定的消费者处于所述空闲状态的情况下， 将所述当前待消费消息投递给所确定 的消费者； 和/或 在所确定的消费者未处于所述空闲状态的情况下， 持续判断所确定的消费者是否处于 所述空闲状态， 直到所确定的消费者处于所述空闲状态， 将所述当前待消费消息投递给所权　利　要　求　书 1/3 页 2 CN 115454679 A 2确定的消费者。 6.根据权利要求1所述的消费方法， 其特 征在于， 所述消费方法还 包括： 将所述当前待消费消息投递给所确定的消费者后， 将所述当前待消费消息存储到预设 缓存空间中。 7.根据权利要求6所述的消费方法， 其特 征在于， 所述消费方法还 包括： 在所确定的消费者消费所述当前待消费消息的过程中出现故障的情况下， 重新为所述 当前待消费消息确定消费者； 从所述预设缓存空间获取 所述当前待消费消息； 以及 将所述当前待消费消息投递给重新确定的消费者。 8.根据权利要求1所述的消费方法， 其特 征在于， 所述消费方法还 包括： 在所述预设内存队列中的待消费消息的数量达到第 一预设值的情况下， 从预设数据库 中获取所述待消费消息放入所述预设内存队列中， 以使得所述数量达到第二预设值， 其中， 所述第一预设值小于所述第二预设值。 9.一种消息的消费装置， 其特 征在于， 所述消费装置包括： 消息处理模块， 用于针对预设内存队列中的待被消费的待消费消息， 依次执行以下内 容： 为当前待消费消息确定消费者； 从所述预设内存队列中获取 所述当前待消费消息； 以及 将所述当前待消费消息投递给 所确定的消费者， 以对所述当前待消费消息进行消费。 10.根据权利要求9所述的消费装置， 其特征在于， 所述消息处理模块为当前待消费消 息确定消费者包括： 在所述当前待消费消息不存在消息组标识 的情况下， 根据第一预设规则， 从预设消费 者列表中为所述当前待消费消息 选择所述消费者； 和/或 在所述当前待消费消息存在所述消息组标识的情况 下， 执行以下内容： 判断预设对应关系表中是否有与所述当前待消费消息的消息组标识对应的所述消费 者， 其中， 所述预设对应关系表包括所述消息组标识与所述消费者的对应关系； 以及 在所述预设对应关系表中没有与所述当前待消费消息的消息组标识对应的所述消费 者的情况下， 根据第二预设规则， 从所述预设消费者列表中为所述当前待消费消息选择所 述消费者； 和/或 在所述预设对应关系表中有与所述当前待消费消息的消息组标识对应的所述消费者 的情况下， 所述预设对应关系中的与所述当前待消费消息的消息组标识对应的所述消费者 即为为所述当前待消费消息确定的所述消费者。 11.根据权利要求10所述的消费装置， 其特 征在于， 所述消息处 理模块还用于： 在所述当前待消费消息存在所述消息组标识的情况下， 在将所述当前待消费消息投递 给所确定的消费者后， 判断所述当前待消费消息是否存在结束标识； 以及 在所述当前待消费消息存在所述结束标识的情况下， 在所述当前待消费消息被消费 后， 在所述预设对应关系表中删除所述当前待消费消息的消息组标识和所述消费者的对应 关系。 12.根据权利要求10所述的消费装置， 其特 征在于， 所述消息处 理模块还用于：权　利　要　求　书 2/3 页 3 CN 115454679 A 3