文章摘要:随着工业互联网平台接入的设备数量日益增多，大量设备的运行数据以及环境数据源源不断地向远程服务端传输，从而使远程服务端面临着高并发压力以及大量数据实时处理响应时间长的问题。为此，文章提出一种工业互联网高并发流数据处理方案，其通过构建基于异步网络通信的Netty服务器框架，将接收到的具有多源异构和高并发特点的数据流推送至消息处理系统Kafka中，再由Kafka消费者将协议解析、数据持久化、实时分析等耗时操作放在服务器集群进行分布式计算。通过在实际数据处理应用中验证，该方法在处理大量设备回传的高并发流式数据保持毫秒级的速度，能满足系统对数据处理的需求。

文章关键词:

论文DOI:10.13889/j.issn.2096-5427.2021.05.200

论文分类号:TP393.09

文章来源：《工业技术创新》 网址: http://www.gyjscxzz.cn/qikandaodu/2021/1010/1393.html