CN114157716B - 基于区块链的数据处理方法、装置和电子设备 - Google Patents

Abstract

本申请实施例提供了一种基于区块链的数据处理方法、装置和电子设备，通过获取待发送数据；根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块，得到多个数据块，其中，多个数据块中每个数据块内包括的数据的第二数据量不大于最大数据量；将多个数据块分次发送给区块链中的接收节点。本申请实施例提供的技术方案使得能够基于区块链传输大量的待发送数据，且数据块包括的数据的第二数据量不大于区块链单次传输对应的最大数据量，能够保证数据成功发送至接收节点，从而提升了数据块传输的效率。

Description

基于区块链的数据处理方法、装置和电子设备

技术领域

本申请涉及科技金融技术领域，尤其涉及一种基于区块链的数据处理方法、装置和电子设备。

背景技术

随着计算机技术的发展，越来越多的技术应用在金融领域，传统金融业正在逐步向金融科技(Finteh)转变，数据处理技术也不例外，但由于金融行业的安全性、实时性要求，这对数据处理技术提出的更高的要求。特别是基于区块链的数据处理技术，随着数据量的不断增加，对于区块链的数据传输技术提出了较高的要求。

区块链作为一种分布式网络，其每个节点均与多个节点连接，为了保持网络的稳定，在传输数据时，需要设计单独的数据传输协议，节点单次发送与接收的数据量不可超过数据量阈值，且数据量阈值较小，例如，联盟链中的链上信使协议，其一次传输的数据量不超过32M。在区块链一次传输的数据量较大但未超过数据量阈值时，受带宽的限制可能导致传输的速度较慢，从而降低了数据传输的效率。然而，当数据量超过区块链一次能传输的数据量阈值时，则数据传输失败，从而导致需要传输大量数据的业务无法使用。

发明内容

本申请实施例提供了一种基于区块链的数据处理方法、装置和电子设备，通过将数据进行分块得到数据块，将数据块分次进行传输，能够保证数据传输的效率。

第一方面，本申请实施例提供了一种基于区块链的数据处理方法，所述基于区块链的数据处理方法包括：

获取待发送数据。

根据所述待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将所述待发送数据进行分块，得到多个数据块，其中，所述多个数据块中每个数据块内包括的数据的第二数据量不大于所述最大数据量。

将所述多个数据块分次发送给所述区块链中的接收节点。

可选的，所述根据所述待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将所述待发送数据进行分块，得到多个数据块，包括：

根据所述第一数据量和所述最大数据量，确定分块数。

按照所述分块数，将所述待发送数据进行分块，得到多个数据块。

可选的，所述将所述多个数据块分次发送给所述区块链中的接收节点，包括：

确定所述每个数据块对应的特征信息，所述特征信息中包括分块数、所述数据块对应的业务标识和所述数据块的序列号中的至少一个。

将所述特征信息携带在对应的所述数据块中发送给所述接收节点。

可选的，所述特征信息中包括所述数据块的序列号。

将所述特征信息携带在对应的所述数据块中发送给所述接收节点，包括：

按照所述多个数据块各自对应的序列号，依次将所述特征信息携带在对应的所述数据块中发送给所述接收节点。

可选的，所述将所述多个数据块分次发送给所述区块链中的接收节点，包括：

分别确定所述每个数据块的头部信息，所述头部信息中包括目标节点的标识信息和所述数据块对应的业务标识。

在所述每个数据块中分别添加对应的头部信息。

分次将添加了头部信息的数据块发送给对应的接收节点。

可选的，所述根据所述待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将所述待发送数据进行分块，包括：

判断所述第一数据量是否大于所述最大数据量。

若所述第一数据量大于所述最大数据量，则根据所述待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将所述待发送数据进行分块。

第二方面，本申请实施例提供了一种基于区块链的数据处理方法，应用于接收节点，所述基于区块链的数据处理方法包括：

依次接收发送节点发送的多个数据块，其中，所述多个数据块中每个数据块内包括的数据的第二数据量不大于区块链中单次传输对应的最大数据量。

将所述多个数据块进行合并，得到目标数据。

可选的，所述将所述多个数据块进行合并，得到目标数据，包括：

分别对所述多个数据块进行解析，得到每个数据块对应的特征信息，所述特征信息中包括分块数、所述数据块对应的业务标识和所述数据块的序列号中的至少一个。

根据所述每个数据块对应的特征信息，将所述多个数据块进行合并，得到目标数据。

可选的，所述特征信息中包括分块数、所述数据块对应的业务标识和所述数据块的序列号。

所述根据所述每个数据块对应的特征信息，将所述多个数据块进行合并，得到目标数据，包括：

从所有接收到的数据块中筛选业务标识相同的多个数据块。

判断所述业务标识相同的多个数据块的数量是否与所述分块数相等；

若相等，则按照每个数据块的序列号，依次将所述业务标识相同的多个数据块进行合并，得到所述目标数据。

可选的，所述每个数据块中还包括头部信息，所述头部信息中包括所述目标节点的标识信息。

所述分别对所述多个数据块进行解析，包括：

分别判断所述每个数据块对应的所述目标节点的标识信息与所述接收节点的标识信息是否相同。

若相同，则分别对所述多个数据块进行解析。

可选的，所述头部信息中还包括所述数据块对应的业务标识。

所述分别对所述多个数据块进行解析，包括：

分别判断所述每个数据块对应的业务标识是否为预设标识。

若为所述预设标识，则分别对所述多个数据块进行解析。

第三方面，本申请实施例提供了一种基于区块链的数据处理装置，所述基于区块链的数据处理装置包括：

获取模块，用于获取待发送数据。

处理模块，用于根据所述待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将所述待发送数据进行分块，得到多个数据块，其中，所述多个数据块中每个数据块内包括的数据的第二数据量不大于所述最大数据量。

发送模块，用于将所述多个数据块分次发送给所述区块链中的接收节点。

