php工具如何使用WebSocket实时通信_php工具长连接的开发教程-php教程-PHP中文网

php工具如何使用WebSocket实时通信_php工具长连接的开发教程

星夢妙者

发布： 2025-11-04 11:06:02

原创

883人浏览过

php工具如何使用websocket实时通信_php工具长连接的开发教程

WebSocket 是一种在单个 TCP 连接上进行全双工通信的协议，相比传统的 HTTP 轮询，它能显著降低延迟并提升性能。PHP 本身是脚本语言，不原生支持长连接，但通过一些工具和扩展，可以实现 WebSocket 实时通信。以下是使用 PHP 工具开发 WebSocket 长连接的实用教程。

选择合适的 PHP WebSocket 工具

由于 PHP 默认以短生命周期运行，要实现长连接，需要借助第三方库或服务。目前主流的解决方案包括：

Swoole：高性能的 PHP 扩展，支持异步、协程、TCP/UDP/HTTP/WebSocket 服务器。
Workerman：纯 PHP 编写的高性能 Socket 服务框架，无需额外扩展，部署简单。
Ratchet：基于 ReactPHP 的 WebSocket 库，适合与传统 PHP 项目集成。

推荐初学者使用 Workerman 或 Swoole，它们文档完善，社区活跃。

使用 Workerman 搭建 WebSocket 服务

Workerman 简洁易用，适合快速搭建 WebSocket 服务。

立即学习“PHP免费学习笔记（深入）”；

步骤一：安装 Workerman

通过 Composer 安装：

composer require workerman/workerman

登录后复制

步骤二：创建 WebSocket 服务文件（如 start.php）

require_once __DIR__ . '/vendor/autoload.php';

use Workerman\Worker;

// 创建一个 WebSocket 服务
$ws = new Worker('websocket://0.0.0.0:8080');

// 设置进程数量
$ws->count = 4;

// 当客户端连接时
$ws->onConnect = function($connection) {
    echo "新客户端连接：{$connection->id}\n";
};

// 接收消息
$ws->onMessage = function($connection, $data) {
    echo "收到消息：$data\n";
    // 向客户端发送响应
    $connection->send("服务端已收到：$data");
};

// 客户端断开
$ws->onClose = function($connection) {
    echo "客户端断开：{$connection->id}\n";
};

// 启动服务
Worker::runAll();

登录后复制

步骤三：启动服务

命令行执行：

php start.php start

登录后复制

若需守护进程模式：

ChatPDF

使用ChatPDF，您的文档将变得智能!跟你的PDF文件对话，就好像它是一个完全理解内容的人一样。

327

查看详情

php start.php start -d

登录后复制

前端连接测试

创建一个 HTML 页面测试连接：

<script>
const ws = new WebSocket('ws://your-server-ip:8080');

ws.onopen = () => {
    console.log('连接成功');
    ws.send('Hello WebSocket Server!');
};

ws.onmessage = (event) => {
    console.log('收到消息：', event.data);
};

ws.onclose = () => {
    console.log('连接关闭');
};
</script>

登录后复制

确保服务器防火墙开放 8080 端口，并允许 WebSocket 连接。

Swoole 的基本使用方式

Swoole 性能更强，适合高并发场景。

步骤一：安装 Swoole 扩展

通过 PECL 安装：

pecl install swoole

登录后复制

并在 php.ini 中启用：extension=swoole.so

步骤二：编写 Swoole WebSocket 服务

$server = new Swoole\WebSocket\Server('0.0.0.0', 8080);

$server->on('start', function ($server) {
    echo "Swoole WebSocket Server started at ws://0.0.0.0:8080\n";
});

$server->on('open', function ($server, $req) {
    echo "客户端连接：{$req->fd}\n";
});

$server->on('message', function ($server, $frame) {
    echo "收到消息：{$frame->data}\n";
    $server->push($frame->fd, "已收到您的消息：{$frame->data}");
});

$server->on('close', function ($server, $fd) {
    echo "客户端断开：$fd\n";
});

$server->start();

登录后复制

运行：php server.php