当前位置：首页 > 文章列表 > 文章 > php教程 > PHP实现WebSocket实时通信教程

PHP实现WebSocket实时通信教程

2026-01-12 17:36:47 0浏览收藏

你在学习文章相关的知识吗？本文《PHP工具实现WebSocket实时通信教程》，主要介绍的内容就涉及到，如果你想提升自己的开发能力，就不要错过这篇文章，大家要知道编程理论基础和实战操作都是不可或缺的哦！

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 服务。

步骤一：安装 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

若需守护进程模式：

php start.php start -d

前端连接测试

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

确保服务器防火墙开放 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