一种报文传输方法和装置

本申请实施例公开了一种报文传输方法和装置，该方法包括以下步骤：基于预先配置的分块策略，对原始报文数据进行结构识别与语义切分，生成多个具备结构完整性的分块数据；为每个分块数据生成包含任务标识、分块索引、总块数、结构哈希摘要和接收时间戳的元数据记录；对每个分块数据执行数据规范化处理，所述处理包括统一字符编码、移除换行符及空格字符；通过Kafka消息队列以事务模式发送各个分块数据，并根据丢包与延迟指标，动态调整分块重试发送时间间隔与次数上限。本申请实施例能够有效解耦业务服务，显著提高系统吞吐量，并实现分块数据的高效排序与完整重组，进而提高传输的可靠性。