用 PHP + Swoole 打造高性能 WebSocket 实时通知系统，QPS 提升 15 倍

传统 PHP 长轮询方案资源消耗大、延迟高。本文手把手带你用 Swoole 协程实现 WebSocket 实时推送，附完整可运行代码，服务端并发从 200 → 3000+，响应延迟从秒级降至毫秒级。

一、别再用轮询了，是时候换个姿势了

相信很多 PHP 开发者都踩过这个坑：

用户："为什么消息通知要等好几秒？"
你（内心）："因为我每隔 3 秒 Ajax 轮询一次……"

传统轮询的三宗罪：

• 🔴 资源浪费：99% 的请求是空转，服务器默默承受
• 🔴 延迟高：最坏情况延迟 = 轮询间隔（3~5s）
• 🔴 扩展难：1000 个用户 = 1000 个并发长连接，PHP-FPM 直接躺平

今天我们用 Swoole + WebSocket 彻底解决这个问题。

二、技术选型：为什么是 Swoole？

Swoole 是 PHP 的异步协程扩展，底层基于 epoll/kqueue，让 PHP 拥有媲美 Go/Node.js 的并发能力，而且你还是在写 PHP。

三、环境准备

# 安装 Swoole（PHP 8.1+）
pecl install swoole

# 验证安装
php -r "echo swoole_version();"
# 输出: 5.1.x

# 项目结构
notification-system/
├── server.php          # WebSocket 服务端
├── client.html         # 前端测试页面
├── push.php            # 消息推送接口
└── storage/
    └── clients.json    # 在线用户映射（生产用 Redis）

四、核心实现：WebSocket 服务端

<?php
// server.php - Swoole WebSocket 服务端

declare(strict_types=1);

use Swoole\WebSocket\Server;
use Swoole\Http\Request;
use Swoole\WebSocket\Frame;
use Swoole\Table;

// =========================================
// 使用 Swoole\Table 共享内存存储在线用户
// 比 Redis 更快，进程间共享，无需序列化
// =========================================
$userTable = new Table(1024);
$userTable->column('fd', Table::TYPE_INT);          // 连接 fd
$userTable->column('user_id', Table::TYPE_INT);     // 业务用户 ID
$userTable->column('connected_at', Table::TYPE_INT);// 连接时间
$userTable->create();

$server = new Server('0.0.0.0', 9501);

$server->set([
    'worker_num'    => swoole_cpu_num(),  // Worker 数 = CPU 核心数
    'max_conn'      => 10000,             // 最大连接数
    'heartbeat_check_interval' => 30,     // 30s 心跳检测
    'heartbeat_idle_time'      => 60,     // 60s 无活动断开
    'open_websocket_ping_frame' => true,  // 开启 Ping/Pong
]);

// =========================================
// 事件1：客户端建立连接
// =========================================
$server->on('Open', function (Server $server, Request $request) use ($userTable) {
    $fd = $request->fd;
    
    // 从请求头或 Query 参数获取用户身份（实际应验证 Token）
    $userId = (int)($request->get['user_id'] ?? 0);
    
    if ($userId <= 0) {
        // 未认证，拒绝连接
        $server->push($fd, json_encode([
            'type' => 'error',
            'msg'  => '请先登录'
        ]));
        $server->close($fd);
        return;
    }
    
    // 存储用户连接信息
    $userTable->set((string)$userId, [
        'fd'           => $fd,
        'user_id'      => $userId,
        'connected_at' => time(),
    ]);
    
    echo "[连接] 用户 {$userId} 已连接，fd={$fd}\n";
    
    // 推送欢迎消息
    $server->push($fd, json_encode([
        'type' => 'connected',
        'msg'  => '实时通知已开启',
        'time' => date('H:i:s'),
    ]));
});

// =========================================
// 事件2：收到客户端消息
// =========================================
$server->on('Message', function (Server $server, Frame $frame) {
    $data = json_decode($frame->data, true);
    
    // 处理心跳包
    if (($data['type'] ?? '') === 'ping') {
        $server->push($frame->fd, json_encode(['type' => 'pong']));
        return;
    }
    
    echo "[消息] fd={$frame->fd}: {$frame->data}\n";
});

