Paho MQTT客户端运行异常求助：树莓派自建Mosquitto Broker遇问题

嘿，刚接触MQTT和树莓派就遇到问题太正常啦，咱们一步步拆解排查，肯定能找到原因！

1. 先补全并检查你的客户端代码完整性 #

你贴的代码里on_message函数明显没写完（if msg...这里断了），这会直接触发语法错误，导致脚本根本跑不起来。另外，新手很容易漏掉客户端初始化和消息循环的关键代码，先把完整的基础结构补上：

import paho.mqtt.client as mqtt

def on_connect(client, userdata, flags, rc):
    print("Connected with result code "+str(rc))
    # 确认订阅的主题拼写完全正确
    client.subscribe("Example/test")
    client.subscribe("Example/topic")

def on_message(client, userdata, msg):
    # 注意：msg.payload是字节类型，要解码成字符串再判断
    payload_str = msg.payload.decode("utf-8")
    print(f"{msg.topic} {payload_str}")
    if payload_str == "Hello":
        print("Received message #1, do something")
    # 把你没写完的条件补全，比如：
    # elif payload_str == "World":
    #     print("Received message #2, do another thing")

# 关键步骤1：创建客户端实例
client = mqtt.Client()
# 关键步骤2：绑定回调函数
client.on_connect = on_connect
client.on_message = on_message
# 关键步骤3：连接到你的Mosquitto Broker
# 如果Broker和客户端在同一台树莓派上，填"localhost"或者树莓派的本地IP；跨设备的话填Broker的IP
client.connect("localhost", 1883, 60)
# 关键步骤4：启动消息循环，保持客户端运行监听消息
client.loop_forever()

重点注意：

• 一定要调用loop_forever()（阻塞式循环）或者loop_start()（后台线程循环），否则客户端连接后会立刻退出，根本收不到消息。
• msg.payload是字节对象，直接和字符串比较会永远不匹配，必须用decode()转成字符串。

2. 确认Mosquitto Broker正常运行 #

先在树莓派终端里检查Broker状态：

sudo systemctl status mosquitto

如果显示不是active (running)，先启动它：

sudo systemctl start mosquitto

要是启动失败，可以看日志找原因：

sudo journalctl -u mosquitto

另外，检查Broker配置文件（默认路径/etc/mosquitto/mosquitto.conf），确保：

• 没有禁用本地连接
• 默认端口1883没有被修改（如果改了，客户端连接时要对应改端口）
• 如果需要跨设备连接，要确保树莓派的防火墙开放了1883端口。

3. 用命令行工具验证Broker功能 #

先抛开Python代码，用Mosquitto自带的命令行工具测试Broker是否正常：

1. 打开一个终端，启动订阅者：

mosquitto_sub -h localhost -t Example/test

2. 打开另一个终端，发布消息：

mosquitto_pub -h localhost -t Example/test -m "Hello"

如果第一个终端能收到Hello，说明Broker完全没问题，问题肯定出在你的Python客户端代码里；如果收不到，那就是Broker的配置或网络问题，先解决这个。

4. 排查连接返回码 #

运行客户端脚本后，看on_connect里打印的result code：

• 0：连接成功
• 1：协议版本不匹配（比如Broker用MQTT 3.1，客户端用了3.1.1）
• 2：客户端ID无效（比如重复的ID）
• 3：Broker不可达（IP/端口错了，或者Broker没启动）
• 4：用户名/密码错误（如果Broker配置了认证）
• 5：未授权（客户端没有订阅/发布权限）
  根据返回码对应找问题就行。

5. 确认发布脚本的主题和Payload匹配 #

检查你的发布脚本，确保：

• 发布的主题和客户端订阅的主题完全一致（MQTT主题大小写敏感！）
• 发布的Payload是字符串（如果是字节的话也要和客户端解码方式匹配）

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