MQTT轻量级消息队列协议专为物联网场景设计，自动售货机用它做数据上报再合适不过。本文从协议原理到实现思路，手把手教你搭建完整的联网方案。
一、为什么售货机联网首选MQTT？
传统的HTTP轮询方式存在明显弊端：每次请求都带完整HTTP头网络开销大，轮询间隔内无法及时获取指令实时性差，持续轮询消耗大量流量成本高，服务器承受大量无效轮询请求压力大。
MQTT相比之下优势明显：最小报文仅2字节网络开销极低，支持推送模式即时响应，协议内置心跳机制自动维持连接，发布订阅模式按需发送流量省，按需推送服务器压力小。MQTT专为物联网设备设计，轻量可靠支持持久会话。
二、MQTT核心概念
发布订阅模式
MQTT采用发布订阅模式，消息发送者和接收者不需要直接连接。售货机作为发布者向主题发送消息如销售数据，后台运维平台作为订阅者订阅感兴趣的主题如所有告警信息。这种模式解耦了设备和服务，便于扩展。
主题设计原则
售货机主题命名建议采用这样的结构：vm加设备编号加数据类型。例如vm001status表示设备状态上报，vm001sales表示销售数据上报，vm001alert表示告警信息上报，vm001cmd表示后台下发指令通道，vm001config表示配置参数下发。
使用通配符可以灵活订阅。vm加号sales可以订阅所有设备的销售数据，vm斜杠001斜杠井号可以订阅001号设备的所有主题。
三、3步实现MQTT联网
第一步：选择MQTT Broker
Broker是消息代理服务器，负责接收消息并转发给订阅者。开源方案有多种选择。EMQX高性能支持百万级连接功能丰富，适合大规模商用部署。Mosquitto轻量级容易安装，适合小规模测试和边缘网关。HiveMQ企业级有可视化监控，适合企业生产环境。
以EMQX为例可以通过Docker一键部署，部署后访问管理后台进行配置。
第二步：设备端MQTT客户端实现
设备端需要实现MQTT客户端功能。建立与Broker的TCP连接并进行身份认证。订阅自己需要接收的主题如指令通道。实现消息到达回调函数处理收到的指令。实现连接丢失回调函数处理断线重连。定期发布消息上报设备状态和销售数据。
第三步：数据上报定时任务
设备需要定期上报数据主要包括：设备状态包括在线状态、温度、库存余量等，建议每分钟上报一次。销售数据包括订单金额、商品信息、支付方式等，触发即上报。告警信息包括故障类型、故障描述等，触发即上报。
四、QoS等级选择策略
MQTT支持三种消息质量等级。QoS 0最多发送一次可能丢失，适用于非关键数据如周期性状态。QoS 1至少发送一次可能重复，适用于关键业务如订单和支付。QoS 2恰好发送一次，适用于极重要且不允许重复的场景。
售货机建议这样配置：销售数据和支付通知使用QoS 1确保送达，业务层去重。周期性状态和库存同步使用QoS 0丢失可下次补发。远程指令执行使用QoS 1确保指令送达。
五、遗嘱消息与异常告警
MQTT支持设置遗嘱消息，当设备异常断开连接时Broker会自动向指定主题发送预设的消息。这个功能非常适合用于设备离线告警。
设置方法是在建立连接前配置遗嘱消息的内容和发布主题。设备正常断开时不会触发遗嘱消息，只有异常断电、网络中断等情况才会触发。后台订阅设备离线主题后，可以及时发现设备异常并安排维修。
六、TLS加密传输
生产环境中务必启用TLS加密传输，防止数据被截获和篡改。需要准备CA证书并在连接时配置启用证书验证。对于高安全要求的场景如金融支付，必须使用加密连接。
七、常见问题排查
连接失败
检查项包括：Broker地址和端口是否正确，用户名密码是否匹配，防火墙是否放行相应端口，设备时间是否准确因为TLS证书校验依赖时间。
消息丢失
排查步骤包括：检查QoS等级是否设置正确，确认Broker日志中是否有异常，检查客户端是否有接收回调。
断线频繁
优化方案包括：增加心跳间隔减少网络开销，检查网络稳定性考虑使用4G备用链路，实现指数退避重连策略避免频繁重试。
八、总结
本文介绍了MQTT协议在自动售货机联网中的应用，核心要点：MQTT轻量高效适合物联网设备低流量实时性需求。三步完成联网部署Broker、编写客户端、实现业务上报。QoS、遗嘱消息、TLS等特性保障可靠性与安全性。持久会话支持离线消息确保指令不丢失。
实际部署时还需结合具体业务需求设计主题结构和消息格式。希望本文能帮助开发者快速搭建稳定的售货机联网系统。
