使用公共MQTT Broker（如Eclipse）出现TimeoutError问题求助

本地Broker（localhost）运行正常，但切换到公共Broker（如mqtt.eclipse.org）时抛出错误：

TimeoutError: timed out

相关代码：

import paho.mqtt.client as mqtt
import time
import datetime

def on_message(client, userdata, message):
    print("Message received: ", message.payload.decode("utf-8"))

broker_address = "mqtt.eclipse.org"
client = mqtt.Client("P1")
client.on_message = on_message

client.connect(broker_address, port=1883)  # 默认MQTT端口为1883

client.loop_start()

while True:
    current_time = datetime.datetime.now().strftime("%Y-%m-%d %H:%M:%S")
    client.publish("house/bulbs/bulb1", current_time)
    print(f"Published: {current_time}")
    time.sleep(1)

client.loop_stop()

排查解决步骤 #

• 测试网络与端口连通性
  公共Broker的1883端口可能被网络防火墙/代理拦截，或服务端限制访问。用以下命令测试端口是否可达：

  telnet mqtt.eclipse.org 1883
  # 或
  nc -zv mqtt.eclipse.org 1883
  

  如果不通，尝试切换到8883端口（TLS加密），修改代码中的端口参数：

  client.connect(broker_address, port=8883)
  

• 添加连接回调与日志
  原代码缺少错误反馈机制，添加回调函数能明确连接失败原因：

  def on_connect(client, userdata, flags, rc):
      if rc == 0:
          print("连接成功")
      else:
          print(f"连接失败，返回码：{rc}")
  
  def on_log(client, userdata, level, buf):
      print(f"日志信息：{buf}")
  
  client.on_connect = on_connect
  client.on_log = on_log
  

  通过返回码和日志可以定位是权限、网络还是协议问题。

• 更换公共Broker
  mqtt.eclipse.org可能存在地区访问限制或服务不稳定，替换为其他公共Broker：

  • test.mosquitto.org
  • broker.hivemq.com
    修改代码中的broker_address即可。

• 使用随机客户端ID
  公共Broker要求客户端ID唯一，固定ID可能导致冲突。让库自动生成随机ID：

  client = mqtt.Client()  # 不指定固定ID
  

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