MQTT on_message消息接收计数问题求助：全局/局部变量失效

嘿，Arun，这个问题确实挺常见的，我来帮你捋清楚为啥count没法正常计数，以及怎么快速解决～

问题根源 #

你现在的代码里，count是局部变量——每次on_message被MQTT客户端触发时，Python都会重新创建这个变量。如果直接写count=count+1，甚至会直接报错（因为count还没被初始化）；就算你在函数里先写count=0，那每次调用回调都会把count重置为0，自然没法累计计数。

解决方案1：使用全局变量 #

最简单的方法是把count定义成全局变量，然后在回调函数里声明要使用这个全局变量：

# 全局初始化计数变量
count = 0

def on_message(client, userdata, message):
    global count  # 声明这里使用的是全局的count变量
    ts_data = str(message.payload.decode("utf-8"))
    count += 1
    print(f"收到消息次数：{count}")

if __name__ == '__main__':
    client = mqtt.Client()
    client.on_message = on_message
    
    # 别忘了补充MQTT连接和订阅逻辑
    # client.connect("你的MQTT服务器地址", 1883, 60)
    # client.subscribe("你要监听的主题")
    # client.loop_forever()  # 启动消息循环

解决方案2：用类封装（更优雅的方式） #

如果不想用全局变量（全局变量在复杂项目里容易出问题），可以把计数和MQTT客户端逻辑封装到类里，用实例属性来保存计数：

import paho.mqtt.client as mqtt

class MQTTMessageCounter:
    def __init__(self):
        self.message_count = 0  # 用实例属性保存计数
        self.client = mqtt.Client()
        # 把类的方法绑定为回调函数
        self.client.on_message = self.on_message_handler

    def on_message_handler(self, client, userdata, message):
        ts_data = str(message.payload.decode("utf-8"))
        self.message_count += 1
        print(f"收到消息次数：{self.message_count}")

    def start_listening(self):
        # 补充连接和订阅逻辑
        # self.client.connect("你的MQTT服务器地址", 1883, 60)
        # self.client.subscribe("你要监听的主题")
        self.client.loop_forever()

if __name__ == '__main__':
    counter = MQTTMessageCounter()
    counter.start_listening()

注意事项 #

• 不管用哪种方法，都要确保你已经正确连接到MQTT服务器，并且订阅了对应的主题，否则on_message回调根本不会被触发～
• 如果你的项目是多线程或者异步场景，还要考虑线程安全问题（比如用threading.Lock来保护计数变量），不过普通单线程MQTT循环里不需要担心这个。

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