在 Python 中使用 MQTT的方法
31 浏览量
2020-09-16
09:34:10
上传
评论 1
收藏 163KB PDF 举报
在在 Python 中使用中使用 MQTT的方法的方法
主要介绍了在 Python 中使用 MQTT的方法，帮助大家更好的理解和学习python，感兴趣的朋友可以了解下
Python 是一种广泛使用的解释型、高级编程、通用型编程语言。Python 的设计哲学强调代码的可读性和简洁的语法（尤其是
使用空格缩进划分代码块，而非使用大括号或者关键词）。Python 让开发者能够用更少的代码表达想法，不管是小型还是大
型程序，该语言都试图让程序的结构清晰明了。
MQTT 是一种基于发布/订阅模式的 轻量级物联网消息传输协议 ，可以用极少的代码和带宽为联网设备提供实时可靠的消息服
务，它广泛应用于物联网、移动互联网、智能硬件、车联网、电力能源等行业。
本文主要介绍如何在 Python 项目中使用 paho-mqtt 客户端库 ，实现客户端与 MQTT 服务器的连接、订阅、取消订阅、收发
消息等功能。
项目初始化项目初始化
本项目使用 Python 3.6 进行开发测试，读者可用如下命令确认 Python 的版本。
➜ ~ python3 --version
Python 3.6.7
选择选择 MQTT 客户端库客户端库
paho-mqtt 是目前 Python 中使用较多的 MQTT 客户端库，它在 Python 2.7 或 3.x 上为客户端类提供了对 MQTT v3.1 和
v3.1.1 的支持。它还提供了一些帮助程序功能，使将消息发布到 MQTT 服务器变得非常简单。
Pip 安装安装 Paho MQTT 客户端客户端
Pip 是 Python 包管理工具，该工具提供了对 Python 包的查找、下载、安装、卸载的功能。
pip3 install -i https://pypi.doubanio.com/simple paho-mqtt
Python MQTT 使用使用
连接连接 MQTT 服务器服务器
本文将使用 EMQ X 提供的 免费公共 MQTT 服务器 ，该服务基于 EMQ X 的 MQTT 物联网云平台 创建。服务器接入信息如
下：
Broker: broker.emqx.io
TCP Port: 1883
Websocket Port: 8083
导入导入 Paho MQTT客户端客户端
from paho.mqtt import client as mqtt_client
设置设置 MQTT Broker 连接参数连接参数
设置 MQTT Broker 连接地址，端口以及 topic，同时我们调用 Python random.randint 函数随机生成 MQTT 客户端 id。
broker = 'broker.emqx.io'
port = 1883
topic = "/python/mqtt"
client_id = f'python-mqtt-{random.randint(0, 1000)}'
编写编写 MQTT 连接函数连接函数
编写连接回调函数 on_connect ，该函数将在客户端连接后被调用，在该函数中可以依据 rc 来判断客户端是否连接成功。通
常同时我们将创建一个 MQTT 客户端，该客户端将连接到 broker.emqx.io 。
def connect_mqtt():
def on_connect(client, userdata, flags, rc):
if rc == 0:
print("Connected to MQTT Broker!")
else:
print("Failed to connect, return code %d", rc)
# Set Connecting Client ID
client = mqtt_client.Client(client_id)
资源评论
