Python Socket程序无法连接MQTT Broker错误排查求助

你代码中存在多个导致MQTT连接失败的问题，按优先级排列如下：

• 端口类型错误：paho.mqtt的client.connect()方法要求第二个端口参数为整数类型，你的代码里broker_port="1883"定义为字符串，传入后会直接触发参数类型错误，连接失败。修改方式为改成broker_port=1883。
• 缩进语法错误：代码里except语句和上层try语句缩进不对齐，且with conn块和外层with socket块缩进平级，会导致要么直接报语法错误无法运行，要么client变量作用域异常、socket提前释放。
• 未启动MQTT客户端网络循环：paho.mqtt客户端需要运行网络循环处理连接握手、心跳、报文收发逻辑，仅调用connect()只是发起连接请求，未完成后续握手流程，is_connected()会一直返回False。需要在connect()成功后调用client.loop_start()启动后台循环处理网络请求。
• 异常捕获逻辑不合理：当前用了裸except不会输出具体错误信息，无法定位问题，建议捕获异常并打印具体报错内容。

另外还有两个影响功能的逻辑问题：

• 生成topic时直接格式化client对象，会生成包含对象内存地址的无效topic，建议改用TCP客户端的IP作为设备标识，比如topic = f"device/{addr[0]}/message"。
• MQTT客户端ID用str(addr)生成，addr是类似('127.0.0.1', 12345)的元组，转字符串后包含特殊字符，部分MQTT Broker不允许客户端ID带特殊字符，建议改成更规范的ID。

修正后的参考代码：

import socket
from obd_data import packet_splitter
# 监听地址如果需要允许外部TCP设备接入，改成0.0.0.0
HOST = '127.0.0.2'
PORT = 65432

import paho.mqtt.client as mqtt
import json
broker_ip = "127.0.0.1"
# 端口改为整数类型
broker_port = 1883

with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
    s.bind((HOST, PORT))
    s.listen()
    conn, addr = s.accept()
    client = None
    try:
        # 生成规范的客户端ID
        client_id = f"tcp_client_{addr[0]}_{addr[1]}"
        client = mqtt.Client(client_id)
        # 连接MQTT Broker
        client.connect(broker_ip, broker_port, 60)
        # 启动后台网络循环处理MQTT报文
        client.loop_start()
        print("MQTT连接成功")
    except Exception as e:
        # 打印具体错误信息方便定位
        print(f"MQTT连接失败，错误信息：{e}")
    
    # 将conn处理逻辑放到socket的with块内部，避免作用域问题
    with conn:
        print('Connected by', addr)
        while True:
            data = conn.recv(1024)
            if not data:
                break
            a = data.hex().upper()
            # 用设备IP生成合法topic
            topic = f"device/{addr[0]}/message"
            payload = {
                "param1": a,
            }
            if client and client.is_connected():
                client.publish(topic, json.dumps(payload))
                print(f"消息发送成功：{topic} - {json.dumps(payload)}")
            else:
                print("MQTT客户端未连接，消息未发送")
            print("=============================")
            conn.sendall(bytes.fromhex('AA00'))
    
    # 程序退出前清理MQTT资源
    if client:
        client.loop_stop()
        client.disconnect()

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