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

通过 mosquitto 了解 MQTT协议

MQTT使用

MQTT与Mosquitto服务器搭建以及Android推送MQTT简介

Ubuntu 16.04安装测试MQTT Mosquitto

MQTT服务器搭建--Mosquitto