// =========================================
// 事件3：连接关闭
// =========================================
$server->on('Close', function (Server $server, int $fd) use ($userTable) {
    // 遍历找到对应用户并删除（生产环境建议用双向映射）
    foreach ($userTable as $userId => $info) {
        if ($info['fd'] === $fd) {
            $userTable->del($userId);
            echo "[断开] 用户 {$userId} 已断开\n";
            break;
        }
    }
});

// =========================================
// 事件4：HTTP 接口 - 接收业务系统推送消息
// 格式: POST /push  Body: {"user_id":123,"title":"","content":""}
// =========================================
$server->on('Request', function (Request $request) use ($server, $userTable) {
    // 允许跨域（开发环境）
    $request->rawContent();
    
    if ($request->server['request_uri'] !== '/push') {
        return;
    }
    
    $body = json_decode($request->rawContent(), true);
    $userId = (int)($body['user_id'] ?? 0);
    
    if ($userId <= 0) {
        // 广播给所有在线用户
        $count = 0;
        foreach ($userTable as $uid => $info) {
            if ($server->isEstablished($info['fd'])) {
                $server->push($info['fd'], json_encode([
                    'type'    => 'notification',
                    'title'   => $body['title'] ?? '',
                    'content' => $body['content'] ?? '',
                    'time'    => date('H:i:s'),
                ]));
                $count++;
            }
        }
        echo "[广播] 推送给 {$count} 个用户\n";
        return;
    }
    
    // 推送给指定用户
    $userInfo = $userTable->get((string)$userId);
    
    if (!$userInfo || !$server->isEstablished($userInfo['fd'])) {
        echo "[推送] 用户 {$userId} 不在线\n";
        return;
    }
    
    $server->push($userInfo['fd'], json_encode([
        'type'    => 'notification',
        'title'   => $body['title'] ?? '新通知',
        'content' => $body['content'] ?? '',
        'time'    => date('H:i:s'),
    ]));
    
    echo "[推送] 已推送给用户 {$userId}\n";
});

echo "🚀 WebSocket 服务启动：ws://0.0.0.0:9501\n";
echo "📮 HTTP 推送接口：http://0.0.0.0:9501/push\n";

$server->start();

五、前端接入（原生 JS，不依赖任何库）

