本文介绍如何用 php 搭建基于 websocket 的实时 api，替代低效的定时轮询（如 setinterval），实现服务端主动推送变更数据至前端 javascript，显著降低请求压力并提升响应时效性。
本文介绍如何用 php 搭建基于 websocket 的实时 api，替代低效的定时轮询（如 setinterval），实现服务端主动推送变更数据至前端 javascript，显著降低请求压力并提升响应时效性。
在传统 Web 开发中，前端常通过 setInterval(() => fetch('/api/status'), 1000) 实现“伪实时”更新——这种客户端主动轮询（Polling）方式虽简单，但存在明显缺陷：大量空响应、带宽浪费、延迟不可控、服务器并发压力陡增。更优解是采用服务端主动推送机制，而 WebSocket 正是现代 PHP 应用实现双向实时通信的标准方案。
✅ 为什么选择 WebSocket？
- 全双工、长连接：单次握手后，服务端可随时向已连接客户端推送数据；
- 低开销：避免 HTTP 头部重复传输与连接重建；
- 高时效：状态变更毫秒级触达前端，无轮询间隔盲区；
- 原生支持：现代浏览器均提供 WebSocket API，PHP 可借助成熟库快速搭建服务端。
? 快速搭建 PHP WebSocket 服务（以 Ratchet 为例）
Ratchet 是 PHP 社区广泛使用的轻量级 WebSocket 库。以下为最小可行示例：
1. 安装依赖（Composer）
composer require cboden/ratchet
2. 创建服务端（server.php）
立即学习“PHP免费学习笔记（深入）”；
<?php
require dirname(__DIR__) . '/vendor/autoload.php';
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
class RealtimePusher implements MessageComponentInterface {
protected $clients;
public function __construct() {
$this->clients = new \SplObjectStorage();
}
public function onOpen(ConnectionInterface $conn) {
$this->clients->attach($conn);
echo "New connection: {$conn->resourceId}\n";
}
public function onMessage(ConnectionInterface $from, $msg) {
// 可选：处理客户端发送的指令（如订阅频道）
// 本例聚焦服务端主动推送，暂不实现接收逻辑
}
public function onClose(ConnectionInterface $conn) {
$this->clients->detach($conn);
echo "Connection {$conn->resourceId} closed\n";
}
public function onError(ConnectionInterface $conn, \Exception $e) {
echo "Error for connection {$conn->resourceId}: {$e->getMessage()}\n";
$conn->close();
}
// 【关键】外部调用此方法推送数据（例如在业务逻辑中触发）
public function broadcast($data) {
$json = json_encode(['type' => 'update', 'payload' => $data]);
foreach ($this->clients as $client) {
if ($client->resourceId && $client->isConnected()) {
$client->send($json);
}
}
}
}
// 启动 WebSocket 服务（监听 8080 端口）
$pusher = new RealtimePusher();
$server = IoServer::factory(
new HttpServer(new WsServer($pusher)),
8080
);
echo "WebSocket server running on ws://localhost:8080\n";
$server->run();3. 前端 JavaScript 连接与监听
const socket = new WebSocket('ws://localhost:8080');
socket.onopen = () => console.log('Connected to real-time API');
socket.onmessage = (event) => {
const data = JSON.parse(event.data);
if (data.type === 'update') {
console.log('Received update:', data.payload);
// ✅ 在此处更新 DOM 或触发 React/Vue 状态
document.getElementById('status').textContent = data.payload.status;
}
};
socket.onerror = (err) => console.error('WebSocket error:', err);4. 在业务逻辑中触发推送（例如 IP 状态变更时）
// 假设你在某个控制器或定时任务中检测到 IP 状态变化
$pusher->broadcast([
'status' => 'blocked',
'ip' => '192.168.1.100',
'at' => date('c')
]);⚠ 注意事项与最佳实践
- 进程管理：PHP WebSocket 服务需常驻运行，建议使用 supervisord 或 systemd 守护进程，避免意外中断；
- 跨域与代理：生产环境若使用 Nginx/Apache，需配置 WebSocket 升级头（Upgrade: websocket / Connection: Upgrade）；
- 连接鉴权：实际项目中应在 onOpen() 中校验 token 或 session，拒绝未授权连接；
- 扩展性考量：单机 Ratchet 适合中小规模；高并发场景建议接入 Redis Pub/Sub 实现多进程/多服务器广播；
- 降级兼容：可结合 Server-Sent Events（SSE）作为 WebSocket 不可用时的备选方案（仅服务端推送）。
✅ 总结
摒弃 setInterval + fetch 的轮询模式，改用 WebSocket 构建 PHP 实时 API，不仅大幅减少无效请求、降低服务器负载，更能实现真正的事件驱动响应。从 Ratchet 入手，数小时即可完成原型；配合合理的部署与安全策略，即可支撑生产级实时交互需求——这是现代 Web API 设计的必然演进方向。
