一种基于区块链的金融大数据处理方法及其系统平台转让专利

申请号 : CN201910708870.7

文献号 : CN110413649B

文献日 :

基本信息:

PDF:

法律信息:

相似专利:

发明人 : 胡明军

申请人 : 深圳前海大数金融服务有限公司

摘要 :

本发明公开了一种基于区块链的金融大数据处理方法及其系统平台包括以下步骤:信息录入单元接收输入的金融交易数据,并将金融交易数据发送至数据优化单元;数据优化单元接收金融交易数据对其进行优化,并向数据管理单元提供金融交易数据存储路径;本发明提高了验证认证算法和协议的效率,在满足金融系统多样化需求的同时,提高资源的利用率,大大简化了用户数据存取的体验。

权利要求 :

1.一种基于区块链的金融大数据处理方法,其特征在于,包括以下步骤:

信息录入单元接收输入的金融交易数据,并将金融交易数据发送至数据优化单元;

数据优化单元接收金融交易数据对其进行优化,并向数据管理单元提供金融交易数据存储路径;

数据管理单元接收数据存储路径以及经过优化后的金融交易数据,并对经过优化后的金融交易数据进行编码,将数据存储路径和数据编码发送至分布式区块缓存节点;

分布式区块缓存节点接收存储路径和数据编码,将数据编码转换为数据存储版本并发送至数据库中进行存储,

当用户需要查询相关金融交易数据时,通过查询单元找出对应区块缓存节点,并向该区块缓存节点发送数据查询请求,分布式区块缓存节点根据数据查询请求查找相应的存储版本,并在找到相应的存储版本时将其推送至查询单元指定的查询端口地址;信息录入单元接收输入的金融交易数据前:客户端通过信息录入单元进行录入,信息录入单元通过安全信道发送密钥序列及公共参数给客户端,客户端将密钥序列存储;金融机构工作人员用工号和密码登录向信息录入单元发送录入请求;信息录入单元从公共参数中随机选定一个随机数,其中,随机数目前只对信息录入单元可知;信息录入单元通过安全信道将随机数发送给客户端并将其存储在客户端上;金融机构工作人员退出登录再次向其客户端输入工号和密码,客户端从公共参数中随机选定一个随机数作为其私钥,并计算其公钥;信息录入单元通过密钥序列对客户端公钥进行验证,验证通过后进行信息录入;所述将数据存储路径和数据编码发送至分布式区块缓存节点时,假如接收金融数据存储路径和金融数据编码的分布式区块缓存节点总数为I,对于分布式区块缓存节点 ,需要传送每个编码所代表的金融数据包的大小为 ,计算金融数据编码的数据传输速率 为:其中, 表示信道增益;为传输功率; 是噪音经过采样后的采样值方差;为链路层所能承受的最大数据长度;为传输金融数据编码的误码率;为信道的强弱程度;e表示自然常数; 是函数Q的反函数,其中 ,x是自变量,t无意义;则其中,B为信道带宽,为数据管理单元调配给分布式区块缓存节点i的传输时间;分布式区块缓存节点接收存储路径和数据编码时,数据管理单元通过调节来达到 即可。

2.根据权利要求1所述基于区块链的金融大数据处理方法,其特征在于:所述分布式区块缓存节点接收存储路径和数据编码时,数据管理单元通过安全信道发送时间戳和随机选取的参数给分布式区块缓存节点;分布式区块缓存节点检查数据管理单元接收一个消息当且仅当其包含一个对分布式区块缓存节点而言足够接近当前时刻的时间戳;若不是,分布式区块缓存节点认为数据管理单元存在重放攻击,分布式区块缓存节点停止金融数据的接收;若是,则分布式区块缓存节点利用其私钥与数据管理单元的公钥检查两者的密码等式是否相等;若不相等,则分布式区块缓存节点停止金融数据的接收;若相等,则数据管理单元随机选定随机参数,并计算会话密钥,分布式区块缓存节点通过安全信道发送时间戳和随机选取的参数给数据管理单元;数据管理单元检查数据管理单元接收一个消息当且仅当其包含一个对数据管理单元而言足够接近当前时刻的时间戳;若不是,数据管理单元认为分布式区块缓存节点存在重放攻击,数据管理单元停止金融数据的传输;若是,则数据管理单元利用其私钥与数据管理单元的公钥检查两者的密码等式是否相等;若不相等,数据管理单元停止金融数据的传输;若相等,数据管理单元计算第一协商密钥并通过安全信道发送给分布式区块缓存节点;分布式区块缓存节点计算第二协商密钥并判断与第一协商密钥是否相等;若不相等,则安全密钥协商失败停止金融数据传输;若相等,则数据管理单元与分布式区块缓存节点都达到了一个信任阈值,通过第二协商密钥与第一协商密钥继续进行金融数据传输。

