用于分布式应用系统的数据传输系统和数据传输方法

摘要

本发明提供了一种用于分布式应用系统的数据传输系统，包括发送方和接收方，其中，所述发送方包括：数据拆分单元，用于将待发送的业务数据拆分为多个数据消息；消息生成单元，用于生成对应于所述数据消息的控制消息；数据发送单元，用于将所述数据消息和所述控制消息发送至消息中间件，以供接收方进行获取并按照所述控制消息来处理所述数据消息。本发明还提出了一种用于分布式应用系统的数据传输方法。通过本发明的技术方案，可以不依赖于具体的消息中间件，从而实现异步的、松耦合的分布式数据传输，具有良好的可移植性，能够有效降低系统实现的复杂性，尤其是解决了在大数据量和集群环境下的常见内存问题、并发问题。

主权项

一种用于分布式应用系统的数据传输系统，其特征在于，包括发送方和接收方，其中，所述发送方包括：数据拆分单元，用于将待发送的业务数据拆分为多个数据消息；消息生成单元，用于生成对应于所述数据消息的控制消息；数据发送单元，用于将所述数据消息和所述控制消息发送至消息中间件，以供接收方进行获取并按照所述控制消息来处理所述数据消息；所述数据消息和所述控制消息各自分开独立发送，多个所述数据消息之间无需保持顺序；标识添加单元，用于为每个所述数据消息添加相应的唯一标识；其中，所述控制消息中包含每个所述数据消息的唯一标识、所述多个数据消息的排列顺序以及对所述多个数据消息的处理方式。