可选的，所述处理模块，具体用于根据所述第一数据量和所述最大数据量，确定分块数；按照所述分块数，将所述待发送数据进行分块，得到多个数据块。

可选的，所述发送模块，具体用于确定所述每个数据块对应的特征信息，所述特征信息中包括分块数、所述数据块对应的业务标识和所述数据块的序列号中的至少一个；将所述特征信息携带在对应的所述数据块中发送给所述接收节点。

可选的，所述特征信息中包括所述数据块的序列号；所述发送模块，具体用于按照所述多个数据块各自对应的序列号，依次将所述特征信息携带在对应的所述数据块中发送给所述接收节点。

可选的，所述发送模块，具体用于分别确定所述每个数据块的头部信息，所述头部信息中包括目标节点的标识信息和所述数据块对应的业务标识；在所述每个数据块中分别添加对应的头部信息；分次将添加了头部信息的数据块发送给对应的接收节点。

可选的，所述处理模块，具体用于判断所述第一数据量是否大于所述最大数据量；在所述第一数据量大于所述最大数据量时，根据所述待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将所述待发送数据进行分块。

第四方面，本申请实施例提供了一种基于区块链的数据处理装置，所述基于区块链的数据处理装置包括：

接收模块，用于依次接收发送节点发送的多个数据块，其中，所述多个数据块中每个数据块内包括的数据的第二数据量不大于区块链中单次传输对应的最大数据量。

合并模块，用于将所述多个数据块进行合并，得到目标数据。

可选的，所述合并模块，具体用于分别对所述多个数据块进行解析，得到每个数据块对应的特征信息，所述特征信息中包括分块数、所述数据块对应的业务标识和所述数据块的序列号中的至少一个；根据所述每个数据块对应的特征信息，将所述多个数据块进行合并，得到目标数据。

可选的，所述特征信息中包括分块数、所述数据块对应的业务标识和所述数据块的序列号；所述合并模块，具体用于从所有接收到的数据块中筛选业务标识相同的多个数据块；判断所述业务标识相同的多个数据块的数量是否与所述分块数相等；在相等时，按照每个数据块的序列号，依次将所述业务标识相同的多个数据块进行合并，得到所述目标数据。

可选的，所述每个数据块中还包括头部信息，所述头部信息中包括所述目标节点的标识信息；所述合并模块，具体用于分别判断所述每个数据块对应的所述目标节点的标识信息与所述接收节点的标识信息是否相同；在相同时，分别对所述多个数据块进行解析。

可选的，所述头部信息中还包括所述数据块对应的业务标识；所述合并模块，具体用于分别判断所述每个数据块对应的业务标识是否为预设标识；在为所述预设标识时，分别对所述多个数据块进行解析。

第五方面，本申请实施例还提供了一种电子设备，该电子设备包括：处理器，以及与所述处理器通信连接的存储器；

所述存储器存储计算机执行指令；

所述处理器执行所述存储器存储的计算机执行指令，以实现上述第一方面任一种可能的实现方式中所述的基于区块链的数据处理方法。

第六方面，本申请实施例还提供了一种计算机可读存储介质，所述计算机可读存储介质中存储有计算机执行指令，当处理器执行所述计算机执行指令时，实现上述第一方面任一种可能的实现方式中所述的基于区块链的数据处理方法。

第七方面，本申请实施例还提供了一种计算机程序产品，包括计算机程序，该计算机程序被处理器执行时，实现上述第一方面任一种可能的实现方式中所述的基于区块链的数据处理方法。

由此可见，本申请实施例提供了一种基于区块链的数据处理方法、装置和电子设备，通过获取待发送数据；根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块，得到多个数据块，其中，多个数据块中每个数据块内包括的数据的第二数据量不大于最大数据量；将多个数据块分次发送给区块链中的接收节点。本申请实施例提供的技术方案通过将待发送数据分为多个数据块，且每个数据块包括的数据的第二数据量不大于区块链单次传输对应的最大数据量，能够保证待发送数据成功发送至接收节点，打破了区块链传输数据的数据量阈值的限制，能够发送大量的数据，有效的提升数据传输的效率，避免了传输的数据量超过数据量阈值导致数据传输失败的问题，从而提升了数据传输的成功率。

附图说明

图1为本申请实施例提供的一种基于区块链的数据处理方法的应用场景示意图；

图2为本申请实施例提供的一种基于区块链的数据处理方法的流程示意图；

图3为本申请实施例提供的另一种基于区块链的数据处理方法的流程示意图；

图4为本申请实施例提供的一种基于区块链的流式数据包的结构示意图；

图5为本申请实施例提供的一种发送节点对隐私密文数据data进行流式处理并发送的流程示意图；

图6为本申请实施例提供的一种接收节点接收流式数据包并合并的流程示意图；

图7为本申请实施例提供的一种基于区块链的数据处理装置的结构示意图；

图8为本申请实施例提供的另一种基于区块链的数据处理装置的结构示意图；

图9为本申请提供的一种电子设备结构示意图。

通过上述附图，已示出本公开明确的实施例，后文中将有更详细的描述。这些附图和文字描述并不是为了通过任何方式限制本公开构思的范围，而是通过参考特定实施例为本领域技术人员说明本公开的概念。

具体实施方式

这里将详细地对示例性实施例进行说明，其示例表示在附图中。下面的描述涉及附图时，除非另有表示，不同附图中的相同数字表示相同或相似的要素。以下示例性实施例中所描述的实施方式并不代表与本公开相一致的所有实施方式。相反，它们仅是与如所附权利要求书中所详述的、本公开的一些方面相一致的装置和方法的例子。

在本申请的实施例中，“至少一个”是指一个或者多个，“多个”是指两个或两个以上。“和/或”，描述关联对象的关联关系，表示可以存在三种关系，例如，A和/或B，可以表示：单独存在A，同时存在A和B，单独存在B这三种情况，其中A，B可以是单数或者复数。在本申请的文字描述中，字符“/”一般表示前后关联对象是一种“或”的关系。

