thinkphp websocket如何实现即时通讯-ThinkPHP-PHP中文网

thinkphp websocket如何实现即时通讯

下次还敢

发布： 2025-09-20 17:21:02

原创

157人浏览过

ThinkPHP实现即时通讯需借助Swoole扩展，通过配置swoole.php启用WebSocket服务，编写事件处理类实现消息广播，并以前端JavaScript连接ws://ip:9502完成实时通信。

thinkphp websocket如何实现即时通讯

ThinkPHP 结合 WebSocket 实现即时通讯，核心在于使用 Swoole 或 Workerman 扩展来支持长连接通信，因为原生的 ThinkPHP（基于 HTTP 短连接）无法直接处理 WebSocket。下面以 Swoole 为例，说明如何在 ThinkPHP 中实现简单的即时通讯功能。

1. 环境准备与扩展安装

确保你的服务器环境已安装 PHP 并支持 Swoole 扩展：

安装 Swoole：通过 pecl 安装 swoole 扩展（建议版本 4.5+）
使用 Composer 安装 ThinkPHP 对 Swoole 的支持（适用于 ThinkPHP 6）：
composer require topthink/think-swoole
配置 .env 文件或 config/swoole.php 启用 WebSocket 服务

2. 配置 WebSocket 服务

在 ThinkPHP 的配置目录下创建或修改 config/swoole.php：

return [
    'server' => [
        'host' => '0.0.0.0',
        'port' => 9502,
        'mode' => SWOOLE_PROCESS,
        'type' => SWOOLE_SOCK_TCP,
    ],
    'websocket' => true, // 开启 WebSocket 支持
];
?>

这将启用 Swoole 的 WebSocket 模式，监听 9502 端口。

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

3. 编写 WebSocket 事件处理逻辑

在 app 目录下创建 WebSocket 服务类，例如 app/listener/WebSocketListener.php：

namespace app\listener;

use think\swoole\contract\websocket\HandlerInterface;
use think\swoole\Websocket;

class WebSocketListener implements HandlerInterface
{
    public function onOpen(\$server, \$request)
    {
        echo "客户端 {$request->fd} 已连接\n";
    }

    public function onMessage(\$server, \$frame)
    {
        // 接收客户端消息
        \$data = \$frame->data;
        // 广播给所有在线用户
        foreach (\$server->connections as \$fd) {
            if (\$server->isEstablished(\$fd)) {
                \$server->push(\$fd, "用户 {\$frame->fd} 说：{\$data}");
            }
        }
    }

    public function onClose(\$server, \$fd)
    {
        echo "客户端 {$fd} 已断开\n";
    }
}
?>

这个类处理连接、消息接收和关闭事件，实现了基本的群聊广播功能。