[go: up one dir, main page]

CN113079200A - 一种数据处理的方法、装置及系统 - Google Patents

一种数据处理的方法、装置及系统 Download PDF

Info

Publication number
CN113079200A
CN113079200A CN202110296513.1A CN202110296513A CN113079200A CN 113079200 A CN113079200 A CN 113079200A CN 202110296513 A CN202110296513 A CN 202110296513A CN 113079200 A CN113079200 A CN 113079200A
Authority
CN
China
Prior art keywords
task
executed
service
result
node
Prior art date
Legal status (The legal status is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the status listed.)
Pending
Application number
CN202110296513.1A
Other languages
English (en)
Inventor
王喜
Current Assignee (The listed assignees may be inaccurate. Google has not performed a legal analysis and makes no representation or warranty as to the accuracy of the list.)
Beijing Sankuai Online Technology Co Ltd
Original Assignee
Beijing Sankuai Online Technology Co Ltd
Priority date (The priority date is an assumption and is not a legal conclusion. Google has not performed a legal analysis and makes no representation as to the accuracy of the date listed.)
Filing date
Publication date
Application filed by Beijing Sankuai Online Technology Co Ltd filed Critical Beijing Sankuai Online Technology Co Ltd
Priority to CN202110296513.1A priority Critical patent/CN113079200A/zh
Publication of CN113079200A publication Critical patent/CN113079200A/zh
Pending legal-status Critical Current

Links

Images

Classifications

    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L67/00—Network arrangements or protocols for supporting network services or applications
    • H04L67/01—Protocols
    • H04L67/10—Protocols in which an application is distributed across nodes in the network
    • G—PHYSICS
    • G06—COMPUTING OR CALCULATING; COUNTING
    • G06Q—INFORMATION AND COMMUNICATION TECHNOLOGY [ICT] SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES; SYSTEMS OR METHODS SPECIALLY ADAPTED FOR ADMINISTRATIVE, COMMERCIAL, FINANCIAL, MANAGERIAL OR SUPERVISORY PURPOSES, NOT OTHERWISE PROVIDED FOR
    • G06Q40/00—Finance; Insurance; Tax strategies; Processing of corporate or income taxes
    • G06Q40/04—Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L63/00—Network architectures or network communication protocols for network security
    • H04L63/04—Network architectures or network communication protocols for network security for providing a confidential data exchange among entities communicating through data packet networks
    • H04L63/0428—Network architectures or network communication protocols for network security for providing a confidential data exchange among entities communicating through data packet networks wherein the data content is protected, e.g. by encrypting or encapsulating the payload
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L63/00—Network architectures or network communication protocols for network security
    • H04L63/12—Applying verification of the received information
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L9/00—Cryptographic mechanisms or cryptographic arrangements for secret or secure communications; Network security protocols
    • H04L9/32—Cryptographic mechanisms or cryptographic arrangements for secret or secure communications; Network security protocols including means for verifying the identity or authority of a user of the system or for message authentication, e.g. authorization, entity authentication, data integrity or data verification, non-repudiation, key authentication or verification of credentials
    • H04L9/3247—Cryptographic mechanisms or cryptographic arrangements for secret or secure communications; Network security protocols including means for verifying the identity or authority of a user of the system or for message authentication, e.g. authorization, entity authentication, data integrity or data verification, non-repudiation, key authentication or verification of credentials involving digital signatures
    • H—ELECTRICITY
    • H04—ELECTRIC COMMUNICATION TECHNIQUE
    • H04L—TRANSMISSION OF DIGITAL INFORMATION, e.g. TELEGRAPHIC COMMUNICATION
    • H04L9/00—Cryptographic mechanisms or cryptographic arrangements for secret or secure communications; Network security protocols
    • H04L9/50—Cryptographic mechanisms or cryptographic arrangements for secret or secure communications; Network security protocols using hash chains, e.g. blockchains or hash trees

Landscapes

  • Engineering & Computer Science (AREA)
  • Computer Security & Cryptography (AREA)
  • Computer Networks & Wireless Communication (AREA)
  • Signal Processing (AREA)
  • Business, Economics & Management (AREA)
  • Accounting & Taxation (AREA)
  • Finance (AREA)
  • General Engineering & Computer Science (AREA)
  • Computing Systems (AREA)
  • Computer Hardware Design (AREA)
  • Strategic Management (AREA)
  • Technology Law (AREA)
  • Physics & Mathematics (AREA)
  • General Business, Economics & Management (AREA)
  • General Physics & Mathematics (AREA)
  • Theoretical Computer Science (AREA)
  • Marketing (AREA)
  • Economics (AREA)
  • Development Economics (AREA)
  • Computer And Data Communications (AREA)

Abstract

本说明书公开了一种数据处理的方法、装置及系统，并具体公开了，该数据处理系统包括客户端、共识网络、业务子系统以及数据存储子系统，该业务子系统包括主节点和从节点，该共识网络中包含有多个区块链节点，其中，业务子系统，确定该业务请求对应的待执行任务，将该待执行任务拆分成若干子待执行任务，并确定对应的子任务结果，最终得到待执行任务对应的综合任务结果，并存储到数据存储子系统中，得到该综合任务结果对应的地址标识，进而将该地址标识存储在区块链中。如此，由于在执行数据处理任务时，可以将该任务划分成多个子任务，再由多个节点并行处理这些子任务，从而提高区块链系统中数据处理的效率。

Description