本申请实施例提供的技术方案可以应用于数据处理的场景中，特别是基于区块链的数据处理。区块链是由一系列区块组成的一条链，每个块上除了记录本块的数据还会记录上一块的Hash值，通过这种方式组成一条链。区块链的核心理念有两个，一个是密码学技术，另一个是去中心化思想，基于这两个理念做到区块链上的历史信息无法被篡改。利用区块链可以进行隐私计算、安全多方计算等。

其中，隐私计算是指在保证数据提供方不泄露原始数据的前提下，对数据进行分析计算的一类信息技术，保障数据在产生、存储、计算、应用、销毁等信息流程全过程的各个环节中“可用不可见”。隐私计算包括安全多方计算、联邦学习、可信执行环境等。安全多方计算(Secure Multi-Party Computation，简称MPC)是指在无可信第三方的情况下，多个参与方协同计算一个约定的函数，并且保证每一方仅获取自己的计算结果，无法通过计算过程中的交互数据推测出其他任意一方的输入和输出数据。

在使用区块链传输数据时，为了保持网络的稳定，在传输数据时，需要设计单独的数据传输协议，区块链的节点单次发送与接收的数据量要小于数据量阈值，且数据量阈值较小，例如，联盟链中的链上信使协议，其一次传输的数据量不超过32M。在区块链一次传输的数据量较大但未超过数据量阈值时，可能收到传输带宽的限制使得传输的速度较慢，从而降低了数据传输的效率。此外，在数据量超过区块链一次能传输的数据量阈值时，会出现数据传输失败的问题，使得隐私计算等需要传输大量数据的业务无法使用。

为了解决区块链数据传输效率较低的问题，可以对大量的数据进行分块处理，以数据块的形式进行数据传输，避免了带宽限制导致传输速度慢的问题，仅数据块中的数据量不大于区块链单次传输对应的最大数据量，使得数据库能够成功发送至接收节点。此外，本申请提供的技术方案能够应用于基于区块链的隐私计算业务发送大规模数据的场景。

图1为本申请实施例提供的一种基于区块链的数据处理方法的应用场景示意图。根据图1所示，在发送节点将待发送数据发送至接收节点100时，根据区块链中单次传输对应的最大数据量和待发送数据的第一数据量可以确定出将待发送数据分成3份，分别放置于3个数据块200中。例如，待发送数据的第一数据量为16，区块链中单次传输对应的最大数据量为8，因此，3个数据块中存储的待发送数据的数量可以为5，5，6，或者为不超过8的其他分配方式，本申请实施例仅以上述为例进行说明，但并不代表本申请实施例仅局限于此。

进一步地，在得到3个数据块之后，将3个数据块分次发送给区块链中的接收节点103。接收节点103通过将接收到的3个数据块中的数据进行合并，得到待发送数据。

本申请实施例提供的技术方案能够将大量的数据放置于多个数据块分次发送至接收节点，提升了数据传输的效率。而且每个数据块内包括的数据的第二数据量均不大于区块链中单词传输对应的最大数据量，能够保证数据传输过程中的成功率。因此，使用本申请实施提供的方法在传输超过数据量阈值的数据时，不会出现传输失败的问题，能够实现使得隐私计算等需要传输大量数据的业务正常使用。

下面，将通过具体的实施例对本申请提供的基于区块链的数据处理方法进行详细地说明。可以理解的是，下面这几个具体的实施例可以相互结合，对于相同或相似的概念或过程可能在某些实施例不再赘述。

图2为本申请实施例提供的一种基于区块链的数据处理方法的流程示意图。该基于区块链的数据处理方法可以由软件和/或硬件装置执行，例如，该硬件装置可以为基于区块链的数据处理装置，该基于区块链的数据处理装置可以为终端或者终端中的处理芯片。示例的，请参见图2所示，该基于区块链的数据处理方法可以包括：

S201、获取待发送数据。

在本步骤中，在获取待发送数据时，可以通过多种渠道从多个数据源获取带发送的数据，例如，可以从多个数据源获取指定企业的各个维度的数据。获取的待发送数据与当前执行的业务相关，示例的，当前执行的业务为隐私计算业务时，则获取的待发送数据为隐私计算的相关数据。本申请实施例对于获取待发送数据以及待发送数据的内容不做任何限定。

S202、根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块，得到多个数据块，其中，多个数据块中每个数据块内包括的数据的第二数据量不大于最大数据量。

在本步骤中，在根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块，得到多个数据块时，可以根据第一数据量和最大数据量，确定分块数；按照分块数，将待发送数据进行分块，得到多个数据块。

示例的，最大数据量为区块链中单次传输对应的最大数据量，可以为10M，或者30M，也可以为其他数量，具体的根据实际情况进行设定，本申请实施例对此不做任何限定。

在本申请实施例中，通过将待发送数据分为多个数据块，实现了将大量数据拆分为多个少量的数据，能够提升数据传输过程的效率，且数据块在传输过程中无线错误的概率较低，因此，能够有效的保证数据的安全性，使得待发送数据能够准确无误的发送至接收节点。

示例的，在根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块时，判断第一数据量是否大于最大数据量；若第一数据量大于最大数据量，则根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块。

示例的，在根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块时，需要确定每个数据块中允许的数据阈值，该数据阈值可能与最大数据量相等，也可能小于最大数据量阈值，具体的可根据实际情况进行设定。例如，在隐私计算业务中，该数据阈值的取值范围为大于9，小于最大数据量与固定参数所占数据量的差值，具体的可以根据区块链和隐私计算的实际情况对数据阈值进行设定，例如，可以取数据阈值为最大数据量的二分之一，本申请实施例对于具体的数据阈值不做任何限定。

在本申请实施例中，根据区块链中单次传输对应的最大数据量对待发送数据进行分块，能够保证数据块中的数据量不超过区块链中单次传输对应的最大数据量，进一步保证数据块能够快速且准确的发送至接收节点。

S203、将多个数据块分次发送给区块链中的接收节点。

