(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211143612.7 (22)申请日 2022.09.20 (71)申请人 杭州数梦 工场科技有限公司 地址 310024 浙江省杭州市转塘科技经济 区块16号 4幢326室 (72)发明人 谢心甜　王鹏　韩广宇　 (74)专利代理 机构 北京清亦华知识产权代理事 务所(普通 合伙) 11201 专利代理师 张润 (51)Int.Cl. G06F 9/54(2006.01) G06F 16/242(2019.01) G06F 16/25(2019.01) (54)发明名称 一种基于消息队列的数据共享方法、 装置及 系统 (57)摘要 本申请提出一种基于消息队列的数据共享 方法、 装置及系统， 其中， 方法包括： 通过响应于 针对目标任务的执行请求， 根据目标任务包含的 资源标识， 从目标消息队列获取目标资源数据， 其中， 目标任务还包括针对目标消息队列中存储 数据的处理规则与针对处理结果的通知模式， 从 而针对处理规则对获取的目标资源数据进行处 理， 得到处理结果， 进而根据通知模式， 共享处理 结果。 由此， 可实现响应于针对目标任务的执行 请求， 基于目标任务中包括的针对目标消息队列 中存储数据的处理规则对获取的目标资源数据 进行处理， 使得消息消费者无需自行开发处理过 程， 同时， 有效避免将消息队列直接暴露给消息 消费者， 保证消息队列的安全性。 权利要求书2页 说明书19页 附图6页 CN 115480939 A 2022.12.16 CN 115480939 A 1.一种基于消息队列的数据共享方法， 其特 征在于， 所述方法包括： 响应于针对目标任务的执行请求， 根据所述目标任务包含的资源标识， 从目标消息队 列获取目标资源数据； 所述目标任务还包括针对所述目标消息队列中存储 数据的处理规则 与针对处 理结果的通知模式； 针对所述处 理规则对获取的目标资源数据进行处 理， 得到处 理结果； 根据所述 通知模式， 共享所述处 理结果。 2.根据权利要求1所述的方法， 其特征在于， 所述根据所述目标任务包含的资源标识， 从目标消息队列获取目标资源数据， 包括： 根据所述资源标识， 获取目标资源数据信息， 以根据所述目标资源数据信息中的数据 连接信息， 与存 储了目标资源数据的目标消息队列建立连接； 通过建立的所述连接， 获取 所述目标资源数据。 3.根据权利要求1所述的方法， 其特征在于， 所述处理规则包括比对规则， 以及比对结 果中保留的保留字段； 所述针对所述处理规则对获取 的目标资源数据进行处理， 得到处理 结果， 包括： 从所述目标资源数据中筛 选出符合所述比对规则的资源数据； 将符合所述比对规则的资源数据中与所述保留字段对应的数据确定为所述处 理结果。 4.根据权利要求1所述的方法， 其特征在于， 所述通知模式包括实时共享模式， 周期共 享模式， 交 互共享模式； 所述 根据所述 通知模式， 共享所述处 理结果， 包括： 响应于所述通知模式为实时共享模式， 实时通过共享连接共享所述处理结果； 所述共 享连接包括 WebSocket连接； 响应于所述通知模式为周期共享模式， 根据预设周期内是否存在所述处理结果， 确定 对应的通知内容， 并通过 所述共享连接周期性共享所述 通知内容； 响应于所述通知模式为交互共享模式， 通过所述共享连接共享所述处理结果之后， 接 收通过所述共享连接发送的新的操作命令并做出相应的处理； 所述新的操作命令包括但不 限于： 重设消费偏移量和查看消费详情。 5.根据权利要求4所述的方法， 其特征在于， 所述响应于所述通知模式为周期共享模 式， 根据预设周期内是否存在所述处理结果， 确定对应的通知内容， 并通过所述共享连接周 期性共享所述 通知内容之后， 还 包括： 响应于预设周期内存在所述处理结果， 接收针对所述处理结果的获取请求， 共享所述 处理结果。 6.根据权利要求1所述的方法， 其特征在于， 所述针对所述处理规则对获取的目标资源 数据进行处 理， 得到处 理结果， 包括： 根据所述目标任务包含的列信息， 对所述目标资源数据进行转换， 得到包含所述列信 息的目标资源数据； 针对所述处 理规则对 包含所述列信息的目标资源数据进行处 理， 得到处 理结果。 7.根据权利要求1 ‑6任一项所述的方法， 其特征在于， 在执行所述目标任务之前， 所述 方法还包括： 接收基于任务接口发起的针对所述目标任务的创建请求， 创建所述目标任务； 所述创 建请求中包括与所述任务接口对应的条件信息； 所述条件信息包括但不限于： 资源标识、 比权　利　要　求　书 1/2 页 2 CN 115480939 A 2对规则、 保留字段和通知模式。 8.根据权利要求7所述的方法， 其特征在于， 所述任务接口为采用类结构化查询语言 SQL写法创建的； 所述任务接口包括创建任务接口、 取消任务接口、 查询任务状态接口、 获取 任务数据接口和数据变化 通知接口。 9.一种基于消息队列的数据共享装置， 其特 征在于， 包括： 获取模块， 用于响应于针对目标任务的执行请求， 根据所述目标任务包含的资源标识， 从目标消息队列获取目标资源数据； 所述目标任务还包括针对所述目标消息队列中存储数 据的处理规则与针对处 理结果的通知模式； 处理模块， 用于针对所述处 理规则对获取的目标资源数据进行处 理， 得到处 理结果； 共享模块， 用于根据所述 通知模式， 共享所述处 理结果。 10.一种基于消息队列的数据共享系统， 其特征在于， 包括配置管理模块、 任务管理模 块及任务处 理模块： 配置管理模块， 用于维护资源数据信息， 所述资源数据信息用于描述资源数据的基本 信息， 包括数据连接信息、 资源信息和列信息； 任务管理模块， 用于提供任务接口； 所述任务接口包括创建任务接口、 取消任务接口、 查询任务状态接口、 获取任务数据接口和数据变化 通知接口； 任务处理模块， 用于执 行权利要求1 ‑8中任一项所述的基于消息队列的数据共享方法。 11.一种服 务器， 其特 征在于， 包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的指令， 所述指令被所述至少一个处 理器执行， 以使所述至少一个处理器能够执行权利要求1 ‑8中任一项所述的基于消息队列 的数据共享方法。 12.一种服 务器， 其特 征在于， 包括： 至少一个处 理器； 以及 与所述至少一个处 理器通信连接的存 储器； 其中， 所述存储器存储有可被所述至少一个处理器执行的指令， 所述指令被所述至少一个处 理器执行， 以使所述至少一个处 理器能够运行 数据推送系统； 其中， 所述数据推送系统包括配置管理模块、 任务管理模块及任务处理模块； 所述配置 管理模块用于维护资源数据信息， 所述资源数据信息用于描述资源数据的基本信息， 包括 数据连接信息、 资源信息和列信息； 所述任务管 理模块用于提供任务接口， 所述任务接口包 括创建任务接口、 取消任务接口、 查询任务状态接口、 获取任务数据接口和数据变化通知接 口； 所述任务处理模块用于执行权利要求1 ‑8中任一项所述的基于消息队列的数据共享方 法。 13.一种存储有计算机指令的非瞬时计算机可读存储介质， 其特征在于， 所述计算机指 令用于使所述计算机执 行权利要求1 ‑8中任一项所述的基于消息队列的数据共享方法。权　利　要　求　书 2/2 页 3 CN 115480939 A 3