(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202211005704.9 (22)申请日 2022.08.22 (71)申请人 中能融合智慧科技有限公司 地址 100013 北京市东城区和平里东 街11 号8号楼三层3 -D1号 (72)发明人 张亚鹏　黄仁亮　杨迪　云淑林　 (74)专利代理 机构 北京正和明知识产权代理事 务所(普通 合伙) 11845 专利代理师 申婕 (51)Int.Cl. H04L 69/163(2022.01) H04L 69/16(2022.01) H04L 67/145(2022.01) H04L 67/1004(2022.01) H04L 49/9057(2022.01)H04L 9/40(2022.01) H04L 47/43(2022.01) (54)发明名称 一种数据传输存储 方法、 装置以及计算机设 备 (57)摘要 本申请涉及一种数据传输存储 方法、 装置以 及计算机设备， 其中数据传输存储 方法包括获取 场站发送的socket请求， 建立与所述场站的TCP 连接， 形成与所述场站长连接的传输通道； 获取 所述场站在所述传输通道上发送的目标数据， 并 基于负载均衡服务器将获取的所述目标数据对 应接收； 确定获取到的所述目标数据是否为重组 包数据； 若是， 则拼接所述重组包数据以生成所 述目标数据； 将获取到的所述目标数据基于预设 规则进行存储； 通过TCP传输方式， 能够减少额外 数据包传输， 且使用 负载均衡服务器进行分发， 中心侧能更快的响应， 同时接收若干个拆分的重 组包数据， 从而可以实现数千家场站将数据安 全、 快速的传给中心侧， 中心侧对其进行存 储。 权利要求书2页 说明书8页 附图5页 CN 115361455 A 2022.11.18 CN 115361455 A 1.一种数据传输存 储方法， 其特 征在于， 该 方法包括： 获取场站发送的socket请求， 建立与所述场站的TCP连接， 形成与所述场站长连接的传 输通道； 获取所述场站在所述传输通道上发送的目标数据， 并基于负载均衡服务器将 获取的所 述目标数据对应接收； 确定获取到的所述目标数据是否为重组包数据； 若是， 则拼接所述重组包数据以生成 所述目标 数据； 将获取到的所述目标 数据基于预设规则进行存 储。 2.根据权利 要求1所述的数据传输存储方法， 其特征在于， 所述获取场站发送的socket 请求， 建立与所述场站的TCP连接， 形成与所述场站的长连接的传输通道之前还 包括： 向各个所述场站发送唯一识别账号和密码信息； 在接收场站发送的socket请求时对该 所述账号和密码进行识别验证； 若验证通过则建立与所述场站的TCP连接 。 3.根据权利要求1所述的数据传输存 储方法， 其特 征在于， 所述获取所述场站在所述传输通道上发送的目标数据之前还包括： 在所述场站和中心 侧之间建立心跳 机制； 所述场站基于预设周期定时向所述中心侧发送探测包， 并同时启动一个超时定时器； 若所述中心侧在预设时间内返回应答包， 则说明连接正常， 并删除所述超时定时器； 若所述中心侧未在预设时间内返回应答包， 则说明连接断开， 需重新连接 。 4.根据权利要求3项所述的数据传输存储方法， 其特征在于， 所述获取所述场站在所述 传输通道上发送的目标数据， 并基于负载均衡服务器将获取的所述目标数据对应接收包 括： 所述场站发送经加密处 理的所述目标 数据传送至所述负载均衡服 务器； 所述负载均衡服 务器接收该 所述目标 数据后进行转码解析处 理； 所述负载均衡服务器根据均衡策略确定对应服务器节点， 并将解密后的所述目标数据 发送至对应的所述 服务器节点。 5.根据权利要求1所述的数据传输存储方法， 其特征在于， 所述获取所述场站在所述传 输通道上发送的目标 数据， 并基于负载均衡服 务器将获取的所述目标 数据对应接收包括： 所述场站对所述目标 数据的大小 进行判断； 若所述目标数据的大小大于预设值 时， 则将所述目标数据拆分为若干个预设大小的小 包数据， 并将所有的所述小包数据和所述目标 数据的MD5值发送至所述中心侧； 若所述目标数据的大小不大于预设值 时， 则所述目标数据按照原始数据 大小进行数据 传输。 6.根据权利要求5所述的数据传输存储方法， 其特征在于， 所述确定获取到的所述目标 数据是否为重组包数据； 若是， 则拼接所述重组包数据以生成所述目标 数据包括： 若确定所述目标数据是重组包数据， 则进一步确定是否已经存在重组包文件夹， 若存 在则读取 该重组包文件夹下的所有 小包数据； 若不存在， 则创建重组包文件夹， 并将重组包数据存 储在所述重组包文件夹内。 7.根据权利要求6所述的数据传输存储方法， 其特征在于， 所述读取该重组包文件夹下权　利　要　求　书 1/2 页 2 CN 115361455 A 2的所有小包数据具体包括： 将重组包文件夹内所有小包数据的数据包字节长度相加并与新收到小包数据的数据 包字节长度相加， 若相加后的数据包字节长度与所述 目标数据的数据包字节长度相等， 则 拼接所有小包数据生成大包数据， 并计算大包数据的MD5值， 若大包数据的MD5值与所述场 站发送的所述目标 数据的MD5值 一致， 则表示传输成功。 8.根据权利要求1所述的数据传输存储方法， 其特征在于， 所述将 获取到的所述目标数 据基于预设规则进行存 储包括： 对获取到的所述目标 数据根据所述目标 数据自带的标记进行分类； 对分类的所述目标数据分别存储于各自对应的所述中心侧的日志文件中； 将存储于所 述日志文件中的所述目标 数据通过flume存 储于存储介质中。 9.一种数据传输存 储装置， 其特 征在于， 该装置包括： 第一获取模块： 用于获取场站发送的socket请求， 建立与所述场站的TCP连接， 形成与 所述场站长连接的传输通道； 第二获取模块： 用于获取所述场站在所述传输通道上发送的目标数据， 并基于负载均 衡服务器将获取的所述目标 数据对应接收； 确定模块： 用于确定获取到的所述目标数据 是否为重组包数据； 若是， 则拼接所述重组 包数据以生成所述目标 数据； 存储模块： 用于将获取到的所述目标数据基于预设规则进行存储， 其中所述预设规则 是指将目标 数据按照类别进行分类的规则。 10.一种计算机设备， 包括存储器、 处理器及存储在存储器上并可在处理器上运行的计 算机程序， 其特征在于， 所述处理器执行所述计算机程序时实现权利要求1至8中任一项所 述方法的步骤。权　利　要　求　书 2/2 页 3 CN 115361455 A 3