在本步骤中，在将多个数据块分次发送给区块链中的接收节点时，可以确定每个数据块对应的特征信息，特征信息中包括分块数、数据块对应的业务标识和数据块的序列号中的至少一个；将特征信息携带在对应的数据块中发送给接收节点。

示例的，数据块可以为流失数据包streamPacket的形式。分块数即为数据块的数量，分块数可以为字符串类型，其占用的字节数为固定的，例如，分块数占用的字节数为4字节。数据块对应的业务标识可以为字符串类型，其占用的字节数为固定的，例如，数据块对应的业务标识占用的字节数为16字节。数据块的序列号可以为整数类型，其占用的字节数为固定的，例如，数据块的序列号占用的字节数为4字节。本申请实施例对于分块数、数据块对应的业务标识和数据块的序列号占用的字节数不做具体限定。

根据上述步骤所述，在对待发送数据进行分块，得到多个数据块时，需要考虑分块数、数据块对应的业务标识和数据块的序列号占用的字节数，对数据块可存储的数据量的影响。例如，数据块中可允许的最大数据量为120，而分块数、数据块对应的业务标识和数据块的序列号占用20，则数据块可允许的最大数据量则变为100。

可以理解的是，特征信息中包括分块数、数据块对应的业务标识和数据块的序列号中的至少一个之外，还可以包括接收节点标识，以指示数据块发送给区块链中指定的接收节点。

在本申请实施例中，通过将分块数、数据块对应的业务标识和数据块的序列号中的至少一个特征信息携带在对应的数据块中，与数据块中的待发送数据一同发送给接收节点，能够根据特征信息确定在数据块传输的进度，以及在数据块传输的过程中是否出现错误，进一步提升数据传输的安全性。

示例的，若特征信息中包括数据块的序列号，则在将特征信息携带在对应的数据块中发送给接收节点时，可以按照多个数据块各自对应的序列号，依次将特征信息携带在对应的数据块中发送给接收节点。

在本申请实施例中，按照第一个数据块各自对应的序列号依次将特征信息携带在对应的数据块中发送给接收节点，使得在发送数据块时，能够保证数据块发送的顺序待发送数据的顺序相同，从而使得接收节点在将接收到的数据块进行合并的效率更高。此外，能够确定数据块在发送至接收节点时是否出现问题。

示例的，数据块还可以包括数据块的头部信息，在分别将多个数据块发送给区块链中的接收节点时，可以分别确定每个数据块的头部信息，头部信息中包括目标节点的标识信息和数据块对应的业务标识；在每个数据块中分别添加对应的头部信息；分次将添加了头部信息的数据块发送给对应的接收节点。

现有技术中，接收节点在接收到发送节点发送的多个数据时，需要对数据进行解析，才可获得数据的业务信息。在本申请实施例中，通过在数据块中添加包括目标节点的标识信息和数据块对应的业务标识的头部信息，使得接收模块可以根据头部信息直接确定数据块对应的业务标识，而不需要对数据块进行解析处理，进一步提升了数据传输的效率。

由此可见，本申请实施例提供的基于区块链的数据处理方法，通过获取待发送数据；根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块，得到多个数据块，其中，多个数据块中每个数据块内包括的数据的第二数据量不大于最大数据量；将多个数据块分次发送给区块链中的接收节点。本申请实施例提供的技术方案通过对将待发送数据以数据块的方式发送给接收节点，实现了区块链传输大量数据。且数据块包括的数据的第二数据量不大于区块链单次传输对应的最大数据量，从而提升了数据传输的效率和成功率。

图3为本申请实施例提供的另一种基于区块链的数据处理方法的流程示意图。该基于区块链的数据处理方法应用于接收节点，可以由软件和/或硬件装置执行，例如，该硬件装置可以为基于区块链的数据处理装置，该基于区块链的数据处理装置可以为终端或者终端中的处理芯片。该基于区块链的数据处理方法应用于接收节点，示例的，请参见图3所示，该基于区块链的数据处理方法可以包括：

S301、依次接收发送节点发送的多个数据块，其中，多个数据块中每个数据块内包括的数据的第二数据量不大于区块链中单次传输对应的最大数据量。

根据上述实施例所述，发送节点在将多个数据块分次发送给区块链中的接收节点时，对于接收节点，按照发送节点发送的顺序依次接收多个数据块。

S302、将多个数据块进行合并，得到目标数据。

示例的，在将多个数据块进行合并，得到目标数据时，可以分别对多个数据块进行解析，得到每个数据块对应的特征信息，特征信息中包括分块数、数据块对应的业务标识和数据块的序列号中的至少一个；根据每个数据块对应的特征信息，将多个数据块进行合并，得到目标数据。本申请实施例对于具体的解析方式不做任何限定。

接收节点接收方在得到每个数据块对应的特征信息之后，可以在本地进行缓存，示例的，可以通过数据流缓存和计数缓存利用每个数据块的特征信息对每个数据块进行缓存。在缓存数据块时，缓存键可以设置为接收节点标识+数据块对应的业务标识+分块数，缓存值可以设置为数据块，用于表示该缓存的内容为数据块。在数据块缓存设置完成后，可以设置计数缓存，计数缓存的键可以设置为接收节点标识+数据块对应的业务标识，使得在接收到一个数据块时，对应计数缓存的值自增1，以对接收到的数据块进行计数。

本申请中将多个数据块进行合并，得到的目标数据为发送节点发送的待发送数据。

在本申请实施例中，由于数据块的特征信息包括分块数、数据块对应的业务标识和数据块的序列号中的至少一个。因此，能够根据每个数据块对应的特征信息，快速的对多个数据块进行合并，使得合并后得到的目标更加有序。

示例的，在特征信息中包括分块数、数据块对应的业务标识和数据块的序列号时；可以从所有接收到的数据块中筛选业务标识相同的多个数据块；判断业务标识相同的多个数据块的数量是否与分块数相等；若相等，则按照每个数据块的序列号，依次将业务标识相同的多个数据块进行合并，得到目标数据。