一种数据处理的方法、装置及系统
技术领域
本说明书涉及互联网技术领域，尤其涉及一种数据处理的方法、装置及系统。
背景技术
随着计算机技术的不断发展，区块链技术应运而生，根据实际的业务需求，可以将需要存证的数据存储在区块链中，以防止这些存证数据被篡改，从而保证了数据的安全性。
目前，当需要对业务数据进行数据处理时，需要先将需要进行数据处理的业务数据同步到本地存储，再对同步到本地的业务数据进行一并数据处理，得到数据处理结果，而后，可以将数据处理结果携带在交易中存储在区块链。然后，若是业务数据的数据量过于庞大，则会极大的降低数据处理的效率。
所以，如何能够提高数据处理的效率，则是一个亟待解决的问题。
发明内容
本说明书提供一种数据处理的方法、装置及系统，以部分的解决现有技术存在的上述问题。
本说明书采用下述技术方案：
本说明书提供了一种数据处理系统，包括客户端、共识网络、业务子系统以及数据存储子系统，所述业务子系统包括主节点和从节点，所述共识网络中包含有多个区块链节点；
所述业务子系统，通过所述主节点接收所述客户端发送的业务请求，根据所述业务请求，确定所述业务请求对应的待执行任务，根据所述待执行任务进行任务拆分，得到若干子待执行任务，针对每个子待执行任务，通过所述主节点，确定执行该子待执行任务的从节点，作为目标从节点，并将该子待执行任务发送给所述目标从节点，通过所述目标从节点，执行该子待执行任务，得到子任务结果，通过所述主节点接收各从节点返回的各子任务结果，并根据所述各子任务结果，得到所述待执行任务对应的综合任务结果，将所述综合任务结果发送给所述数据存储子系统，以从所述数据存储子系统中获取到所述综合任务结果对应的地址标识，向区块链对应的共识网络发送携带有所述地址标识的交易，以使所述共识网络通过包含的各区块链节点确定所述交易通过共识后，将所述地址标识存储在所述区块链中；
所述数据存储子系统，接收所述业务子系统发送的所述综合任务结果，根据所述综合任务结果，生成所述综合任务结果对应的地址标识，将所述地址标识返回给所述业务子系统，并将所述综合任务结果存储在所述数据存储子系统本地。
可选地，所述数据处理系统还包括：至少两个预校验系统；
所述预校验系统，接收所述客户端发送的业务请求，根据所述业务请求，对所述业务请求对应的待执行任务进行校验，得到校验结果，并将所述校验结果返回给所述客户端；
所述客户端，分别向所述至少两个预校验系统发送业务请求，并接收所述至少两个预校验系统返回的校验结果，若确定所述至少两个预校验系统返回的校验结果满足预设条件，向所述业务子系统发送所述业务请求。
可选地，所述客户端，从所述至少两个预校验系统返回的校验结果中确定出通过校验的校验结果，作为目标结果，若确定所述目标结果在所述至少两个预校验系统返回的校验结果中的占比超过设定占比，确定所述至少两个预校验系统返回的校验结果满足所述预设条件。
可选地，所述业务子系统，通过预设的接口，向所述共识网络中包含的各区块链节点发送获取请求，以获取所述共识网络中包含的各区块链节点对应的加密规则，根据所述加密规则，对所述交易进行加密，得到加密信息，将所述加密信息携带所述交易中发送给所述共识网络，以针对所述共识网络中包含的每个区块链节点，通过该区块链节点对应的加密规则，对所述加密信息进行验证。
可选地，所述共识网络中包含的每个区块链节点，从预设的安全机构中获取各业务安全等级对应的加密规则，在接收到所述业务子系统发送的所述获取请求时，确定所述获取请求对应的业务安全等级，作为目标安全等级，并将所述目标安全等级对应的加密规则返回给所述业务子系统。
可选地，所述加密规则包括：国产商用密码算法。
可选地，所述业务子系统接收所述客户端发送的数据查询请求，从所述区块链中查询出所述数据查询请求所对应的地址标识，作为目标地址标识，通过所述目标地址标识，向所述客户端返回所述数据存储子系统中存储的所述目标地址标识对应的数据。
可选地，所述数据存储子系统包括：星际文件系统IPFS，所述业务子系统包括：Hyperledger Fabric，所述地址标识包括：哈希地址。
本说明书提供了一种数据处理的方法，包括：
通过业务子系统包含的主节点接收客户端发送的业务请求；
根据所述业务请求，确定所述业务请求对应的待执行任务；
根据所述待执行任务进行任务拆分，得到若干子待执行任务；
针对每个子待执行任务，通过所述主节点，确定所述业务子系统中执行该子待执行任务的从节点，作为目标从节点，并将该子待执行任务发送给所述目标从节点，以通过所述目标从节点，执行该子待执行任务，得到子任务结果；
通过所述主节点接收各从节点返回的各子任务结果，并根据所述各子任务结果，得到所述待执行任务对应的综合任务结果；
将所述综合任务结果发送给所述数据存储子系统，以从所述数据存储子系统中获取到所述综合任务结果对应的地址标识；
向区块链对应的共识网络发送携带有所述地址标识的交易，以使所述共识网络通过包含的各区块链节点确定所述交易通过共识后，将所述地址标识存储在所述区块链中。
本说明书提供了一种数据处理的装置，包括：
接收模块，用于通过业务子系统包含的主节点接收客户端发送的业务请求；
确定模块，用于根据所述业务请求，确定所述业务请求对应的待执行任务；
拆分模块，用于根据所述待执行任务进行任务拆分，得到若干子待执行任务；
执行模块，用于针对每个子待执行任务，通过所述主节点，确定所述业务子系统中执行该子待执行任务的从节点，作为目标从节点，并将该子待执行任务发送给所述目标从节点，以通过所述目标从节点，执行该子待执行任务，得到子任务结果；
处理模块，用于通过所述主节点接收各从节点返回的各子任务结果，并根据所述各子任务结果，得到所述待执行任务对应的综合任务结果；
获取模块，用于将所述综合任务结果发送给所述数据存储子系统，以从所述数据存储子系统中获取到所述综合任务结果对应的地址标识；
发送模块，用于向区块链对应的共识网络发送携带有所述地址标识的交易，以使所述共识网络通过包含的各区块链节点确定所述交易通过共识后，将所述地址标识存储在所述区块链中。
本说明书提供了一种计算机可读存储介质，所述存储介质存储有计算机程序，所述计算机程序被处理器执行时实现上述数据处理的方法。
本说明书提供了一种电子设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，所述处理器执行所述程序时实现上述数据处理的方法。
本说明书采用的上述至少一个技术方案能够达到以下有益效果：
在本说明书提供的数据处理系统中，包括客户端、共识网络、业务子系统以及数据存储子系统，该业务子系统包括主节点和从节点，该共识网络中包含有多个区块链节点，其中，业务子系统，通过主节点接收客户端发送的业务请求后，确定该业务请求对应的待执行任务，而后，根据该待执行任务进行任务拆分，得到若干子待执行任务，针对每个子待执行任务，通过主节点，确定执行该子待执行任务的从节点，作为目标从节点，并将该子待执行任务发送给该目标从节点，通过目标从节点，执行该子待执行任务，得到子任务结果。进一步地，通过主节点接收各从节点返回的各子任务结果，并根据各子任务结果，得到待执行任务对应的综合任务结果，并将所述综合任务结果发送给所述数据存储子系统。随后，数据存储子系统，接收业务子系统发送的综合任务结果，根据所述综合任务结果，生成该综合任务结果对应的地址标识，将该地址标识返回给业务子系统，并将综合任务结果存储在数据存储子系统本地。接着，业务子系统从数据存储子系统中获取到该综合任务结果对应的地址标识，向区块链对应的共识网络发送携带有地址标识的交易，以使该共识网络通过包含的各区块链节点确定交易通过共识后，将该地址标识存储在区块链中。
从上述系统中可以看出，由于在执行数据处理任务时，可以将该任务划分成多个子任务，再由多个节点并行处理这些子任务，从而提高区块链系统中数据处理的效率。
附图说明
此处所说明的附图用来提供对本说明书的进一步理解，构成本说明书的一部分，本说明书的示意性实施例及其说明用于解释本说明书，并不构成对本说明书的不当限定。在附图中：
图1为本说明书中一种数据处理的方法示意图；
图2为本说明书提供的一种数据处理系统的结构示意图；
图3为本说明书提供的一种数据处理的装置的示意图；
图4为本说明书提供的对应于图1的电子设备示意图。
具体实施方式
为使本说明书的目的、技术方案和优点更加清楚，下面将结合本说明书具体实施例及相应的附图对本说明书技术方案进行清楚、完整地描述。显然，所描述的实施例仅是本说明书一部分实施例，而不是全部的实施例。基于本说明书中的实施例，本领域普通技术人员在没有做出创造性劳动前提下所获得的所有其他实施例，都属于本说明书保护的范围。
以下结合附图，详细说明本说明书各实施例提供的技术方案。
图1为本说明书中一种数据处理的方法的流程示意图，具体包括以下步骤：
步骤S100，通过业务子系统包含的主节点接收客户端发送的业务请求。
如图2所示，本说明书涉及一种数据处理系统，该数据处理系统包括客户端、共识网络、业务子系统以及数据存储子系统，业务子系统包括主节点和从节点，共识网络中包含有多个区块链节点。
其中，业务子系统可以是Hyperledger Fabric，数据存储子系统可以是星际文件系统(Inter Planetary File System，IPFS)，业务子系统中所包含的主节点可以是Hyperledger Fabric中排序节点(orderer节点)，业务子系统中所包含的从节点Hyperledger Fabric中对等节点(peer节点)。在本说明书中，业务子系统中可以通过主节点来执行数据的上链操作，即，通过主节点将数据存储在区块链上，当然，业务子系统中的其他从节点也可以执行数据的上链操作。业务子系统中的各节点(包括主节点和从节点)若不是共识网络中的区块链节点，则可以通过预设的接口，将数据存储在区块链中，即，通过预设的接口实现与共识网络的交互。当然，业务子系统中包含的各节点本身可以是共识网络中的区块链节点。
具体实施中，当用户需要进行业务处理时，首先会通过终端设备(如手机、平板电脑、台式电脑等)上安装的客户端(或应用(application，APP))进行注册或登录，以接入该数据处理系统。而后，用户通过该客户端向业务子系统包含的主节点发送业务请求，以使该业务子系统执行该业务请求对应的业务。
其中，在向主节点发送业务请求之前，数据处理系统需要对该用户发起的业务请求进行校验，以确定该业务请求是否满足预设的消息格式，该用户是否具有执行该项业务的资格，以及该业务请求对应的预执行结果是否符合条件等。
基于此，本说明书中的数据处理系统还可以包括至少两个预校验系统，用于在用户通过客户端向主节点发送业务请求之前，对来自客户端的业务请求进行校验，并将校验结果返回给该客户端。
具体实施中，接入数据处理系统的客户端首先确定业务请求所涉及的预校验系统，并分别向该业务请求所涉及的每个预校验系统发送业务请求。而后，各个预校验系统接收到业务请求后，将对该业务请求对应的待执行任务进行校验，得到校验结果，并将校验结果返回给客户端。随后，客户端根据这些预校验系统返回的校验结果，确定这些预校验系统返回的校验结果满足预设条件时，再向业务子系统发送所述业务请求。
其中，对于每个预校验系统来说，该预校验系统对待执行任务进行校验时，可以模拟执行该待执行任务，得到预执行结果，作为预校验结果，可以包括预校验系统预执行该业务请求对应的业务后所得到的结果。相应的，该预校验系统可以将该预执行结果作为校验结果返回给客户端。进而在后续过程中，客户端可以根据各预校验系统返回的校验结果，判断各预校验系统返回的校验结果满足预设条件。其中，业务子系统是Hyperledger Fabric时，该预校验系统则可以是Hyperledger Fabric中的背书节点。
客户端接收到各预校验系统返回的校验结果，需要根据这些校验结果以及该业务请求所对应的业务的预设条件，判断这些校验结果是否满足该预设条件。也就是说，不同的业务对应的预设条件可以是不同的，具体实施时，业务请求所对应的业务的预设条件可以需要根据实际的业务需求而定。
其中，客户端可以在确定通过校验的校验结果的数目在所有预校验系统返回的校验结果的数目中的占比超过设定占比时，确定校验结果满足预设条件。例如，对A类业务的业务请求进行校验时，涉及的预校验系统有6个，客户端可以从这5个预校验系统返回的校验结果中确定出通过校验的校验结果，作为目标结果，并确定出目标结果的数量为5个。而后，客户端确定出在所有预校验系统返回的目标结果的占比为5/6，大于设定占比2/3，因而，确定各预校验系统返回的校验结果满足预设条件。
当然，客户端也可以在确定特定预校验系统返回的校验结果是通过校验的校验结果后，进一步确定剩余的预校验系统返回的校验结果中与特定预校验系统返回的校验结果相同的校验结果的数量，并确定该数量与所有预校验系统返回的校验结果的总数量之间的占比是否超过设定占比，若确定超过设占比，则可以确定校验结果满足预设条件。例如，在对B类业务的业务请求进行检验时，涉及预校验系统有A、B、C和F，客户端若是在确定出预校验系统F(即特定预校验系统)返回的校验结果为校验通过的情况下，确定剩余预校验系统A、B、C三者中至少存在两个预校验系统返回的校验结果与预校验系统F返回的校验结果一致，则可以确定各预校验系统返回的校验结果满足预设条件。
本说明书中，客户端确定各预校验系统返回的校验结果满足预设条件后，将业务请求发送给业务子系统，以使的该业务子系统确定该业务请求对应的待执行任务，进而确定出该待执行任务对应的执行结果。
步骤S102，根据所述业务请求，确定所述业务请求对应的待执行任务。
步骤S104，根据所述待执行任务进行任务拆分，得到若干子待执行任务。
步骤S106，针对每个子待执行任务，通过所述主节点，确定所述业务子系统中执行该子待执行任务的从节点，作为目标从节点，并将该子待执行任务发送给所述目标从节点，以通过所述目标从节点，执行该子待执行任务，得到子任务结果。
步骤S108，通过所述主节点接收各从节点返回的各子任务结果，并根据所述各子任务结果，得到所述待执行任务对应的综合任务结果。
上述步骤中，业务子系统在接收到来自客户端的业务请求后，首先确定该业务请求对应的待执行任务，并将该待执行任务拆分成多个子待执行任务。而后，针对每个子待执行任务，该业务子系统确定执行该子待执行任务的目标从节点，并将这些子待执行任务分发至系统内该子待执行任务对应的目标从节点处，由这些目标从节点负责确定各个子待执行任务对应的子任务结果，并将确定出的子任务结果返回给主节点。最后，主节点根据所有子任务结果，确定待执行任务对应的综合任务结果。如此，在业务请求所对应的业务是大量数据的分析处理任务时，业务子系统可以将该分析处理任务拆分成多个子任务，而后由业务子系统对这些子任务进行并行处理，进而提高数据分析处理的效率。
当然，业务子系统也可以在确定出业务请求对应的待执行任务后，先获取业务子系统内各从节点的剩余算力资源，从中确定出可以执行待执行任务的从节点(例如，剩余算力资源不小于设定算力资源阈值的从节点)，作为目标从节点，而后，根据各从节点的剩余算力资源，对待执行任务进行切分，得到各目标从节点对应的子待执行任务，然后，针对每个子待执行任务，将该子待执行任务发送至对应的目标从节点处，由该目标从节点负责执行该子待执行任务，得到该子待执行任务对应的子任务结果并返回给主节点，进而由主节点根据所有子任务结果，确定待执行任务对应的综合任务结果。
本说明书中业务子系统是Hyperledger Fabric时，可以在Hyperledger Fabric所包含的节点上搭建出实时流处理框架(如spark、storm和flink)，其中，由HyperledgerFabric中的排序节点(orderer节点)，也就是主节点，担任实时流处理框架中的工作管理节点(job-manager节点)的职责，Hyperledger Fabric中的对等节点(peer节点)，也就是从节点，担任实时流处理框架中的工作节点(worker节点)的职责。
步骤S110，将所述综合任务结果发送给所述数据存储子系统，以从所述数据存储子系统中获取到所述综合任务结果对应的地址标识。
步骤S112，向区块链对应的共识网络发送携带有所述地址标识的交易，以使所述共识网络通过包含的各区块链节点确定所述交易通过共识后，将所述地址标识存储在所述区块链中。
本说明书中，主节点得到综合任务结果后，将该综合任务结果发送给数据存储子系统。数据存储子系统将该综合任务结果存储到设定的存储空间后，将向该主节点返回该综合任务结果对应的地址标识。随后，主节点向区块链对应的共识网络发送携带有该地址标识的交易，以使共识网络通过包含的各区块链节点确定交易通过共识后，将地址标识存储在区块链中。
其中，数据存储子系统为IPFS时，数据存储子系统返回的地址标识可以是哈希地址。该哈希地址可以是数据存储子系统根据该综合任务结果的内容进行哈希加密后得到的。也就是说，该哈希地址即为该综合任务结果对应的内容摘要。数据存储子系统存储该综合任务结果时，按照Hash(该综合任务结果对应的内容摘要)＝index(该综合任务结果的存储空间的索引值)的格式构建键值对，并存储到分布式哈希表((Distributed Hash Table，DHT)中。如此，当需要查询数据，数据存储子系统可以根据接收到的地址标识，从上述分布式哈希表查询到分布式哈希表中与之对应的存储空间索引值，进而从对应的存储空间中获取到该地址标识所对应的需要查询的数据。
具体实施中，当用户需要查询数据时，可以在校验通过后，通过客户端向主节点发送数据查询请求，主节点接收到客户端发送的数据查询请求后，根据该数据查询请求中携带的信息查询区块链，从区块链中查询出该数据查询请求所对应的地址标识(即，目标地址标识)。而后，主节点可以直接根据该目标地址标识向数据存储子系统发送数据获取请求，再由该数据存储子系统基于该目标地址标识、以及已构建的分布式哈希表，确定出该目标地址标识所对应的存储空间，进而获取到数据存储子系统中存储的该目标地址标识对应的数据，并向客户端返回该查询结果。当然，主节点也可以将该目标地址标识返回给客户端，再由客户端根据该目标地址标识向数据存储子系统发送数据获取请求，以获取到该目标地址标识对应的数据。
本说明书中涉及的区块链是基于密码学技术发展起来一项技术，从提交交易开始，一直到包含该交易的区块完成上链操作，这期间需要各个区块链节点频繁的进行加密、解密、签名、验签、哈希运算等操作。
在大数据快速发展的今天，国家愈发重视国家级的数据信息安全，故而国家中国家密码管理局针对不涉及国家机密的商业业务开发了国产商用密码算法，以实现国内公民的数据信息安全。
基于此，为了更好的满足多样的业务要求，在本说明书中需要将上述国产商用密码算法集成到共识网络中，在需要采用国产商用密码算法对数据进行加密的商业场景中，采用国产商用密码算法对这些数据进行加密上链。在其他不是必须采用国产商用密码算法对数据进行加密的商业场景中，则可以根据实际业务需求自主选择所需的加密算法。
目前，共识网络中加解密功能是由证书颁发机构(Certificate Authority，CA)中的区块链密码服务提供者(Blockchain Cryptographic Service Provider，BCCSP)提供的。其中，BCCSP能够实现的接口功能可以包括：密钥生命周期管理(可以包括KeyGen密钥产生、KeyDeriv密钥派生、KeyImport密钥导入、GetKey密钥导出等)、哈希散列管理(可以包括散列哈希运算、GetHash获取哈希功能等)、签名验证管理(可以包括签名功能、验证验签功能等)、加解密功能(可以包括Encrypt加密功能、Decrypt解密功能等)等。
现有的共识网络的密码算法多是依赖上述四类接口功能完成的，因此，可以直接改进共识网络的CA中的BCCSP。如，在共识网络的现有的CA中的BCCSP中增加实现国产商用密码算法的程序模块，并编写相对应的调用接口，在需要使用国产商用密码算法进行加密时，共识网络内节点可以通过这些调用接口，调用国产商用密码算法完成相应的加解密操作。
其中，CA可以是Fabric-CA。具体实现过程中，Fabric-CA主要是为了实现对加入联盟链的成员的身份控制以及数据生成保管，在增加实现国产商用密码算法的程序模块时，需要在Lib中通过接口将解析申请证书请求以及签发证书流流程中的加密算法修改为国密算法，通过Util(该包数据工具类)在证书的编解码等操作中扩展国密算法，最后，需要在Fabric中的BCCSP中将原有加密算法替换为国产商用密码算法，或者在原有加密算法替换之外增加国产商用密码算法。
当然，若是不在共识网络的CA的BCCSP中集成国产商用密码算法，则，可以在golang lib(GO语言算法库)中增加实现国产商用密码算法的程序模块，并编写相对应的调用接口，在需要使用国产商用密码算法进行加密时，共识网络内节点可以通过这些调用接口，调用golang lib中的国产商用密码算法完成相应的加解密操作。
具体使用时，在Fabric-SDK(一个区块链的大框架，每一个应用发布上去，可以调用提供的SDK的功能)中的应用可以通过API定义国产商用密码算法的调用接口，以实现诸如访问共识网络中的账本、交易信息等数据。进一步地，为了能够使Fabric支持国产商用密码算法，可以在Vendor文件中替换对Fabric包的引用，以提供对国密算法的支持。
本说明书中，业务子系统可以通过预设的接口，向共识网络中包含的各区块链节点发送获取请求，以获取共识网络中包含的各区块链节点对应的加密规则，根据加密规则，对交易进行加密，得到加密信息，将加密信息携带交易中发送给共识网络，以针对共识网络中包含的每个区块链节点，通过该区块链节点对应的加密规则，对加密信息进行验证。
其中，业务子系统中各节点也可以直接通过预设的接口，从集成该加密规则的BCCSP或者golang lib中获取签名证书、共识网络内其他节点的签名公钥等信息。其中该加密规则可以是国产商用密码算法。
当然，在本说明书中，共识网络中包含的每个区块链节点，从预设的安全机构中获取各业务安全等级对应的加密规则，在接收到业务子系统发送的获取请求时，确定所述获取请求对应的业务安全等级，作为目标安全等级，并将所述目标安全等级对应的加密规则返回给所述业务子系统。
即，不同的业务对应的安全等级可能不同，不同的安全等级所需使用的加密规则也可能略有差别，本说明书中，在业务子系统处理业务时，共识网络中包含的每个区块链节点需要获取该业务所对应的加密规则时，可以先确定根据该业务子系统所处理的业务的业务安全等级，而后，在确定该业务安全等级所对应的加密规则，最终将与该业务安全等级所对应的加密规则返回给业务子系统。其中，在这些加密规则中可以包含有上述国产商用密码算法，也可以包含有其他场景的加密算法。
另外，在本说明书中，若客户端确定各预校验系统返回的校验结果不满足预设条件，此时可以向用户展示提示信息，拒绝执行该业务请求对应的待执行任务，并不将该业务请求继续提交给主节点。当然，客户端在拒绝执行该业务请求对应的待执行任务的同时，也可以确定此次业务请求以及业务请求的校验结果等数据，作为操作日志信息，而后将该操作日志信息发送给主节点，以通过该主节点将此次业务请求对应的操作日志信息，作为需要上链的数据进行存储以及在共识网络中进行共识并完成上链。
以上为本说明书的一个或多个实施例提供的数据处理的方法，基于同样的思路，本说明书还提供了相应的数据处理的装置，如图3所示。
图3为本说明书提供的一种数据处理的装置示意图，具体包括：
接收模块300，用于通过业务子系统包含的主节点接收客户端发送的业务请求；
确定模块301，用于根据所述业务请求，确定所述业务请求对应的待执行任务；
拆分模块302，用于根据所述待执行任务进行任务拆分，得到若干子待执行任务；
执行模块303，用于针对每个子待执行任务，通过所述主节点，确定所述业务子系统中执行该子待执行任务的从节点，作为目标从节点，并将该子待执行任务发送给所述目标从节点，以通过所述目标从节点，执行该子待执行任务，得到子任务结果；
处理模块304，用于通过所述主节点接收各从节点返回的各子任务结果，并根据所述各子任务结果，得到所述待执行任务对应的综合任务结果；
获取模块305，用于将所述综合任务结果发送给所述数据存储子系统，以从所述数据存储子系统中获取到所述综合任务结果对应的地址标识；
发送模块306，用于向区块链对应的共识网络发送携带有所述地址标识的交易，以使所述共识网络通过包含的各区块链节点确定所述交易通过共识后，将所述地址标识存储在所述区块链中。
可选地，所述发送模块306，通过预设的接口，向所述共识网络中包含的各区块链节点发送获取请求，以获取所述共识网络中包含的各区块链节点对应的加密规则，根据所述加密规则，对所述交易进行加密，得到加密信息，将所述加密信息携带所述交易中发送给所述共识网络，以针对所述共识网络中包含的每个区块链节点，通过该区块链节点对应的加密规则，对所述加密信息进行验证。
可选地，所述加密规则包括：国产商用密码算法。
可选地，所述装置还包括：
查询模块307，接收所述客户端发送的数据查询请求，从所述区块链中查询出所述数据查询请求所对应的地址标识，作为目标地址标识，通过所述目标地址标识，向所述客户端返回所述数据存储子系统中存储的所述目标地址标识对应的数据。
可选地，所述数据存储子系统包括：星际文件系统IPFS，所述业务子系统包括：Hyperledger Fabric，所述地址标识包括：哈希地址。
本说明书还提供了一种计算机可读存储介质，该存储介质存储有计算机程序，计算机程序可用于执行上述图1提供的数据处理的方法。
本说明书还提供了图4所示的电子设备的示意结构图。如图4所述，在硬件层面，该电子设备包括处理器、内部总线、网络接口、内存以及非易失性存储器，当然还可能包括其他业务所需要的硬件。处理器从非易失性存储器中读取对应的计算机程序到内存中然后运行，以实现上述图1所述的数据处理的方法。当然，除了软件实现方式之外，本说明书并不排除其他实现方式，比如逻辑器件抑或软硬件结合的方式等等，也就是说以下处理流程的执行主体并不限定于各个逻辑单元，也可以是硬件或逻辑器件。
在20世纪90年代，对于一个技术的改进可以很明显地区分是硬件上的改进(例如，对二极管、晶体管、开关等电路结构的改进)还是软件上的改进(对于方法流程的改进)。然而，随着技术的发展，当今的很多方法流程的改进已经可以视为硬件电路结构的直接改进。设计人员几乎都通过将改进的方法流程编程到硬件电路中来得到相应的硬件电路结构。因此，不能说一个方法流程的改进就不能用硬件实体模块来实现。例如，可编程逻辑器件(Programmable Logic Device,PLD)(例如现场可编程门阵列(Field Programmable GateArray，FPGA))就是这样一种集成电路，其逻辑功能由用户对器件编程来确定。由设计人员自行编程来把一个数字系统“集成”在一片PLD上，而不需要请芯片制造厂商来设计和制作专用的集成电路芯片。而且，如今，取代手工地制作集成电路芯片，这种编程也多半改用“逻辑编译器(logic compiler)”软件来实现，它与程序开发撰写时所用的软件编译器相类似，而要编译之前的原始代码也得用特定的编程语言来撰写，此称之为硬件描述语言(Hardware Description Language，HDL)，而HDL也并非仅有一种，而是有许多种，如ABEL(Advanced Boolean Expression Language)、AHDL(Altera Hardware DescriptionLanguage)、Confluence、CUPL(Cornell University Programming Language)、HDCal、JHDL(Java Hardware Description Language)、Lava、Lola、MyHDL、PALASM、RHDL(RubyHardware Description Language)等，目前最普遍使用的是VHDL(Very-High-SpeedIntegrated Circuit Hardware Description Language)与Verilog。本领域技术人员也应该清楚，只需要将方法流程用上述几种硬件描述语言稍作逻辑编程并编程到集成电路中，就可以很容易得到实现该逻辑方法流程的硬件电路。
控制器可以按任何适当的方式实现，例如，控制器可以采取例如微处理器或处理器以及存储可由该(微)处理器执行的计算机可读程序代码(例如软件或固件)的计算机可读介质、逻辑门、开关、专用集成电路(Application Specific Integrated Circuit，ASIC)、可编程逻辑控制器和嵌入微控制器的形式，控制器的例子包括但不限于以下微控制器：ARC 625D、Atmel AT91SAM、Microchip PIC18F26K20以及Silicone Labs C8051F320，存储器控制器还可以被实现为存储器的控制逻辑的一部分。本领域技术人员也知道，除了以纯计算机可读程序代码方式实现控制器以外，完全可以通过将方法步骤进行逻辑编程来使得控制器以逻辑门、开关、专用集成电路、可编程逻辑控制器和嵌入微控制器等的形式来实现相同功能。因此这种控制器可以被认为是一种硬件部件，而对其内包括的用于实现各种功能的装置也可以视为硬件部件内的结构。或者甚至，可以将用于实现各种功能的装置视为既可以是实现方法的软件模块又可以是硬件部件内的结构。
上述实施例阐明的系统、装置、模块或单元，具体可以由计算机芯片或实体实现，或者由具有某种功能的产品来实现。一种典型的实现设备为计算机。具体的，计算机例如可以为个人计算机、膝上型计算机、蜂窝电话、相机电话、智能电话、个人数字助理、媒体播放器、导航设备、电子邮件设备、游戏控制台、平板计算机、可穿戴设备或者这些设备中的任何设备的组合。
为了描述的方便，描述以上装置时以功能分为各种单元分别描述。当然，在实施本说明书时可以把各单元的功能在同一个或多个软件和/或硬件中实现。
本领域内的技术人员应明白，本发明的实施例可提供为方法、系统、或计算机程序产品。因此，本发明可采用完全硬件实施例、完全软件实施例、或结合软件和硬件方面的实施例的形式。而且，本发明可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。
本发明是参照根据本发明实施例的方法、设备(系统)、和计算机程序产品的流程图和/或方框图来描述的。应理解可由计算机程序指令实现流程图和/或方框图中的每一流程和/或方框、以及流程图和/或方框图中的流程和/或方框的结合。可提供这些计算机程序指令到通用计算机、专用计算机、嵌入式处理机或其他可编程数据处理设备的处理器以产生一个机器，使得通过计算机或其他可编程数据处理设备的处理器执行的指令产生用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的装置。
这些计算机程序指令也可存储在能引导计算机或其他可编程数据处理设备以特定方式工作的计算机可读存储器中，使得存储在该计算机可读存储器中的指令产生包括指令装置的制造品，该指令装置实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能。
这些计算机程序指令也可装载到计算机或其他可编程数据处理设备上，使得在计算机或其他可编程设备上执行一系列操作步骤以产生计算机实现的处理，从而在计算机或其他可编程设备上执行的指令提供用于实现在流程图一个流程或多个流程和/或方框图一个方框或多个方框中指定的功能的步骤。
在一个典型的配置中，计算设备包括一个或多个处理器(CPU)、输入/输出接口、网络接口和内存。
内存可能包括计算机可读介质中的非永久性存储器，随机存取存储器(RAM)和/或非易失性内存等形式，如只读存储器(ROM)或闪存(flash RAM)。内存是计算机可读介质的示例。
计算机可读介质包括永久性和非永久性、可移动和非可移动媒体可以由任何方法或技术来实现信息存储。信息可以是计算机可读指令、数据结构、程序的模块或其他数据。计算机的存储介质的例子包括，但不限于相变内存(PRAM)、静态随机存取存储器(SRAM)、动态随机存取存储器(DRAM)、其他类型的随机存取存储器(RAM)、只读存储器(ROM)、电可擦除可编程只读存储器(EEPROM)、快闪记忆体或其他内存技术、只读光盘只读存储器(CD-ROM)、数字多功能光盘(DVD)或其他光学存储、磁盒式磁带，磁带磁磁盘存储或其他磁性存储设备或任何其他非传输介质，可用于存储可以被计算设备访问的信息。按照本文中的界定，计算机可读介质不包括暂存电脑可读媒体(transitory media)，如调制的数据信号和载波。
还需要说明的是，术语“包括”、“包含”或者其任何其他变体意在涵盖非排他性的包含，从而使得包括一系列要素的过程、方法、商品或者设备不仅包括那些要素，而且还包括没有明确列出的其他要素，或者是还包括为这种过程、方法、商品或者设备所固有的要素。在没有更多限制的情况下，由语句“包括一个……”限定的要素，并不排除在包括所述要素的过程、方法、商品或者设备中还存在另外的相同要素。
本领域技术人员应明白，本说明书的实施例可提供为方法、系统或计算机程序产品。因此，本说明书可采用完全硬件实施例、完全软件实施例或结合软件和硬件方面的实施例的形式。而且，本说明书可采用在一个或多个其中包含有计算机可用程序代码的计算机可用存储介质(包括但不限于磁盘存储器、CD-ROM、光学存储器等)上实施的计算机程序产品的形式。
本说明书可以在由计算机执行的计算机可执行指令的一般上下文中描述，例如程序模块。一般地，程序模块包括执行特定任务或实现特定抽象数据类型的例程、程序、对象、组件、数据结构等等。也可以在分布式计算环境中实践本说明书，在这些分布式计算环境中，由通过通信网络而被连接的远程处理设备来执行任务。在分布式计算环境中，程序模块可以位于包括存储设备在内的本地和远程计算机存储介质中。
本说明书中的各个实施例均采用递进的方式描述，各个实施例之间相同相似的部分互相参见即可，每个实施例重点说明的都是与其他实施例的不同之处。尤其，对于系统实施例而言，由于其基本相似于方法实施例，所以描述的比较简单，相关之处参见方法实施例的部分说明即可。
以上所述仅为本说明书的实施例而已，并不用于限制本说明书。对于本领域技术人员来说，本说明书可以有各种更改和变化。凡在本说明书的精神和原理之内所作的任何修改、等同替换、改进等，均应包含在本说明书的权利要求范围之内。

Claims (12)

1.一种数据处理系统，其特征在于，包括客户端、共识网络、业务子系统以及数据存储子系统，所述业务子系统包括主节点和从节点，所述共识网络中包含有多个区块链节点；
所述业务子系统，通过所述主节点接收所述客户端发送的业务请求，根据所述业务请求，确定所述业务请求对应的待执行任务，根据所述待执行任务进行任务拆分，得到若干子待执行任务，针对每个子待执行任务，通过所述主节点，确定执行该子待执行任务的从节点，作为目标从节点，并将该子待执行任务发送给所述目标从节点，通过所述目标从节点，执行该子待执行任务，得到子任务结果，通过所述主节点接收各从节点返回的各子任务结果，并根据所述各子任务结果，得到所述待执行任务对应的综合任务结果，将所述综合任务结果发送给所述数据存储子系统，以从所述数据存储子系统中获取到所述综合任务结果对应的地址标识，向区块链对应的共识网络发送携带有所述地址标识的交易，以使所述共识网络通过包含的各区块链节点确定所述交易通过共识后，将所述地址标识存储在所述区块链中；
所述数据存储子系统，接收所述业务子系统发送的所述综合任务结果，根据所述综合任务结果，生成所述综合任务结果对应的地址标识，将所述地址标识返回给所述业务子系统，并将所述综合任务结果存储在所述数据存储子系统本地。
2.如权利要求1所述的数据处理系统，其特征在于，所述数据处理系统还包括：至少两个预校验系统；
所述预校验系统，接收所述客户端发送的业务请求，根据所述业务请求，对所述业务请求对应的待执行任务进行校验，得到校验结果，并将所述校验结果返回给所述客户端；
所述客户端，分别向所述至少两个预校验系统发送业务请求，并接收所述至少两个预校验系统返回的校验结果，若确定所述至少两个预校验系统返回的校验结果满足预设条件，向所述业务子系统发送所述业务请求。
3.如权利要求2所述的数据处理系统，其特征在于，所述客户端，从所述至少两个预校验系统返回的校验结果中确定出通过校验的校验结果，作为目标结果，若确定所述目标结果在所述至少两个预校验系统返回的校验结果中的占比超过设定占比，确定所述至少两个预校验系统返回的校验结果满足所述预设条件。
4.如权利要求1所述的数据处理系统，其特征在于，所述业务子系统，通过预设的接口，向所述共识网络中包含的各区块链节点发送获取请求，以获取所述共识网络中包含的各区块链节点对应的加密规则，根据所述加密规则，对所述交易进行加密，得到加密信息，将所述加密信息携带所述交易中发送给所述共识网络，以针对所述共识网络中包含的每个区块链节点，通过该区块链节点对应的加密规则，对所述加密信息进行验证。
5.如权利要求4所述的数据处理系统，其特征在于，所述共识网络中包含的每个区块链节点，从预设的安全机构中获取各业务安全等级对应的加密规则，在接收到所述业务子系统发送的所述获取请求时，确定所述获取请求对应的业务安全等级，作为目标安全等级，并将所述目标安全等级对应的加密规则返回给所述业务子系统。
6.如权利要求5所述的数据处理系统，其特征在于，所述加密规则包括：国产商用密码算法。
7.如权利要求1所述的数据处理系统，其特征在于，所述业务子系统接收所述客户端发送的数据查询请求，从所述区块链中查询出所述数据查询请求所对应的地址标识，作为目标地址标识，通过所述目标地址标识，向所述客户端返回所述数据存储子系统中存储的所述目标地址标识对应的数据。
8.如权利要求1～7任一项所述的数据处理系统，其特征在于，所述数据存储子系统包括：星际文件系统IPFS，所述业务子系统包括：Hyperledger Fabric，所述地址标识包括：哈希地址。
9.一种数据处理的方法，其特征在于，包括：
通过业务子系统包含的主节点接收客户端发送的业务请求；
根据所述业务请求，确定所述业务请求对应的待执行任务；
根据所述待执行任务进行任务拆分，得到若干子待执行任务；
针对每个子待执行任务，通过所述主节点，确定所述业务子系统中执行该子待执行任务的从节点，作为目标从节点，并将该子待执行任务发送给所述目标从节点，以通过所述目标从节点，执行该子待执行任务，得到子任务结果；
通过所述主节点接收各从节点返回的各子任务结果，并根据所述各子任务结果，得到所述待执行任务对应的综合任务结果；
将所述综合任务结果发送给所述数据存储子系统，以从所述数据存储子系统中获取到所述综合任务结果对应的地址标识；
向区块链对应的共识网络发送携带有所述地址标识的交易，以使所述共识网络通过包含的各区块链节点确定所述交易通过共识后，将所述地址标识存储在所述区块链中。
10.一种数据处理的装置，其特征在于，包括：
接收模块，用于通过业务子系统包含的主节点接收客户端发送的业务请求；
确定模块，用于根据所述业务请求，确定所述业务请求对应的待执行任务；
拆分模块，用于根据所述待执行任务进行任务拆分，得到若干子待执行任务；
执行模块，用于针对每个子待执行任务，通过所述主节点，确定所述业务子系统中执行该子待执行任务的从节点，作为目标从节点，并将该子待执行任务发送给所述目标从节点，以通过所述目标从节点，执行该子待执行任务，得到子任务结果；
处理模块，用于通过所述主节点接收各从节点返回的各子任务结果，并根据所述各子任务结果，得到所述待执行任务对应的综合任务结果；
获取模块，用于将所述综合任务结果发送给所述数据存储子系统，以从所述数据存储子系统中获取到所述综合任务结果对应的地址标识；
发送模块，用于向区块链对应的共识网络发送携带有所述地址标识的交易，以使所述共识网络通过包含的各区块链节点确定所述交易通过共识后，将所述地址标识存储在所述区块链中。
11.一种计算机可读存储介质，其特征在于，所述存储介质存储有计算机程序，所述计算机程序被处理器执行时实现上述权利要求9所述的方法。
12.一种电子设备，包括存储器、处理器及存储在存储器上并可在处理器上运行的计算机程序，其特征在于，所述处理器执行所述程序时实现上述权利要求9所述的方法。
CN202110296513.1A 2021-03-19 2021-03-19 一种数据处理的方法、装置及系统 Pending CN113079200A (zh)

Priority Applications (1)

Application Number Priority Date Filing Date Title
CN202110296513.1A CN113079200A (zh) 2021-03-19 2021-03-19 一种数据处理的方法、装置及系统

Applications Claiming Priority (1)

Application Number Priority Date Filing Date Title
CN202110296513.1A CN113079200A (zh) 2021-03-19 2021-03-19 一种数据处理的方法、装置及系统

Publications (1)

Publication Number Publication Date
CN113079200A true CN113079200A (zh) 2021-07-06

Family

ID=76612857

Family Applications (1)

Application Number Title Priority Date Filing Date
CN202110296513.1A Pending CN113079200A (zh) 2021-03-19 2021-03-19 一种数据处理的方法、装置及系统

Country Status (1)

Country Link
CN (1) CN113079200A (zh)

Cited By (19)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN113608859A (zh) * 2021-08-24 2021-11-05 京东科技控股股份有限公司 节点任务的执行方法、装置及存储介质
CN113630451A (zh) * 2021-07-27 2021-11-09 山东浪潮科学研究院有限公司 一种基于区块链、spark的计算服务系统
CN113645283A (zh) * 2021-07-29 2021-11-12 北京三快在线科技有限公司 一种多链路通信方法、装置、存储介质及电子设备
CN113672593A (zh) * 2021-08-19 2021-11-19 中国建设银行股份有限公司 一种数据存储方法、装置及设备
CN113743949A (zh) * 2021-11-04 2021-12-03 支付宝(杭州)信息技术有限公司 在区块链中执行交易的方法、区块链、主节点和从节点
CN114168557A (zh) * 2021-12-06 2022-03-11 广东飞翔云计算有限公司 一种访问日志的处理方法、装置、计算机设备和存储介质
CN114221814A (zh) * 2021-12-16 2022-03-22 上海市共进通信技术有限公司 实现终端设备安全开启特殊业务的系统、方法、装置、处理器及其计算机可读存储介质
CN114448995A (zh) * 2021-12-24 2022-05-06 苏州纳智天地智能科技有限公司 基于raft选主策略的分布式计算方法
CN114637970A (zh) * 2022-03-21 2022-06-17 中国银行股份有限公司 基于区块链的数字水印识别方法及装置
CN115525828A (zh) * 2022-09-30 2022-12-27 支付宝(杭州)信息技术有限公司 一种业务处理的方法、装置、存储介质以及电子设备
CN115766025A (zh) * 2022-11-02 2023-03-07 卫盈联信息技术（深圳）有限公司 基于隐私保护的数据处理方法、装置、设备及存储介质
CN116010529A (zh) * 2023-03-08 2023-04-25 阿里云计算有限公司 数据处理方法及系统
CN116107708A (zh) * 2023-02-09 2023-05-12 之江实验室 一种任务执行的方法、装置、存储介质及电子设备
CN116185596A (zh) * 2023-04-24 2023-05-30 之江实验室 提升广域多集群分布式系统执行任务效率的方法及装置
CN116506439A (zh) * 2023-05-29 2023-07-28 成都质数斯达克科技有限公司 区块链分层网络共识方法、装置、设备及存储介质
CN117155575A (zh) * 2022-05-24 2023-12-01 华为云计算技术有限公司 一种数据处理系统、方法、节点及设备
CN117555697A (zh) * 2024-01-11 2024-02-13 之江实验室 一种面向分布式训练的缓存加载系统、方法、装置及设备
CN118802911A (zh) * 2024-03-29 2024-10-18 中国移动通信集团浙江有限公司 算力网络的边缘节点协同方法及装置
CN119030987A (zh) * 2024-08-05 2024-11-26 广州三七极梦网络技术有限公司 一种业务执行方法、装置、设备及可读存储介质

Cited By (29)

* Cited by examiner, † Cited by third party
Publication number Priority date Publication date Assignee Title
CN113630451A (zh) * 2021-07-27 2021-11-09 山东浪潮科学研究院有限公司 一种基于区块链、spark的计算服务系统
CN113630451B (zh) * 2021-07-27 2023-05-16 山东浪潮科学研究院有限公司 一种基于区块链、spark的计算服务系统
CN113645283B (zh) * 2021-07-29 2023-04-07 北京三快在线科技有限公司 一种多链路通信方法、装置、存储介质及电子设备
CN113645283A (zh) * 2021-07-29 2021-11-12 北京三快在线科技有限公司 一种多链路通信方法、装置、存储介质及电子设备
CN113672593A (zh) * 2021-08-19 2021-11-19 中国建设银行股份有限公司 一种数据存储方法、装置及设备
CN113608859A (zh) * 2021-08-24 2021-11-05 京东科技控股股份有限公司 节点任务的执行方法、装置及存储介质
CN113608859B (zh) * 2021-08-24 2024-08-16 京东科技控股股份有限公司 节点任务的执行方法、装置及存储介质
CN113743949A (zh) * 2021-11-04 2021-12-03 支付宝(杭州)信息技术有限公司 在区块链中执行交易的方法、区块链、主节点和从节点
CN114168557A (zh) * 2021-12-06 2022-03-11 广东飞翔云计算有限公司 一种访问日志的处理方法、装置、计算机设备和存储介质
CN114221814A (zh) * 2021-12-16 2022-03-22 上海市共进通信技术有限公司 实现终端设备安全开启特殊业务的系统、方法、装置、处理器及其计算机可读存储介质
CN114221814B (zh) * 2021-12-16 2023-10-27 上海市共进通信技术有限公司 实现终端设备安全开启特殊业务的系统、方法、装置、处理器及其计算机可读存储介质
CN114448995A (zh) * 2021-12-24 2022-05-06 苏州纳智天地智能科技有限公司 基于raft选主策略的分布式计算方法
CN114637970A (zh) * 2022-03-21 2022-06-17 中国银行股份有限公司 基于区块链的数字水印识别方法及装置
CN117155575A (zh) * 2022-05-24 2023-12-01 华为云计算技术有限公司 一种数据处理系统、方法、节点及设备
CN115525828A (zh) * 2022-09-30 2022-12-27 支付宝(杭州)信息技术有限公司 一种业务处理的方法、装置、存储介质以及电子设备
WO2024066758A1 (zh) * 2022-09-30 2024-04-04 支付宝(杭州)信息技术有限公司 一种业务处理的方法、装置、存储介质以及电子设备
CN115766025B (zh) * 2022-11-02 2026-01-06 卫盈联信息技术（深圳）有限公司 基于隐私保护的数据处理方法、装置、设备及存储介质
CN115766025A (zh) * 2022-11-02 2023-03-07 卫盈联信息技术（深圳）有限公司 基于隐私保护的数据处理方法、装置、设备及存储介质
CN116107708A (zh) * 2023-02-09 2023-05-12 之江实验室 一种任务执行的方法、装置、存储介质及电子设备
CN116010529A (zh) * 2023-03-08 2023-04-25 阿里云计算有限公司 数据处理方法及系统
CN116010529B (zh) * 2023-03-08 2023-08-29 阿里云计算有限公司 数据处理方法及系统
CN116185596B (zh) * 2023-04-24 2023-08-01 之江实验室 提升广域多集群分布式系统执行任务效率的方法及装置
CN116185596A (zh) * 2023-04-24 2023-05-30 之江实验室 提升广域多集群分布式系统执行任务效率的方法及装置
CN116506439A (zh) * 2023-05-29 2023-07-28 成都质数斯达克科技有限公司 区块链分层网络共识方法、装置、设备及存储介质
CN117555697A (zh) * 2024-01-11 2024-02-13 之江实验室 一种面向分布式训练的缓存加载系统、方法、装置及设备
CN117555697B (zh) * 2024-01-11 2024-04-05 之江实验室 一种面向分布式训练的缓存加载系统、方法、装置及设备
CN118802911A (zh) * 2024-03-29 2024-10-18 中国移动通信集团浙江有限公司 算力网络的边缘节点协同方法及装置
CN118802911B (zh) * 2024-03-29 2025-11-25 中国移动通信集团浙江有限公司 算力网络的边缘节点协同方法及装置
CN119030987A (zh) * 2024-08-05 2024-11-26 广州三七极梦网络技术有限公司 一种业务执行方法、装置、设备及可读存储介质

Similar Documents

Publication Publication Date Title
CN113079200A (zh) 一种数据处理的方法、装置及系统
US10698885B2 (en) Method and device for writing service data in block chain system
CN107196900B (zh) 一种共识校验的方法及装置
CN110189121B (zh) 数据处理方法、装置、区块链客户端和区块链节点
CN111737304B (zh) 一种区块链数据的处理方法、装置及设备
CN109347839B (zh) 集中式密码管理方法、装置、电子设备及计算机存储介质
CN110781192A (zh) 区块链数据的验证方法、装置及设备
CN115098866A (zh) 检测隐私数据泄漏的方法
CN112182506A (zh) 一种数据的合规检测方法、装置及设备
CN113282959A (zh) 业务数据处理方法、装置及电子设备
CN112287376A (zh) 一种隐私数据的处理方法及装置
CN111767556A (zh) 区块链中实现隐私保护的方法及节点、存储介质
CN107578338B (zh) 一种业务发布方法、装置及设备
WO2024092932A1 (zh) 交易执行方法和区块链节点
CN113282628A (zh) 大数据平台访问方法、装置及大数据平台、电子设备
CN111131474A (zh) 一种基于区块链管理用户协议的方法、设备及介质
CN113673844A (zh) 一种信息反馈方法、装置及设备
CN110995447B (zh) 一种数据存证方法、装置、设备以及介质
CN109144743A (zh) 一种数据的获取方法、装置及设备
CN114301710B (zh) 确定报文是否被篡改的方法、密管平台和密管系统
CN113572611A (zh) 密钥处理方法、装置及电子装置
CN112818367B (zh) 文件的加密方法、装置、存储介质及处理器
US10339295B2 (en) Tracking work between system entities
HK40023133A (zh) 区块链数据的验证方法、装置及设备
HK40023133B (zh) 区块链数据的验证方法、装置及设备

Legal Events

Date Code Title Description
PB01 Publication
PB01 Publication
SE01 Entry into force of request for substantive examination
SE01 Entry into force of request for substantive examination