Python 连接 MQTT，接受、发送消息示例

""" python 收发 mqtt 消息 """ import json import paho.mqtt.client as mqtt # 该函数为连接 mqtt server 成功时的回调函数，可以再这个函数中发送消息 def on_connect(client, userdata, rc, *extra_params): print('Connected with result code ' + str(rc)) print('connected') # 为了测试收发消息，需要先订阅一个主题用来接收我发送的消息 client.subscribe(f'demo', qos=0) data = { 'code': 0, 'message': 'hello' } # 发送消息. payload 为消息负载，发送的消息格式一般为 json。所以这里我们使用 json.dumps() 将数据转成 json client.publish('demo', payload=json.dumps(data), qos=0) print("send message finished") # 该函数为接受到 mqtt 消息时的回调函数 def on_message(client, userdata, msg): print(f'Incoming message\nTopic: {msg.topic}\nMessage: {str(msg.payload)}') if __name__ == '__main__': # 创建 mqtt 客户端实例 client = mqtt.Client() # 设置用户名及密码 client.username_pw_set('device_declare', '123456') client.on_connect = on_connect client.on_message = on_message # 连接 mqtt server client.connect('192.168.1.151', port=53883) client.loop_forever()