可以理解的是，接收节点在统一时刻或者统一时间段内可能会接收到来自多个发送节点发送的属于同一业务的数据块，也可能接收到不同发送节点发送的属于不同业务的数据块。因此，接收节点需要筛选出业务标识相同的多个数据块，并判断业务标识相同的多个数据块的数量是否与分块数相等。示例的，业务标识相同的多个数据块的数量可以通过计数缓存的值确定，其中，若业务标识相同的多个数据块的数量与分块数相等，则说明该业务标识的数据块已全部接收，则可以按照每个数据块的序列号，依次将业务标识相同的多个数据块合并。

在本申请实施例中，通过判断业务标识相同的多个数据块的数量是否与分块数相等，确定同一业务标识的数据块是否已全部接收，并在业务标识相同的多个数据块的数量与分块数相等时，依次将业务标识相同的多个数据块合并，使得合并后得到的目标数据为根据数据块的序列号排列的，即目标数据与发送节点发送的待发送数据的顺序完全一致，从而保证了接收到的数据的准确性。

示例的，每个数据块中还可以包括头部信息，头部信息中包括目标节点的标识信息；因此，在分别对多个数据块进行解析时，可以分别判断每个数据块对应的目标节点的标识信息与接收节点的标识信息是否相同；若相同，则分别对多个数据块进行解析。可以理解的是，目标节点为接收节点。

在本申请实施例中，通过判断每个数据块对应的目标节点的标识信息与接收节点的标识信息是否相同，并在相同时，分别对多个数据块进行解析，可以确定数据块是否属于当前的解说节点，能够避免接收节点对不属于该接收节点的数据块进行解析，使得解析后的数据块中的数据对接收节点接收到的正确数据造成干扰，能够提升接收节点得到的目标数据的准确度。

示例的，头部信息中还可以包括数据块对应的业务标识；在分别对多个数据块进行解析时，可以分别判断每个数据块对应的业务标识是否为预设标识；若为预设标识，则分别对多个数据块进行解析。

可以理解的是，预设标识可以接收节点与发送节点提前确定好的业务标识，也可以为接收节点设置的业务标识，本申请实施例对此不做任何限定。

示例的，多个数据块对应的业务标识可以包含编号，例如，属于同一业务的多个数据块对应的业务标识可以为A业务-1，A业务-2，A业务-3，A业务-4，A业务-5，因此，可以根据多个数据块对应的业务标识确定多个数据块的排列顺序，使得不需要对数据块进行解析即可确定多个数据块的序列号。

在本申请实施例中，仅对数据块对应的业务标识为预设标识的多个数据块进行解析，能够避免接收节点对错误的业务标识的数据块进行解析，即能够避免错误的数据块中的数据对于接收节点得到的目标数据造成影响，并且

由此可见，本申请实施例提供的基于区块链的数据处理方法，通过依次接收发送节点发送的多个数据块，其中，多个数据块中每个数据块内包括的数据的第二数据量不大于区块链中单次传输对应的最大数据量；将多个数据块进行合并，得到目标数据。能够实现数据的有序接收，使得得到的目标数据与发送节点发送的待发送数据完全相同，从而提升了接收节点接收数据的准确性，能够有效的提升合并数据的效率。

为了便于理解本申请实施例提供的基于区块链的数据处理方法，下面，将以数据块为基于区块链的流式数据包为例，对本申请实施例提供的技术方案进行详细的描述。示例的，流式数据包的结构可参见图4所示，图4为本申请实施例提供的一种基于区块链的流式数据包的结构示意图。根据图4所示，该流式数据包可以包括接收节点标识nodeId，其为字符串类型，表示区块链的接收节点标识，大小固定为16字节；业务标识businessId，其为字符串类型，表示业务标识，大小固定为16字节；数据包数量dataBlockCount，即分块数，流式数据包的总数量，其为整数类型，表示流式分块总数，大小固定为4字节；数据包序列号blockSerialNumber，其为整数类型，表示流式分块数据的序列号，大小固定为4字节；流式数据内容dataStream，其为字节数据类型，表示流式数据内容，大小小于区块链单次传输数据量，即上述实施例所述的最大数据量。

示例的，根据图4所述的流式数据包，发送节点对隐私密文数据data进行流式处理并发送。具体的可参见图5所示，图5为本申请实施例提供的一种发送节点对隐私密文数据data进行流式处理并发送的流程示意图。根据图5所示，发送节点对隐私密文数据data进行流式处理并发送可包括下述步骤：

步骤1、获取隐私密文数据data，并确定数据阈值。

流式数据阈值即上述实施例所述的数据包可允许的数据量的最大值。

示例的，假设区块链一次能传输的最大数据量为m，指定流式数据阈值r，r可根据区块链和隐私计算业务的实际情况进行设定。由于流式数据结构中接收节点标识nodeId、业务标识businessId、数据包数量dataBlockCount和数据包序列号blockSerialNumber需要固定占用16+16+4+4＝40字节，因此r需要满足0<r≤m-40。通过数据阈值r可以调节区块链传输的数据量大小，单次输出的数据量越小，则传输次数越多。单次输出的数据量越大，则传输次数越少。例如，可以将r取值为m/2。

步骤2、判断数据data大小是否大于数据阈值，若数据data大小大于数据阈值，则执行步骤3，若数据data大小小于或等于数据阈值，则直接发送数据。

步骤3、将数据data转换为字节流数据bdata。

例如，将一个字符串“c2VsZWN0IHNvdX”通过ASCII码表将每个字符对应其ASCII值，每个ASCII码值为一个0-127直接的数。转为字节流数据bdata为[99，50，86，115，90，87，78，48，73，72，78，118，100，88]，字节流数据bdata的大小I为14。

其中，ASCII码为使用指定的7位二进制数组合来表示128种可能的字符，包括所有的大写和小写字母，数字0到9、标点符号。

步骤4、将字节流数据bdata分为多个流式数据包，确定数据包序列号和每个流式数据包的流式数据内容。

