Docker网络中Flask与Mosquitto MQTT通信异常排查求助

一、先解决Docker日志无print输出的问题 #

Flask默认日志级别为WARNING，普通print输出不会被捕获到Docker日志中，可通过两种方式修复：

• 方法1：改用Python日志系统输出
  在Flask代码中配置日志，替换print为日志打印：

  import logging
  logging.basicConfig(level=logging.INFO)
  logger = logging.getLogger(__name__)
  
  # 示例：替换print("消息已发送")为
  logger.info("MQTT消息已发送")
  

• 方法2：开启Python无缓冲输出
  在Flask容器的Dockerfile中添加环境变量：

  ENV PYTHONUNBUFFERED=1
  

  确保stdout/stderr直接输出到Docker日志。

二、Flask与Mosquitto消息传输问题排查 #

1. 验证MQTT连接参数 #

• 确认Flask中连接Mosquitto使用容器名mosquitto作为地址（Docker Compose同网络内可通过容器名访问），端口为默认的1883；同时设置合理的心跳时间避免超时断开：

  import paho.mqtt.client as mqtt
  
  client = mqtt.Client()
  # 心跳设为60秒，避免短时间内断开
  client.connect("mosquitto", 1883, 60)
  

2. 启动MQTT客户端循环 #

Paho-MQTT必须启动网络循环才能处理消息收发，在Flask中通过后台线程启动：

import threading

def mqtt_loop():
    client.loop_forever()

# Flask启动时启动后台线程
threading.Thread(target=mqtt_loop, daemon=True).start()

未启动循环会导致客户端仅能建立连接，无法收发消息，最终超时断开。

3. 检查Mosquitto匿名访问配置 #

默认eclipse-mosquitto镜像可能禁用匿名连接，需修改mosquitto.conf：

allow_anonymous true
listener 1883 0.0.0.0

在docker-compose.yml中挂载该配置文件到容器的/mosquitto/config/mosquitto.conf路径。

4. 验证消息收发逻辑 #

• 确认webhook处理函数中正确调用MQTT发布方法：

  from flask import Flask, request
  import json
  
  app = Flask(__name__)
  
  @app.route('/webhook', methods=['POST'])
  def handle_webhook():
      data = request.get_json()
      # 确认topic和payload格式正确
      client.publish("directus/events", json.dumps(data))
      logger.info(f"已发布消息到directus/events: {data}")
      return "OK", 200
  

• 添加订阅逻辑测试消息接收：

  def on_message(client, userdata, msg):
      logger.info(f"收到消息: {msg.topic} -> {str(msg.payload)}")
  
  client.on_message = on_message
  client.subscribe("directus/events")
  

三、Docker Compose网络配置检查 #

确保三个容器处于同一自定义网络，在docker-compose.yml中定义：

version: '3.8'
services:
  directus:
    # 其他配置
    networks:
      - mqtt-network
  app:
    # 其他配置
    networks:
      - mqtt-network
  mosquitto:
    # 其他配置
    networks:
      - mqtt-network
networks:
  mqtt-network:
    driver: bridge

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