think-swoole 框架底层的一个“隐藏陷阱”

发表于 2026-06-27 更新于 2026-06- 27

作者 mdo

7~9 分钟 阅读

在 think-swoole 的底层实现中，当你调用 $websocket->to('room')->push($data) 时，由于 push 方法需要向特定的 FD 直接发送原始数据，框架为了保证主 Worker 进程不被网络 I/O 阻塞，在底层确实会自动把发送任务投递给 Task 进程去异步执行。

因此，当你线上高频发布消息时，即使使用了 Room，如果调用的是 push()，依然会疯狂占用这 8 个 Task 进程，最终再次导致 Task 队列塞满、消息收不到！

为了彻底解决高频下 push() 走 Task 导致的瓶颈，你有以下两种彻底重构和优化的最佳方案：

方案一：改用 emit() 方法（最推荐，避开 Task）

在 think-swoole 中，emit() 和 push() 的底层行为是不同的：

push($data)：发送的是纯文本/原始数据，底层会走 Task 异步投递。
emit($event, $data)：发送的是事件流机制（类似 Socket.io 协议）。它的底层不会走 Task，而是直接利用 Swoole 的主进程事件轮询（Event Loop）配合内存共享表，直接把数据推向网卡，速度极快。

代码改造示例：

php

// ❌ 线上高频时不要用 push，它会走 Task 导致阻塞
// $this->websocket->to('all_online_users')->push($message);

//  改用 emit，直接走事件轮询，完全不占用 Task 进程
$this->websocket->to('all_online_users')->emit('all_push', [
    'msg' => $message
]);

请谨慎使用此类代码。

提示：使用 emit 后，前端（客户端）不能再直接解析原始字符串了，需要按照 Socket.io 或 think-swoole 的前端规范，监听 all_push 这个事件名来接收数据。

方案二：绕过框架，直接调用 Swoole 原生底层方法（追求极致性能）

如果你不希望前端修改接收逻辑（必须接收 push 格式的原始字符串），同时又绝对不想让它走 think-swoole的 Task 转发，你可以绕过框架封装，直接从 Swoole 底层获取 Room 的 FD 集合，然后用原生方法发送。

通过 think-swoole 的容器，可以直接拿到原生的 Swoole\Server 和 Room 内存表：

php

use think\Container;
use think\swoole\contract\WebsocketRepositoryInterface;

// 1. 获取 think-swoole 的 Room 仓库实例
$repository = Container::getInstance()->make(WebsocketRepositoryInterface::class);

// 2. 从全员房间中获取当前在线的所有客户端 FD 数组（这步是在内存中操作，极快）
$fds = $repository->getFdsByRoom('all_online_users');

// 3. 获取原生 Swoole Server
$swooleServer = Container::getInstance()->make(\Swoole\Server::class);

// 4. 绕过 Task，利用非阻塞的协程/直接发送
foreach ($fds as $fd) {
    // 检查连接是否还在线，在线则直接发送纯文本
    if ($swooleServer->isEstablished($fd)) {
        // 原生 push 只要配置了协程，就是非阻塞的，不会进 Task 队列
        $swooleServer->push($fd, $message);
    }
}

请谨慎使用此类代码。

🛠️ 配合方案的关键参数确认

不管你选择上述哪种方案，既然知道了底层在疯狂压榨 Task，请去 config/swoole.php 中将我们在上一步提到的网络缓冲区参数再放大一倍。因为绕过了 Task 后，压力会直接转移到 Worker 进程的网卡输出缓冲区 上：

php

'options' => [
    'task_worker_num'    => 8,
    // 必须调大这两个参数，否则在高频原生 push 或 emit 时，网卡来不及发就会丢包
    'buffer_output_size' => 64 * 1024 * 1024, // 64MB
    'socket_buffer_size' => 128 * 1024 * 1024, // 128MB
]

请谨慎使用此类代码。

你目前前端是直接接收纯文本字符串，还是已经在用 Socket.io / 事件监听 的方式接收消息了？如果前端可以改动，直接用 方案一（emit 方法） 是最优雅、代码量最少的解法！

技术

许可协议: CC BY 4.0