Django中继承paho mqtt基类后子类无法获取消息payload如何解决

• 父类Initializer的__init__方法中未显式绑定on_message回调到MQTT客户端实例，导致回调逻辑未按预期走多态分发，若其他位置隐式绑定了父类的on_message方法，就会出现子类重写方法不触发的问题。
• 父类未实现已绑定的on_subscribe回调方法，存在运行时报错隐患。
• 子类begin方法中订阅主题使用了硬编码的"topic"字符串，而非传入的topic参数，导致实际订阅主题和预期不一致。

1. 父类__init__中补全on_message回调绑定，利用Python类的多态特性，子类重写on_message后会自动调用子类实现，无需在子类重复绑定。
2. 补全父类缺失的on_subscribe方法，避免运行时异常。
3. 修正子类begin方法中的订阅逻辑，使用传入的topic参数而非硬编码值。
4. 移除子类中冗余的on_message重复绑定代码。

父类实现 #

import time
import paho.mqtt.client as mqtt

# 替换为实际MQTT配置
mqtt_server = "MQTT服务地址"
mqtt_username = "账号"
mqtt_password = "密码"
broker = "Broker地址"
mqtt_port = 1883

class Initializer():
    def __init__(self):
        self.client = mqtt.Client(mqtt_server+str(int(time.time())))  
        self.client.username_pw_set(username=mqtt_username, password=mqtt_password)
        # 绑定全量回调
        self.client.on_connect = self.on_connect
        self.client.on_subscribe = self.on_subscribe
        self.client.on_message = self.on_message
        self.client.connect(broker, mqtt_port)
        self.client.loop_start()
    
    def on_connect(self, client, userdata, flags, rc):
        if rc == 0:
            print("设备连接成功")
        else:
            print(f"连接失败，错误码：{rc}")
    
    def on_subscribe(self, client, userdata, mid, granted_qos):
        print(f"订阅成功，消息ID：{mid}，QoS等级：{granted_qos}")

    def on_message(self, client, userdata, message):
        print(f"父类接收消息，主题：{message.topic}，内容：{message.payload}")

子类实现 #

class PublishData(Initializer):
    def __init__(self):
        super().__init__()
    
    def on_message(self, client, userdata, message):
        # payload为字节类型，需解码为字符串
        print(f"子类接收消息，主题：{message.topic}，内容：{message.payload.decode('utf-8')}")

    def begin(self, topic, data):
        self.client.subscribe(topic)
        self.client.publish(topic, str(data))

# 调用示例
if __name__ == "__main__":
    test_topic = "test/custom_topic"
    test_data = {"content": "测试消息"}
    publishData = PublishData()
    # 等待连接建立完成再操作，避免连接未就绪导致操作失败
    time.sleep(1)
    publishData.begin(test_topic, test_data)
    # 保持进程运行监听消息
    while True:
        time.sleep(2)

• MQTT消息的payload默认是字节类型，需调用decode('utf-8')方法转换为字符串后再做业务处理。
• 生产环境建议将订阅、发布逻辑放到on_connect回调中触发，避免硬编码等待时长不可靠的问题。
• 类名建议遵循Python大驼峰命名规范，首字母大写，更符合通用编码规范。
• Django项目中使用时，需注意MQTT的loop_start会启动独立线程，不要在请求处理方法中频繁实例化该类，避免创建大量MQTT连接和线程，建议将实例作为全局单例使用。

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