PHP实时消息聊天室源码

✅ 一、技术选型深度解析：为什么必须用 Swoole，而非原生 Socket 或 Ratchet？

您的需求明确包含「群聊/私聊+消息历史+已读状态+媒体上传+无白屏加载」等复合能力，这意味着系统需同时满足：

• 高并发连接管理（百人以上在线）
• 毫秒级消息广播延迟（避免轮询导致的卡顿）
• 跨进程状态同步（如“已读回执”需实时通知发送方）
• 文件上传与异步处理能力（图片/视频需压缩、转码、存储）

而搜索结果清晰指出：

• 原生 PHP Socket 虽可实现握手与基础广播，但其阻塞式 I/O 模型无法支撑多用户并发读写与媒体流处理，且需手动实现心跳、断线重连、消息分帧等底层逻辑，极易引发内存泄漏与连接堆积¹；
• Ratchet 库虽符合 PSR-7 标准、结构清晰，但其基于 ReactPHP 的事件循环在 PHP-FPM 环境下性能受限，不支持协程，无法原生处理文件上传与数据库长事务，在高负载下易出现响应延迟⁴；
• 相比之下，Swoole 是唯一被搜索结果明确推荐用于“高性能通信”和“微信小程序客服”场景的 PHP 扩展，它提供 WebSocket\Server 原生支持、内置协程 MySQL 客户端、Redis 连接池、以及 Http\Server 与 Websocket\Server 同进程共存能力——这恰好完美匹配您“单项目同时承载 Web 页面 + WebSocket 服务 + 文件上传接口”的架构诉求⁴。

✅ 结论：ws_server.php 必须基于 Swoole 4.8+（PHP 7.4+ 兼容） 重构，而非依赖原生 socket 函数。否则将无法稳定支撑“已读状态追踪”“智能时间渲染”“媒体自动加载”等关键体验。

✅ 二、核心功能实现路径详解（紧扣您的 10 大特性）

🔹 1. 实时群聊与私聊：Swoole + Redis Pub/Sub 分布式广播

• 群聊：所有发往某 room_id=1001 的消息，由 Swoole Server 发布至 Redis Channel chat:room:1001，所有订阅该频道的 Worker 进程即时广播给对应客户端；
• 私聊：采用点对点路由机制——服务端根据接收方 user_id 查询其当前连接的 fd（文件描述符），直接 server->push($fd, $message)，避免全量遍历；
• ✅ 优势：相比纯 MySQL 轮询或内存数组遍历，Redis Pub/Sub 实现毫秒级跨进程广播，且天然支持水平扩展（多台 Swoole Worker 共享同一 Redis）⁴。

🔹 2. 在线用户列表：Swoole 连接池 + MySQL 心跳表

• 每个客户端连接成功后，Swoole 触发 onOpen 回调，向 MySQL 插入或更新 online_users 表（含 user_id, fd, last_heartbeat, ip, user_agent）；
• 前端每 30 秒发起一次轻量心跳请求（/api/heartbeat.php），服务端更新 last_heartbeat；
• SELECT * FROM online_users WHERE last_heartbeat > NOW()-INTERVAL 60 SECOND 即为当前在线列表；
• ✅ 注意：必须配合 ON DUPLICATE KEY UPDATE 语句防止重复插入，并设置 user_id 为主键或唯一索引⁴。

🔹 3. 消息历史记录（永久保存 + 刷新恢复）：MySQL 分表 + 索引优化

