在数字化快速发展的今天，企业对于在线客服系统的要求已不再局限于简单的“能聊天”，而是追求高并发、低延迟、易维护的现代化解决方案。传统的PHP-FPM架构因其阻塞式I/O模型，在实时通信领域早已力不从心。本文将带你基于

，从零构建一个支持WebSocket协议、具备访客分配与消息存储功能的新版企业级在线客服系统。

技术栈选型：为什么是PHP 8.5 + Workerman？ 

在开始编码前，我们有必要明确这套技术组合的核心优势，这决定了系统的性能上限与开发效率。

Workerman是一款纯PHP开发的高性能Socket服务器框架，它彻底改变了PHP只能用于短生命周期Web脚本的刻板印象。

2. 语言版本：PHP 8.5（2025年11月发布） 

截至2026年，PHP 8.5已成为主流稳定版本。相较于旧版本，它引入了多项提升开发体验与代码安全性的新特性：

本教程假设你的服务器（或本地开发机）位于

# 1. 添加PHP 8.5 PPA源并安装（适用于Ubuntu）
sudo add-apt-repository ppa:ondrej/php
sudo apt update
sudo apt install php8.5 php8.5-cli php8.5-fpm php8.5-mysql php8.5-redis php8.5-mbstring

# 2. 安装Composer（PHP依赖管理）
curl -sS https://getcomposer.org/installer | sudo php -- --install-dir=/usr/local/bin --filename=composer

# 3. 检查关键扩展（Workerman运行必需）
php -m | grep -E 'pcntl|posix|redis'
# 应输出：pcntl、posix、redis

扩展，请务必确认它们已启用。

# 创建项目目录
mkdir enterprise-kefu && cd enterprise-kefu

# 初始化Composer并安装Workerman核心
composer require workerman/workerman
# 安装GatewayWorker（推荐用于客服系统）
composer require workerman/gateway-worker

# 安装Web前端依赖（假设使用npm）
npm install -D tailwindcss ws

文件将包含运行所需的核心依赖。

核心源码搭建：从长连接到业务逻辑 

我们将系统拆分为三个核心部分：WebSocket服务端、数据库设计、前端交互。

1. WebSocket服务端（start_gateway.php） 

这是整个系统的通信中枢，负责维护所有客服和访客的连接。

<?php
// start_gateway.php
use GatewayWorker\Gateway;
use GatewayWorker\Register;
use Workerman\Worker;

// 自动加载类
require_once __DIR__ . '/vendor/autoload.php';

// 初始化Gateway进程
$gateway = new Gateway("websocket://0.0.0.0:8282");
$gateway->name = 'KefuGateway';
$gateway->count = 4; // 进程数，建议与CPU核数一致
$gateway->lanIp = '127.0.0.1';
$gateway->startPort = 2900;
$gateway->pingInterval = 55; // 心跳间隔
$gateway->pingData = '{"type":"ping"}'; // 心跳数据

// 服务注册地址（用于分布式部署，单机可忽略）
$register = new Register('text://127.0.0.1:1238');

// 如果不是在根目录启动，则运行runAll方法
if (!defined('GLOBAL_START')) {
    Worker::runAll();
}
?>

2. 业务逻辑Worker（start_businessworker.php） 

这里处理具体的消息分发、客服分配和数据库操作。

<?php
// start_businessworker.php
use GatewayWorker\BusinessWorker;
use Workerman\Worker;
use Workerman\MySQL\Connection;

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

// 业务Worker进程
$worker = new BusinessWorker();
$worker->name = 'KefuBusiness';
$worker->count = 2; // 建议设置为CPU核数的1-2倍
$worker->registerAddress = '127.0.0.1:1238';

// 设置事件处理类
$worker->eventHandler = 'App\\Events\\KefuEvent';

// 数据库连接配置（使用PHP 8.5的新写法）
$dbConfig = [
    'host' => '127.0.0.1',
    'port' => 3306,
    'user' => 'kefu_user',
    'password' => 'your_secure_password',
    'dbname' => 'enterprise_kefu'
];

// 全局容器（简易DI）
global $db;
$db = new Connection(
    $dbConfig['host'],
    $dbConfig['port'],
    $dbConfig['user'],
    $dbConfig['password'],
    $dbConfig['dbname']
);

Worker::runAll();
?>

3. 事件处理类（App/Events/KefuEvent.php） 

这是业务核心，我们利用PHP 8.5的新特性优化代码。

<?php
namespace App\Events;

use GatewayWorker\Lib\Gateway;

class KefuEvent
{
    // 使用PHP 8.5的 #[\NoDiscard] 属性，防止忽略发送结果
    #[\NoDiscard]
    private static function sendToClient(string $clientId, array $message): void
    {
        Gateway::sendToClient($clientId, json_encode($message, JSON_UNESCAPED_UNICODE));
    }

