胡喜明，胡 淼

(杭州电子科技大学 通信工程学院，浙江 杭州 310018)

0 引 言

随着物联网技术的发展，人们能够通过移动终端方便获取所需要的信息与服务[1]。为了保证网络设备与物理设备间可靠的传输，用户将传统的消息拉取模式转变为应用消息推送。与消息拉取模式相比，由服务器将所产生的消息推送用户，符合当前互联网流量管理以及资源分配的需求，同时在传输的实时性、高效性以及流量资源节约方面都有较大的提升[2]。物联网设备需要考虑到硬件相关参数，例如CPU性能、最大带宽容量、电池使用时间、网络最大实时流量等方面的问题，在服务推送方面需要一种功能完善、更加轻量、带宽占比小且性能高的服务推送技术[3]。

当前主流的服务推送方案有GCM服务、MQTT以及HTTP消息轮循[4]。其中HTTP轮循方式最为简单，但是在实用性、可靠性以及可扩展性方面有所欠缺。GCM服务是google研发的一款云推送框架，拥有完善的推送方案，但是受限于网络原因，无法在国内使用。MQTT协议具有低延迟、低带宽、推送速度快等优势，适合大部分物联网开发场景，然而单纯的MQTT协议本身过于简单，在消息推送、安全性管理、主题化推送方式、数据缓存性等方面开发难度大，因此需要对MQTT协议进行二次开发[5]。

本文提出一种基于Reactor-Netty+MQTT的高性能服务推送框架。项目中应用Reactor-Netty技术替代传统Netty技术对MQTT协议进行封装，借助该技术的响应式非阻塞编程、事件驱动等特性构建高性能通信服务。通过Redis进行数据缓存和Kafka实现消息代理转发进一步提高系统服务处理能力以及线程安全。……