CN110381116A - 信息同步系统和信息同步方法 - Google Patents
信息同步系统和信息同步方法 Download PDFInfo
- Publication number
- CN110381116A CN110381116A CN201910532830.1A CN201910532830A CN110381116A CN 110381116 A CN110381116 A CN 110381116A CN 201910532830 A CN201910532830 A CN 201910532830A CN 110381116 A CN110381116 A CN 110381116A
- Authority
- CN
- China
- Prior art keywords
- node
- information data
- block chain
- target service
- synchronization
- 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
Links
- 238000000034 method Methods 0.000 title claims abstract description 29
- 230000001360 synchronised effect Effects 0.000 claims abstract description 38
- 238000012216 screening Methods 0.000 claims abstract description 35
- 238000004891 communication Methods 0.000 claims abstract description 17
- 238000012856 packing Methods 0.000 claims description 10
- 238000005516 engineering process Methods 0.000 description 8
- 238000010586 diagram Methods 0.000 description 4
- 238000012986 modification Methods 0.000 description 4
- 230000004048 modification Effects 0.000 description 4
- 230000008901 benefit Effects 0.000 description 2
- 230000008859 change Effects 0.000 description 2
- 238000010276 construction Methods 0.000 description 2
- 230000000694 effects Effects 0.000 description 2
- 230000006870 function Effects 0.000 description 2
- 238000012544 monitoring process Methods 0.000 description 2
- 230000008569 process Effects 0.000 description 2
- 241001269238 Data Species 0.000 description 1
- 238000012217 deletion Methods 0.000 description 1
- 230000037430 deletion Effects 0.000 description 1
- 238000000151 deposition Methods 0.000 description 1
- 238000001514 detection method Methods 0.000 description 1
- 238000012545 processing Methods 0.000 description 1
- 238000007873 sieving Methods 0.000 description 1
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
- H04L67/1095—Replication or mirroring of data, e.g. scheduling or transport for data synchronisation between network nodes
Landscapes
- Engineering & Computer Science (AREA)
- Computer Networks & Wireless Communication (AREA)
- Signal Processing (AREA)
- Information Transfer Between Computers (AREA)
- Information Retrieval, Db Structures And Fs Structures Therefor (AREA)
Abstract
本发明提供一种信息同步系统和信息同步方法,所述系统包括区块链节点模块以及、通讯模块、节点筛选模块和信息同步模块;区块链节点模块包括多个业务信息关联的服务器,每个服务器作为信息同步系统的区块链节点;通讯模块用于接收区块链节点模块中区块链节点上传的业务信息数据,并将业务信息数据打包放入系统的区块链;业务信息数据包括目标业务信息数据;节点筛选模块用于根据目标业务信息数据从区块链节点模块的区块链节点中筛选出同步节点;信息同步模块用于将区块链中的所述目标业务信息数据同步到节点筛选模块的各个同步节点中。上述系统同步企业各个部门的业务信息,无需单独给关联部门同步业务信息,提高企业内部业务信息推送效率。
Description
技术领域
本发明涉及区块链技术领域,具体而言,本发明涉及一种信息同步系统和信息同步方法。
背景技术
企业内部部门众多,各个部门之间跨部门间的沟通及跨部门间的资源协调,成本太高。另外,各部门所掌握的信息不对称,某项业务或企业内部产品在各部分进行推送时,需要分别给关联部门同步业务信息及协调资源,工作效率不高。
发明内容
本发明提出一种信息同步系统和信息同步方法,以同步企业相关部门的业务信息数据,无需单独一一给关联部门同步业务信息,提高了企业内部业务信息推送的效率。
本发明提供以下方案:
一种信息同步系统,包括区块链节点模块以及、通讯模块、节点筛选模块和信息同步模块;所述区块链节点模块包括多个业务信息关联的服务器,每个服务器作为信息同步系统的区块链节点;所述通讯模块,用于接收所述区块链节点模块中所述区块链节点上传的业务信息数据,并将所述业务信息数据打包放入系统的区块链;其中,所述业务信息数据包括目标业务信息数据;所述节点筛选模块,用于根据所述目标业务信息数据从所述区块链节点模块的区块链节点中筛选出同步节点;所述信息同步模块,用于将所述区块链中的所述目标业务信息数据同步到所述节点筛选模块的各个所述同步节点中。
在其中一个实施例中,还包括节点更新模块;所述节点更新模块用于在确定所述目标业务信息数据进行更新时,根据更新后的目标业务信息数据对所述节点筛选模块中所述同步节点进行调整,以使调整后的所述节点筛选模块中的同步节点与所述更新后的所述目标业务信息数据匹配。
在其中一个实施例中,所述节点筛选模块中,每个所述同步节点还用于在接收到所述信息同步模块同步的目标业务信息数据时,将所述目标业务信息数据广播到相邻的同步节点。
在其中一个实施例中,所述节点筛选模块中,每个所述同步节点还用于从其他同步节点中拉取所述目标业务信息数据。
在其中一个实施例中,所述目标业务信息数据包括与目标业务信息相关的数据以及目标业务信息的资源信息数据;所述每个同步节点还用于根据所述与目标业务信息相关的数据从其他同步节点中拉取所述目标业务信息的资源信息数据。
在其中一个实施例中,还包括业务信息验证模块;所述业务信息验证模块用于对所述区块链节点模块中所述区块链节点上传的所述业务信息数据的完整性进行验证,并在所述区块链节点上传的所述业务信息数据不完整时,对不完整的业务信息数据进行标识,将标识后的业务信息数据放入所述区块链中。
一种信息同步方法,包括以下步骤:获取多个业务信息关联的服务器,将每个所述服务器作为区块链节点,根据多个所述区块链节点得到信息同步系统;所述信息同步系统获取每个所述区块链节点上传的业务信息数据,将所述业务信息数据打包放入系统的区块链;其中,所述业务信息数据包括目标业务信息数据;根据所述目标业务信息数据从多个所述区块链节点中筛选出同步节点;将所述区块链中的所述目标业务信息数据同步到各个所述同步节点中。
在其中一个实施例中,所述将所述区块链中的所述目标业务信息数据同步到各个所述同步节点之后,还包括:确定所述目标业务信息数据进行更新时,根据更新后的目标业务信息数据对所述同步节点进行调整,以使调整后的同步节点与所述更新后的所述目标业务信息数据匹配。
在其中一个实施例中,所述目标业务信息数据包括多个业务类别的信息数据;所述将所述区块链中的所述目标业务信息数据同步到各个所述同步节点之后,还包括:任一所述同步节点接收到所述目标业务信息数据时,记录所述目标业务信息数据,并将所述目标业务信息数据广播到相邻同步节点;汇总预置时间段内的目标业务信息数据,对汇总后的目标业务信息数据中所述多个业务类别的信息数据进行分析,得到所述信息同步系统的各业务类别的百分占比,将所述各业务类别的百分占比打包放入所述区块链中。
在其中一个实施例中,所述方法还包括:所述信息同步系统对所述区块链节点上传的所述业务信息数据的完整性进行验证,并在所述区块链节点上传的所述业务信息数据不完整时,对不完整的业务信息数据进行标识,将标识后的业务信息数据放入所述区块链中。
上述实施例提供的信息同步系统,将多个业务信息关联的服务器分别作为区块链节点,构造基于区块链技术的信息同步系统。系统中每个服务器作为区块链节点,将业务信息数据上传到系统,通讯模块将上传的业务信息数据进行打包后放入系统的区块链。系统可从区块链中筛选出目标业务信息数据,节点筛选模块根据该目标业务信息数据从区块链模块中筛选出需要同步信息的区块链节点作为同步节点。最终由信息同步模块将该目标业务信息数据同步到各个同步节点中。因此,通过该系统可将与目标业务信息数据相关的企业相关部门的服务器作为系统的同步节点,并由系统将目标业务信息数据同步相关的企业相关部门的服务器,无需企业员工单独一一给关联部门同步目标业务信息,提高了企业内部业务信息推送的效率。
上述实施例提供的信息同步方法,将多个业务信息关联的服务器作为区块链节点,基于区块链技术构造出信息同步系统。每个区块链节点将业务信息数据上传到信息同步系统,系统将业务信息数据打包放入系统区块链中。进一步地,从区块链中筛选出目标业务信息数据,根据该目标业务信息数据筛选出需要同步信息的区块链节点作为同步节点。最终将该目标业务信息数据同步到各个同步节点中。因此,上述方法可将与目标业务信息数据相关的企业相关部门的服务器作为系统的同步节点,并由系统将目标业务信息数据同步相关的企业相关部门的服务器,无需企业员工单独一一给关联部门同步目标业务信息,提高了企业内部业务信息推送的效率。
本发明附加的方面和优点将在下面的描述中部分给出,这些将从下面的描述中变得明显,或通过本发明的实践了解到。
附图说明
本发明上述的和/或附加的方面和优点从下面结合附图对实施例的描述中将变得明显和容易理解,其中:
图1为本发明提供的一种信息同步系统的结构示意图;
图2为本发明提供的一种信息同步方法的一实施例中的方法流程图;
图3为本发明提供的一种信息同步方法的另一实施例中的方法流程图;
图4为本发明提供的一种信息同步方法的又一实施例中的方法流程图。
具体实施方式
下面详细描述本发明的实施例,所述实施例的示例在附图中示出,其中自始至终相同或类似的标号表示相同或类似的元件或具有相同或类似功能的元件。下面通过参考附图描述的实施例是示例性的,仅用于解释本发明,而不能解释为对本发明的限制。
本技术领域技术人员可以理解,除非特意声明,这里使用的单数形式“一”、“一个”、“所述”和“该”也可包括复数形式,这里使用的“第一”、“第二”仅用于区别同一技术特征,并不对该技术特征的顺序和数量等加以限定。应该进一步理解的是,本发明的说明书中使用的措辞“包括”是指存在所述特征、整数、步骤、操作、元件和/或组件,但是并不排除存在或添加一个或多个其他特征、整数、步骤、操作、元件、组件和/或它们的组。
本技术领域技术人员可以理解,除非另外定义,这里使用的所有术语(包括技术术语和科学术语),具有与本发明所属领域中的普通技术人员的一般理解相同的意义。还应该理解的是,诸如通用字典中定义的那些术语,应该被理解为具有与现有技术的上下文中的意义一致的意义,并且除非像这里一样被特定定义,否则不会用理想化或过于正式的含义来解释。
本发明提供一种信息同步系统,将各个业务关联的部门的服务器作为系统的区块链节点,通过区块链技术将各个部门的业务信息进行同步推广,提高企业内部业务信息推送的效率。
在一实施例中,如图1所示,该信息同步系统包括区块链节点模块100、通讯模块200、节点筛选模块300和信息同步模块400。区块链节点模块100包括多个业务信息关联的服务器,每个服务器作为信息同步系统的区块链节点110。每个服务器基于区块链技术设置数据块,将该数据块包括块头和块体。区块头由区块元数据组成,包括引用父区块哈希值的数据,时间戳和merkle树根等。引用父区块哈希值的数据用于将该服务器与区块链中前一服务器相连接。时间戳则是与该服务器挖矿竞争成为区块链节点相关。merkle树根则是用于有效地总结服务器作为区块链节点时所有交易的数据结构。数据块中的块体,则是用于装载该数据库的所有事务。例如,将本服务器上的业务信息数据打包成数据包,该数据包用于上传到系统的区块链10中。此外,每个服务器还可对本服务器从区块链10中下载的业务信息数据进行记录并存储等。
在一实施例中,区块链节点110还用于广播业务信息数据、接收广播业务信息数据以及存储业务信息数据。具体地,区块链节点110将本节点的业务信息数据打包上传到系统之后,将业务信息数据进行广播。或者,在接收到系统广播的业务信息数据,并将业务信息数据进行存储。
在该实施例的一个实施方式中,区块链节点模块100中,每个区块链节点110还用于在接收到系统广播的业务信息数据时,将业务信息数据广播到相邻区块链节点110。具体地,业务推动者通过区块链节点110将业务信息数据提交至系统,系统存储后将业务信息数据广播至系统中各个区块链节点110,接收到业务信息数据的区块链节点110将业务信息数据记录下来,并主动给邻近区块链节点110进行广播,因此可做到业务信息数据的最快、范围最大的传播。
在该实施例的一个实施方式中,区块链节点模块100中,每个区块链节点110还用于从其他区块链节点110中拉取业务信息数据。具体地,区块链节点110除了可以向邻近的区块链节点110广播接收到的业务信息数据之外,还可通过主动向其他区块链节点110拉取所述业务信息数据。
通讯模块200用于接收区块链节点模块100中,区块链节点110上传的业务信息数据,并将业务信息数据打包放入系统区块链300后,广播至区块链节点模块100的各个区块链节点110。在一实施例中,通讯模块200还用于将业务信息数据打包放入区块链300后,向区块链节点模块100的各个区块链节点实时广播新的区块入链的通知。
其中,区块链节点110上传的业务信息数据包括目标业务信息数据。系统根据目标业务信息数据,可从区块链模块100中筛选出需要进行信息同步的区块链节点。例如,根据多个业务信息关联的服务器得到的信息同步系统,包括区块链节点A(服务器A)、区块链节点B(服务器B)、区块链节点C(服务器C)、区块链节点D(服务器D)、区块链节点E(服务器E)和区块链节点F(服务器F)。区块链节点A、区块链节点B、区块链节点C、区块链节点D、区块链节点E和区块链节点F分别将本节点的业务信息数据上传到系统的区块链中。系统需要根据区块链中的业务信息数据,筛选出需要进行信息同步的业务信息数据,即目标业务信息数据。根据该目标业务信息数据可确定出区块链模块100中需要进行信息同步的区块链节点作为信息同步对象。也即是,信息同步对象为区块链模块100中的一个或多个区块链节点。
节点筛选模块300用于根据所述目标业务信息数据从所述区块链节点模块100的区块链节点中筛选出同步节点。在具体的实施方式中,节点筛选模块300从系统的区块链10中读取出目标业务信息数据,根据目标业务信息数据确定出目标业务的特点。将目标业务的特点与区块链模块100中各个区块链节点标识的业务进行匹配,根据匹配结果筛选出需进行信息同步的区块链节点作为所述同步节点。
信息同步模块400用于将区块链10中的目标业务信息数据同步到节点筛选模块300的各个所述同步节点中。具体地,节点筛选模块300从区块链节点模块100中筛选出同步节点之后,信息同步模块400从区块链10中读取目标业务信息数据,将目标业务信息数据同步到节点筛选模块300筛选出的各个所述同步节点中。同步的方式可以是,通过区块链10将目标业务信息数据下发到各个同步节点中。或者,将目标业务信息数据对应的下载链接下发到各个同步节点中,以便同步节点触发下载链接时从区块链10中下载目标业务信息数据。
在一实施例中,所述节点筛选模块300中,每个所述同步节点还用于在接收到所述信息同步模块400同步的目标业务信息数据时,将所述目标业务信息数据广播到相邻的同步节点。具体地,当同步节点接收到目标业务信息数据时,可直接将目标业务信息数据广播到相邻同步节点,以便相邻同步节点能够快速获得目标业务信息数据。
此外,所述节点筛选模块300中,每个所述同步节点还用于从其他同步节点中拉取所述目标业务信息数据。具体地,同步节点除了可以给相邻同步节点广播目标业务信息数据之外,还可主动从相邻同步节点中拉取目标业务信息数据。因此,可使得系统在进行信息同步时,各个同步节点能够快速获得系统同步的目标业务信息数据。
进一步地,所述目标业务信息数据包括与目标业务信息相关的数据以及目标业务信息的资源信息数据;所述每个同步节点还用于根据所述与目标业务信息相关的数据从其他同步节点中拉取所述目标业务信息的资源信息数据。具体地,上传所述目标业务信息数据的区块链节点,假设为第一区块链节点,将与目标业务信息相关的数据以及目标业务信息的资源信息数据打包放入系统区块链10之后,节点筛选模块300筛选出向其他同步节点,假设为第二区块链节点,广播所述与目标业务信息相关的数据以及目标业务信息的资源信息数据的通知。第二区块链节点中,某一同步节点从区块链10中拉取了所述与目标业务信息相关的数据以及目标业务信息的资源信息数据。第二区块链节点中,其他同步节点内包含有所述与目标业务信息相关的数据,但缺少所述目标业务信息的资源信息数据。此时,其他同步节点可根据本节点的所述与目标业务信息相关的数据向该某一同步节点拉取所述目标业务信息的资源信息数据,无需重复拉取所述与目标业务信息相关的数据即可达到业务信息数据的同步,减少了节点服务器的任务量,同时也可保证到业务信息数据的完整性推送。
在一实施中,系统还包括节点更新模块。所述节点更新模块用于在确定所述目标业务信息数据进行更新时,根据更新后的目标业务信息数据对所述节点筛选模块300中所述同步节点进行调整,以使调整后的所述节点筛选模块中的同步节点与所述更新后的所述目标业务信息数据匹配。
具体地,节点更新模块实时监控区块链10中目标业务信息数据是否存在更新。若存在更新,系统根据更新后的目标业务信息数据进行信息同步的对象将发生改变。节点筛选模块300中筛选出的有些区块链节点无需获知更新后的目标业务信息数据。节点筛选模块300未筛选到的有些区块链节点则需要获知更新后的目标业务信息数据。此时,将节点更新模块根据更新后的目标业务信息数据对节点筛选模块300中的同步节点进行调整。调整的方式可以是,将节点筛选模块300中与所述更新后的目标业务信息数据不匹配的同步节点删除。或者,从区块链模块100中不属于所述同步节点的且与所述更新后的目标业务信息数据匹配的区块链节点加入到节点筛选模块300筛选的同步节点中。因此,可使调整后的所述节点筛选模块300中的同步节点与所述更新后的所述目标业务信息数据匹配。
在一实施例中,系统还包括业务信息验证模块。业务信息验证模块用于对区块链节点模块100中所述区块链节点上传的所述业务信息数据的完整性进行验证,并在所述区块链节点上传的所述业务信息数据不完整时,对不完整的业务信息数据进行标识,将标识后的业务信息数据放入所述区块链10中。
具体地,区块链节点模块100的区块链节点,在上传业务信息数据时,可能存在系统故障,导致上传的业务信息数据不完整。当业务信息验证模块检测到区块链节点上传的业务信息数据不完整时,对该业务信息数据进行标识,以便在后续的信息同步时,对同步到该业务信息数据的区块链节点进行业务信息数据的不完整性提醒。
上述实施例提供的信息同步系统,将多个业务信息关联的服务器分别作为区块链节点,构造基于区块链技术的信息同步系统。系统中每个服务器作为区块链节点,将业务信息数据上传到系统,通讯模块将上传的业务信息数据进行打包后放入系统的区块链。系统可从区块链中筛选出目标业务信息数据,节点筛选模块根据该目标业务信息数据从区块链模块中筛选出需要同步信息的区块链节点作为同步节点。最终由信息同步模块将该目标业务信息数据同步到各个同步节点中。因此,通过该系统可将与目标业务信息数据相关的企业相关部门的服务器作为系统的同步节点,并由系统将目标业务信息数据同步相关的企业相关部门的服务器,无需企业员工单独一一给关联部门同步目标业务信息,提高了企业内部业务信息推送的效率。
本发明还提供一种信息同步方法。在一实施例中,如图2所示,该信息同步方法,包括以下步骤:
S100,获取多个业务信息关联的服务器,将每个所述服务器作为区块链节点,根据多个所述区块链节点得到信息同步系统。
在本实施例中,多个业务信息关联的服务器,每个服务器作为信息同步系统的区块链节点,得到包含多个所述区块链节点的信息同步系统。每个服务器基于区块链技术设置数据块,将该数据块包括块头和块体。区块头由区块元数据组成,包括引用父区块哈希值的数据,时间戳和merkle树根等。引用父区块哈希值的数据用于将该服务器与区块链中前一服务器相连接。时间戳则是与该服务器挖矿竞争成为区块链节点相关。merkle树根则是用于有效地总结服务器作为区块链节点时所有交易的数据结构。数据块中的块体,则是用于装载该数据库的所有事务。例如,将本服务器上的业务信息数据打包成数据包,该数据包用于上传到系统的区块链10中。此外,每个服务器还可对本服务器从区块链10中下载的业务信息数据进行记录并存储等。
S200,所述信息同步系统获取每个所述区块链节点上传的业务信息数据,将所述业务信息数据打包放入系统的区块链;其中,所述业务信息数据包括目标业务信息数据。
在本实施例中,信息同步系统接收区块链节点上传的业务信息数据,并将业务信息数据打包放入系统的区块链后,广播至各个区块链节点。其中,区块链节点上传的业务信息数据包括目标业务信息数据。系统根据目标业务信息数据,可从区块链模块100中筛选出需要进行信息同步的区块链节点。例如,根据多个业务信息关联的服务器得到的信息同步系统,包括区块链节点A(服务器A)、区块链节点B(服务器B)、区块链节点C(服务器C)、区块链节点D(服务器D)、区块链节点E(服务器E)和区块链节点F(服务器F)。区块链节点A、区块链节点B、区块链节点C、区块链节点D、区块链节点E和区块链节点F分别将本节点的业务信息数据上传到系统的区块链中。系统需要根据区块链中的业务信息数据,筛选出需要进行信息同步的业务信息数据,即目标业务信息数据。根据该目标业务信息数据可确定出需要进行信息同步的区块链节点作为信息同步对象。
S300,根据所述目标业务信息数据从多个所述区块链节点中筛选出同步节点。
在本实施例中,系统根据所述目标业务信息数据从区块链节点中筛选出同步节点。在具体的实施方式中,从系统的区块链中读取出目标业务信息数据,根据目标业务信息数据确定出目标业务的特点。将目标业务的特点与各个区块链节点标识的业务进行匹配,根据匹配结果筛选出需进行信息同步的区块链节点作为所述同步节点。
S400,将所述区块链中的所述目标业务信息数据同步到各个所述同步节点中。
在本实施例中,系统筛选出同步节点之后,从区块链中读取目标业务信息数据,将目标业务信息数据同步到筛选出的各个所述同步节点中。同步的方式可以是,通过区块链将目标业务信息数据下发到各个同步节点中。或者,将目标业务信息数据对应的下载链接下发到各个同步节点中,以便同步节点触发下载链接时从区块链中下载目标业务信息数据。
上述实施例提供的信息同步方法,将多个业务信息关联的服务器作为区块链节点,基于区块链技术构造出信息同步系统。每个区块链节点将业务信息数据上传到信息同步系统,系统将业务信息数据打包放入系统区块链中。进一步地,从区块链中筛选出目标业务信息数据,根据该目标业务信息数据筛选出需要同步信息的区块链节点作为同步节点。最终将该目标业务信息数据同步到各个同步节点中。因此,上述方法可将与目标业务信息数据相关的企业相关部门的服务器作为系统的同步节点,并由系统将目标业务信息数据同步相关的企业相关部门的服务器,无需企业员工单独一一给关联部门同步目标业务信息,提高了企业内部业务信息推送的效率。
在一实施例中,如图3所示,步骤S400之后,还包括:
S500,确定所述目标业务信息数据进行更新时,根据更新后的目标业务信息数据对所述同步节点进行调整,以使调整后的同步节点与所述更新后的所述目标业务信息数据匹配。
在该实施例中,系统实时监控区块链中目标业务信息数据是否存在更新。若存在更新,系统根据更新后的目标业务信息数据进行信息同步的对象将发生改变。系统之前筛选出的有些区块链节点无需获知更新后的目标业务信息数据。系统之前未筛选到的有些区块链节点则需要获知更新后的目标业务信息数据。此时,根据更新后的目标业务信息数据对同步节点进行调整。调整的方式可以是,将与所述更新后的目标业务信息数据不匹配的同步节点删除。或者,将不属于所述同步节点的且与所述更新后的目标业务信息数据匹配的区块链节点加入到同步节点中。因此,可使调整后的同步节点与所述更新后的所述目标业务信息数据匹配。
在一实施例中,所述目标业务信息数据包括多个业务类别的信息数据。如图4所示,步骤S400之后,还包括:
S600,任一所述同步节点接收到所述目标业务信息数据时,记录所述目标业务信息数据,并将所述目标业务信息数据广播到相邻同步节点。
S700,汇总预置时间段内的目标业务信息数据,对汇总后的目标业务信息数据中所述多个业务类别的信息数据进行分析,得到所述信息同步系统的各业务类别的百分占比,将所述各业务类别的百分占比打包放入所述区块链中。
在该实施例中,业务推动者通过区块链节点将目标业务信息数据提交至系统,系统存储后将目标业务信息数据广播至各个同步节点。同步节点接收到目标业务信息数据时将目标业务信息数据记录下来,并主动给邻近同步节点进行广播,因此可做到目标业务信息数据的最快、范围最大的传播。
进一步地,目标业务信息数据包括多个业务类别的信息数据。系统中的任一同步节点能够从系统区块链中获得目标业务信息数据时,分析目标业务信息数据中不同业务类别的信息数据,从而可统计出每个业务类别在系统总体业务中的百分占比,根据该百分占比确定系统的整体业务情况。同时,任一同步节点均可将统计得到的各业务类别的百分占比打包后放入系统的区块链,以便其他区块链节点(同步节点或非同步节点)可以直接从区块链中读取各业务类别的百分占比,减少其他区块链节点对于多个业务类别的信息数据的分析操作。此处,利用系统中区块链节点信息的不可篡改性,使得得到的各业务类别的百分占比准确度高,有利于分析系统中业务的趋向方向,避免了现有技术的系统信息有可能被篡改而可能导业务类别百分比的误查。
在该实施例的一个实施方式中,步骤S600之后,还包括:任一所述同步节点未接收到所述目标业务信息数据时,从其他同步节点中拉取所述目标业务信息数据。
在该实施方式中,同步节点除了可以向邻近的同步节点广播接收到的目标业务信息数据之外,还可通过主动向其他同步节点拉取所述目标业务信息数据。在该实施方式中,任一所述同步节点未接收到所述目标业务信息数据时,确认预置通信距离范围内的多个其他同步节点,从所述多个其他同步节点中筛选出包含有所述目标业务信息数据的同步节点,得到待选择同步节点;从所述待选择同步节点中获取离本同步节点通信距离最近的同步节点,从该同步节点中拉取所述目标业务信息数据。
具体地,任一所述同步节点在接收到所述信息同步系统的广播信息后,预置时间内若未接收到所述目标业务信息数据,则触发从其他同步节点中拉取所述目标业务信息数据。拉取的方式具体为:确定距离本同步节点预置通信距离范围内的多个其他同步节点,进一步识别该多个其他同步节点中包含有所述目标业务信息数据的同步节点,得到待选择同步节点。在该待选择同步节点中选择通信距离最近的同步节点作为拉取所述目标业务信息数据的目标对象。因此,可避免该任一同步节点按照距离本节点通信距离从近到远逐个筛选出包含所述目标业务信息数据时,导致的节点服务器的资源浪费。同时还可提高该任一同步节点拉取所述目标业务信息数据时的效率。
在一实施例中,所述方法还包括:所述信息同步系统对所述区块链节点上传的所述业务信息数据的完整性进行验证,并在所述区块链节点上传的所述业务信息数据不完整时,对不完整的业务信息数据进行标识,将标识后的业务信息数据放入所述区块链中。
在该实施例中,区块链节点在上传业务信息数据时,可能存在系统故障,导致上传的业务信息数据不完整。当系统检测到区块链节点上传的业务信息数据不完整时,对该业务信息数据进行标识,以便在后续的信息同步时,对同步到该业务信息数据的区块链节点进行业务信息数据的不完整性提醒。
综上,在具体的实施过程中,使用区块链技术打造一个内部信息同步系统。将所有部门作为单个区块链节点注册进信息同步系统。业务推动者持续将业务信息数据及所需资源信息提交至信息同步系统,系统将业务信息数据打包入链后广播至所有区块链节点,所有参与的区块链节点将会实时的收到新的区块入链通知。因此,打通各个部门的信息孤岛,解决信息不对称问题,也可以保证信息不可被随意篡改。
以上所述仅是本发明的部分实施方式,应当指出,对于本技术领域的普通技术人员来说,在不脱离本发明原理的前提下,还可以做出若干改进和润饰,这些改进和润饰也应视为本发明的保护范围。
应该理解的是,在本发明各实施例中的各功能单元可集成在一个处理模块中,也可以各个单元单独物理存在,也可以两个或两个以上单元集成于一个模块中。上述集成的模块既可以采用硬件的形式实现,也可以采用软件功能模块的形式实现。
以上所述仅是本发明的部分实施方式,应当指出,对于本技术领域的普通技术人员来说,在不脱离本发明原理的前提下,还可以做出若干改进和润饰,这些改进和润饰也应视为本发明的保护范围。
Claims (10)
1.一种信息同步系统,其特征在于,包括区块链节点模块、通讯模块、节点筛选模块和信息同步模块;
所述区块链节点模块包括多个业务信息关联的服务器,每个服务器作为信息同步系统的区块链节点;
所述通讯模块,用于接收所述区块链节点模块中所述区块链节点上传的业务信息数据,并将所述业务信息数据打包放入系统的区块链;其中,所述业务信息数据包括目标业务信息数据;
所述节点筛选模块,用于根据所述目标业务信息数据从所述区块链节点模块的区块链节点中筛选出同步节点;
所述信息同步模块,用于将所述区块链中的所述目标业务信息数据同步到所述节点筛选模块的各个所述同步节点中。
2.根据权利要求1所述的系统,其特征在于,还包括节点更新模块;所述节点更新模块用于在确定所述目标业务信息数据进行更新时,根据更新后的目标业务信息数据对所述节点筛选模块中所述同步节点进行调整,以使调整后的所述节点筛选模块中的同步节点与所述更新后的所述目标业务信息数据匹配。
3.根据权利要求1所述的系统,其特征在于,所述节点筛选模块中,每个所述同步节点还用于在接收到所述信息同步模块同步的目标业务信息数据时,将所述目标业务信息数据广播到相邻的同步节点。
4.根据权利要求3所述的系统,其特征在于,所述节点筛选模块中,每个所述同步节点还用于从其他同步节点中拉取所述目标业务信息数据。
5.根据权利要求4所述的系统,其特征在于,所述目标业务信息数据包括与目标业务信息相关的数据以及目标业务信息的资源信息数据;所述每个同步节点还用于根据所述与目标业务信息相关的数据从其他同步节点中拉取所述目标业务信息的资源信息数据。
6.根据权利要求1所述的信息同步系统,其特征在于,还包括业务信息验证模块;所述业务信息验证模块用于对所述区块链节点模块中所述区块链节点上传的所述业务信息数据的完整性进行验证,并在所述区块链节点上传的所述业务信息数据不完整时,对不完整的业务信息数据进行标识,将标识后的业务信息数据放入所述区块链中。
7.一种信息同步方法,其特征在于,包括以下步骤:
获取多个业务信息关联的服务器,将每个所述服务器作为区块链节点,根据多个所述区块链节点得到信息同步系统;
所述信息同步系统获取每个所述区块链节点上传的业务信息数据,将所述业务信息数据打包放入系统的区块链;其中,所述业务信息数据包括目标业务信息数据;
根据所述目标业务信息数据从多个所述区块链节点中筛选出同步节点;
将所述区块链中的所述目标业务信息数据同步到各个所述同步节点中。
8.根据权利要求7所述的方法,其特征在于,所述将所述区块链中的所述目标业务信息数据同步到各个所述同步节点之后,还包括:
确定所述目标业务信息数据进行更新时,根据更新后的目标业务信息数据对所述同步节点进行调整,以使调整后的同步节点与所述更新后的所述目标业务信息数据匹配。
9.根据权利要求7所述的方法,其特征在于,所述目标业务信息数据包括多个业务类别的信息数据;所述将所述区块链中的所述目标业务信息数据同步到各个所述同步节点之后,还包括:
任一所述同步节点接收到所述目标业务信息数据时,记录所述目标业务信息数据,并将所述目标业务信息数据广播到相邻同步节点;
汇总预置时间段内的目标业务信息数据,对汇总后的目标业务信息数据中所述多个业务类别的信息数据进行分析,得到所述信息同步系统的各业务类别的百分占比,将所述各业务类别的百分占比打包放入所述区块链中。
10.根据权利要求7所述的方法,其特征在于,所述方法还包括:
所述信息同步系统对所述区块链节点上传的所述业务信息数据的完整性进行验证,并在所述区块链节点上传的所述业务信息数据不完整时,对不完整的业务信息数据进行标识,将标识后的业务信息数据放入所述区块链中。
Priority Applications (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201910532830.1A CN110381116A (zh) | 2019-06-19 | 2019-06-19 | 信息同步系统和信息同步方法 |
Applications Claiming Priority (1)
Application Number | Priority Date | Filing Date | Title |
---|---|---|---|
CN201910532830.1A CN110381116A (zh) | 2019-06-19 | 2019-06-19 | 信息同步系统和信息同步方法 |
Publications (1)
Publication Number | Publication Date |
---|---|
CN110381116A true CN110381116A (zh) | 2019-10-25 |
Family
ID=68249283
Family Applications (1)
Application Number | Title | Priority Date | Filing Date |
---|---|---|---|
CN201910532830.1A Pending CN110381116A (zh) | 2019-06-19 | 2019-06-19 | 信息同步系统和信息同步方法 |
Country Status (1)
Country | Link |
---|---|
CN (1) | CN110381116A (zh) |
Cited By (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN113034281A (zh) * | 2021-03-16 | 2021-06-25 | 中国工商银行股份有限公司 | 基于区块链的业务数据处理方法、相关系统及节点 |
CN114691774A (zh) * | 2020-12-29 | 2022-07-01 | 中移动信息技术有限公司 | 一种同步业务变动信息的方法、装置、设备及存储介质 |
Citations (6)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN107315786A (zh) * | 2017-06-12 | 2017-11-03 | 腾讯科技(深圳)有限公司 | 业务数据存储方法及装置 |
WO2018112940A1 (zh) * | 2016-12-23 | 2018-06-28 | 深圳前海达闼云端智能科技有限公司 | 区块链节点的业务执行方法、装置及节点设备 |
CN108230109A (zh) * | 2018-01-02 | 2018-06-29 | 罗梅琴 | 一种基于区块链技术的共享系统及方法 |
CN109242500A (zh) * | 2018-09-20 | 2019-01-18 | 百度在线网络技术(北京)有限公司 | 区块链交易有效性验证方法、装置及存储介质 |
CN109446273A (zh) * | 2018-12-04 | 2019-03-08 | 深圳前海环融联易信息科技服务有限公司 | 区块链的数据同步方法、装置、计算机设备及存储介质 |
CN109740937A (zh) * | 2019-01-03 | 2019-05-10 | 深圳壹账通智能科技有限公司 | 基于区块链的资产数据处理方法和系统 |
-
2019
- 2019-06-19 CN CN201910532830.1A patent/CN110381116A/zh active Pending
Patent Citations (6)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
WO2018112940A1 (zh) * | 2016-12-23 | 2018-06-28 | 深圳前海达闼云端智能科技有限公司 | 区块链节点的业务执行方法、装置及节点设备 |
CN107315786A (zh) * | 2017-06-12 | 2017-11-03 | 腾讯科技(深圳)有限公司 | 业务数据存储方法及装置 |
CN108230109A (zh) * | 2018-01-02 | 2018-06-29 | 罗梅琴 | 一种基于区块链技术的共享系统及方法 |
CN109242500A (zh) * | 2018-09-20 | 2019-01-18 | 百度在线网络技术(北京)有限公司 | 区块链交易有效性验证方法、装置及存储介质 |
CN109446273A (zh) * | 2018-12-04 | 2019-03-08 | 深圳前海环融联易信息科技服务有限公司 | 区块链的数据同步方法、装置、计算机设备及存储介质 |
CN109740937A (zh) * | 2019-01-03 | 2019-05-10 | 深圳壹账通智能科技有限公司 | 基于区块链的资产数据处理方法和系统 |
Cited By (2)
Publication number | Priority date | Publication date | Assignee | Title |
---|---|---|---|---|
CN114691774A (zh) * | 2020-12-29 | 2022-07-01 | 中移动信息技术有限公司 | 一种同步业务变动信息的方法、装置、设备及存储介质 |
CN113034281A (zh) * | 2021-03-16 | 2021-06-25 | 中国工商银行股份有限公司 | 基于区块链的业务数据处理方法、相关系统及节点 |
Similar Documents
Publication | Publication Date | Title |
---|---|---|
FI115941B (fi) | Datakäsittelyjärjestelmä tietoliikenneverkkoa varten | |
US8463617B2 (en) | Network subscriber usage recording system | |
CN106126407A (zh) | 一种针对分布式存储系统的性能监控调优系统及方法 | |
US20140078177A1 (en) | Image synthesizing system, image processing apparatus, and image processing method | |
CN110383268A (zh) | 对用于处理带键网络数据流的参数化应用的动态执行 | |
CN110381116A (zh) | 信息同步系统和信息同步方法 | |
CN104317921B (zh) | 一种跨数据库数据同步系统及方法 | |
US8521684B2 (en) | System and method for aligning data frames in time | |
CN106127428B (zh) | 一种粘贴于快递上的广告单的投放方法 | |
CN109936486A (zh) | 基于区块链的自动拨测方法、装置、设备和存储介质 | |
CN101784998A (zh) | 用于递送软件的系统和方法 | |
CN104270424B (zh) | 一种数据库同步方法、服务器及系统 | |
US7895158B2 (en) | Data logging in content routed networks | |
CN108710681A (zh) | 文件获取方法、装置、设备及存储介质 | |
CN107134146B (zh) | 一种多个停车场管理的云端车牌自动校正系统 | |
KR101425868B1 (ko) | 규칙집합 기반 대용량 데이터 처리 시스템 및 방법 | |
CN104717302B (zh) | 一种信息推送方法及装置 | |
CN107808306A (zh) | 基于标签库的业务对象的切分方法、电子装置及存储介质 | |
CN105721567A (zh) | 卖场广告网络推送系统及其推送控制方法 | |
CN114979216A (zh) | 一种服务端数据采集配置方法及其系统 | |
CN104732358A (zh) | 一种烟叶生产移动应用管理系统及方法 | |
US7676032B2 (en) | Method and system for determining maximum transactions within a communications network | |
CN106340200A (zh) | 一种监控方法 | |
CN113538071B (zh) | 一种提升风控策略效果的方法及装置 | |
TWI513287B (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 | ||
AD01 | Patent right deemed abandoned | ||
AD01 | Patent right deemed abandoned |
Effective date of abandoning: 20240105 |