<!-- client.html -->
<!DOCTYPE html>
<html lang="zh-CN">
<head>
    <meta charset="UTF-8">
    <title>实时通知测试</title>
    <style>
        body { font-family: Arial, sans-serif; padding: 20px; background: #f5f5f5; }
        #notifications { max-height: 400px; overflow-y: auto; }
        .notif { background: #fff; border-left: 4px solid #4CAF50; padding: 10px 15px;
                 margin: 8px 0; border-radius: 4px; box-shadow: 0 1px 3px rgba(0,0,0,.1); }
        .notif .title { font-weight: bold; color: #333; }
        .notif .time  { font-size: 12px; color: #999; margin-top: 4px; }
        #status { padding: 6px 12px; border-radius: 20px; display: inline-block; font-size: 14px; }
        .connected    { background: #e8f5e9; color: #2e7d32; }
        .disconnected { background: #ffebee; color: #c62828; }
    </style>
</head>
<body>
    <h2>🔔 实时通知演示</h2>
    <p>状态：<span id="status" class="disconnected">● 未连接</span></p>
    <div id="notifications"></div>

<script>
    const userId  = 1001; // 模拟用户 ID
    const wsUrl   = `ws://127.0.0.1:9501?user_id=${userId}`;
    const statusEl = document.getElementById('status');
    const listEl   = document.getElementById('notifications');

    let ws, reconnectTimer, reconnectDelay = 1000;

    function connect() {
        ws = new WebSocket(wsUrl);

        ws.onopen = () => {
            statusEl.textContent = '● 已连接';
            statusEl.className = 'connected';
            reconnectDelay = 1000; // 重置重连间隔
        };

        ws.onmessage = (event) => {
            const data = JSON.parse(event.data);

            // 心跳响应
            if (data.type === 'pong') return;

            // 渲染通知卡片
            if (data.type === 'notification') {
                const div = document.createElement('div');
                div.className = 'notif';
                div.innerHTML = `
                    <div class="title">🔔 ${data.title}</div>
                    <div>${data.content}</div>
                    <div class="time">${data.time}</div>
                `;
                listEl.prepend(div); // 最新的排最前面
            }
        };

        ws.onclose = () => {
            statusEl.textContent = '● 已断开，重连中...';
            statusEl.className = 'disconnected';
            // 指数退避重连（最大 30s）
            reconnectDelay = Math.min(reconnectDelay * 2, 30000);
            reconnectTimer = setTimeout(connect, reconnectDelay);
        };

        // 每 25s 发送心跳，防止连接被防火墙断开
        setInterval(() => {
            if (ws.readyState === WebSocket.OPEN) {
                ws.send(JSON.stringify({ type: 'ping' }));
            }
        }, 25000);
    }

    connect();
</script>
</body>
</html>

六、消息推送接口调用示例

<?php
// push.php - 业务代码中调用此函数推送消息
// 生产环境建议用消息队列异步推送，避免阻塞

/**
 * 向指定用户推送实时通知
 *
 * @param int    $userId  目标用户ID（0 = 广播所有在线用户）
 * @param string $title   通知标题
 * @param string $content 通知内容
 * @return bool
 */
function pushNotification(int $userId, string $title, string $content): bool
{
    $payload = json_encode([
        'user_id' => $userId,
        'title'   => $title,
        'content' => $content,
    ]);

    // 向 Swoole HTTP 接口发送推送请求
    $ch = curl_init('http://127.0.0.1:9501/push');
    curl_setopt_array($ch, [
        CURLOPT_POST           => true,
        CURLOPT_POSTFIELDS     => $payload,
        CURLOPT_HTTPHEADER     => ['Content-Type: application/json'],
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_TIMEOUT        => 1,          // 1s 超时，不阻塞业务
    ]);
    
    $result = curl_exec($ch);
    $error  = curl_error($ch);
    curl_close($ch);

    if ($error) {
        error_log("推送失败: {$error}");
        return false;
    }

    return true;
}

// 使用示例：订单支付成功通知
pushNotification(1001, '支付成功', '您的订单 #20260515001 已支付，正在备货中 🎉');

// 广播系统公告
pushNotification(0, '系统维护通知', '今晚 22:00-23:00 系统升级，请提前保存数据');

七、性能对比数据

用 wrk 对两种方案进行压测（4C8G 服务器，1000 并发用户）：

💡 数据说明：测试环境 PHP 8.2 + Swoole 5.1，轮询方案每次请求 50ms 处理时间。

八、生产环境注意事项

8.1 用 Redis 替代共享内存（多机部署必备）

// 单机用 Swoole\Table，多机集群用 Redis
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);

// 存储用户连接（格式: user:{userId}:fd → fd）
// 注意：fd 是当前进程的，多 Worker 时要带上 worker_id
$redis->setex("user:{$userId}:fd", 3600, "{$workerId}:{$fd}");

8.2 Nginx 反向代理配置

# nginx.conf - WebSocket 反向代理
upstream swoole_ws {
    server 127.0.0.1:9501;
}

server {
    listen 443 ssl;
    server_name your-domain.com;

    location /ws {
        proxy_pass http://swoole_ws;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;     # 关键：升级协议
        proxy_set_header Connection "upgrade";       # 关键：保持连接
        proxy_set_header Host $host;
        proxy_read_timeout 3600s;                   # 长连接超时
    }
}

8.3 进程守护（推荐 Supervisor）

; /etc/supervisor/conf.d/swoole-ws.conf
[program:swoole-websocket]
command=php /var/www/notification-system/server.php
directory=/var/www/notification-system
autostart=true
autorestart=true
stderr_logfile=/var/log/swoole-ws.err.log
stdout_logfile=/var/log/swoole-ws.out.log
user=www-data

九、发布前质量检查

在部署之前，对照以下 6 项逐一确认：

• 1. 认证安全：WebSocket 握手时验证 Token，防止未授权连接
• 2. 心跳机制：客户端定时 Ping，服务端配置 heartbeat_idle_time
• 3. 断线重连：前端实现指数退避重连，避免服务端瞬间被打爆
• 4. 消息格式：统一 JSON 格式，包含 type 字段便于扩展
• 5. 错误监控：接入日志系统，记录连接/断开/异常事件
• 6. 压测验收：上线前用 wrk 或 Apache Bench 模拟真实并发

十、结语

WebSocket + Swoole 不是银弹，但对于实时通知这个场景，它是目前 PHP 生态中性价比最高的方案：

• 🎯 不用换语言：PHP 开发者零学习成本
• 🚀 性能炸裂：QPS 从 200 飙到 3000+，内存降低 77%
• 🔧 可渐进迁移：旧系统轮询接口可以并行保留，灰度切流