3.一种根据权利要求1或2所述基于区块链的金融大数据处理方法的系统平台,其特征在于包括:信息录入单元、数据优化单元、数据管理单元、分布式区块缓存节点和查询单元,所述信息录入单元、数据优化单元、数据管理单元、分布式区块缓存节点和查询单元依顺次相连。

说明书 :

一种基于区块链的金融大数据处理方法及其系统平台

技术领域

[0001] 本发明属于区块链金融技术领域,具体涉及一种基于区块链的金融大数据处理方法及其系统平台。

背景技术

[0002] 随着信息科学技术的飞速发展,特别是区块链、云计算、大数据技术在互联网金融广泛应用,尤其是区块链在国际汇兑、信用证、股权登记和证券交易所等金融领域有着潜在的巨大应用价值。将区块链技术应用在金融行业中,能够省去第三方中介环节,实现点对点的直接对接,从而在大大降低成本的同时,快速完成交易支付,未来金融业的核心竞争力很大程度上依赖于从大数据中提取信息和知识的速度与能力,而这种速度和能力,取决于数据处理和应用水平。随着互联网金融、移动支付等新型金融业态的不断涌现,对金融数据平台要求也相应提高。
[0003] 金融数据库对数据的准确性、可靠性要求很高,并且其必须具有较强的可复查性。大部分的金融产品需要长时间跟踪处理,其数据也具有多样性、复杂性。但是目前实际情况是金融产品数据处理过程复杂,金融业务核心数据在交互时误码率高且安全频频受到威胁,银行金融理财、证券、保险公司的VI P客户进行业务操作和访问时和普通客户的数据体验以及速度体验差异不大,同时,也存在新开发的金融产品与现存的业务系统数据共享存在不兼容的问题。

发明内容

[0004] 本发明的目的是为了克服上述不足提供一种基于区块链的金融大数据处理方法及其系统平台。
[0005] 一种基于区块链的金融大数据处理方法,包括以下步骤:
[0006] 信息录入单元接收输入的金融交易数据,并将金融交易数据发送至数据优化单元;
[0007] 数据优化单元接收金融交易数据对其进行优化,并向数据管理单元提供金融交易数据存储路径;
[0008] 数据管理单元接收数据存储路径以及经过优化后的金融交易数据,并对经过优化后的金融交易数据进行编码,将数据存储路径和数据编码发送至分布式区块缓存节点;
[0009] 分布式区块缓存节点接收存储路径和数据编码,将数据编码转换为数据存储版本并发送至数据库中进行存储,
[0010] 当用户需要查询相关金融交易数据时,通过查询单元找出对应区块缓存节点,并向该区块缓存节点发送数据查询请求,分布式区块缓存节点根据数据查询请求查找相应的存储版本,并在找到相应的存储版本时将其推送至查询单元指定的查询端口地址。
[0011] 信息录入单元接收输入的金融交易数据前:客户端通过信息录入单元进行录入,信息录入单元通过安全信道发送密钥序列及公共参数给客户端,客户端将密钥序列存储;金融机构工作人员用工号和密码登录向信息录入单元发送录入请求;信息录入单元从公共参数中随机选定一个随机数,其中,随机数目前只对信息录入单元可知;信息录入单元通过安全信道将随机数发送给客户端并将其存储在客户端上;金融机构工作人员退出登录再次向其客户端输入工号和密码,客户端从公共参数中随机选定一个随机数作为其私钥,并计算其公钥;信息录入单元通过密钥序列对客户端公钥进行验证,验证通过后进行信息录入。
[0012] 所述基于区块链的金融大数据处理方法的系统平台包括:信息录入单元、数据优化单元、数据管理单元、分布式区块缓存节点和查询单元,所述信息录入单元、数据优化单元、数据管理单元、分布式区块缓存节点和查询单元依顺次相连。
[0013] 本发明具有以下效果:本发明提高了验证认证算法和协议的效率,对其安全级别进行对比,避免了金融数据传输中可能承受攻击,放弃了传统的通信计算机制,只需根据数据管理单元调配给分布式区块缓存节点的传输时间即可使错码率降到最低,而且还提高了安全通信的效率,通过分布式资源分配方法,在满足金融系统多样化需求的同时,提高资源的利用率,大大简化了用户数据存取的体验。

附图说明

[0014] 图1是本发明系统结构示意图。