示例的，在将字节流数据bdata分为多个流式数据包时，可以将字节流数据bdata按照数据阈值r进行切分，字节流数据bdata的大小记为I，则切分的流式数据包数量dataBlockCount＝I//r，其中，//代表向上取整的除法，例如3//2＝2，4//2＝2。数据包序列号blockSerialNumber分别为1，2，…,dataBlockCount。流式数据内容dataStream分别为bdata[0，r-1]，bdata[r，2r-1]，…，bdata[(dataBlockCount-1)*r，I-1]。

对于步骤3中的示例，假设数量阈值r的值设定为5，则流式数据包数量dataBlockCount＝I//r＝14//5＝3，数据包序列号blockSerialNumber分别为1，2，3。流式数据内容dataStream分别是bdata[0，4]＝[99，50，86，115，90]，bdata[5，9]＝[87，78，48，73，72]，bdata[10，13]＝[78，118，100，88]。

步骤5、根据数据包序列号和每个流式数据包的流式数据内容，组装多个流式数据包。

示例的，组装如图4所示的多个流式数据包，根据步骤4中的示例，对数据包序列号blockSerialNumber分别为1，2，3；流式数据内容dataStream分别是bdata[0，4]＝[99，50，86，115，90]，bdata[5，9]＝[87，78，48，73，72]，bdata[10，13]＝[78，118，100，88]，的流式数据包，设置接收节点标识nodeId，业务标识businessId，数据包数量dataBlockCount，以及流式数据内容dataStream。其中，接收节点标识nodeId可根据世界级情况进行设置，例如，接收节点标识为node1。业务标识businessId与流式数据data对应的业务相关，例如，业务标识可以为job1。数据包数量dataBlockCount为3。

步骤6、添加流式数据包的头部信息。

示例的，为了使得数据发送的有序性，可以通过主题监听结合数据包序列号blockSerialNumber机制发送数据包。具体的，在发送数据前，发送节点和接收节点均需要设定监听的主题，使得区块链的两节点能够根据特定的主题收发数据data。例如，监听的主题可以为流式数据包的头部信息。监听的主题还可以直接设定传输的数据的形式，即普通数据或流式数据包，本申请实施例对于监听的主题不做具体限定。

在流式数据包添加头部信息时，头部信息可以用一个字符串表示，例如，一个区块链发送节点node1发送的流式数据包头部信息为node2-job1，其中，node2表示接收节点的标识，job1表示任务为job的第一个流式数据包，因此，node2-job1表示发送的数据是给node2，任务为job1的流式数据包。在同一个任务job下的流式数据包，再通过数据包序列号blockSerialNumber区分数据的发送顺序，便于接收方按顺序合并还原数据，使得区块链能够实现双向多轮有序发送数据。

步骤7、发送添加头部信息的流式数据包。

图6为本申请实施例提供的一种接收节点接收流式数据包并合并的流程示意图。根据图6所示，接收节点接收流式数据包并合并可包括以下步骤：

步骤1、接收数据。

步骤2、判断是否接收到流式数据包，若接收到流式数据包，则执行步骤2，若接收到普通数据，则根据区块链原生传输接收数据方式进行处理。

示例的，在判断是否接收到流式数据包时，可以通过设定的监听的主题进行确定，若监听的主题为接收到的数据的形式，即为普通数据还是流式数据包，则可以直接确定，若监听的主题为流式数据包的头部信息，则在存在头部信息时，可以接收到流式数据包。本申请实施例仅以此为例进行说明，但并不代表本申请实施例仅局限于此。

步骤3、对流式数据包进行解析，获取流式数据包信息。

示例的，获得流式数据包streamPacket，并解析获取其中的接收节点标识nodeId，业务标识businessId，数据包数量dataBlockCount，数据包序列号blockSerialNumber和流式数据内容dataStream。

步骤4、设置数据流缓存和计数缓存。

示例的，在设置数据流缓存和技术缓存时，接收节点在本地设置两种缓存，分别为数据流缓存和计数缓存。其中，数据流缓存用于保存流式数据，其键设置为nodeId+businessId+blockSerialNumber，其值设置为dataStream。当数据流缓存设置成功之后，再设置计数缓存，计数缓存的键设为nodeId+businessId，当接收到一个流式数据包时，对应的计数缓存的值自增1，以通过计数缓存确定接收到的流式数据包的数量。

步骤5、判断计数缓存的值是否等于数据包数量，若，等于，则执行步骤6，若不等于，则执行上述步骤1-3。

示例的，在判断计数缓存的值是否等于数据包数量时，可以通过上述步骤3中，对流式数据包进行解析获取的数据包数量，与当前技术缓存的值进行比较，若计数缓存的值等于数据包数量，则表示流式数据包已全部接收完成，若计数缓存的值不等于数据包数量，则表示为还存在未接收的数据包，需要继续接收流式数据包，直至所有流式数据包接收完成。

步骤6、合并流式数据包，得到隐私密文数据data。

示例的，依次遍历查询数据流缓存的键为nodeId+businessId+1，nodeId+businessId+2，…，nodeId+businessId+dataBlockCount的值。将查询到的数据流缓存值按查询顺序依次合并，可以避免流式数据包在发送或接收过程中出现乱序，导致发送和接收的数据不一致的问题。根据上述实施例所述将数据分为多个流式数据包的方法，在将流式数据包合并时，可以按照bdata[0，r-1]，bdata[r，2r-1]，…，bdata[(dataBlockCount-1)*r，l-1]依次存到到一个长度为I的bdata字节数组中，能够保证接收节点接收到的数据与发送节点发送的数据的一致性。

步骤7、删除数据流缓存和计数缓存。

示例的，合并完流式数据包之后，可以删除键为nodeId+businessId的计数缓存和键为nodeId+businessId+blockSerialNumber的数据流缓存。

图7为本申请实施例提供的一种基于区块链的数据处理装置70的结构示意图，示例的，请参见图7所示，该基于区块链的数据处理装置70可以包括：

