php 实现websokect
PHP 实现 WebSocket 的方法
使用 PHP 原生 Socket 扩展
PHP 原生提供了 Socket 扩展，可以用来实现 WebSocket 服务器。以下是基本实现步骤：
$socket = socket_create(AF_INET, SOCK_STREAM, SOL_TCP);
socket_set_option($socket, SOL_SOCKET, SO_REUSEADDR, 1);
socket_bind($socket, '0.0.0.0', 8080);
socket_listen($socket);
while (true) {
$client = socket_accept($socket);
$handshake = socket_read($client, 1024);
if (preg_match("/Sec-WebSocket-Key: (.*)\r\n/", $handshake, $match)) {
$key = base64_encode(sha1($match[1] . '258EAFA5-E914-47DA-95CA-C5AB0DC85B11', true));
$headers = "HTTP/1.1 101 Switching Protocols\r\n";
$headers .= "Upgrade: websocket\r\n";
$headers .= "Connection: Upgrade\r\n";
$headers .= "Sec-WebSocket-Accept: $key\r\n\r\n";
socket_write($client, $headers, strlen($headers));
}
// 处理消息
$data = socket_read($client, 1024);
// 解码 WebSocket 帧并处理消息
}使用 Ratchet 库
Ratchet 是一个流行的 PHP WebSocket 库，简化了 WebSocket 服务器的实现：
use Ratchet\MessageComponentInterface;
use Ratchet\ConnectionInterface;
use Ratchet\Server\IoServer;
use Ratchet\Http\HttpServer;
use Ratchet\WebSocket\WsServer;
class MyWebSocket implements MessageComponentInterface {
public function onOpen(ConnectionInterface $conn) {
// 新连接
}
public function onMessage(ConnectionInterface $from, $msg) {
// 处理消息
}
public function onClose(ConnectionInterface $conn) {
// 连接关闭
}
public function onError(ConnectionInterface $conn, \Exception $e) {
// 错误处理
}
}
$server = IoServer::factory(
new HttpServer(new WsServer(new MyWebSocket())),
8080
);
$server->run();使用 Swoole 扩展
Swoole 是一个高性能 PHP 协程框架，内置 WebSocket 服务器支持：
$server = new Swoole\WebSocket\Server("0.0.0.0", 9501);
$server->on('open', function (Swoole\WebSocket\Server $server, $request) {
echo "connection open: {$request->fd}\n";
});
$server->on('message', function (Swoole\WebSocket\Server $server, $frame) {
$server->push($frame->fd, "received: {$frame->data}");
});
$server->on('close', function ($server, $fd) {
echo "connection close: {$fd}\n";
});
$server->start();WebSocket 客户端实现
PHP 也可以作为 WebSocket 客户端连接服务器：
$client = new WebSocket\Client("ws://localhost:8080");
$client->send("Hello Server!");
echo $client->receive();
$client->close();注意事项
- WebSocket 协议需要 HTTP 升级握手，必须正确处理握手过程
- 生产环境建议使用成熟的库如 Ratchet 或 Swoole
- PHP 作为脚本语言，长时间运行的服务器需要考虑内存管理和稳定性
- WebSocket 通信需要处理帧编码/解码
- 考虑添加心跳机制保持连接活跃
以上方法提供了从底层到高级的多种实现方式，可根据项目需求选择合适的方案。
