WebSocket是一种全双工通信协议，允许客户端和服务端建立持久连接，实现双向实时数据传输，相比传统的HTTP轮询方式，能大幅降低通信开销，提升实时性。PHP可以通过原生socket函数或者第三方扩展实现WebSocket服务，其中Swoole扩展是常用的选择，它提供了完整的WebSocket服务端支持，开发效率高且性能稳定。
环境准备
使用Swoole实现WebSocket服务需要先安装Swoole扩展，要求PHP版本不低于7.2，Swoole版本不低于4.0。可以通过PECL命令安装：
pecl install swoole
安装完成后在php.ini中添加extension=swoole.so，重启PHP服务即可生效。
WebSocket服务端实现
下面是使用Swoole搭建WebSocket服务端的完整代码：
<?php
// 创建WebSocket服务器对象，监听0.0.0.0:9501端口
$server = new SwooleWebSocketServer('0.0.0.0', 9501);
// 监听WebSocket连接打开事件
$server->on('open', function (SwooleWebSocketServer $server, $request) {
echo "客户端{$request->fd}连接成功n";
// 向客户端发送欢迎消息
$server->push($request->fd, "欢迎连接WebSocket服务");
});
// 监听WebSocket消息接收事件
$server->on('message', function (SwooleWebSocketServer $server, $frame) {
echo "收到客户端{$frame->fd}的消息：{$frame->data}n";
// 将收到的消息原样返回给客户端
$server->push($frame->fd, "服务端已收到你的消息：{$frame->data}");
});
// 监听WebSocket连接关闭事件
$server->on('close', function ($server, $fd) {
echo "客户端{$fd}断开连接n";
});
// 启动服务器
$server->start();
代码中的核心事件说明：
- open事件：客户端与WebSocket服务建立连接时触发，可在该事件中处理用户鉴权、记录连接信息等逻辑
- message事件：服务端收到客户端发送的消息时触发，可在此处理消息解析、业务逻辑处理、消息广播等操作
- close事件：客户端断开连接时触发，可在此清理连接相关的资源
客户端实现
前端可以使用浏览器原生的WebSocket API连接服务端，示例代码如下：
// 创建WebSocket连接，地址为服务端的IP和端口
const socket = new WebSocket('ws://127.0.0.1:9501');
// 连接成功时触发
socket.onopen = function() {
console.log('WebSocket连接成功');
// 连接成功后发送一条测试消息
socket.send('这是客户端发送的第一条消息');
};
// 收到服务端消息时触发
socket.onmessage = function(event) {
console.log('收到服务端消息：', event.data);
};
// 连接关闭时触发
socket.onclose = function() {
console.log('WebSocket连接已关闭');
};
// 连接出错时触发
socket.onerror = function(error) {
console.error('WebSocket连接出错：', error);
};
服务启动与测试
将服务端代码保存为server.php，在命令行执行以下命令启动服务：
php server.php
启动后打开浏览器的开发者工具控制台，运行客户端代码，就可以看到连接建立、消息收发的效果。如果需要实现多客户端消息广播，可以在message事件中遍历所有连接的客户端，调用push方法发送消息。
常见问题处理
端口占用问题
如果启动服务时提示端口被占用，可以修改代码中的监听端口，或者关闭占用对应端口的进程。
跨域问题
如果需要跨域访问WebSocket服务，可以在服务端open事件中添加跨域头处理，或者在Swoole服务器配置中设置对应的跨域参数。
长连接保活
WebSocket连接长时间无数据交互可能会被中间网络设备断开，可以在服务端设置心跳检测机制，定期向客户端发送心跳包，客户端收到后回复心跳，维持连接活性。