Title:
python开发的mqtt发送与接收程序
[Print this page]
Author:
sky999
Time:
2023-11-27 11:40
Title:
python开发的mqtt发送与接收程序
发送--------------------- import paho.mqtt.publish as publish # MQTT服务器的地址 mqtt_broker = "127.0.0.1" # 要发布的主题 mqtt_topic = "www.caffz.com" # 要发布的内容 mqtt_message = "Hello from
www.caffz.com!
" # 发布消息 publish.single(mqtt_topic, mqtt_message, hostname=mqtt_broker) 接收-------------------------- import paho.mqtt.client as mqtt # MQTT服务器的地址 mqtt_broker = "127.0.0.1" # 订阅的主题 mqtt_topic = "www.caffz.com" def on_connect(client, userdata, flags, rc): print("Connected with result code "+str(rc)) # 订阅主题 client.subscribe(mqtt_topic) def on_message(client, userdata, msg): print(f"Received message: {msg.payload.decode()}") # 创建MQTT客户端 client = mqtt.Client() # 设置连接和消息回调 client.on_connect = on_connect client.on_message = on_message # 连接到MQTT服务器 client.connect(mqtt_broker, 1883, 60) # 保持连接 client.loop_forever()
Welcome AbyssalSwamp (http://bbs.caffz.com:12345/mud/AbyssalSwamp/index/)
caffz.com
