PHP Webman自定义进程类_Webman实现长连接与数据监听逻辑【进阶】

秋静姑娘_4965

秋静姑娘_4965

2026-05-24

828人浏览

原创

webman长连接需通过继承support\process的自定义进程实现,不可直接extends workerman\worker;onworkerstart中创建worker实例并调用listen(),由webman主循环托管;连接状态、粘包、心跳、数据推送等均需手动管理。

php webman自定义进程类_webman实现长连接与数据监听逻辑【进阶】

Webman 本身不提供“长连接管理器”或“数据监听抽象层”,所有长连接(TCP/WS)和实时数据监听逻辑,都必须通过自定义进程 + Workerman 原生 API 实现。你不能在 app/controller 或中间件里写 onMessage,也不能靠路由转发二进制帧。

自定义进程类必须继承 support\Process,不是 Workerman\Worker

这是最常踩的坑:很多人照着 Workerman 文档直接 extends Workerman\Worker,结果进程启动后无日志、onWorkerStart 不执行、ps aux 看不到子进程。

  • support\Process 是 Webman 封装的基类,它负责将进程注册进主循环、处理信号转发(如 SIGTERM)、兼容 config/process.php 配置项(如 count、user)
  • 若手动 extends Workerman\Worker,就绕过了 Webman 的进程生命周期管理,onWorkerStart 可能被忽略,onWorkerStop 根本不会触发
  • 正确写法:class TcpMonitorProcess extends support\Process,且必须实现 public function onWorkerStart($worker)
  • 类文件路径必须是 app/Process/TcpMonitorProcess.php(注意大小写与命名空间匹配),否则自动加载失败报 Class not found

onWorkerStart 里不能阻塞,但可以启动 Worker 实例

Webman 自定义进程的 onWorkerStart 是一个回调入口,不是长期运行的主循环。你想监听 TCP,就得在里面 new 一个 Workerman\Worker 实例并 runAll() —— 但这会阻塞当前进程,导致 Webman 主循环卡死。正确做法是把 Worker 当作子服务启动,由它自己管理事件循环。

btpanel phpsite 宝塔面板PHP网站
btpanel phpsite 宝塔面板PHP网站

宝塔面板 PHP 网站管理:站点创建、删除、启停、PHP 版本切换、域名管理、SSL证书管理、伪静态管理、数据库管理

下载
  • 在 onWorkerStart 中创建 Workerman\Worker 实例,例如:$tcp_worker = new Worker('tcp://0.0.0.0:9502');
  • 设置 $tcp_worker->count = 1;(避免多进程冲突端口)
  • 绑定 onConnect/onMessage 回调,但不要调用 Worker::runAll() —— Webman 主进程已托管事件循环
  • 最后执行 $tcp_worker->listen();,Workerman 内部会自动将其纳入全局事件循环
  • 若漏掉 listen(),进程看似启动,实则不监听任何连接,客户端 connect 后立刻 EOF

长连接状态必须自己维护,没有内置连接池或上下文

HTTP 请求有 Request/Response 对象封装生命周期,而 TCP 连接没有“请求上下文”。每个 TcpConnection 是裸对象,onMessage 收到的数据是原始字节流,断连后连接对象即销毁 —— 你要存用户 ID、会话状态、心跳时间,全得自己来。

  • 用 static $connections = []; 或 swoole_table(需扩展)缓存活跃连接,key 为 $connection->id
  • 在 onConnect 中记录连接时间、IP、初始化 session 字段;在 onClose 中 unset 对应条目
  • 粘包/半包必须手动处理:不能直接 json_decode($data),要先解析协议头(如前4字节为包长度),再循环 $connection->recv() 直到收满
  • 心跳超时检测不能依赖 HTTP 中间件,得用 Workerman\Timer::add() 定期遍历 $connections,对超过 60 秒无 onMessage 的连接主动 close()
  • 数据库操作要用 support\Db:: 静态门面,但注意事务不跨连接 —— 每个 TCP 连接的操作都是独立会话,别指望 Db::transaction() 能覆盖多个 onMessage 调用

监听数据变更不能靠“事件总线”,得轮询或订阅底层存储

Webman 没有类似 Laravel 的 Event 系统广播到所有长连接。你想让某个 TCP 连接实时收到“订单状态更新”,不能发个 event(new OrderUpdated) 就完事。

  • 常见做法是:在业务代码(如控制器)中,更新数据库后,显式调用一个推送函数,遍历目标连接列表并 $connection->send()
  • 更高效的方式是接入消息队列(如 RabbitMQ),在 RabbitMQProcess 中消费消息,再根据 routing key 或 payload 决定推送给哪些 TCP 连接
  • Redis Pub/Sub 也可行,但要注意:PHP Redis 连接默认非持久,subscribe() 会阻塞,必须用 set_timeout(0) + 循环 read(),且无法在 onMessage 中直接调用(会冲突事件循环)
  • 切勿在 onMessage 回调里做耗时同步操作(如 file_get_contents、curl_exec),会阻塞整个 Worker 进程,影响其他连接

真正的难点不在启动监听,而在连接生命周期管理与数据一致性 —— 每个 TcpConnection 是孤立的,没有共享内存、没有自动 GC、没有请求 ID 追踪。你写的每一行 onClose 和 Timer::add(),都在补 HTTP 模型缺失的那一块地基。

php免费学习视频:立即使用
踏上前端学习之旅,开启通往精通之路!从前端基础到项目实战,循序渐进,一步一个脚印,迈向巅峰!

相关文章

PHP速学教程(入门到精通)
PHP速学教程(入门到精通)

PHP怎么学习?PHP怎么入门?PHP在哪学?PHP怎么学才快?不用担心,这里为大家提供了PHP速学教程(入门到精通),有需要的小伙伴保存下载就能学习啦!

下载

相关标签:

webman php

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

相关专题

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

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

2023.09.01

10104

6

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

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

2023.10.11

5981

5

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

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

2023.10.11

2075

5

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

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

2023.10.23

3748

4

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

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

2023.10.23

4454

6

html怎么上传
html怎么上传

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

2023.11.03

3491

9

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

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

2023.11.09

4977

8

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

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

2023.11.13

3902

8

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

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

2023.11.27

11862

4

热门下载

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

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Webman和FastAPI的性能对比
Webman和FastAPI的性能对比

共0课时 | 310人学习

Webman中文手册
Webman中文手册

共0课时 | 0人学习

webman初步使用及后台搭建
webman初步使用及后台搭建

共15课时 | 2.7万人学习