1.传统PHP在实时通信上的短板
PHP传统的请求-响应模式(无状态、短连接)不适合长连接场景。对于实时聊天、游戏、通知推送,需要WebSocket协议保持双向通信。但借助Swoole和Workerman,PHP可以很好地实现WebSocket服务器,突破传统限制。
参考:https://www.rvxif.cn/category/puerh-tea.html
2.Swoole实现WebSocket服务器
Swoole是一个PHP扩展,使PHP可以常驻内存、异步非阻塞、支持TCP/UDP/WebSocket服务器。一个简单的聊天室服务器逻辑:
启动WebSocket服务,监听端口。
当有新连接时,保存连接资源($fd)到Redis集合。
接收客户端消息,广播给所有其他客户端。
连接关闭时,从Redis删除。
Swoole基于epoll,单机可以支撑数万并发连接,配合分布式部署(按连接哈希分片)可扩展到百万级。
3.会话管理与身份认证
在实时通信中,需要将HTTP认证与WebSocket握手结合。通常流程:
客户端先通过RESTAPI获取token(JWT或随机字符串)。
WebSocket连接时,在协议头或query参数中携带token。
服务器在握手阶段验证token,解析用户ID,并与$fd绑定,存入RedisHash(user:uid=>fd)。
4.私聊与消息存储
私聊需要根据接收者ID查找其$fd,然后单播。如果接收者不在线,消息需暂存(例如RedisList),待用户下次上线时拉取。PHP代码中,使用Swoole的push方法发送文本或二进制数据。为支持消息已读/未读,可以存储消息ID、时间戳等元数据到MySQL。
参考:https://www.rvxif.cn/category/oolong-tea.html
5.房间与群组
群聊可以设计“房间”概念:RedisSet存储房间成员(用户ID)。当消息发送到房间时,遍历成员并分别推送。性能优化:如果房间人数巨大(如直播弹幕),可以改用“订阅-发布”模式,每个WebSocket服务器订阅Redis频道,消息只广播到该服务器内的连接。
6.心跳与断线重连
WebSocket需要定期ping/pong保持连接。Swoole支持设置心跳检测,若长时间无数据则主动断开。客户端应实现重连机制:使用指数退避策略重新连接,并在恢复后拉取离线消息。
7.横向扩展与负载均衡
单个PHPWebSocket服务器有上限(受限于服务器内存和fd数量)。横向扩展方案:
使用Nginx的stream模块或HAProxy做四层负载均衡,按IP哈希或最少连接分发。
所有服务器通过Redis的Pub/Sub进行跨服务器消息转发:当服务器A收到一条需要推送给在服务器B上的用户的消息时,A发布到Redis频道,B订阅后推送。
参考:https://www.rvxif.cn/category/black-tea.html
8.案例:某在线教育的实时答疑系统
学生通过网页与老师一对一实时文字聊天。系统要求消息必达、历史记录可查。技术选型:
后端:SwooleWebSocket服务器(PHP8.2)。
消息存储:MySQL分区表(按天分区)。
在线状态:Redis存储user:fd映射。
离线消息:RedisList,用户上线后拉取。
部署:K8s部署4个Pod,Service为HeadlessService,前端通过NginxIngress连接(WebSocket支持)。
系统支持并发5000路聊天,消息延迟低于100ms,稳定性满足要求。
9.总结
使用PHP+Swoole实现WebSocket服务,改变了“PHP不适合实时通信”的刻板印象。对于中小型项目,PHP开发者可以在不引入Node.js或Go的情况下,完成实时聊天、游戏、通知等功能的开发,复用已有业务逻辑和团队技能。
参考:https://www.rvxif.cn