讲师中心 微信公众号

工具推荐

视频效率加速
AniShort
AniShort

AI短剧协同制作平台

updream

一键生成高质量推广成片

Seko
Seko

AI短剧一键生成成片

剧云
剧云

中文短剧剧本制作平台

Python IoT 协议的 MQTT Python 客户端

阿墨吖_7855

阿墨吖_7855

发布时间:2026-02-23 20:11:02

|

969人浏览过

|

来源于php中文网

原创

MQTT客户端需手动启动网络循环才能收发消息;QoS消息依赖broker持久化和固定client_id;payload始终为bytes类型,需显式解码;认证失败多因凭证设置顺序或TLS路径错误。

python iot 协议的 mqtt python 客户端

connect() 调用后没反应?检查 loop_start() 或手动 loop()

MQTT 客户端连接成功不等于消息能收发——connect() 只是发起 TCP 连接并完成协议握手,后续的保活、重连、收包、分发回调全靠网络循环驱动。paho-mqtt 默认不自动启循环,所以常见现象是:日志显示 Connected with result code 0,但 on_message 死活不触发,publish() 也卡住不发。

  • 要么在 connect() 后立刻调用 client.loop_start()(开后台线程,适合长期运行)
  • 要么在主逻辑里写死循环:while True: client.loop(); time.sleep(0.1)(适合脚本或调试)
  • 别用 loop_forever() 做主循环——它会阻塞,后续代码不执行,且无法优雅退出
  • 如果用 loop_start(),记得程序退出前调 client.disconnect() 和 client.loop_stop(),否则可能残留线程

QoS 1/2 消息发出去就消失?确认 broker 支持且客户端没设 clean_session=False

MQTT 的 QoS 不是“发了就一定到”,它依赖 broker 配置和客户端 session 状态。典型表现:本地 publish(topic, payload, qos=1) 返回正常,但订阅端收不到,broker 日志也没记录。

  • 先查 broker 是否启用持久化(如 Mosquitto 需配置 persistence true 和 autosave_interval)
  • 如果客户端初始化时传了 clean_session=False,但没指定 client_id,paho 会自动生成随机 ID——每次启动都是新 session,broker 丢弃旧队列
  • QoS 1 消息在客户端断线重连后,只有 clean_session=False + 固定 client_id 才可能被 broker 重发
  • Python 客户端默认 clean_session=True,别以为设了 QoS 就自动保消息

收到中文乱码或字节对象?payload 是 bytes,不是 str

MQTT 协议本身不关心 payload 编码,paho-mqtt 一律以 bytes 形式传递。常见错误:直接 print(msg.payload) 看到 b'\xe4\xbd\xa0\xe5\xa5\xbd',或者 msg.payload.decode('utf-8') 报 UnicodeDecodeError。

Python Hardener
Python Hardener

通过完整的安全审查、代码整洁重构、健壮的错误处理、正确的日志记录以及完整的文档字符串覆盖,强化 Python 脚本。

下载
  • msg.payload 永远是 bytes 类型,哪怕你 publish 时传的是 str;paho 会自动 encode 成 utf-8,但不会自动 decode
  • 安全解码方式:msg.payload.decode('utf-8', errors='ignore')(忽略非法字节)或 msg.payload.decode('utf-8', errors='replace')(替换成 )
  • 如果 payload 是 JSON,别先 decode 再 json.loads —— 直接 json.loads(msg.payload.decode('utf-8')),少一层中间变量
  • 某些设备(如 ESP32)可能发 GBK 编码,此时需按实际编码 decode,不能硬写 utf-8

频繁断连或 Connection Refused: not authorised?检查 username/password 和 TLS 配置顺序

MQTT 连接失败常被归为“网络问题”,但多数出在认证环节。错误信息如 Connection Refused: not authorised 或静默超时,往往不是防火墙挡的,而是凭证或协议层没对齐。

