Python的paho-mqtt客户端库使用例程

# python 3.6 import random import time from paho.mqtt import client as mqtt_client broker = '192.168.1.88' port = 1883 topic = "zigbee2mqtt/0x54ef44100035e399/set" # generate client ID with pub prefix randomly client_id = f'python-mqtt-{random.randint(0, 1000)}' def connect_mqtt(): def on_connect(client, userdata, flags, rc): if rc == 0: print("Connected to MQTT Broker!") else: print("Failed to connect, return code %d\n", rc) client = mqtt_client.Client(client_id) client.username_pw_set("autozq","39176430") # 必须设置，否则会返回「Connected with result code 4 client.on_connect = on_connect client.connect(broker, port) return client def publish(client): msg_count = 0 while True: time.sleep(1) msg = "{\"state\": \"TOGGLE\"}"#f"messages: {msg_count}" result = client.publish(topic, msg) # result: [0, 1] status = result[0] if status == 0: print(f"Send `{msg}` to topic `{topic}`") else: print(f"Failed to send message to topic {topic}") msg_count += 1 def run(): client = connect_mqtt() client.loop_start() publish(client) if __name__ == '__main__': run()