PHP 怎么PHP 推送

wen PHP项目 2026-07-27 2

PHP消息推送实战指南：从轮询到WebSocket的完整技术演进

📚 目录导读

核心问题：为什么PHP需要消息推送？
传统方案：PHP短轮询与长轮询实现
进阶方案：PHP + Redis发布订阅模式
高性能方案：PHP WebSocket推送详解
企业级方案：SSE服务器推送事件
常见问题FAQ：PHP推送性能优化与坑点

核心问题：为什么PHP需要消息推送？

在Web应用开发中,我们经常遇到这样的场景：

PHP 怎么PHP 推送

用户A发布一条新消息，用户B需要立刻看到
后台任务执行完毕，前端需要实时获取结果
股票价格、游戏比分等数据动态更新

传统HTTP请求是“客户端请求-服务器响应”的单向模式，服务器无法主动向客户端发送数据，这就需要PHP实现消息推送机制,让服务器能主动推送数据到浏览器。

Q：PHP做推送有什么限制？ A：PHP本质是同步阻塞语言，每个请求独立执行，但通过现代工具组合（如Swoole、Workerman）,PHP完全可以胜任高并发推送场景。

传统方案：PHP短轮询与长轮询

短轮询实现

// 客户端每隔3秒请求
// server.php
$lastId = $_GET['last_id'] ?? 0;
$newData = getNewMessage($lastId); // 查询数据库
echo json_encode($newData);

缺点：大量无效请求，服务器压力大,实时性差。

长轮询实现

// 客户端发起一次请求，服务器挂起连接直到有新数据
set_time_limit(60);
while (true) {
    $data = checkNewData(); // 循环检查
    if ($data) {
        echo json_encode($data);
        break;
    }
    usleep(500000); // 休眠0.5秒
}

Q：长轮询比短轮询好在哪？ A：减少请求次数，但依然占用连接资源,且PHP进程会阻塞。

进阶方案：PHP + Redis发布订阅

这是目前PHP项目中最流行的高效方案：

架构设计

客户端 -> AJAX请求 -> PHP (订阅者) -> Redis -> PHP (发布者) -> 数据库

发布者代码

// publish.php  - 接收用户提交的数据
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
$message = $_POST['content'];
// 存储数据库
saveToDB($message);
// 发送到Redis频道
$redis->publish('chat_channel', json_encode([
    'content' => $message,
    'time' => time()
]));

订阅者代码（长连接）

// subscribe.php - 专供长轮询使用
$redis = new Redis();
$redis->connect('127.0.0.1', 6379);
set_time_limit(0); // 不超时
$channel = 'chat_channel';
$redis->subscribe([$channel], function($redis, $chan, $msg) {
    // 收到消息立即返回给客户端
    echo "data: {$msg}\n\n";
    ob_flush();
    flush();
});

Q：Redis订阅有什么坑？ A：单线程监听，如果频道消息量巨大，PHP可能处理不及，建议使用psubscribe模式匹配多个频道。

高性能方案：PHP WebSocket推送详解

使用Workerman实现WebSocket服务器

// ws_server.php
use Workerman\Worker;
use Workerman\Lib\Timer;
$ws_worker = new Worker('websocket://0.0.0.0:8080');
$ws_worker->onConnect = function($connection) {
    $connection->uid = uniqid(); // 分配唯一标识
};
$ws_worker->onMessage = function($connection, $data) {
    // 处理客户端消息
    $data = json_decode($data, true);
    if ($data['type'] == 'subscribe') {
        // 订阅某个频道
        $connection->channel = $data['channel'];
    }
};
// 定时推送任务
Timer::add(1, function() use ($ws_worker) {
    foreach ($ws_worker->connections as $conn) {
        if (isset($conn->channel) && $conn->channel == 'global') {
            $conn->send(json_encode([
                'type' => 'notification',
                'msg' => '每秒更新'
            ]));
        }
    }
});
Worker::runAll();

客户端JavaScript

