(19)中华 人民共和国 国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210037194.7 (22)申请日 2022.01.13 (71)申请人 北京沃东天骏信息技 术有限公司 地址 100176 北京市北京经济技 术开发区 科创十一 街18号院2号楼4层A402室 申请人 北京京东世纪贸易有限公司 (72)发明人 赵力　 (74)专利代理 机构 中原信达知识产权代理有限 责任公司 1 1219 代理人 张一军　王安娜 (51)Int.Cl. G06F 16/22(2019.01) G06F 16/23(2019.01) G06F 16/2455(2019.01) G06F 16/27(2019.01) (54)发明名称 一种数据缓存方法和装置 (57)摘要 本发明公开了一种数据缓存方法和装置， 涉 及计算机技术领域。 该方法的一具体实施方式包 括： 监听分布式调度中心的各个节点； 其中， 所述 节点的目录与各个数据库中的各个数据表一一 对应， 所述节 点保存的节点信息包括所述节点对 应的数据表的数据变更时间戳； 若监听到所述节 点保存的节 点信息发生变更， 则根据所述节点的 目录和变更后的节点信息生成缓存标识和布隆 过滤器； 将所述缓存标识与所述布隆过滤器关 联， 并将所述缓存标识及其对应的布隆过滤器存 储至过滤器集合中。 该实施方式能够解决开发难 度大、 内存不均、 阻塞查询或者数据不一致的技 术问题。 权利要求书2页 说明书15页 附图7页 CN 114398372 A 2022.04.26 CN 114398372 A 1.一种数据缓存方法， 其特 征在于， 应用于服 务端， 包括： 监听分布式调度中心的各个节点； 其中， 所述节点的目录与各个数据库中的各个数据 表一一对应， 所述节点保存的节点信息包括所述节点对应的数据表的数据变更时间戳； 若监听到所述节点保存的节点信 息发生变更， 则根据所述节点的目录和变更后的节点 信息生成 缓存标识和布隆过 滤器； 将所述缓存标识与 所述布隆过滤器关联， 并将所述缓存标识及其对应的布隆过滤器存 储至过滤器集合中。 2.根据权利要求1所述的方法， 其特征在于， 所述缓存标识包括所述节点的目录和所述 节点对应的数据表的数据变更时间戳。 3.根据权利要求1所述的方法， 其特征在于， 所述分布式调度中心从消息队列中获取消 息， 解析所述消息以得到数据库信息、 数据 表信息和数据变更时间戳， 从而变更所述数据库 和所述数据表对应的节点保存的节点信息； 其中， 所述消息由数据存 储引擎生成并写入所述消息队列中。 4.根据权利要求3所述的方法， 其特征在于， 将所述缓存标识及其对应的布隆过滤器存 储至过滤器集合中之后， 还 包括： 配置所述布隆过滤器的失效时间戳； 其中， 所述失效时间戳为当前时间戳加上失效时 长， 所述失效时长大于所述数据存 储引擎的批写入周期。 5.一种数据缓存方法， 其特 征在于， 应用于客户端， 包括： 监听分布式调度中心的目标节点； 其中， 所述分布式调度中心 的节点的目录与各个数 据库中的各个数据表 一一对应， 所述目标节点保存的节点信息包括所述目标节点对应的数 据表的数据变更时间戳； 若监听到所述目标节点保存的节点信息发生变更， 则拉取变更后的节点信息 。 6.根据权利要求5所述的方法， 其特 征在于， 还 包括： 接收数据查询请求； 其中， 所述数据查询请求携带 数据库信息、 数据表信息和入参； 根据所述数据库信息和所述数据表信息匹配出 数据变更时间戳， 从而生成 缓存标识； 从过滤器集合中获取 所述缓存标识对应的布隆过 滤器； 基于所述入参和所述布隆过 滤器获取 所述数据查询请求对应的查询数据。 7.根据权利要求6所述的方法， 其特征在于， 所述缓存标识包括所述数据库信息、 所述 数据表信息和数据变更时间戳。 8.根据权利要求6所述的方法， 其特征在于， 基于所述入参和所述布隆过滤器获取所述 数据查询请求对应的查询数据， 包括： 根据所述 客户端提供的接口 的类路径、 方法名以及所述入参 生成字符串标识； 采用哈希函数对所述字符串标识进行计算， 得到标识位； 基于所述标识位判断所述布隆过滤器是否命中； 若是， 则从缓存中获取所述字符串标 识对应的查询数据； 若否， 则从所述数据库中的所述数据表中获取所述数据查询请求对应 的查询数据。 9.根据权利要求8所述的方法， 其特征在于， 根据所述客户端提供的接口的类路径、 方 法名以及所述入参 生成字符串标识， 包括： 将所述客户端提供的接口 的类路径、 方法名以及所述入参封装成字符串；权　利　要　求　书 1/2 页 2 CN 114398372 A 2采用信息摘要算法对所述字符串 进行加密， 得到 字符串标识。 10.根据权利要求8所述的方法， 其特征在于， 从缓存中获取所述字符串标识对应的查 询数据， 包括： 基于所述字符串标识判断缓存是否命中； 若是， 则从所述缓存获取 所述字符串标识对应的查询数据； 若否， 则从所述数据库中的所述数据表中获取 所述数据查询请求对应的查询数据。 11.根据权利要求8所述的方法， 其特征在于， 从所述数据库中的所述数据表中获取所 述数据查询请求对应的查询数据之后， 还 包括： 将所述字符串标识和所述数据查询请求对应的查询数据存储到缓存中， 并基于所述标 识位更新所述布隆过 滤器的值。 12.根据权利要求11所述的方法， 其特征在于， 将所述字符串标识和所述数据查询请求 对应的查询数据存 储到缓存中， 包括： 判断所述数据查询请求对应的查询数据的数据集大小是否大于等于阈值； 若是， 则将所述查询数据存储到HDFS中， 并将所述字符串标识和所述查询数据在HDFS 中的存储路径存 储到HBase中； 若否， 则所述字符串标识和所述 查询数据存 储到HBase中。 13.一种数据缓存 装置， 其特 征在于， 设置 于服务端， 包括： 第一监听模块， 用于监 听分布式调度中心的各个节点； 其中， 所述节点的目录与各个数 据库中的各个数据表 一一对应， 所述节点保存的节点信息包括所述节点对应的数据表的数 据变更时间戳； 生成模块， 用于若监听到所述节点保存的节点信息发生变更， 则根据所述节点的目录 和变更后的节点信息生成 缓存标识和布隆过 滤器； 存储模块， 用于将所述缓存标识与所述布隆过滤器关联， 并将所述缓存标识及其对应 的布隆过 滤器存储至过滤器集合中。 14.一种数据缓存 装置， 其特 征在于， 设置 于客户端， 包括： 第二监听模块， 用于监 听分布式调度中心的目标节点； 其中， 所述分布式调度中心的节 点的目录与各个数据库中的各个数据 表一一对应， 所述目标节点保存的节点信息包括所述 目标节点对应的数据表的数据变更时间戳； 拉取模块， 用于若监听到所述目标节点保存的节点信息发生变更， 则拉取变更后的节 点信息。 15.一种电子设备， 其特 征在于， 包括： 一个或多个处 理器； 存储装置， 用于存 储一个或多个程序， 当所述一个或多个程序被所述一个或多个处理器执行时， 所述一个或多个处理器实现 如权利要求1 ‑12中任一所述的方法。 16.一种计算机可读介质， 其上存储有计算机程序， 其特征在于， 所述程序被处理器执 行时实现如权利要求1 ‑12中任一所述的方法。权　利　要　求　书 2/2 页 3 CN 114398372 A 3