用 python 进行 MQTT 通信

简介

MQtT（Message Queuing Telemetry Transport）是一种轻量级的消息传输协议，常用于物联网设备之间的通信。Python 提供了多个 MQTT 客户端库，可以方便地实现 MQTT 通信。

本文将介绍如何使用 Python 进行 MQTT 通信，并提供一些基本的使用示例。

安装 MQTT 客户端库

在开始之前，我们需要安装 Python 的 MQTT 客户端库。在命令行中执行以下命令来安装 paho-mqtt 库：

pip install paho-mqtt

MQTT 发布者

以下是一个简单的 MQTT 发布者示例，用于向 MQTT 代理（broker）发布消息。

import paho.mqtt.client as mqtt# 连接成功回调函数def on_connect(client, userdata, flags, rc):    print("Connected with result code " + str(rc))    client.publish("topic/test", "Hello, MQTT!")# 创建客户端实例client = mqtt.Client()# 设置连接成功回调函数client.on_connect = on_connect# 连接到 MQTT 代理client.connect("broker.example.com", 1883, 60)# 循环处理网络流量client.loop_forever()

上述代码创建了一个 MQTT 客户端实例，并设置了连接成功的回调函数。在回调函数中，我们使用 publish 方法向主题 “topic/test” 发布消息。

MQTT 订阅者

以下是一个简单的 MQTT 订阅者示例，用于从 MQTT 代理接收消息。

import paho.mqtt.client as mqtt# 连接成功回调函数def on_connect(client, userdata, flags, rc):    print("Connected with result code " + str(rc))    client.subscribe("topic/test")# 消息接收回调函数def on_message(client, userdata, msg):    print(msg.topic + " " + str(msg.payload))# 创建客户端实例client = mqtt.Client()# 设置连接成功和消息接收的回调函数client.on_connect = on_connectclient.on_message = on_message# 连接到 MQTT 代理client.connect("broker.example.com", 1883, 60)# 循环处理网络流量client.loop_forever()

上述代码创建了一个 MQTT 客户端实例，并设置了连接成功和消息接收的回调函数。在回调函数中，我们使用 subscribe 方法订阅主题 “topic/test”，并在接收到消息时打印消息内容。

总结

使用 Python 进行 MQTT 通信非常简单。通过 paho-mqtt 客户端库，我们可以轻松地实现 MQTT 发布者和订阅者，并与 MQTT 代理进行消息交互。希望本文能够帮助你入门使用 Python 进行 MQTT 通信。

来源地址：https://blog.csdn.net/sinat_35773915/article/details/131475532