MQTT

安装

pip install paho-mqtt

import paho.mqtt.client as mqtt
import time

def on_connect(client, userdata, flag, rc):
    print("连接")
    print("Connect result" + str(rc))


def on_message(client, userdata, msg):
    print("消息内容")
    print(msg.topic + " " + str(msg.payload))

def on_subscribe(client, userdata, mid, granted_qos):
    print("订阅")
    print("On Subscribed: qos = %d" % granted_qos)


#   取消订阅回调
def on_unsubscribe(client, userdata, mid, granted_qos):
    print("取消订阅")
    print("On unSubscribed: qos = %d" % granted_qos)


def on_publish(client, userdata, mid):
    print("发布消息")
    print("On onPublish: qos = %d" % mid)


def on_disconnect(client, userdata, rc):
    print("断开链接")
    print("Unexpected disconnection rc = " + str(rc))



client = mqtt.Client()
client.on_connect = on_connect
client.on_message = on_message
client.on_publish = on_publish
client.on_disconnect = on_disconnect
client.on_unsubscribe = on_unsubscribe
client.on_subscribe = on_subscribe
client.connect('110.41.39.131', 1883, 600) # 600为keepalive的时间间隔

# client.subscribe('hello', qos=0)
# client.loop_forever() # 保持连接
while True:
    client.publish(topic='Z_topic', payload='{"msg": "LED1open"}', qos=0, retain=False)
    time.sleep(20)