Python MQTT服务Docker部署：如何传入外部Broker主机与端口？

核心原因 #

容器内的127.0.0.1指向容器自身的本地环路，而非宿主机或外部MQTT Broker的地址，硬编码地址会导致连接被拒绝。同时你的报错里还存在地址拼写错误（127.0.0.0.1多了一个0），需要一并修正。

解决方案步骤 #

1. 修改Python代码，通过环境变量动态获取Broker参数 #

把硬编码的Broker地址和端口改成从环境变量读取，让容器启动时可动态传入：

import os
import paho.mqtt.client as mqtt

# 从环境变量读取配置，可设置默认值
mqtt_broker = os.getenv("MQTT_BROKER", "127.0.0.1")
mqtt_port = int(os.getenv("MQTT_PORT", 61613))

client = mqtt.Client()
# 修正拼写错误，使用动态参数
client.connect(mqtt_broker, mqtt_port, 60)

2. 优化Dockerfile（可选） #

原Dockerfile中的EXPOSE 61613是用来声明容器对外监听的端口，但你的服务是作为客户端去连接外部Broker，无需暴露端口，可删除该行：

FROM python:3.11

ADD clean.py .
ADD requirements.txt .

RUN pip install -r requirements.txt

CMD ["python", "clean.py"]

3. 启动容器时传入Broker地址与端口 #

使用docker run命令的-e参数注入环境变量，替换为你的实际Broker地址和端口：

# 示例：外部Broker地址为192.168.1.100，端口为1883
docker run -e MQTT_BROKER=192.168.1.100 -e MQTT_PORT=1883 [你的镜像名称]

如果Broker运行在宿主机上，可使用Docker提供的特殊地址：

• Linux/macOS/Windows（Docker 18.03+）：host.docker.internal

docker run -e MQTT_BROKER=host.docker.internal -e MQTT_PORT=61613 [你的镜像名称]

额外排查项 #

• 确认外部Broker的端口未被防火墙、安全组拦截
• 检查Broker配置是否允许外部连接（需绑定0.0.0.0而非仅127.0.0.1）

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