一种通过可伸缩数据处理的消息传输优化系统

本发明公开了一种通过可伸缩数据处理的消息传输优化系统，数据采集模块，用于基于边缘节点对设备数据进行采集并进行数据预处理；数据接入模块，用于基于分布式架构进行数据接入，并在全部集群节点范围内完成数据同步；数据处理模块，用于基于微服务架构，根据当前负载自动调整集群节点数量；集群管理模块，用于针对集群中的每个节点进行心跳检测，针对存在故障的节点进行故障转移。通过本发明对采集到的设备数据进行快速接入和分布式传输，并基于数据处理模块灵活地基于数据量，合理配置处理节点，对当前数据进行处理，并对集群自动故障转移，大大提高了处理资源配置的合理性、系统运行效率以及系统稳定性。