(19)国家知识产权局 (12)发明 专利 (10)授权公告 号 (45)授权公告日 (21)申请 号 202210478504.9 (22)申请日 2022.05.05 (65)同一申请的已公布的文献号 申请公布号 CN 114579611 A (43)申请公布日 2022.06.03 (73)专利权人 北京理工大 学 地址 100081 北京市海淀区中关村南大街5 号 专利权人 人民法院信息技 术服务中心 (72)发明人 李斌　孙福辉　成雨蓉　王晓燕　 张志威　张艺璐　袁野　张娴　 王国仁　 (74)专利代理 机构 北京三友知识产权代理有限 公司 11127 专利代理师 许曼　贾磊 (51)Int.Cl. G06F 16/2453(2019.01)G06F 16/2455(2019.01) G06F 16/2457(2019.01) G06F 16/2458(2019.01) G06F 16/27(2019.01) (56)对比文件 CN 112491959 A,2021.0 3.12 CN 112882802 A,2021.0 6.01 CN 112651046 A,2021.04.13 CN 113360547 A,2021.09.07 CN 113452781 A,2021.09.28 US 2020026700 A1,2020.01.23 贾大宇 等.存 储容量可扩展区块链系统的 高效查询模型. 《软件学报》 .2019, 张志威 等.区块链的数据管理技 术综述. 《软件学报》 .2020, 审查员 吴卿 (54)发明名称 一种跨链系统的数据并行查询方法及装置 (57)摘要 本文涉及区块链数据查询领域， 提供了一种 跨链系统的数据并行查询方法及装置， 方法包 括： 解析各源区块链发送的总查询请求得到同构 总查询请求； 将各同构总查询请求中的查询内容 拆分为子查询请求； 根据同构总查询请求及子查 询请求， 修改查询请求管理表及查询队列表； 将 查询队列表中子查询请求类型标识及子查询请 求转换为目的区块链识别格式后发送至目的区 块链； 接收目的区块链发送的查询结果， 根据查 询结果修改链 查询请求管理表及查询队列表； 根 据查询请求管理表， 将同构总查询请求对应的子 查询请求状态均为查询成功的查询结果进行汇 总及格式转换后， 发送至相关源区块链。 本文能 够实现跨链区块链查询高效并行处理， 保证一致 性及安全性。 权利要求书2页 说明书13页 附图6页 CN 114579611 B 2022.07.05 CN 114579611 B 1.一种跨链系统 的数据并行查询方法， 其特征在于， 应用于 中继链， 所述中继链连接多 个异构的区块链， 所述方法包括： 解析各源区块链发送的总查询 请求得到同构总查询 请求， 所述同构总查询 请求包括源 区块链标识及查询内容； 将各同构总查询请求中的查询内容拆分为子查询请求； 根据所述同构总查询请求及所述子查询请求， 修改查询请求管理表及查询队列表， 所 述查询请求管理表记录有同构总查询请求与子查询请求状态之 间的关联关系， 查询队列 表 记录有子查询请求类型 标识与同类子查询请求的常量信息之间的关联关系； 将查询队列表中子查询请求类型标识及子查询请求的常量信息转换为目的区块链识 别格式后发送至目的区块链， 以使目的区块链根据子查询请求类型标识判断是否存在缓存 查询路径， 若存在， 则根据所述缓存查询路径及子查询请求的常量信息查询数据； 接收目的区块链发送的查询结果， 根据所述查询结果修改所述查询 请求管理表及查询 队列表； 根据所述查询请求管理表， 将同构总查询请求对应的子查询 请求状态均为查询成功的 查询结果进行汇总及格式转换后， 发送至相关源区块链。 2.如权利要求1所述的方法， 其特征在于， 将各同构总查询请求拆分为子查询请求包 括： 从预设字典中查询同构总查询 请求， 所述预设字典存储有各类型同构总查询请求与其 拆分后子查询请求； 若匹配成功， 则将查询出的同构总查询请求关联的子查询请求作为拆分结果； 若匹配失败， 则按照预设拆分规则对同构总查询请求进行拆分。 3.如权利要求2所述的方法， 其特征在于， 若匹配失败， 还将同构总查询请求及拆分为 的子查询请求记录 于字典预备队列中； 统计在第一预定时间段内各类型同构总查询请求及拆分为的子查询请求进入字典预 备队列的次数； 若统计次数大于预定次数， 则将同构总查询 请求及拆分为的子查询 请求存储于所述预 设字典中。 4.如权利要求1所述的方法， 其特征在于， 根据所述同构总查询请求及所述子查询请 求， 修改查询请求管理表及查询队列表包括： 将每一同构总查询 请求及状态、 所述同构总查询请求的子查询请求及状态记录于查询 请求管理表中； 利用预定量 替换所述子查询请求中的常量， 对替换后的请求计算哈希值； 将哈希值作为子查询请求类型标识记录于查询队列表中， 将同一哈希值的子查询请求 及常量信息记录 于查询队列表中。 5.如权利要求1所述的方法， 其特 征在于， 还 包括： 监控所述查询请求管理表中同构总查询请求及其子查询请求处于查询未完成状态的 时长； 若某一子查询请求 时长超过预定时间阈值， 则设置该子查询 请求对应的同构总查询请 求状态为 查询失败， 删除查询队列表中该子查询请求相关的子查询请求；权　利　要　求　书 1/2 页 2 CN 114579611 B 2若某一同构总查询 请求时长超过所述预定时间阈值， 则设置该同构总查询 请求的状态 为查询失败， 删除查询队列表中该同构总查询请求相关的子查询请求。 6.一种跨链系统的数据并行查询方法， 其特 征在于， 应用于区块链， 包括： 发送总查询请求至中继链； 接收所述中继链发送的子查询请求类型 标识及子查询请求的常量信息； 根据子查询请求类型标识判断是否存在缓存查询路径， 若存在， 则根据缓存的查询路 径及子查询请求中的常量信息进 行查询处理， 若不存在， 则根据子查询请求 获取查询路径， 并根据查询路径及子查询请求中的常量信息进行查询处理， 缓存子查询请求类型标识及对 应的查询路径， 发送查询结果至所述中继链。 7.如权利要求6所述的方法， 其特 征在于， 还 包括： 统计第二预定时间段内各子查询请求类型的子查询请求 量； 若子查询请求 量大于预定量， 则将子查询请求类型对应的数据缓存至内存中。 8.一种跨链系统 的数据并行查询装置， 其特征在于， 应用于 中继链， 所述中继链连接多 个异构的区块链， 所述装置包括： 解析单元， 用于解析各源区块链发送的总查询请求得到同构总查询请求， 所述同构总 查询请求包括源区块链标识及查询内容； 拆分单元， 用于将各同构总查询请求中的查询内容拆分为子查询请求； 表管理单元， 用于根据所述同构总查询请求及所述子查询请求， 修改查询请求管理表 及查询队列 表， 所述查询请求管理表记录有同构总查询请求与子查询请求状态之 间的关联 关系， 查询队列 表记录有子查询请求类型标识与同类子查询请求的常量信息之 间的关联关 系； 发送单元， 用于将查询队列表中子查询 请求类型标识及子查询请求的常量信 息转换为 目的区块链识别格式后发送至目的区块链， 以使目的区块链根据子查询请求类型标识判断 是否存在缓存查询路径， 若存在， 则根据所述缓存查询路径及子查询请求的常量信息查询 数据； 查询结果管理单元， 用于接收目的区块链发送的查询结果， 根据所述查询结果修改所 述查询请求管理表及查询队列表； 查询结果反馈单元， 用于根据所述查询请求管理表， 将同构总查询请求对应的子查询 请求状态均为 查询成功的查询结果进行汇总及格式转换后， 发送至相关源区块链。 9.一种跨链系统的数据并行查询装置， 其特 征在于， 应用于区块链， 包括： 请求发送单 元， 用于发送总查询请求至中继链； 请求接收单元， 用于接收所述中继链发送的子查询 请求类型标识及子查询 请求的常量 信息； 查询管理单元， 用于根据子查询请求类型标识判断是否存在缓存查询路径， 若存在， 则 根据缓存的查询路径及子查询请求中的常量信息进行查询处理， 若不存在， 则根据子查询 请求获取查询路径， 并根据查询路径及子查询请求中的常量信息进行查询处理， 缓存子查 询请求类型 标识及对应的查询路径， 发送查询结果至所述中继链。 10.一种计算机设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计 算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现权利要求1至7任一所述方法。权　利　要　求　书 2/2 页 3 CN 114579611 B 3