获取模块701，用于获取待发送数据。

处理模块702，用于根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块，得到多个数据块，其中，多个数据块中每个数据块内包括的数据的第二数据量不大于最大数据量。

发送模块703，用于将多个数据块分次发送给区块链中的接收节点。

可选的，处理模块702，具体用于根据第一数据量和最大数据量，确定分块数；按照分块数，将待发送数据进行分块，得到多个数据块。

可选的，发送模块703，具体用于确定每个数据块对应的特征信息，特征信息中包括分块数、数据块对应的业务标识和数据块的序列号中的至少一个；将特征信息携带在对应的数据块中发送给接收节点。

可选的，特征信息中包括数据块的序列号；发送模块703，具体用于按照多个数据块各自对应的序列号，依次将特征信息携带在对应的数据块中发送给接收节点。

可选的，发送模块703，具体用于分别确定每个数据块的头部信息，头部信息中包括目标节点的标识信息和数据块对应的业务标识；在每个数据块中分别添加对应的头部信息；分次将添加了头部信息的数据块发送给对应的接收节点。

可选的，处理模块702，具体用于判断第一数据量是否大于最大数据量；在第一数据量大于最大数据量时，根据待发送数据的第一数据量和区块链中单次传输对应的最大数据量，将待发送数据进行分块。

本申请实施例提供的基于区块链的数据处理装置，可以执行上述任一实施例中的基于区块链的数据处理方法的技术方案，其实现原理以及有益效果与基于区块链的数据处理方法的实现原理及有益效果类似，可参见基于区块链的数据处理方法的实现原理及有益效果，此处不再进行赘述。

图8为本申请实施例提供的另一种基于区块链的数据处理装置80的结构示意图，示例的，请参见图8所示，该基于区块链的数据处理装置80可以包括：

接收模块801，用于依次接收发送节点发送的多个数据块，其中，多个数据块中每个数据块内包括的数据的第二数据量不大于区块链中单次传输对应的最大数据量。

合并模块802，用于将多个数据块进行合并，得到目标数据。

可选的，合并模块802，具体用于分别对多个数据块进行解析，得到每个数据块对应的特征信息，特征信息中包括分块数、数据块对应的业务标识和数据块的序列号中的至少一个；根据每个数据块对应的特征信息，将多个数据块进行合并，得到目标数据。

可选的，特征信息中包括分块数、数据块对应的业务标识和数据块的序列号；合并模块802，具体用于从所有接收到的数据块中筛选业务标识相同的多个数据块；判断业务标识相同的多个数据块的数量是否与分块数相等；在相等时，按照每个数据块的序列号，依次将业务标识相同的多个数据块进行合并，得到目标数据。

可选的，每个数据块中还包括头部信息，头部信息中包括目标节点的标识信息；合并模块802，具体用于分别判断每个数据块对应的目标节点的标识信息与接收节点的标识信息是否相同；在相同时，分别对多个数据块进行解析。

可选的，头部信息中还包括数据块对应的业务标识；合并模块802，具体用于分别判断每个数据块对应的业务标识是否为预设标识；在为预设标识时，分别对多个数据块进行解析。

本申请实施例提供的基于区块链的数据处理装置，可以执行上述任一实施例中的基于区块链的数据处理方法的技术方案，其实现原理以及有益效果与基于区块链的数据处理方法的实现原理及有益效果类似，可参见基于区块链的数据处理方法的实现原理及有益效果，此处不再进行赘述。

图9为本申请提供的一种电子设备结构示意图。如图9所示，该电子设备900可以包括：至少一个处理器901和存储器902。

存储器902，用于存放程序。具体地，程序可以包括程序代码，程序代码包括计算机操作指令。

存储器902可能包含高速RAM存储器，也可能还包括非易失性存储器(non-volatile memory)，例如至少一个磁盘存储器。

处理器901用于执行存储器902存储的计算机执行指令，以实现前述方法实施例所描述的基于区块链的数据处理方法。其中，处理器901可能是一个中央处理器(CentralProcessing Unit，简称为CPU)，或者是特定集成电路(Application Specific IntegratedCircuit，简称为ASIC)，或者是被配置成实施本申请实施例的一个或多个集成电路。具体的，在实现前述方法实施例所描述的基于区块链的数据处理方法时，该电子设备例如可以是终端、服务器等具有处理功能的电子设备。

可选的，该电子设备900还可以包括通信接口903。在具体实现上，如果通信接口903、存储器902和处理器901独立实现，则通信接口903、存储器902和处理器901可以通过总线相互连接并完成相互间的通信。总线可以是工业标准体系结构(Industry StandardArchitecture，简称为ISA)总线、外部设备互连(Peripheral Component，简称为PCI)总线或扩展工业标准体系结构(Extended Industry Standard Architecture，简称为EISA)总线等。总线可以分为地址总线、数据总线、控制总线等，但并不表示仅有一根总线或一种类型的总线。

可选的，在具体实现上，如果通信接口903、存储器902和处理器901集成在一块芯片上实现，则通信接口903、存储器902和处理器901可以通过内部接口完成通信。

本申请还提供了一种计算机可读存储介质，该计算机可读存储介质可以包括：U盘、移动硬盘、只读存储器(ROM，Read-Only Memory)、随机存取存储器(RAM，Random AccessMemory)、磁盘或者光盘等各种可以存储程序代码的介质，具体的，该计算机可读存储介质中存储有程序指令，程序指令用于上述实施例中的方法。

本申请还提供一种程序产品，该程序产品包括执行指令，该执行指令存储在可读存储介质中。电子设备的至少一个处理器可以从可读存储介质读取该执行指令，至少一个处理器执行该执行指令使得电子设备实施上述的各种实施方式提供的基于区块链的数据处理方法。

最后应说明的是：以上各实施例仅用以说明本申请的技术方案，而非对其限制；尽管参照前述各实施例对本申请进行了详细的说明，本领域的普通技术人员应当理解：其依然可以对前述各实施例所记载的技术方案进行修改，或者对其中部分或者全部技术特征进行等同替换；而这些修改或者替换，并不使相应技术方案的本质脱离本申请各实施例技术方案的范围。

