EMQX中MQTT消息订阅后为何收不到消息？

Question

在EMQX中，MQTT消息订阅后收不到消息可能由多种原因导致。首先，检查客户端是否正确连接到EMQX服务器，网络问题或错误的服务器地址可能导致连接失败。其次，确认订阅的主题（Topic）与发布消息的主题完全匹配，注意区分大小写和通配符使用。此外，确保QoS等级设置合理，过高的QoS要求可能引发问题。再者，客户端的订阅权限可能受限，需核实EMQX的ACL配置是否允许该客户端访问指定主题。最后，查看EMQX的日志文件，排查是否存在资源限制、队列满或其他系统异常。通过以上步骤，可有效定位并解决收不到消息的问题。

Answer 1

1. 基础检查：客户端连接状态

在EMQX中，MQTT消息订阅后收不到消息的首要原因可能是客户端未正确连接到服务器。以下是检查步骤：

• 确认客户端是否成功连接到EMQX服务器。
• 检查网络连接是否正常，避免因防火墙或路由器配置问题导致连接中断。
• 确保服务器地址和端口设置正确，例如默认的MQTT端口为1883。

如果客户端无法连接，请使用以下命令测试网络连通性：

telnet <emqx_server_ip> 1883

2. 主题匹配与区分大小写

订阅的主题（Topic）必须与发布消息的主题完全匹配。以下是关键点：

1. 确保订阅和发布的主题名称一致，包括大小写。
2. 合理使用通配符“+”和“#”，例如“sensor/+/data”可以匹配“sensor/1/data”。
3. 避免因主题层级不匹配导致的消息丢失。

可以通过以下代码示例验证主题匹配：

mqtt_client.subscribe("sensor/#");

3. QoS等级设置合理性

QoS（Quality of Service）等级可能影响消息传递效果。以下是建议：

QoS等级	描述	适用场景
0	最多一次传递，不保证消息到达。	对实时性要求高但容许少量丢包的场景。
1	至少一次传递，保证消息到达但可能重复。	需要确保消息被接收但可接受重复消息的场景。
2	仅一次传递，保证消息到达且无重复。	对可靠性要求极高的场景。

过高的QoS等级可能导致性能瓶颈，需根据实际需求调整。

4. ACL权限配置检查

客户端的订阅权限受限是常见问题之一。以下是排查方法：

• 检查EMQX的ACL（Access Control List）配置文件，确保允许该客户端访问指定主题。
• 通过EMQX管理界面或命令行工具验证权限设置。

以下是一个简单的ACL规则示例：

{allow, all, subscribe, ["$SYS/#", "my_topic/#"]}.

5. 系统日志分析

最后，查看EMQX的日志文件以排查潜在问题：

以下是日志分析的流程图：

mermaid
graph TD;
    A[检查日志路径] --> B{是否存在错误信息};
    B --是--> C[定位资源限制问题];
    B --否--> D[进一步检查队列状态];
    D --> E[确认是否有队列满的情况];

日志文件通常位于/var/log/emqx/目录下，重点关注error.log和console.log。