(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211237370.8 (22)申请日 2022.10.11 (71)申请人 苏州万店掌网络科技有限公司 地址 215011 江苏省苏州市高新区竹园路 209号 (72)发明人 顾悦　薛飞　黄岗　周圣强　 (74)专利代理 机构 北京集佳知识产权代理有限 公司 11227 专利代理师 杨帆 (51)Int.Cl. G06F 9/50(2006.01) G06F 9/54(2006.01) (54)发明名称 一种消息消费方法、 装置、 设备及 介质 (57)摘要 本申请公开了一种消息消费方法、 装置、 设 备及介质， 涉及智能平台技术领域， 该方法包括： 利用预设消费者组件从预设消息发布系统中拉 取第一目标消息， 并将第一目标消息发送至第一 目标消息所属的目标分区唯一对应的目标分区 工作者组件； 控制目标分区工作者组件利用预设 的业务执行者组件对第一目标消息进行处理， 并 在第一目标消息处理完成后， 将所述目标分区工 作者组件的运行状态标记为完成状态， 并记录所 述目标分区工作者组件的位移量； 当预设消费者 组件监测到目标分区工作者组件的运行状态为 完成状态， 则获取目标分区工作者组件的位移 量， 将位移量手动提交至预设消息发布系统。 本 发明自定义消费者类组件， 实现消息处理与消息 处理管理的解耦。 权利要求书2页 说明书10页 附图6页 CN 115328664 A 2022.11.11 CN 115328664 A 1.一种消息消费方法， 其特 征在于， 包括： 利用预设的消费者组件从预设消息发布系统中拉取第 一目标消息， 并将所述第 一目标 消息发送至所述第一目标消息所属的目标分区唯一对应的目标分区工作者组件； 控制所述目标分区工作者组件利用预设的业务执行者组件对所述第一目标消息进行 处理； 在所述第一目标消息处理完成后， 将所述目标分区工作者组件的运行状态标记为完成 状态， 并记录所述目标分区工作者组件的位移量； 当所述预设的消费者组件监测到所述目标分区工作者组件的运行状态为完成状态， 则 获取所述目标分区工作者组件的位移量， 并将所述位移 量手动提交至所述预设消息发布系 统。 2.根据权利要求1所述的消息消费方法， 其特征在于， 所述将所述第 一目标消息发送至 所述第一目标消息所属的目标分区唯一对应的目标分区工作者组件， 包括： 确定所述第 一目标消息的消息标识， 并基于所述消息标识中的所述第 一目标消息所属 的目标主题与分区标识确定目标分区； 将所述第一目标消息发送至所述目标分区唯一对应的目标分区工作者组件。 3.根据权利要求1所述的消息消费方法， 其特征在于， 所述将所述第 一目标消息发送至 所述第一目标消息所属的目标分区唯一对应的目标分区工作者组件， 包括： 将所述第一目标消息发送至所述第一目标消息所属的目标分区唯一对应的目标分区 工作者组件的消息队列中； 相应的， 所述控制所述目标分区工作者组件利用预设的业务执行者组件对所述第 一目 标消息进行处理， 并在所述第一 目标消息处理结束后， 将所述 目标分区工作者组件的运行 状态标记为完成状态， 并记录所述目标分区工作者组件的位移量， 包括： 控制所述目标分区工作者组件利用预设的业务执行者组件对所述消息队列中的第一 目标消息进行 处理， 并在所述消息队列中全部消息处理完成后 将所述目标分区工作者组件 的运行状态标记为完成状态， 并记录所述目标分区工作者组件的位移量。 4.根据权利要求3所述的消息消费方法， 其特征在于， 所述控制所述目标分区工作者组 件利用预设的业务执行者组件对所述消息队列中的第一目标消息进行 处理， 并在所述消息 队列中全部消息处理完成后 将所述目标分区工作者组件的运行状态标记为完成状态， 并记 录所述目标分区工作者组件的位移量， 包括： 控制所述目标分区工作者组件调用预设的业务执行者组件中预先定义的第一方法对 所述目标分区工作者组件对应的消息队列中的消息进 行处理， 并监测所述目标分区工作者 组件对应的消息队列中是否存在未处 理消息； 若所述目标分区工作者组件对应的消息队列中不存在未处理消息， 则将所述目标分区 工作者组件的运行状态标记为完成状态； 调用所述预设的业务执行者组件中预先定义的第 二方法对目标功能接口进行调用， 并 记录所述目标分区工作者组件的位移量。 5.根据权利要求1所述的消息消费方法， 其特 征在于， 还 包括： 当所述预设的消费者组件监测到所述目标分区工作者组件的运行状态为未完成状态， 则获取并记录所述目标分区工作者组件的位移 量， 并禁止执行所述将所述位移 量手动提交权　利　要　求　书 1/2 页 2 CN 115328664 A 2至所述预设消息发布系统的步骤。 6.根据权利要求1至5任一项所述的消息消费方法， 其特征在于， 所述利用预设的消费 者组件从预设消息发布系统中拉取第一目标消息， 并将所述第一目标消息发送至所述第一 目标消息所属的目标分区唯一对应的目标分区工作者组件之后， 还 包括： 调用所述预设消息发布系统中的预设应用程序编程接口控制所述预设的消费者组件 下次拉取消息时跳过 所述目标分区， 以从所述目标分区的下一分区拉取消息； 相应的， 所述在所述第一目标消息处 理结束之后， 还 包括： 调用所述预设消息发布系统中的预设应用程序编程接口控制所述预设的消费者组件 从所述目标分区拉取第二目标消息， 并将所述第二目标消息发送至所述第二目标消息所属 的目标分区唯一对应的目标分区工作者组件。 7.根据权利要求6所述的消息消费方法， 其特征在于， 所述控制所述预设的消费者组件 从所述目标分区拉取第二目标消息， 并将所述第二目标消息发送至所述第二目标消息所属 的目标分区唯一对应的目标分区工作者组件， 包括： 将所述目标分区中所述目标分区工作者组件的位移量的下一位置确定为目标消息拉 取位置， 并控制所述预设的消费者组件从所述 目标消息拉取位置拉取第二 目标消息， 然后 将所述第二目标消息发送至所述第二目标消息所属的目标分区唯一对应的目标分区工作 者组件。 8.一种消息消费装置， 其特 征在于， 包括： 消息拉取模块， 用于利用预设的消费者组件从预设消息发布系统中拉取第一目标消 息， 并将所述第一目标消息发送至所述第一目标消息所属的目标分区唯一对应的目标分区 工作者组件； 分区工作者组件工作模块， 用于控制所述目标分区工作者组件利用预设的业务执行者 组件对所述第一目标消息进行处理， 并在所述第一 目标消息处理完成后， 将所述 目标分区 工作者组件的运行状态标记为完成状态， 并记录所述目标分区工作者组件的位移量； 位移量提交模块， 用于当所述预设的消费者组件监测到所述目标分区工作者组件的运 行状态为完成状态， 则获取所述 目标分区工作者组件的位移量， 并将所述位移量手动提交 至所述预设消息发布系统。 9.一种电子设备， 其特征在于， 包括处理器和存储器； 其中， 所述处理器执行所述存储 器中保存的计算机程序时实现如权利要求1至7任一项所述的消息消费方法。 10.一种计算机可读存储介质， 其特征在于， 用于存储计算机程序； 其中， 所述计算机程 序被处理器执行时实现如权利要求1至7任一项所述的消息消费方法。权　利　要　求　书 2/2 页 3 CN 115328664 A 3