python MQTT消息中间件mosquitto 消息获取(从MQTT服务器取消息)
Posted Dontla
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了python MQTT消息中间件mosquitto 消息获取(从MQTT服务器取消息)相关的知识,希望对你有一定的参考价值。
一个简单的python demo,从MQTT消息中间件获取消息
安装paho-mqtt库
apt update ; apt install python3-pip ; pip3 install paho-mqtt
编写代码
testReceive.py
import paho.mqtt.client as mqtt
#定义连接成功后的回调函数
def on_connect(client, userdata, flags, rc):
print("Connected with result code "+str(rc))
#订阅主题
client.subscribe("kyai")
#定义收到消息后的回调函数
def on_message(client, userdata, msg):
print(msg.topic+" "+str(msg.payload))
#创建MQTT客户端实例
client = mqtt.Client()
#设置连接成功和收到消息的回调函数
client.on_connect = on_connect
client.on_message = on_message
#连接MQTT代理服务器
client.connect("192.168.1.91", 1883, 60)
#启动MQTT客户端的网络循环
client.loop_forever()
注释解释如下:
- import paho.mqtt.client as mqtt:导入paho.mqtt.client模块,用于连接MQTT代理服务器。
- def on_connect(client, userdata, flags, rc)::定义连接成功后的回调函数,其中client表示MQTT客户端实例,userdata表示用户自定义数据,flags表示连接标志,rc表示连接返回码。
- print("Connected with result code "+str(rc)):打印连接成功的信息,并输出返回码。
- client.subscribe(“kyai”):订阅主题为"kyai"的消息。
- def on_message(client, userdata, msg)::定义收到消息后的回调函数,其中client表示MQTT客户端实例,userdata表示用户自定义数据,msg表示接收到的消息。
- print(msg.topic+" "+str(msg.payload)):打印接收到的消息的主题和内容。
- client = mqtt.Client():创建MQTT客户端实例。
- client.on_connect = on_connect:设置连接成功的回调函数。
- client.on_message = on_message:设置收到消息的回调函数。
- client.connect(“192.168.1.91”, 1883, 60):连接MQTT代理服务器,其中"192.168.1.91"是MQTT代理服务器的IP地址,1883是MQTT代理服务器的端口号,60是连接超时时间(以秒为单位)。
- client.loop_forever():启动MQTT客户端的网络循环,用于处理收到的消息。该函数将一直阻塞,直到程序结束或出现异常。
运行
python3 testReceive.py
运行结果
以上是关于python MQTT消息中间件mosquitto 消息获取(从MQTT服务器取消息)的主要内容,如果未能解决你的问题,请参考以下文章
9.Arduino基础入门— 如何在Windows上安装Mosquitto MQTT Broker
MQTT与Mosquitto服务器搭建以及Android推送MQTT简介