具体实施方式

[0015] 以下结合具体实施例对本发明作进一步的说明:
[0016] 一种基于区块链的金融大数据处理方法,包括以下步骤:
[0017] 信息录入单元接收输入的金融交易数据,并将金融交易数据发送至数据优化单元;
[0018] 数据优化单元接收金融交易数据对其进行优化,并向数据管理单元提供金融交易数据存储路径;
[0019] 数据管理单元接收数据存储路径以及经过优化后的金融交易数据,并对经过优化后的金融交易数据进行编码,将数据存储路径和数据编码发送至分布式区块缓存节点;
[0020] 分布式区块缓存节点接收存储路径和数据编码,将数据编码转换为数据存储版本并发送至数据库中进行存储,
[0021] 当用户需要查询相关金融交易数据时,通过查询单元找出对应区块缓存节点,并向该区块缓存节点发送数据查询请求,分布式区块缓存节点根据数据查询请求查找相应的存储版本,并在找到相应的存储版本时将其推送至查询单元指定的查询端口地址。
[0022] 信息录入单元接收输入的金融交易数据前:客户端通过信息录入单元进行录入,信息录入单元通过安全信道发送密钥序列及公共参数给客户端,客户端将密钥序列存储;金融机构工作人员用工号和密码登录向信息录入单元发送录入请求;信息录入单元从公共参数中随机选定一个随机数,其中,随机数目前只对信息录入单元可知;信息录入单元通过安全信道将随机数发送给客户端并将其存储在客户端上;金融机构工作人员退出登录再次向其客户端输入工号和密码,客户端从公共参数中随机选定一个随机数作为其私钥,并计算其公钥;信息录入单元通过密钥序列对客户端公钥进行验证,验证通过后进行信息录入。
[0023] 所述将数据存储路径和数据编码发送至分布式区块缓存节点时,假如接收金融数据存储路径和金融数据编码的分布式区块缓存节点总数为I,对于分布式区块缓存节点i∈{1,2,...,I},需要传送每个编码所代表的金融数据包的大小为dx,计算金融数据编码的数据传输速率vsi为:
[0024]
[0025] 其中,zyi表示信道增益;Pi为传输功率;σ2是噪音经过采样后的采样值方差;li为链路层所能承受的最大数据长度;wi为传输金融数据编码的误码率;sti为信道的强弱程度;-1
e表示自然常数;Q (x)是函数Q的反函数,其中 x是自变量,t无意义;

[0026]
[0027] 其中,B为信道带宽,ti为数据管理单元调配给分布式区块缓存节点i的传输时间;分布式区块缓存节点接收存储路径和数据编码时,数据管理单元通过调节ti来达到minwi即可。
[0028] 所述分布式区块缓存节点接收存储路径和数据编码时,数据管理单元通过安全信道发送时间戳和随机选取的参数给分布式区块缓存节点;分布式区块缓存节点检查数据管理单元接收一个消息当且仅当其包含一个对分布式区块缓存节点而言足够接近当前时刻的时间戳;若不是,分布式区块缓存节点可能认为数据管理单元存在重放攻击,分布式区块缓存节点停止金融数据的接收;若是,则分布式区块缓存节点利用其私钥与数据管理单元的公钥检查两者的密码等式是否相等;若不相等,则分布式区块缓存节点停止金融数据的接收;若相等,则数据管理单元随机选定随机参数,并计算会话密钥,分布式区块缓存节点通过安全信道发送时间戳和随机选取的参数给数据管理单元;数据管理单元检查数据管理单元接收一个消息当且仅当其包含一个对数据管理单元而言足够接近当前时刻的时间戳;若不是,数据管理单元可能认为分布式区块缓存节点存在重放攻击,数据管理单元停止金融数据的传输;若是,则数据管理单元利用其私钥与数据管理单元的公钥检查两者的密码等式是否相等;若不相等,数据管理单元停止金融数据的传输;若相等,数据管理单元计算第一协商密钥并通过安全信道发送给分布式区块缓存节点;分布式区块缓存节点计算第二协商密钥并判断与第一协商密钥是否相等;若不相等,则安全密钥协商失败停止金融数据传输;若相等,则数据管理单元与分布式区块缓存节点都达到了一个信任阈值,用第二协商密钥并判断与第一协商密钥继续进行金融数据传输。
[0029] 所述基于区块链的金融大数据处理方法的系统平台包括:信息录入单元、数据优化单元、数据管理单元、分布式区块缓存节点和查询单元,所述信息录入单元、数据优化单元、数据管理单元、分布式区块缓存节点和查询单元依顺次相连。