libmosquitto向RabbitMQ(MQTT Broker)发首条消息后断连求助

以下是针对你的场景的具体排查步骤：

1. 确认Docker容器间的网络连通性与地址正确性 #

• 如果你在libmosquitto容器中连接localhost:1883，这会指向容器自身而非RabbitMQ容器。必须使用Docker Compose中RabbitMQ服务的名称作为主机地址，比如rabbitmq:1883（假设你的服务名是rabbitmq）。
• 在libmosquitto容器内执行ping rabbitmq验证网络可达性，确保容器间能正常通信。

2. 检查RabbitMQ用户权限配置 #

• 执行docker exec <rabbitmq-container-name> rabbitmqctl list_user_permissions <your-username>查看用户权限，确认该用户在对应vhost（默认是/）下拥有：
  • write权限（对应MQTT发布操作），至少覆盖amq.topic交换器（RabbitMQ MQTT插件默认将topic映射到该交换器）
  • 若需要订阅，还要有read权限
• 示例正确权限输出应包含类似/、write.*、read.*的条目，或者更精准的write:amq.topic、read:amq.topic。

3. 验证MQTT协议版本与认证参数 #

• libmosquitto默认可能使用MQTT 3.1.1，确保RabbitMQ MQTT插件支持该版本（默认支持3.1和3.1.1）。
• 确认你的示例代码中正确设置了用户名和密码：

  mosquitto_username_pw_set(mosq, "your-username", "your-password");
  

• 若未设置认证参数，即使RabbitMQ关闭了匿名访问，也会导致连接被拒绝（日志可能未明确提示）。

4. 查看RabbitMQ详细日志定位原因 #

• 在docker-compose.yml中为RabbitMQ服务添加环境变量开启debug日志：

  environment:
    - RABBITMQ_LOG_LEVEL=debug
  

• 重启服务后，执行docker logs -f <rabbitmq-container-name>查看日志，重点关注断开连接前的日志条目，比如是否有权限拒绝、协议帧错误、心跳超时等具体提示。

5. 检查libmosquitto程序的事件循环逻辑 #

• 确保程序在发布消息后持续处理网络事件：
  • 如果使用同步模式，需在发布后循环调用mosquitto_loop(mosq, -1, 1)，或者启用异步循环mosquitto_loop_start(mosq)。
  • 若只调用一次mosquitto_loop，可能无法处理RabbitMQ的确认帧或心跳包，导致连接被主动断开。
• 检查消息的QoS设置：如果使用QoS 1/2，需确保程序能处理PUBACK/PUBCOMP帧，否则RabbitMQ可能因超时关闭连接。

内容的提问来源于stack exchange，提问作者Johnny Vm