    public static function onConnect($clientId)
    {
        // 新连接建立，记录到Redis或内存中
        echo "New connection: $clientId\n";
    }

    public static function onMessage($clientId, $message)
    {
        $data = json_decode($message, true);
        if (json_last_error() !== JSON_ERROR_NONE) {
            self::sendToClient($clientId, ['type' => 'error', 'msg' => 'Invalid JSON']);
            return;
        }

        // 使用PHP 8.5的管道操作符 |> 处理消息类型路由
        $type = $data['type'] |> strtolower(trim($$));

        match ($type) {
            'visitor_join' => self::handleVisitorJoin($clientId, $data),
            'kefu_send' => self::handleKefuSend($clientId, $data),
            'transfer' => self::handleTransfer($clientId, $data),
            default => self::sendToClient($clientId, ['type' => 'error', 'msg' => 'Unknown command'])
        };
    }

    private static function handleVisitorJoin($clientId, $data)
    {
        // 1. 分配客服（简单轮询或最少接待策略）
        $kefuId = self::assignKefu();
        
        // 2. 绑定关系（访客ClientId -> 客服ClientId）
        Gateway::bindUid($clientId, 'visitor_' . $data['visitor_id']);
        Gateway::joinGroup($clientId, 'kefu_group_' . $kefuId);

        // 3. 通知客服有新访客
        $noticeMsg = [
            'type' => 'new_visitor',
            'visitor_id' => $data['visitor_id'],
            'page' => $data['page'] ?? 'Unknown'
        ];
        self::sendToClient($kefuId, $noticeMsg);

        // 4. 回复访客
        self::sendToClient($clientId, [
            'type' => 'join_success',
            'kefu_id' => $kefuId
        ]);
    }

    private static function handleKefuSend($clientId, $data)
    {
        global $db;
        $content = htmlspecialchars($data['content'] ?? '');

        // 存储消息到MySQL
        $msgId = $db->insert('kefu_messages')->cols([
            'from_id' => $data['from'],
            'to_id' => $data['to'],
            'content' => $content,
            'create_time' => date('Y-m-d H:i:s')
        ])->query();

        // 使用 clone with 语法创建消息对象（假设有Message类）
        // $message = clone ($baseMessage, ['content' => $content, 'id' => $msgId]);

        // 转发消息给对方
        $targetId = ($data['to_type'] === 'visitor') ? 'visitor_' . $data['to'] : 'kefu_' . $data['to'];
        Gateway::sendToUid($targetId, json_encode([
            'type' => 'chat',
            'from' => $data['from'],
            'content' => $content,
            'time' => date('H:i:s')
        ]));
    }

    public static function onClose($clientId)
    {
        // 连接断开，清理资源
        Gateway::closeClient($clientId);
        echo "Connection closed: $clientId\n";
    }
}
?>