Claims (9)

1.一种基于区块链的数据处理方法，其特征在于，包括：

获取隐私密文数据，并确定每个流式数据包中允许的数据阈值；其中，所述数据阈值小于区块链中单次传输对应的最大数据量与固定参数所占数据量的差值，所述固定参数包括分块数、流式数据包对应的业务标识、流式数据包的序列号和接收节点标识；

当所述隐私密文数据的第一数据量大于所述数据阈值时，将所述隐私密文数据转换为字节流数据，并根据所述第一数据量和所述数据阈值，将所述字节流数据进行分块，得到多个流式数据包，其中，所述多个流式数据包中每个流式数据包内包括的数据的第二数据量不大于所述数据阈值；

分别确定每个所述流式数据包的头部信息，所述头部信息包括所述流式数据包对应的业务标识和目标节点的标识信息；

在每个所述流式数据包中分别添加对应的头部信息；

根据所述流式数据包的序列号，依次将添加了头部信息的多个流式数据包分次发送给所述区块链中的接收节点。

2.根据权利要求1所述的方法，其特征在于，所述根据所述第一数据量和所述数据阈值，将所述字节流数据进行分块，得到多个流式数据包，包括：

根据所述第一数据量和所述数据阈值，确定分块数；

按照所述分块数，将所述字节流数据进行分块，得到多个数据块。

3.一种基于区块链的数据处理方法，其特征在于，应用于接收节点，所述方法包括：

依次接收发送节点根据流式数据包的序列号发送的多个流式数据包，其中，所述多个流式数据包是在隐私密文数据的第一数据量大于所述数据阈值时，根据所述第一数据量和所述数据阈值，将所述隐私密文数据转换得到的字节流数据进行分块并添加头部信息后得到的，所述多个流式数据包中每个流式数据包内包括的数据的第二数据量不大于所述数据阈值，所述述数据阈值小于区块链中单次传输对应的最大数据量与固定参数所占数据量的差值，所述固定参数包括分块数、数据块对应的业务标识、数据块的序列号和接收节点标识；所述头部信息包括所述流式数据包对应的业务标识和目标节点的标识信息；

分别对所述多个流式数据包进行解析，得到每个流式数据包对应的头部信息；

根据所述头部信息，从所有接收到的流式数据包中筛选业务标识相同的多个流式数据包；并判断所述业务标识相同的多个流式数据包的数量是否与所述头部信息中的分块数相等；

若相等，则按照每个流式数据包的序列号，依次将所述业务标识相同的多个流式数据包进行合并，得到隐私密文数据。

4.根据权利要求3所述的方法，其特征在于，

所述分别对所述多个流式数据包进行解析，包括：

分别判断所述每个流式数据包对应的所述目标节点的标识信息与所述接收节点的标识信息是否相同；

若相同，则分别对所述多个流式数据包进行解析。

5.根据权利要求4所述的方法，其特征在于，

所述分别对所述多个流式数据包进行解析，包括：

分别判断所述每个流式数据包对应的业务标识是否为预设标识；

若为所述预设标识，则分别对所述多个流式数据包进行解析。

6.一种基于区块链的数据处理装置，其特征在于，包括：

获取模块，用于获取隐私密文数据，并确定每个流式数据包中允许的数据阈值；其中，所述数据阈值小于区块链中单次传输对应的最大数据量与固定参数所占数据量的差值，所述固定参数包括分块数、流式数据包对应的业务标识、流式数据包的序列号和接收节点标识；

处理模块，用于当所述隐私密文数据的第一数据量大于所述数据阈值时，将所述隐私密文数据转换为字节流数据，并根据所述第一数据量和所述数据阈值，将所述字节流数据进行分块，得到多个流式数据包，其中，所述多个流式数据包中每个流式数据包内包括的数据的第二数据量不大于所述数据阈值；

发送模块，用于分别确定每个所述流式数据包的头部信息，所述头部信息包括所述流式数据包对应的业务标识和目标节点的标识信息；在每个所述流式数据包中分别添加对应的头部信息；根据所述流式数据包的序列号，依次将添加了头部信息的多个流式数据包分次发送给所述区块链中的接收节点。

7.一种基于区块链的数据处理装置，其特征在于，包括：

接收模块，用于依次接收发送节点根据流式数据包的序列号发送的多个流式数据包，其中，所述多个流式数据包是在隐私密文数据的第一数据量大于所述数据阈值时，根据所述第一数据量和所述数据阈值，将所述隐私密文数据转换得到的字节流数据进行分块并添加头部信息后得到的，所述多个流式数据包中每个流式数据包内包括的数据的第二数据量不大于所述数据阈值，所述述数据阈值小于区块链中单次传输对应的最大数据量与固定参数所占数据量的差值，所述固定参数包括分块数、流式数据包对应的业务标识、流式数据包的序列号和接收节点标识；所述头部信息包括所述流式数据包对应的业务标识和目标节点的标识信息；

合并模块，用于分别对所述多个流式数据包进行解析，得到每个流式数据包对应的头部信息；根据所述头部信息，从所有接收到的流式数据包中筛选业务标识相同的多个流式数据包；并判断所述业务标识相同的多个流式数据包的数量是否与所述头部信息中的分块数相等；若相等，则按照每个流式数据包的序列号，依次将所述业务标识相同的多个流式数据包进行合并，得到隐私密文数据。

8.一种电子设备，包括：处理器，以及与所述处理器通信连接的存储器；

所述存储器存储计算机执行指令；

所述处理器执行所述存储器存储的计算机执行指令，以实现如权利要求1-5中任一项所述的方法。

9.一种计算机可读存储介质，其特征在于，所述计算机可读存储介质中存储有计算机执行指令，所述计算机执行指令被处理器执行时用于实现如权利要求1-5中任一项所述的方法。