立即学习“Python免费学习笔记(深入)”;

  • username 和 password 必须在 connect() 前调用 username_pw_set() 设置,不能只传进 connect 参数里(paho 旧版本会忽略)
  • 用 TLS 时,必须在 connect() 前调 tls_set(),且路径要写绝对路径(ca_certs="/etc/mosquitto/ca.crt"),相对路径容易静默失败
  • Mosquitto 默认禁用匿名登录,如果没配 allow_anonymous false 却又没设账号,就会拒绝所有连接
  • 某些云 MQTT 服务(如阿里云 IoT)要求 client_id 包含设备三元组,格式不对也会返回授权失败
事情说清了就结束。MQTT 的坑不在协议多复杂,而在 Python 客户端把底层细节藏太深——connect 不等于可用,payload 不是字符串,QoS 不是银弹,而错误提示常常只告诉你“不行”,不说“哪不行”。

热门AI工具

更多
WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

Lovart
Lovart Hot

一款面向视觉设计创作的AI设计平台,可通过智能体和画布工作流辅助制作海报、Logo、网页、PPT及其他视觉内容。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

二狗PPT
二狗PPT Hot

一款AI演示文稿工具,主要用于专为中式职场打造的AI PPT生成工具,适合需要提升相关任务效率的用户。

Seko
Seko Hot

一款AI视频创作工具,主要用于商汤科技推出的创编一体的AI短视频创作Agent,适合需要提升相关任务效率的用户。

咔片AIPPT

一款在线AI演示文稿制作工具,可根据主题和内容需求辅助生成PPT结构与页面,提高演示材料制作效率。

相关专题

更多
json数据格式
json数据格式

JSON是一种轻量级的数据交换格式。本专题为大家带来json数据格式相关文章,帮助大家解决问题。

2295

2023.08.07

json是什么
json是什么

JSON是一种轻量级的数据交换格式,具有简洁、易读、跨平台和语言的特点,JSON数据是通过键值对的方式进行组织,其中键是字符串,值可以是字符串、数值、布尔值、数组、对象或者null,在Web开发、数据交换和配置文件等方面得到广泛应用。本专题为大家提供json相关的文章、下载、课程内容,供大家免费下载体验。

3742

2023.08.23

jquery怎么操作json
jquery怎么操作json

操作的方法有:1、“$.parseJSON(jsonString)”2、“$.getJSON(url, data, success)”;3、“$.each(obj, callback)”;4、“$.ajax()”。更多jquery怎么操作json的详细内容,可以访问本专题下面的文章。

1236

2023.10.13

go语言处理json数据方法
go语言处理json数据方法

本专题整合了go语言中处理json数据方法,阅读专题下面的文章了解更多详细内容。

4319

2025.09.10

python中print函数的用法
python中print函数的用法

python中print函数的语法是“print(value1, value2, ..., sep=' ', end=' ', file=sys.stdout, flush=False)”。本专题为大家提供print相关的文章、下载、课程内容,供大家免费下载体验。

3360

2023.09.27

python print用法与作用
python print用法与作用

本专题整合了python print的用法、作用、函数功能相关内容,阅读专题下面的文章了解更多详细教程。

269

2026.02.03

while的用法
while的用法

while的用法是“while 条件: 代码块”,条件是一个表达式,当条件为真时,执行代码块,然后再次判断条件是否为真,如果为真则继续执行代码块,直到条件为假为止。本专题为大家提供while相关的文章、下载、课程内容,供大家免费下载体验。

354

2023.09.25

session失效的原因
session失效的原因

session失效的原因有会话超时、会话数量限制、会话完整性检查、服务器重启、浏览器或设备问题等等。详细介绍:1、会话超时:服务器为Session设置了一个默认的超时时间,当用户在一段时间内没有与服务器交互时,Session将自动失效;2、会话数量限制:服务器为每个用户的Session数量设置了一个限制,当用户创建的Session数量超过这个限制时,最新的会覆盖最早的等等。

580

2023.10.17

Postman身份认证怎么配置
Postman身份认证怎么配置

本专题从实际API接口调试场景出发,讲解Postman身份认证的完整配置流程,包括常见认证协议介绍、授权参数设置、访问令牌填写、OAuth 2.0授权及认证失败排查,帮助用户正确完成接口授权与访问验证。

40

2026.11.06

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn