如何将ThinkPHP与WebSocket集成实现实时消息通知功能？

本文共计930个文字，预计阅读时间需要4分钟。

ThinkPHP 本身不内置 WebSocket 服务，因此要实现长连接功能，必须依赖外部常驻进程（如 Swoole 或 Workerman）来维持。直接在 HTTP 请求中调用一次就推送一条的方法是无效的——这仅仅是普通的 HTTP 响应，不是实时推送。

---

为什么不能用 curl_init("ws://...") 或 new WebSocket() 在 PHP 里发推送

这是最常踩的坑：误以为 PHP 能像浏览器 JS 那样直接连 ws://。

• curl_init("ws://") 会报 Unsupported protocol —— cURL 根本不识别 ws:// 协议
• class WebSocket not found —— PHP 没有原生 WebSocket 类，JS 的 WebSocket 构造函数只存在于浏览器环境
• 用 stream_socket_client("tcp://") 手动发字符串，浏览器收不到数据 —— 缺少 WebSocket 握手（HTTP Upgrade）、帧封装（MASK、FIN、opcode），协议层面就不合法

真正可行的路径只有一条：业务 PHP 进程通过轻量通道（HTTP / Redis / Socket）通知已常驻的 WebSocket 服务进程，由它执行 $connection->send()。

---

think-swoole 的 onMessage 只处理客户端上行，怎么从后端主动推？

onMessage 是 WebSocket 连接收到前端消息时触发的回调，它不负责“后端发指令”。要实现“订单创建后推全员”，得另起一套通信机制。

立即学习“PHP免费学习笔记（深入）”；

• 推荐用 Redis pub/sub：WebSocket 进程启动时 $redis->subscribe(['notify_channel'])，业务逻辑中 $redis->publish('notify_channel', json_encode([...]))
• 或走内部 HTTP：让 Swoole 同时监听一个 HTTP 端口（如 9502），业务用 file_get_contents("http://127.0.0.1:9502/api/push", [...]) 触发推送逻辑
• 切勿在 onMessage 里写数据库查询再 foreach $server->connections —— 这会阻塞当前 Worker，影响其他连接

示例关键点：think-swoole 的控制器里不能直接访问 $server->connections，需通过 \Swoole\Server 实例或全局管理器获取；若用多 Worker，连接列表是隔离的，必须用 Table 或 Redis 做跨进程共享。

---

部署时 php think swoole 启不起来？检查这三处

常见失败不是代码问题，而是环境卡点。

• 确认 swoole 扩展已安装且启用：php -m | grep swoole，没输出就先 pecl install swoole
• 端口被占或防火墙拦截：netstat -tuln | grep 9501，宝塔用户还要进「安全组」放行对应端口
• think-swoole 版本与 TP 版本不匹配：TP6 用 topthink/think-swoole:^3.0，TP8 则需 ^4.0；旧版配置项如 'type' => 'websocket' 在新版已废弃，改用 serverType = 'websocket'

启动命令不是 php start.php start（那是 Workerman），TP 原生集成下统一用 php think swoole；加 -d 守护后日志默认写入 runtime/swoole.log，出错先看它。

---

实际推送链路里最易被忽略的，是连接生命周期管理：用户登录时绑定 fd 到 uid，退出时解绑，断网重连时要续接而非新建。这些状态若只存在内存里，多 Worker 下会丢失，必须落地到 Redis 或 Swoole\Table。