针对实际工业现场,采用异步的生产者/消费者模式,设计了一套面向消息的物联网中间件,完成底层传感器网关节点之间、网关与服务端之间的交互和数据通信,以屏蔽底层网络的异构性,实现实时数据的稳定可靠传输。通过分析物联网的体系结构,针对节点部署和数据采集的多样性以及通信的异构型等特点提出了物联网消息中间件的功能需求。依据网关节点的能量、计算、存储能力和通信带宽有限的限制条件提出了物联网消息中间件的性能需求,并根据工业环境的严格、复杂的特点提出了安全性和扩展性的需求。将中间件分成协议转换、命令控制、数据处理、缓存控制、日志调试、熔断器、定时器等模块,实现了网关的动态接入、传输协议之间的相互转换、系统和设备的实时控制、感知层数据的预处理、系统的熔断保护、异常数据的报警和恢复、网关设备的状态监控等功能。通过在模拟测试环境中对中间件的功能完整性、健壮性和并发性进行了测试,测试结果显示了其对于工业物联网具有很高的适用性,为物联网Web服务提供了逻辑清晰、稳定的数据源,并且网络适配层和应用业务适配层具有很高的扩展性。最后将消息中间件应用于实际工业物联网环境,实现了不同系统之间的数据互通和共享,确保了来源于工业现场的实时数据稳定性、可靠性。同时,消息中间件对数据的预处理大大减轻了应用系统的负载。