讲师中心 微信公众号
AI工具推荐 视频效率加速

Workerman怎么用MQTT协议_实现物联网通信方法【方法】

冬芳同学_8630

冬芳同学_8630

发布时间:2026-03-13 20:40:03

|

815人浏览过

|

来源于php中文网

原创

不能。Workerman 本身不内置 MQTT 协议栈,需借助官方扩展 workerman/mqtt 实现,该扩展基于 Workerman 构建,支持 MQTT v3.1.1,提供 Server 类并需显式调用 listen() 启动监听。

workerman怎么用mqtt协议_实现物联网通信方法【方法】

Workerman 能不能直接跑 MQTT 服务?

不能。Workerman 本身不内置 MQTT 协议栈,也没有 MQTTServer 类。它只提供 TCP/UDP/WebSocket 底层通信能力,MQTT 是应用层协议,必须自己解析或借助第三方库。

常见错误现象:Connection refused 或客户端连上就断,往往是因为误以为启动了 MQTT 服务,实际只是开了个裸 TCP 端口。

正确做法是:用 Workerman 搭建一个自定义的 Worker,监听 TCP 端口,再在 onMessage 里手动处理 MQTT 的 CONNECT、PUBLISH、SUBSCRIBE 等报文——但这极容易出错,不推荐从零写。

推荐方案:用 workerman/mqtt 扩展包

workerman/mqtt 是官方维护的轻量 MQTT 服务端实现,基于 Workerman 构建,支持 MQTT v3.1.1,能直接响应标准客户端(如 MQTTX、mosquitto_sub)。

安装方式:

composer require workerman/mqtt

关键点:

  • MQTT\Server 是核心类,不是 Worker 子类,但内部依赖 Workerman 启动
  • 必须显式调用 $server->listen(),否则不会真正监听端口
  • 默认不启用 TLS,若需 ssl:// 连接,得额外配置 context 参数并监听 8883
  • 订阅关系由内存管理,重启即丢失;如需持久化,得自己对接 Redis 或数据库

怎么写一个可运行的 MQTT 服务端?

最小可用示例(保存为 mqtt_server.php):

use Workerman\MQTT\Server;

$server = new Server('0.0.0.0', 1883);
$server->onConnect = function ($connection) {
    echo "Client connected: {$connection->getRemoteIp()}\n";
};
$server->onSubscribe = function ($connection, $topics) {
    echo "Client subscribed to: " . implode(', ', array_keys($topics)) . "\n";
};
$server->onPublish = function ($connection, $topic, $payload, $qos) {
    echo "Received on {$topic}: {$payload} (QoS={$qos})\n";
    // 可在此做转发、存库、触发业务逻辑
};
$server->listen();

运行命令:

php mqtt_server.php start -d

注意:

  • 别漏掉 -d,否则进程前台运行,关终端就停
  • 如果本地测试,mosquitto_pub -h 127.0.0.1 -p 1883 -t 'test' -m 'hello' 可验证通路
  • onPublish 回调里不能阻塞太久,否则影响并发;重逻辑建议投递到 TaskWorker

为什么消息收不到?几个高频坑

不是代码写错,而是协议细节没对齐:

  • 客户端用 MQTT v5 连接 v3.1.1 服务端会静默断开,workerman/mqtt 当前不支持 v5
  • 主题(topic)区分大小写,sensor/temp 和 SENSOR/TEMP 是两个不同主题
  • QoS=1/2 的消息,客户端未正确回复 PUBACK/PUBREC,服务端会反复重发,导致连接异常中断
  • Workerman 主进程被 kill 后,子进程可能残留,用 ps aux | grep mqtt_server 清理干净再重启

最常被忽略的一点:MQTT 的「遗嘱消息(Will Message)」和「Clean Session」标志位,会影响客户端重连时的订阅恢复行为——这和 Workerman 无关,但调试时若没意识到,会误判为服务端问题。

热门AI工具

更多
蛙蛙写作

一款AI论文写作工具,主要用于超级AI智能写作助手,适合需要提升相关任务效率的用户。

火山引擎

火山引擎是一款面向企业的云计算与AI服务平台。

豆包大模型

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

小橡皮AI

一款AI工具,主要用于小橡皮一键去AI味,将机器味重的内容改得更有活人感,防止因为 AI 内容被平台打上 AI 标签,以及限流,适合需要提升相关任务效率的用户。

WorkBuddy

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

DeepSeek

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

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

PixTV
PixTV Hot

PixTV是一款面向AIGC内容创作的AI视频生成工具。

相关专题

更多
Workerman安装配置教程
Workerman安装配置教程

Workerman安装配置教程专题提供Workerman安装配置、WebSocket开发、TCP通信、异步编程、高并发服务搭建与PHP实时通信开发教程。

206

2026.05.20

Workerman实时通信与长连接开发教程
Workerman实时通信与长连接开发教程

WWorkerman实时通信与长连接开发教程聚合实时通信、聊天室、长连接、消息推送、AI流式输出等Workerman高并发开发内容。

222

2026.05.20

Workerman异步通信与TCP服务器开发
Workerman异步通信与TCP服务器开发

Workerman异步通信与TCP服务器开发专题整理Workerman异步通信、TCP服务、HTTP服务、WebSocket开发与高并发PHP服务器教程。

207

2026.05.20

Gradle插件开发入门教程
Gradle插件开发入门教程

本专题介绍Gradle插件开发的基本流程,涵盖插件类编写、自定义任务注册、扩展参数设计和插件应用方法,帮助你理解插件如何组织构建逻辑,减少多个项目之间的重复配置。

60

2026.10.22

Gradle Wrapper配置教程
Gradle Wrapper配置教程

本专题介绍Gradle Wrapper的基本作用,涵盖文件组成、生成方法、版本配置和任务调用,帮助你理解项目如何使用指定的Gradle版本,减少不同开发环境带来的构建差异。

40

2026.10.22

Golangci-lint检查器使用教程
Golangci-lint检查器使用教程

本专题整理Golangci-lint常用Linters的用途与配置方法,覆盖错误处理、无效代码、安全、复杂度、命名和依赖检查,帮助项目合理选规则。

40

2026.10.22

Gradle怎么构建Java项目
Gradle怎么构建Java项目

本专题介绍Gradle Java项目构建方法,涵盖Java插件配置、依赖声明、源码编译、测试执行和打包检查,帮助你理解各阶段的任务关系,逐步完成项目构建。

20

2026.10.22

PHP时间戳漏洞修复教程
PHP时间戳漏洞修复教程

本专题汇总PHP常见时间戳漏洞,包括2038年溢出、时区漂移、时间戳伪造、重放攻击、时间盲注与日志审计失效等,并给出升级64位环境、使用 DateTimeImmutable、统一UTC、严格超时校验、预处理绑定、hash_equals 比对等修复方案,帮助开发者快速排查和加固时间相关代码。

40

2026.10.22

Golangci-lint配置文件与规则设置
Golangci-lint配置文件与规则设置

本专题聚焦Golangci-lint YAML配置文件,讲清运行参数、规则启停、目录排除、问题过滤及严重级别设置,便于团队统一检查标准。

20

2026.10.22

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Webman中文手册
Webman中文手册

共0课时 | 0人学习

Workerman官方手册
Workerman官方手册

共0课时 | 0人学习

ThinkPHP5.1完全开发手册
ThinkPHP5.1完全开发手册

共0课时 | 0人学习

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

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