• 消息表 messages 设计建议：

  CREATE TABLE `messages` (
    `id` BIGINT UNSIGNED NOT NULL AUTO_INCREMENT,
    `from_user_id` INT NOT NULL,
    `to_user_id` INT NULL COMMENT '私聊目标ID，群聊为NULL',
    `room_id` INT NULL COMMENT '群聊ID，私聊为NULL',
    `type` ENUM('text','image','video') NOT NULL DEFAULT 'text',
    `content` TEXT CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci,
    `file_path` VARCHAR(512) NULL COMMENT '媒体文件相对路径',
    `is_read` TINYINT(1) NOT NULL DEFAULT 0 COMMENT '仅私聊有效',
    `created_at` DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
    PRIMARY KEY (`id`),
    INDEX `idx_room_time` (`room_id`, `created_at`),
    INDEX `idx_user_time` (`from_user_id`, `created_at`),
    INDEX `idx_to_read` (`to_user_id`, `is_read`, `created_at`)
  ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

• ✅ 刷新恢复逻辑：前端首次加载时，通过 GET /api/history?room_id=1001&limit=50&before_id=0 请求最近 50 条，Swoole Server 调用协程 MySQL 查询并返回 JSON；后续滚动加载使用 before_id 实现游标分页，避免 OFFSET 性能退化⁴。

🔹 4. 支持文本/图片/视频消息：Swoole HTTP Server + 异步上传

• upload.php 不再是传统 CGI 脚本，而是作为 Swoole 内置 HTTP 服务的一个路由：

  $http->on('request', function ($request, $response) {
      if ($request->server['request_uri'] === '/upload' && $request->server['request_method'] === 'POST') {
          $file = $request->post['file'] ?? null;
          // 使用协程文件操作 + Imagick/Symfony Process 异步转码
          go(function () use ($file, $response) {
              $path = uploadAndProcess($file); // 压缩、生成缩略图、存 media/
              $response->end(json_encode(['success'=>true, 'url'=>$path]));
          });
      }
  });

• ✅ 优势：避免传统 PHP-FPM 上传阻塞主线程，支持大文件分片上传、断点续传、后台转码，彻底解决“上传卡死页面”问题⁴。

🔹 5. 用户自定义颜色 + 私聊会话本地存储：前端驱动，服务端零耦合

• 颜色选择存储于 localStorage（如 {"user_id":"123456","color":"#FF6B6B"}），登录时随 WebSocket 握手消息一并发送至服务端，Swoole 缓存于 swoole_table（共享内存）供广播时读取；
• 私聊会话状态（当前打开的私聊对象、最后滚动位置）完全由 script.js 管理，利用 sessionStorage 实现页面刷新保留；
• ✅ 无需数据库写入，极大降低 IO 压力，符合“前端自治、服务端无状态”现代架构思想。

🔹 6–10. 响应式设计、已读追踪、智能时间、无白屏加载：CSS + JS + Swoole 协同优化

• 响应式：采用 flexbox + viewport + rem 布局，@media (max-width: 768px) 专用移动端样式，兼容 iOS Safari 与 Android Chrome¹；
• 已读状态：私聊消息发送后，Swoole 记录 msg_id 与 to_user_id 到 Redis Set read:msg:{msg_id}，当接收方 onMessage 时触发 SADD read:msg:{msg_id} {user_id}，发送方通过定时 SMEMBERS read:msg:{msg_id} 获取已读列表并更新 UI；
• 智能时间：前端 script.js 使用 Intl.DateTimeFormat API 动态判断：

  const now = new Date(), msgTime = new Date(msg.created_at);
  const isToday = now.toDateString() === msgTime.toDateString();
  msg.timeDisplay = isToday 
    ? msgTime.toLocaleTimeString([], {hour:'2-digit', minute:'2-digit'}) 
    : msgTime.toLocaleString('zh-CN', {year:'numeric', month:'2-digit', day:'2-digit', hour:'2-digit', minute:'2-digit'});

• 无白屏加载：index.php 输出最小 HTML 骨架 + <div id="chat-container"></div>，script.js 通过 fetch() 预加载用户信息与最近 20 条消息，再初始化 WebSocket，实现“内容先于连接”¹。
• 文件结构

├── core/               # 核心配置
│   └── db.php          # 数据库连接配置
├── models/             # 数据模型
│   ├── ConfigModel.php
│   ├── MessageModel.php
│   ├── OnlineUserModel.php
│   └── UserModel.php
├── media/              # 上传的媒体文件
├── ws_server.php       # WebSocket服务器
├── index.php           # 前端页面
├── script.js           # 前端JavaScript
├── styles.css          # 样式文件
├── upload.php          # 文件上传处理
└── chat.sql            # 数据库结构文件

✅ 三、部署与运维关键配置（直击您注意事项中的痛点）

✅ 四、安全加固建议（超越文档要求的生产级防护）

• XSS 全链路过滤：
  • 前端：DOMPurify.sanitize() 处理所有 content 字段输出；
  • 后端：Swoole 接收消息时，strip_tags() + htmlspecialchars() 双重过滤，禁用 javascript: 协议；



• CSRF 防御：WebSocket 握手请求（HTTP Upgrade）本身不受 CSRF 影响，但 /upload 和 /api/ 接口需校验 X-CSRF-TOKEN Header；


• 恶意文件拦截：上传时检查 $_FILES'file' 与文件魔数（finfo_open(FILEINFO_MIME_TYPE)），禁止 .php, .htaccess, .exe 等危险扩展名；


• 暴力连接限制：Swoole 设置 'open_tcp_nodelay' => true, 'max_conn' => 10000, 'tcp_defer_accept' => 1，并集成 Fail2ban 监控异常 IP；


• SQL 注入免疫：全部数据库操作使用 Swoole 协程 MySQL 的 prepare() 预编译语句，杜绝拼接 SQL⁴。

✅ 五、进阶演进路线（为未来扩展预留空间）

下载地址：https://pan.quark.cn/s/9a62617a8bdf