韦通明，张送，温丰蔚，温丽梅，张亮

（上汽通用五菱汽车股份有限公司技术中心，广西 柳州545007）

前言

随着汽车智能网联化的发展，汽车变得更加智能化的同时，也产生更多的数据。在传统的数据接收端中，数据的接收以及转发都是阻塞式运行，当数据量大的时候，接收端可能卡死甚至宕机。接收端的宕机可能导致终端数据的丢失，会对公司造成重大的口碑和经济损失。因此，保证平台平稳而高效的运行，对于智能网联汽车平台的重要性不言而喻。

使用 Netty作为数据平台的接收端，在业界内早已有人进行了实践，王鑫等[2]就提出了一种基于Netty作为基础的数据通信框架；李熙、谢锦洋[3]也基于Netty和HDFS分布式文件系统设计出了一种大数据的接收以及采集系统。但是上面的两个系统都是单纯利用Netty接收和转发，Netty的Boss线程和Worker线程互相耦合，资源互相竞争，可能导致数据无法接受或者转发[1]，可能存在数据堆积等风险。

本文针对以上存在的不足，引入了Kafka消息中间件作为Netty的下游，使得Netty接收到的数据可以快速被转发。Kafka被设计为能承受数十万迸发的分布式消息中间件，能快速地缓存并且转发数据，减轻 Netty接收端的压力。Kafka支持集群多副本部署，能够防止数据丢失。我们将Netty与Kafka整合，能降低接收端集群的压力，并且系统更加可靠。

1 系统方案与架构

1.1 Netty模型

Netty引用并优化了JDK5引入的线程池技术，并且修复了JDK原生NIO的BUG，并且将接收线程池与业务线程池进行了分离。其中Acceptor线程池负责接受连接，worker线程池负责处理连接的读写事件。……