用 Workerman 4.0.34 搭建高性能网关

浅敏酱_6056

浅敏酱_6056

2026-08-07

725人浏览

原创

workerman 4.0.34 搭建高性能网关须严格区分协议:mqtt 必用 workerman/mqtt 扩展实现完整协议栈,tcp/http/websocket 可基于 workerman/workerman 构建,禁止裸 worker 监听 1883 端口手动解析;需 php ≥ 7.4、linux/macos/wsl2 环境,启用 pcntl 和 posix 扩展;安装 composer require workerman/mqtt:^2.0;mqtt 网关必须 use workerman\mqtt\server,实例化 new server('0.0.0.0', 1883) 并调用 ->listen();tcp 网关转发禁用字符串处理,鉴权网关需在 onconnect 绑定 client_id 并 onmessage 校验授权;部署后用 mosquitto_sub 或 mqttx 验证,日志默认输出至 ./workerman.log。

用 workerman 4.0.34 搭建高性能网关

用 Workerman 4.0.34 搭建高性能网关,需严格区分协议类型与组件职责:MQTT 网关必须用 workerman/mqtt 扩展实现完整协议栈,TCP/HTTP/WebSocket 网关可直接基于 workerman/workerman 构建,不可混用裸 Worker 监听 1883 端口并手动解析二进制帧。

安装与环境准备

执行 composer create-project workerman/workerman 初始化项目骨架,避免 autoload 配置遗漏;确认 PHP CLI 已启用 pcntl 和 posix 扩展:php -m | grep -E "pcntl|posix",缺失则需在 php.ini 中取消对应 extension 行注释。

Workerman 4.0.34 要求 PHP 版本 ≥ 7.4,且仅支持 Linux/macOS/WSL2 环境;Windows 用户若强行运行,将触发 undefined function pcntl_fork() 致命错误。

安装 MQTT 服务端扩展:composer require workerman/mqtt:^2.0,该版本已适配 Workerman 4.0.x 主线,不兼容 v1.x 的旧写法。

启动标准 MQTT 网关

创建 mqtt_gateway.php,内容如下:

第一行必须引入 use Workerman\MQTT\Server;不能写成 use Workerman\Worker; + 手动解析 CONNECT 包,否则客户端连上即断,现象为 Connection reset by peer

实例化时传入地址和端口:$server = new Server('0.0.0.0', 1883);;注意协议前缀 mqtt:// 是非法的,Workerman 不识别该字符串,会导致监听失败。

调用 $server->listen(); 启动监听,缺此行端口不会真正打开;若需 TLS,则改用 new Server('0.0.0.0', 8883, ['ssl' => $context]) 并配置证书上下文。

构建 TCP 协议透传网关

方法一:纯转发模式(无协议解析)

CodiumAI
CodiumAI

CodiumAI是一款用于生成测试、代码审查和保障代码质量的 AI 开发工具,现品牌为 Qodo。

下载

创建 tcp_gateway.php,使用 Worker('tcp://0.0.0.0:9000') 实例化;onMessage 回调中禁止对 $data 做任何字符串截取或 JSON 解码,因原始字节流可能含 \x00 或非 UTF-8 字符,强行 decode 会中断连接。

转发逻辑写为:$upstream->send($data);,其中 $upstream 是预建立的上游连接对象;连接池需自行维护,Workerman 不提供内置连接池。

方法二:带设备鉴权的 TCP 网关

onConnect 中记录 client_id 与 IP 绑定关系;onMessage 开头先查该 connection 是否已通过 /auth 主题完成握手,未通过则 $connection->close();

鉴权成功后,将 connection 存入全局数组:$connections[$client_id] = $connection;;后续下行指令按 client_id 查表推送,避免广播风暴。

部署与验证

执行 php mqtt_gateway.php start -d 后,用 mosquitto_sub -t '#' -v -h 127.0.0.1 -p 1883 测试订阅;若返回 Connection refused,检查是否漏掉 $server->listen() 或防火墙拦截 1883 端口。

使用 MQTTX 客户端连接时,Broker 地址填 mqtt://127.0.0.1:1883,协议版本选 3.1.1;若提示 Not authorized,说明 onConnect 回调中未调用 $connection->authorize(true) 显式放行。

日志输出默认写入 ./Workerman.log,每条记录含时间戳与连接 ID;调试阶段建议临时关闭守护模式:php mqtt_gateway.php start,实时观察控制台输出。

相关文章

数码产品性能查询
数码产品性能查询

该软件包括了市面上所有手机CPU,手机跑分情况,电脑CPU,电脑产品信息等等,方便需要大家查阅数码产品最新情况,了解产品特性,能够进行对比选择最具性价比的商品。

下载

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

相关专题

更多
php文件怎么打开
php文件怎么打开

打开php文件步骤:1、选择文本编辑器;2、在选择的文本编辑器中,创建一个新的文件,并将其保存为.php文件;3、在创建的PHP文件中,编写PHP代码;4、要在本地计算机上运行PHP文件,需要设置一个服务器环境;5、安装服务器环境后,需要将PHP文件放入服务器目录中;6、一旦将PHP文件放入服务器目录中,就可以通过浏览器来运行它。

2023.09.01

8984

6

php怎么取出数组的前几个元素
php怎么取出数组的前几个元素

取出php数组的前几个元素的方法有使用array_slice()函数、使用array_splice()函数、使用循环遍历、使用array_slice()函数和array_values()函数等。本专题为大家提供php数组相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.11

5461

5

php反序列化失败怎么办
php反序列化失败怎么办

php反序列化失败的解决办法检查序列化数据。检查类定义、检查错误日志、更新PHP版本和应用安全措施等。本专题为大家提供php反序列化相关的文章、下载、课程内容,供大家免费下载体验。

2023.10.11

1995

5

php怎么连接mssql数据库
php怎么连接mssql数据库

连接方法:1、通过mssql_系列函数;2、通过sqlsrv_系列函数;3、通过odbc方式连接;4、通过PDO方式;5、通过COM方式连接。想了解php怎么连接mssql数据库的详细内容,可以访问下面的文章。

2023.10.23

3388

4

php连接mssql数据库的方法
php连接mssql数据库的方法

php连接mssql数据库的方法有使用PHP的MSSQL扩展、使用PDO等。想了解更多php连接mssql数据库相关内容,可以阅读本专题下面的文章。

2023.10.23

4054

6

html怎么上传
html怎么上传

html通过使用HTML表单、JavaScript和PHP上传。更多关于html的问题详细请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.03

3171

9

PHP出现乱码怎么解决
PHP出现乱码怎么解决

PHP出现乱码可以通过修改PHP文件头部的字符编码设置、检查PHP文件的编码格式、检查数据库连接设置和检查HTML页面的字符编码设置来解决。更多关于php乱码的问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.09

4497

8

php文件怎么在手机上打开
php文件怎么在手机上打开

php文件在手机上打开需要在手机上搭建一个能够运行php的服务器环境,并将php文件上传到服务器上。再在手机上的浏览器中输入服务器的IP地址或域名,加上php文件的路径,即可打开php文件并查看其内容。更多关于php相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

2023.11.13

3502

8

sprintf函数用法详解
sprintf函数用法详解

sprintf函数的用法:1、格式化字符串;2、指定输出宽度和精度;3、返回值。更多关于sprintf函数用法详解的内容,大家可以阅读下面的文章。

2023.11.27

11562

4

热门下载

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

精品课程

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

共0课时 | 0人学习

Workerman官方手册
Workerman官方手册

共0课时 | 0人学习

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

共0课时 | 0人学习