// 浏览器端
const ws = new WebSocket('ws://yourdomain.com:8080');
ws.onopen = () => {
    ws.send(JSON.stringify({type: 'subscribe', channel: 'global'}));
};
ws.onmessage = (event) => {
    const data = JSON.parse(event.data);
    // 更新页面
};

Q：WebSocket和SSE有什么区别？ A：WebSocket是全双工双向通信，SSE是单向服务器推送，WebSocket更适合即时通讯,SSE更简单且兼容HTTP协议。

企业级方案：SSE服务器推送事件

PHP SSE推送代码

// sse.php
header('Content-Type: text/event-stream');
header('Cache-Control: no-cache');
header('Connection: keep-alive');
$lastId = 0;
while (true) {
    $data = getRecentNews();
    if ($data) {
        echo "id: {$data['id']}\n";
        echo "data: " . json_encode($data) . "\n\n";
        flush();
    }
    sleep(3); // 每3秒检查一次
}

前端监听

const source = new EventSource('/sse.php');
source.onmessage = (event) => {
    const data = JSON.parse(event.data);
    // 实时更新UI
};

Q：SSE适合哪些场景？ A：新闻推送、通知提醒、股票行情等单向数据流场景,它的优势是自动重连和兼容HTTP协议。

常见问题FAQ：PHP推送性能优化与坑点

❿ 如何保证推送不丢数据？

使用Redis List做消息队列，先存储再推送
客户端维护消息确认机制（ACK）

❾ 高并发下PHP进程阻塞怎么办？

使用Swoole的协程特性，让PHP变异步
或者用Nginx + php-fpm + 多进程订阅

❽ 推送延迟如何控制？

短轮询延迟高但简单，控制间隔在3-5秒
WebSocket延迟最低，可达毫秒级
使用CDN加速WebSocket握手

❼ 如何做推送权限验证？

// WebSocket握手时验证Token
$ws_worker->onWebSocketConnect = function($connection, $http_header) {
    $token = $http_header['sec-websocket-protocol'] ?? '';
    if (!validateToken($token)) {
        $connection->close();
    }
};

❻ 多服务器环境如何实现推送？

使用Redis的Pub/Sub跨服务器传递消息
或者用RabbitMQ等消息队列统一分发

❺ 推送消息格式如何设计？

{
    "type": "new_message",
    "target": ["user_id_1", "user_id_2"],
    "payload": {
        "content": "你好",
        "sender": "user_3"
    },
    "timestamp": 1700000000
}

❹ 内存泄漏怎么检查？

使用memory_get_usage()监控每个连接的内存
Workerman中设置onBufferFull回调
定期重启Workerman进程（建议24小时）

❸ 为什么我的WebSocket一直断开？

检查防火墙是否允许8080端口
WebSocket需要HTTP升级协议支持
确保Nginx配置了WebSocket代理支持

❷ 推送服务如何做负载均衡？

使用Nginx的hash_ip策略保持连接固定服务器
配合Redis共享状态，让任一服务器都能处理推送

❶ 适合PHP推送的最佳实践总结

场景	方案	并发支持
简单通知	短轮询	低
中等流量	长轮询+Redis	中
实时聊天	WebSocket(Swoole)	高
数据看板	SSE	中

📌 推送方案选择决策树

是否需要客户端主动向服务器发送消息？
- 是 → WebSocket
- 否 → SSE或轮询
并发连接数是否超过1000？
- 是 → 必须用Swoole/Workerman
- 否 → 长轮询+Redis可行
是否需要跨服务器推送？
- 是 → 引入Redis Pub/Sub或消息队列
- 否 → 单机WebSocket即可
客户端是否移动端为主？
- 是 → 使用WebSocket，减少频繁请求
- 否 → SSE更省资源

通过本文，您应该已经掌握了从传统轮询到现代WebSocket的全部PHP推送实现方式，建议从Redis长轮询开始学习，再向高性能方向进阶，如果您正在开发实时推送功能，推荐优先考虑Swoole或Workerman框架,它们让PHP也能拥抱高性能异步编程。