买专利卖专利找龙图腾，真高效！ 查专利查商标用IPTOP,全免费！专利年费监控用IP管家,真方便！

龙图腾网获悉中电云数智科技有限公司申请的专利一种基于Flink的非结构化文件传输方法获国家发明授权专利权，本发明授权专利权由国家知识产权局授予，授权公告号为：CN116708406B 。

龙图腾网通过国家知识产权局官网在2026-01-02发布的发明授权授权公告中获悉：该发明授权的专利申请号/专利号为：202310403406.3，技术领域涉及：H04L67/06；该发明授权一种基于Flink的非结构化文件传输方法是由何德峰设计研发完成，并于2023-04-17向国家知识产权局提交的专利申请。

本一种基于Flink的非结构化文件传输方法在说明书摘要公布了：本发明涉及数据处理技术领域，提供一种基于Flink的非结构化文件传输方法，本发明的方法包括：读取源文件配置信息，获取文件数量和文件同步执行线程数；根据获取的文件数量和文件同步执行线程数分配文件传输任务；校验目标文件，为通过校验的目标文件创建源文件服务器连接，查询对应的源文件；为查询所得的源文件创建目标文件服务器连接，将目标文件写入对应的目标文件路径下。根据本发明示例性实施例的基于Flink的非结构化文件传输方法，可以降低部署难度，降低维护难度，提升系统稳定性，避免文件重复传输、重复读写，减少磁盘额外读写消耗，降低整个同步所消耗的时间。

本发明授权一种基于Flink的非结构化文件传输方法在权利要求书中公布了：1.一种基于Flink的非结构化文件传输方法，其特征在于，所述方法包括： 步骤S1：读取源文件配置信息，获取文件数量和文件同步执行线程数； 步骤S2：根据获取的文件数量和文件同步执行线程数分配文件传输任务； 步骤S3：校验目标文件，为通过校验的目标文件创建源文件服务器连接，查询对应的源文件； 步骤S4：为查询所得的源文件创建目标文件服务器连接，将目标文件写入对应的目标文件路径下； 步骤S4包括： 为查询所得的源文件创建目标文件服务器连接，当目标文件服务器连接创建成功，通过所述目标文件服务器连接根据目标文件的配置信息查询对应的目标文件路径； 当目标文件路径不存在时，创建目标文件的目标文件路径并创建目标文件临时文件，通过步骤S3中的源文件服务器连接获取对应的读文件流和写入流，将所述读文件流和写入流写入目标文件临时文件中； 当目标文件路径存在时，在所述目标文件路径下查询是否存在对应的目标文件临时文件，所述目标文件临时文件以目标文件名命名，以.temp为后缀； 当所述目标文件路径下不存在对应的目标文件临时文件，创建目标文件临时文件，通过步骤S3中的源文件服务器连接获取对应的读文件流和写入流，将所述读文件流和写入流写入目标文件临时文件中； 当所述目标文件路径下存在对应的目标文件临时文件，获取所述目标文件临时文件的缓存大小，将读文件流跳过对应的缓存大小后与写文件流写入目标文件临时文件中； 将目标文件临时文件的文件名称修改为目标文件的文件名称，当所述目标文件路径下已经存在目标文件，则对已经存在的目标文件进行覆盖； 将写入的目标文件的文件id配置保存至全局缓存checkpoint中，直至所有分配到线程的任务执行完成后，清除该任务的checkpoint信息，将任务状态标记为已完成。

如需购买、转让、实施、许可或投资类似专利技术，可联系本专利的申请人或专利权人中电云数智科技有限公司，其通讯地址为：430058 湖北省武汉市蔡甸区经济技术开发区人工智能科技园N栋研发楼3层N3013号；或者联系龙图腾网官方客服，联系龙图腾网可拨打电话0551-65771310或微信搜索“龙图腾网”。

以上内容由龙图腾AI智能生成。