-- 客服会话表
CREATE TABLE `kefu_sessions` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `visitor_id` varchar(64) NOT NULL COMMENT '访客唯一标识',
  `kefu_id` int(11) NOT NULL COMMENT '客服ID',
  `status` tinyint(1) DEFAULT 1 COMMENT '1:进行中 0:已结束',
  `create_time` datetime DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  KEY `idx_kefu_id` (`kefu_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

-- 消息记录表
CREATE TABLE `kefu_messages` (
  `id` bigint(20) NOT NULL AUTO_INCREMENT,
  `session_id` bigint(20) NOT NULL,
  `from_id` varchar(64) NOT NULL COMMENT '发送方ID',
  `to_id` varchar(64) NOT NULL COMMENT '接收方ID',
  `content` text NOT NULL,
  `msg_type` tinyint(1) DEFAULT 1 COMMENT '1:文本 2:图片',
  `create_time` datetime DEFAULT CURRENT_TIMESTAMP,
  PRIMARY KEY (`id`),
  KEY `idx_session_id` (`session_id`)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4;

<!DOCTYPE html>
<html lang="zh-CN">
<head>
    <meta charset="UTF-8">
    <title>在线客服</title>
    <script src="https://unpkg.com/@tailwindcss/browser@4"></script>
</head>
<body class="bg-gray-100">
    <div id="chatBox" class="h-96 overflow-y-auto p-4"></div>
    <input type="text" id="msgInput" placeholder="输入消息..." class="border p-2 w-4/5">
    <button onclick="sendMsg()" class="bg-blue-500 text-white p-2 w-1/5">发送</button>

    <script>
        const ws = new WebSocket('ws://your-domain.com:8282');
        const visitorId = 'visitor_' + Math.random().toString(36).substr(2, 9);

        ws.onopen = () => {
            // 加入客服系统
            ws.send(JSON.stringify({
                type: 'visitor_join',
                visitor_id: visitorId,
                page: window.location.href
            }));
        };

        ws.onmessage = (e) => {
            const data = JSON.parse(e.data);
            if (data.type === 'chat') {
                document.getElementById('chatBox').innerHTML += 
                    `<div class="mb-2">${data.from}: ${data.content}</div>`;
            }
        };

        function sendMsg() {
            const input = document.getElementById('msgInput');
            ws.send(JSON.stringify({
                type: 'visitor_send',
                content: input.value,
                to: 'kefu_001' // 假设客服ID
            }));
            input.value = '';
        }
    </script>
</body>
</html>

由于浏览器对WebSocket的安全限制，通常需要通过Nginx进行代理。

# /etc/nginx/sites-available/kefu.conf
server {
    listen 80;
    server_name kefu.yourcompany.com; # 你的域名

    # 静态资源（客服管理后台）
    location /admin {
        root /var/www/enterprise-kefu/public;
        index index.html;
    }

    # WebSocket代理（关键配置）
    location /ws {
        proxy_pass http://127.0.0.1:8282;
        proxy_http_version 1.1;
        proxy_set_header Upgrade $http_upgrade;
        proxy_set_header Connection "upgrade";
        proxy_set_header Host $host;
        proxy_read_timeout 300s; # 长连接超时时间
    }
}

# 进入项目根目录
cd /var/www/enterprise-kefu

# 调试模式启动（观察日志）
php start_gateway.php start
php start_businessworker.php start

# 生产环境使用守护进程模式
php start_gateway.php start -d
php start_businessworker.php start -d

# 停止服务
php start_gateway.php stop
php start_businessworker.php stop

在数字服务已成为企业核心竞争力的2026年，在线客服系统早已超越简单的沟通工具，成为企业连接用户的重要桥梁。通过本文基于PHP 8.5与Workerman框架的实战搭建，我们不仅获得了一套高性能、可扩展的实时通信解决方案，更重要的是见证了PHP语言在新时代的进化与突破。这套系统的核心价值在于：它用最熟悉的技术栈（PHP）解决了曾经需要依赖Node.js或Go等语言才能应对的高并发实时通信难题。Workerman框架的事件驱动架构与PHP 8.5的现代化语法特性完美结合，让传统PHP团队也能轻松驾驭实时服务开发。无论是宜昌的跨境电商企业，还是武汉的科技公司，都能以最低的学习成本，获得专业级的在线客服能力。从技术角度看，这只是一个开始。基于此系统，企业可进一步集成AI智能回复、多渠道接入、数据分析看板等进阶功能，打造真正智能化的客户服务体系。在数字化转型浪潮中，技术选型的智慧不在于追逐最前沿，而在于选择最适合、最高效的解决方案。本攻略提供的不仅是一套代码，更是一条清晰的技术升级路径——让每一家企业都能以可控的成本，构建属于自己的专业级实时通信能力，在市场竞争中赢得先机。

在数字化快速发展的今天，企业对于在线客服系统的要求已不再局限于简单的“能聊天”，而是追求高并发、低延迟、易维护的现代化解决方案。传统的PHP-FPM架构因其阻塞式I/O模型，在实时通信领域早已力不从心。本文将带你基于PHP 8.5与Workerman框架，从零构建一个支持WebSocket协议、具备访客分配与消息存储功能的新版企业级在线客服系统。

PHP 8.5+Workerman框架：新版企业级网页在线客服系统源码搭建全攻略附代码

架构设计

基于PHP8.5与Workerman框架构建高性能企业级在线客服系统，支持WebSocket协议实现实时双向通信。采用GatewayWorker分布式架构，解决高并发问题，结合MySQL和Redis实现消息存储与状态管理。系统具备访客分配、消息路由、会话记录等功能，适合企业数字化转型需求。

数据存储

PHP语言

数据库

服务器

容器

路由

Ubuntu

MySQL

Linux

HTML5

Redis

JSON

2026采购季 | AI焕新·智启新局

tencentdb-catalog

腾讯云数据库特惠，新用户首单0.5折起


4核4G3M云服务器 新用户低至38元/年！

domain

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云AI代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

功能1上新10个字符

功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符功能2描述100个字符。

功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符功能2上新100个字符。

功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符功能5描述100个字符

功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符功能5上新100个字符

功能4上新

文章&问答评论现已支持表情

全新交互，全新视觉，新增快捷键、悬浮工具栏、高亮块等功能并同时优化现有功能，全面提升创作效率和体验

社区富文本编辑器全新改版！诚邀体验～ 

精选全网热门MCP server，让你的AI更好用 🚀

💥开发者 MCP广场重磅上线！

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

PHP 8.5+Workerman框架：新版企业级网页在线客服系统源码搭建全攻略附代码

PHP 8.5+Workerman框架：新版企业级网页在线客服系统源码搭建全攻略附代码

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