0

0

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

蓮花仙者

蓮花仙者

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

|

735人浏览过

|

来源于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

关键点:

Cliclic AI
Cliclic AI

Cliclic商品背景图编辑器是一款功能强大的AI工具,帮助用户快速生成具有吸引力的商品图背景。

下载
  • 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/tempSENSOR/TEMP 是两个不同主题
  • QoS=1/2 的消息,客户端未正确回复 PUBACK/PUBREC,服务端会反复重发,导致连接异常中断
  • Workerman 主进程被 kill 后,子进程可能残留,用 ps aux | grep mqtt_server 清理干净再重启

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

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

WorkBuddy
WorkBuddy

腾讯云推出的AI原生桌面智能体工作台

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
session失效的原因
session失效的原因

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

336

2023.10.17

session失效解决方法
session失效解决方法

session失效通常是由于 session 的生存时间过期或者服务器关闭导致的。其解决办法:1、延长session的生存时间;2、使用持久化存储;3、使用cookie;4、异步更新session;5、使用会话管理中间件。

776

2023.10.18

cookie与session的区别
cookie与session的区别

本专题整合了cookie与session的区别和使用方法等相关内容,阅读专题下面的文章了解更详细的内容。

97

2025.08.19

堆和栈的区别
堆和栈的区别

堆和栈的区别:1、内存分配方式不同;2、大小不同;3、数据访问方式不同;4、数据的生命周期。本专题为大家提供堆和栈的区别的相关的文章、下载、课程内容,供大家免费下载体验。

444

2023.07.18

堆和栈区别
堆和栈区别

堆(Heap)和栈(Stack)是计算机中两种常见的内存分配机制。它们在内存管理的方式、分配方式以及使用场景上有很大的区别。本文将详细介绍堆和栈的特点、区别以及各自的使用场景。php中文网给大家带来了相关的教程以及文章欢迎大家前来学习阅读。

605

2023.08.10

常用的数据库软件
常用的数据库软件

常用的数据库软件有MySQL、Oracle、SQL Server、PostgreSQL、MongoDB、Redis、Cassandra、Hadoop、Spark和Amazon DynamoDB。更多关于数据库软件的内容详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1007

2023.11.02

内存数据库有哪些
内存数据库有哪些

内存数据库有Redis、Memcached、Apache Ignite、VoltDB、TimesTen、H2 Database、Aerospike、Oracle TimesTen In-Memory Database、SAP HANA和ache Cassandra。更多关于内存数据库相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

673

2023.11.14

mongodb和redis哪个读取速度快
mongodb和redis哪个读取速度快

redis 的读取速度比 mongodb 更快。原因包括:1. redis 使用简单的键值存储,而 mongodb 存储 json 格式的数据,需要解析和反序列化。2. redis 使用哈希表快速查找数据,而 mongodb 使用 b-tree 索引。因此,redis 在需要高性能读取操作的应用程序中是一个更好的选择。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

501

2024.04.02

TypeScript类型系统进阶与大型前端项目实践
TypeScript类型系统进阶与大型前端项目实践

本专题围绕 TypeScript 在大型前端项目中的应用展开,深入讲解类型系统设计与工程化开发方法。内容包括泛型与高级类型、类型推断机制、声明文件编写、模块化结构设计以及代码规范管理。通过真实项目案例分析,帮助开发者构建类型安全、结构清晰、易维护的前端工程体系,提高团队协作效率与代码质量。

26

2026.03.13

热门下载

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

精品课程

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号