Swoole onRequest和WebSocket怎么配合-Swoole-PHP中文网

onrequest是websocket服务器暴露http接口的刚需通道，因swoole_websocket_server继承自swoole_http_server，天然支持http请求；未注册onrequest时非websocket请求会直接返回400错误。

swoole onrequest和websocket怎么配合

onRequest 是 WebSocket 服务器对外暴露 HTTP 接口的唯一入口，不是可选补充，而是主动推送、健康检查、管理控制的刚需通道。

为什么 WebSocket 服务器能用 onRequest

Swoole 的 swoole_websocket_server 类继承自 swoole_http_server，所以它天然支持 HTTP 协议层能力。只要没显式禁用或覆盖，收到非 WebSocket 握手的 HTTP 请求（比如 GET /push?uid=1001）就会触发 onRequest 回调，而不是直接返回 400 错误。

常见错误现象：启动了 WebSocket 服务，但用 curl http://localhost:9501/health 得到空白响应或 400 —— 这是因为没定义 onRequest 回调，Swoole 默认拒绝非升级请求。

必须手动注册 onRequest，否则所有非 WebSocket 请求都会被丢弃
onRequest 和 onOpen/onMessage 运行在同一个进程内，共享内存（如全局数组、Swoole\Table），但不共享协程上下文
不能在 onRequest 里直接调用 $server->push()，因为没有 $fd；得先查连接状态，再发消息

onRequest 里怎么安全地向 WebSocket 客户端发消息

核心难点是：HTTP 请求不知道哪个客户端该收这条消息，所以得靠外部标识（如用户 ID、房间号）反查在线连接。推荐用 Swoole\Table 做映射表，比 PHP 数组更安全、支持多进程读写。

WebSocket 8.18.2

WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。

下载

示例逻辑：

<pre class="brush:php;toolbar:false;">$table = new Swoole\Table(1024);
$table->column('uid', Swoole\Table::TYPE_STRING, 64);
$table->column('fd', Swoole\Table::TYPE_INT, 8);
$table->create();

$server->on('open', function ($server, $request) use ($table) {
    $uid = $request->get['uid'] ?? '';
    if ($uid) {
        $table->set($uid, ['uid' => $uid, 'fd' => $request->fd]);
    }
});

$server->on('close', function ($server, $fd) use ($table) {
    foreach ($table as $key => $row) {
        if ($row['fd'] == $fd) {
            $table->del($key);
            break;
        }
    }
});

$server->on('request', function ($request, $response) use ($server, $table) {
    if ($request->server['request_uri'] === '/push' && $request->get['uid']) {
        $uid = $request->get['uid'];
        $row = $table->get($uid);
        if ($row && $server->exist($row['fd']) && $server->isEstablished($row['fd'])) {
            $server->push($row['fd'], $request->get['msg'] ?? 'no message');
            $response->end('OK');
        } else {
            $response->status(404);
            $response->end('offline');
        }
        return;
    }
    $response->status(404);
    $response->end('Not Found');
});

别用 $_GET 或全局变量传 <code>uid，必须从 $request->get 取，这是 Swoole 封装后的干净数据
每次 push 前必须调用 $server->exist() 和 $server->isEstablished()，避免向已断开但未触发 onClose 的 fd 发送数据导致崩溃
Swoole\Table 不支持复杂结构，不要存对象或闭包；只存基础类型字段