(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210343990.3 (22)申请日 2022.03.31 (71)申请人 蚂蚁区块链科技 （上海） 有限公司 地址 200010 上海市黄浦区外马路618号8 层803室 (72)发明人 谢桂鲁　邓福喜　石柯　王毅飞　 (74)专利代理 机构 北京博思佳知识产权代理有 限公司 1 1415 专利代理师 李威 (51)Int.Cl. H04L 67/10(2022.01) H04L 9/32(2006.01) H04L 9/40(2022.01) H04L 67/104(2022.01) H04L 67/141(2022.01)H04L 67/63(2022.01) (54)发明名称 直连通道的建立方法及装置 (57)摘要 本说明书实施例提供一种直连通道的建立 方法和装置。 该方法应用于部署有第一区块链节 点和第一计算引擎的第一节点设备， 第一区块链 节点所属的区块链网络部署有链下计算合约； 所 述方法包括： 监听所述链下计算合约生成的针对 链下协作任务的任务事件； 在所述任务事件表明 第一区块链节点和第二区块链节点属于所述链 下协作任务的参与方的情况下， 通过第一区块链 节点和第二区块链节点之间的共识链路向第二 区块链节点所处的第二节点设备发送第一计算 引擎的第一地址信息， 以由第二节 点设备上部署 的第二计算引擎根据第一地址信息与第一计算 引擎建立直连通道， 所述直连通道用于第一计算 引擎和第二计算引擎在执行所述链下协作任务 时的协同交 互。 权利要求书5页 说明书22页 附图3页 CN 114710492 A 2022.07.05 CN 114710492 A 1.一种直连通道的建立方法， 应用于部署有第一 区块链节点和第一计算引擎的第一节 点设备， 第一区块链 节点所属的区块链网络 部署有链下计算 合约； 所述方法包括： 监听所述链下计算 合约生成的针对链下协作任务的任务事 件； 在所述任务事件表明第一区块链节点和第二区块链节点属于所述链下协作任务的参 与方的情况下， 通过第一区块链节点和第二区块链节点之 间的共识链路向第二区块链节点 所处的第二节点设备发送第一计算引擎的第一地址信息， 以由第二节点设备上部署的第二 计算引擎根据第一地址信息与第一计算引擎建立直连通道， 所述直连通道用于第一计算引 擎和第二计算引擎在执 行所述链下协作任务时的协同交 互。 2.根据权利要求1所述的方法， 所述链下计算合约维护有链下计算任务的任务完成状 态， 所述任务完成状态用于描述所述链下计算任务包含的各子任务的完成状态； 在所述链 下协作任务属于所述链下计算任务的子任务的情况下， 所述监听所述链下计算合约生成的 针对链下协作任务的任务事 件， 包括： 监听所述链下计算合约在所述任务完成状态满足所述链下协作任务的执行条件的情 况下生成的针对所述链下协作任务的所述任务事 件。 3.根据权利要求2所述的方法， 所述任务完成状态由所述链下计算合约响应于所述链 下计算任务对应的交易而更新， 其中， 所述链下计算任务对应的交易包括所述链下计算任 务对应的任务创建交易， 或者任一节点设备在执行所述各子任务中任一子任务完毕的情况 下发起的结果返回交易。 4.根据权利要求1所述的方法， 第 一节点设备中部署有第 一区块链节点对应的第 一P2P 组件， 第二节点设备中部署有第二区块链节点对应的第二P2P组件， 所述共识链路为第一 P2P组件和第二P2P组件之间建立的共识 链路。 5.根据权利要求1所述的方法， 第一节点设备中还部署有第一调度框架， 所述监听所述链下计算合约生成的针对链下协作任务的任务事件， 包括： 由第一调度 框架监听所述链下计算 合约生成的针对链下协作任务的任务事 件； 所述方法还包括： 第一调度框架根据监听到的所述任务事件， 将所述链下协作任务分 发至第一计算引擎执 行。 6.根据权利要求5所述的方法， 所述第一调度框架将监听到的所述任务事件下发至第 一计算引擎， 包括： 第一调度框架在第一计算引 擎的计算类型匹配于所述链下协作任务的任务类型的情 况下， 将所述链下协作任务分发至第一计算引擎。 7.根据权利要求1所述的方法， 所述通过第一区块链节点和第二区块链节点之间的共 识链路向第二区块链 节点所处的第二节点设备发送第一计算引擎的第一 地址信息， 包括： 响应于第一计算引擎发起的地址发送请求， 通过第 一区块链节点和第 二区块链节点之 间的共识链路向第二区块链节点 发送第一地址信息， 第一地址信息由第一节点设备预先获 取或者包 含在所述 地址发送请求中。 8.根据权利要求1所述的方法， 所述第一计算引擎基于所述直连通道在执行所述链下 协作任务时与第二计算引擎协同交 互， 包括： 第一计算引擎在确定自身执行所述链下协作任务所需的目标数据由第二计算引擎所 维护的情况下， 通过所述直连通道向第二计算引擎发起针对所述目标数据 的数据获取请权　利　要　求　书 1/5 页 2 CN 114710492 A 2求； 第一计算引擎使用第二计算引擎返回的所述目标 数据执行所述链下协作任务。 9.根据权利要求1所述的方法， 所述第一计算引擎基于所述直连通道在执行所述链下 协作任务时与第二计算引擎协同交 互， 包括： 第一计算引擎在确定第二计算引 擎执行所述链下协作任务所需的目标数据由第一计 算引擎所维护的情况下， 通过所述直连通道向第二计算引擎发送所述 目标数据， 以由第二 计算引擎使用所述目标 数据执行所述链下协作任务。 10.根据权利要求9所述的方法， 所述第 一计算引擎通过所述直连通道向第 二计算引擎 发送所述目标 数据， 包括： 第一计算引擎响应于第二计算引 擎通过所述直连通道针对所述目标数据发起的数据 获取请求， 通过 所述直连通道将所述目标 数据返回至第二计算引擎。 11.根据权利要求10所述的方法， 所述数据获取请求包含根据随机数、 公钥以及所述目 标数据的数据标识 生成的令牌， 所述第一计算引擎通过所述直连通道将所述目标数据返回 至第二计算引擎， 包括： 第一计算引擎在所述令牌表明所述数据获取请求有 效的情况下， 通过所述直连通道将 所述目标 数据返回至第二计算引擎。 12.根据权利要求1 1所述的方法， 在接收到所述数据获取请求之前， 还 包括： 第一计算引擎接收令牌获取请求， 所述令牌获取请求包含所述目标数据的数据标识、 所述令牌获取请求的发起方 的发起方公钥以及该发起方基于发起方私钥对所述数据标识 和所述发起方公钥生成的第二签名； 第一计算引擎在第二签名通过所述发起方公钥验证的情况下， 根据随机数、 所述发起 方公钥以及所述数据标识生成所述令牌， 并将生成的所述令牌返回至所述令牌获取请求的 发起方。 13.根据权利要求11所述的方法， 所述数据获取请求还包含针对所述令牌的第 一签名， 所述第一计算引擎 通过所述直连通道将所述目标 数据返回至第二计算引擎， 包括： 第一计算引擎在第 一签名通过生成所述令牌的所述公钥验证的情况下， 通过所述直连 通道将所述目标 数据返回至第一计算引擎。 14.根据权利要求10所述的方法， 所述数据获取请求包含时间戳、 所述数据请求方的发 起方的公钥以及所述目标数据的数据标识， 所述第一计算引擎通过所述直连通道将所述目 标数据返回至第二计算引擎， 包括： 第一计算引擎在 当前时刻处于所述 时间戳对应的时间区间的情况下， 通过所述直连通 道将所述目标 数据返回至第一计算引擎。 15.根据权利要求14所述的方法， 所述数据获取请求还包含所述数据请求方基于自身 的私钥对所述时间戳、 所述公钥以及所述数据标识生成的第三签名， 所述第一计算引擎通 过所述直连通道将所述目标 数据返回至第二计算引擎， 包括： 第一计算引擎在第 三签名通过所述公钥验证的情况下， 通过所述直连通道将所述目标 数据返回至第一计算引擎。 16.根据权利要求1所述的方法， 所述链下协作任务由第一计算引擎执行， 或者由第一 计算引擎允许调用的远程计算引擎执 行。权　利　要　求　书 2/5 页 3 CN 114710492 A 3