(19)国家知识产权局 (12)发明 专利申请 (10)申请公布号 (43)申请公布日 (21)申请 号 202210869373.7 (22)申请日 2022.07.22 (71)申请人 中国电信股份有限公司 地址 100033 北京市西城区金融大街31号 (72)发明人 刘家康　刘东鑫　董浩　张静静　 (74)专利代理 机构 北京律智知识产权代理有限 公司 11438 专利代理师 李建忠 (51)Int.Cl. H04L 9/32(2006.01) H04L 9/40(2022.01) H04L 67/06(2022.01) (54)发明名称 基于Kafka的文件验证传输方法、 装置、 设备 及存储 (57)摘要 本公开提供了一种基于Kafka的文件验证传 输方法、 装置、 设备及存储， 涉及大数据和数据安 全技术领域。 该方法包括， 通过对原始文件进行 分片处理， 获得多个文件分片； 将多个文件分片 的标识信息发送到中间件， 使得所述中间件根据 多个文件分片的标识信息创建一一对应的文件 分片主题； 将每个文件分片切分为多份消息切片 发送到中间件， 使得中间件根据消息切片对应的 文件分片主题对消息切片 进行存储； 拉取所述中 间件中的每个消息切片与对应的文件分片中的 消息切片进行对比验证， 当对比验证一致， 则确 定中间件中的消息切片为第一消息切片。 本公开 将中间件中的消息切片与对应的文件分片中的 消息切片进行对比验证， 保障了发送端到中间件 的消息可靠性。 权利要求书2页 说明书13页 附图11页 CN 115250181 A 2022.10.28 CN 115250181 A 1.一种基于Kafka的文件 验证传输方法， 应用于发送端， 其特 征在于， 包括： 对原始文件进行分片处 理， 获得多个文件分片； 将多个文件分片的标识信 息发送到中间件， 使得所述中间件根据多个文件分片的标识 信息创建一 一对应的文件分片主题； 将每个文件分片切分为多份消息切片发送到 中间件， 使得中间件根据消息切片对应的 文件分片主题对消息切片进行存 储， 其中， 所述消息切片包括对应的文件分片的标识信息； 拉取所述中间件中的每个消息切片与对应的文件分片中的消息切片进行对比验证， 当 对比验证一致， 则确定中间件中的消息切片为第一消息切片， 其中， 所述第一消息切片表征 发送端传输 到中间件通过验证的消息切片。 2.根据权利要求1所述的基于Kafka的文件验证传输方法， 其特征在于， 拉取所述中间 件中的每 个消息切片与对应的文件分片中的消息切片进行对比验证， 包括： 当对比验证不 一致， 重新发送验证不 一致的消息切片到中间件。 3.根据权利要求1所述的基于Kafka的文件验证传输方法， 其特征在于， 对原始文件进 行分片处 理包括： 获取原始文件， 确定原 始文件的文件元信息； 根据所述文件元信息对原 始文件切分， 获得多个文件分片。 4.根据权利要求3所述的基于Kafka的文件验证传输方法， 其特征在于， 在获取原始文 件， 确定原 始文件的文件元信息之后， 所述方法还 包括： 将所述文件元信 息发送到 中间件， 使得接收端通过所述中间件获取所述文件元信 息用 于组合文件分片。 5.一种基于Kafka的文件 验证传输方法， 应用于 接收端， 其特 征在于， 包括： 拉取中间件中的多个第一消息切片组合得到多个文件分片， 其中， 所述第一消息切片 表征发送端传输 到中间件通过验证的消息切片； 拉取文件元信息， 根据所述文件元信息组合每 个文件分片， 确定组合文件； 将所述组合文件的MD5值与原始文件 的MD5值进行验证， 当验证一致时， 确定所述组合 文件为发送端的原 始文件， 完成文件接收验证。 6.一种基于Kafka的文件 验证传输系统， 其特 征在于， 包括： 发送端、 中间件、 接收端； 其中， 发送端用于对原始文件进行分片处理， 获得多个文件分片； 将多个文件分片的标 识信息发送到中间件； 将每个文件分片切分为多份消息切片发送到中间件； 拉取所述中间 件中的每个消息切片与对应的文件分片 中的消息切片进行对比验证， 当对比验证一致， 则 确定中间件中的消息切片为第一消息切片； 中间件用于接收发送端发送的多个文件分片的标识信 息， 根据多个文件分片的标识信 息创建一一对应的文件分片主题； 接 收发送端发送的多份消息切片， 根据所述消息切片对 应的文件分片主题对消息切片进行存 储； 接收端用于拉取中间件中的多个第 一消息切片组合得到多个文件分片； 拉取文件元信 息， 根据所述文件元信息组合每个文件分片， 确定组合文件； 将所述组合文件的MD5值与原 始文件的MD5值进行验证， 当验证一致时， 确定所述组合文件为发送端的原始文件， 完成文 件接收验证； 其中， 所述消息切片包括对应的文件分片的标识信息， 所述第一消息切片表征发送端权　利　要　求　书 1/2 页 2 CN 115250181 A 2传输到中间件通过验证的消息切片。 7.一种基于Kafka的文件 验证传输装置， 应用于发送端， 其特 征在于， 包括： 文件分片模块， 用于对原 始文件进行分片处 理， 获得多个文件分片； 第一发送模块， 用于将多个文件分片的标识信息发送到中间件， 使得所述中间件根据 多个文件分片的标识信息创建一 一对应的文件分片主题； 第二发送模块， 用于将每个文件分片切分为多份消息切片发送到中间件， 使得中间件 根据消息切片对应的文件分片主题对消息切片进行存储， 其中， 所述消息切片包括对应的 文件分片的标识信息； 发送验证模块， 用于拉取所述中间件中的每个消息切片与对应的文件分片中的消息切 片进行对比验证， 当对比验证一致， 则确定中间件中的消息切片为第一消息切片， 其中， 所 述第一消息切片表征发送端传输 到中间件通过验证的消息切片。 8.一种基于Kafka的文件 验证传输装置， 其特 征在于， 应用于 接收端， 包括： 消息切片拉取模块， 用于拉取中间件中的多个第一消息切片组合得到多个文件分片， 其中， 所述第一消息切片表征发送端传输 到中间件通过验证的消息切片； 文件元信息拉取模块， 用于拉取文件元信 息， 根据所述文件元信 息组合每个文件分片， 确定组合文件； 接收验证模块， 用于将所述组合文件的MD5值与原始文件的MD5值进行验证， 当验证一 致时， 确定所述组合文件为发送端的原 始文件， 完成文件接收验证。 9.一种电子设备， 其特 征在于， 包括： 处理器； 以及 存储器， 用于存 储所述处 理器的可 执行指令； 其中， 所述处理器配置为经由执行所述可执行指令来执行权利要求1～5 中任意一项所 述基于Kafka的文件 验证传输方法。 10.一种计算机可读存储介质， 其上存储有计算机程序， 其特征在于， 所述计算机程序 被处理器执行时实现权利要求1～5中任意 一项所述的基于Kafka的文件 验证传输方法。权　利　要　求　书 2/2 页 3 CN 115250181 A 3