MQTT客户端连接后立即断开，无法保持连接并发布消息，请求代码问题排查

嘿，看了你的代码和日志，马上抓出了关键问题：日志里的Received CONNACK (0, 5)，这里的返回码rc=5在MQTT协议里明确表示未授权（Not Authorized），这就是连接没法保持、消息发不出去的根本原因！下面一步步帮你解决：

1. 先处理最可能的原因：代理需要身份认证 #

你的代码里完全没设置用户名和密码，但绝大多数MQTT代理（不管是公共的还是私有部署的）都开启了身份验证。如果你的代理要求认证，必须在连接前添加这行代码：

# 把这行放在client.connect()之前，替换成你的代理用户名和密码
client.username_pw_set("你的用户名", "你的密码")

2. 修复代码里的小细节问题 #

除了认证，你的代码还有几个小瑕疵，可能会导致后续逻辑混乱：

• on_connect函数里的参数拼写错了：usedata应该是userdata，虽然暂时不影响功能，但规范写法更利于维护
• 你声明了global connected但根本没定义这个变量，其实完全可以直接用已经设置的client.connected_flag，不需要额外的全局变量
• 无限等待连接的逻辑风险高，可以加个超时，避免程序一直卡着

调整后的完整代码示例：

import paho.mqtt.client as mqtt
import time

broker = "*************"
port = ****
# 替换成你的代理认证信息
mqtt_username = "your_username"
mqtt_password = "your_password"

def on_log(client, userdata, level, buf):
    print(buf)

def on_connect(client, userdata, flags, rc):
    # 修复参数拼写错误
    if rc == 0:
        client.connected_flag = True
        print("client is connected")
    else:
        # 打印具体错误含义，方便排查
        print(f"连接失败，错误码={rc} - {mqtt.connack_string(rc)}")
        client.loop_stop()

def on_disconnect(client, userdata, rc):
    print(f"客户端已断开连接，断开码={rc}")

def on_publish(client, userdata, mid):
    print("发布回调触发，mid= ", mid)

# 给Client类添加连接标志位
mqtt.Client.connected_flag = False
# 创建客户端实例，也可以不指定client_id让paho自动生成随机ID（避免重复冲突）
client = mqtt.Client("MyClient-01")
# 绑定回调函数
client.on_log = on_log
client.on_connect = on_connect
client.on_disconnect = on_disconnect
client.on_publish = on_publish

# 添加身份认证（关键！）
client.username_pw_set(mqtt_username, mqtt_password)

# 发起连接
client.connect(broker, port)
client.loop_start()

# 添加连接超时逻辑，避免无限等待
wait_timeout = 10  # 超时时间10秒
start_time = time.time()
while not client.connected_flag:
    print("等待连接中...")
    time.sleep(1)
    if time.time() - start_time > wait_timeout:
        print("连接超时！")
        client.loop_stop()
        break

# 只有连接成功才执行发布逻辑
if client.connected_flag:
    print("开始发布消息")
    ret = client.publish("house/bulb1", "Test message 0", 0)
    print(f"消息0发布结果: {ret}")
    time.sleep(3)
    ret = client.publish("house/bulb1", "Test message 1", 1)
    print(f"消息1发布结果: {ret}")
    time.sleep(3)
    ret = client.publish("house/bulb1", "Test message 2", 2)
    print(f"消息2发布结果: {ret}")
    time.sleep(3)

    # 停止循环并断开连接
    client.loop_stop()
    client.disconnect()

3. 其他可能的排查方向 #

如果加了认证还是不行，可以试试这些：

• 检查客户端ID唯一性：如果MyClient-01已经被其他客户端占用，有些代理会拒绝连接。可以改成自动生成随机ID：

  client = mqtt.Client()  # 不指定client_id，paho会自动生成唯一ID
  

• 验证代理网络权限：确认你的客户端IP在代理的防火墙/安全组白名单里，能正常访问指定端口
• 检查MQTT协议版本兼容性：paho默认用MQTT 3.1.1，如果你的代理只支持3.1版本，创建客户端时指定：

  client = mqtt.Client("MyClient-01", protocol=mqtt.MQTTv31)
  

先从添加用户名密码开始试，这是rc=5错误最常见的原因！

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