WebSocket是构建实时在线客服系统的核心技术，通过全双工长连接替代轮询，实现低延迟、高并发消息传输；其关键在于承载业务逻辑——多渠道标识绑定、动态坐席分流、会话生命周期管理、断线重连与配置化策略。
WebSocket 是实现网页端实时在线客服系统的核心技术，它能建立浏览器与服务器之间的全双工长连接，避免轮询开销，保障消息低延迟、高并发送达。要构建“多渠道+智能分流”的在线客服系统，关键不在 WebSocket 本身，而在于如何用它承载业务逻辑：识别用户来源（微信H5、官网、APP内嵌页等）、维护坐席状态、执行分流策略（如空闲优先、技能匹配、会话数均衡）、同步会话上下文。下面从架构要点和代码逻辑两个层面说明实现路径。
一、WebSocket 连接初始化与多渠道标识绑定
用户进入页面时，前端需在建立 WebSocket 连接前，携带明确的渠道标识（channel）和用户身份信息（如 user_id、session_id），不能依赖 Cookie 或 localStorage 在 ws 握手阶段传递——因为 WebSocket 协议不发送 Cookie（除非显式配置 withCredentials），且服务端无法直接读取前端存储。
- 推荐方式：将参数拼在 WebSocket URL 中，例如：
ws://your-api.com/ws?channel=wechat_h5&user_id=U12345&source_page=/product/detail - 服务端（如 Node.js + ws 库）在 connection 事件中解析 query 参数，存入该 socket 实例的元数据：
socket.channel = urlParams.get('channel');
socket.userId = urlParams.get('user_id');
socket.context = { source_page: urlParams.get('source_page') }; - 后续所有消息路由、分流、日志记录都基于这些初始字段，确保同一用户在不同渠道打开多个标签页时，也能被识别为独立会话源。
二、坐席状态管理与实时分流决策
分流不是静态分配，而是动态决策过程。需维护一个全局可读写的坐席状态池（如 Redis Hash 或内存 Map），每个坐席对象包含：id、name、status（online/idle/busy/offline）、skills（['售前','投诉','技术']）、currentLoad（当前会话数）、lastActiveAt（最后响应时间）。
- 坐席登录/登出、状态切换（如点击“小休”按钮）时，通过 WebSocket 向服务端发送控制指令（如 { "type": "update_status", "data": { "status": "idle", "skills": ["售前"] } }），服务端更新状态池并广播给管理后台。
- 新用户接入时（即收到用户发来的 {"type":"init_chat"}），服务端按预设策略选择坐席：
- 优先筛选 status === 'idle' 且 skills 包含用户咨询类型（如用户带参 ?topic=tech，则匹配含 '技术' 的坐席）；
- 若无技能匹配，则 fallback 到 currentLoad 最低 的在线坐席；
- 若全部忙碌，加入等待队列，并向前端推送 {"type":"queued", "queuePos": 3}，支持前端显示“前面还有3人”。
三、会话生命周期与跨端消息透传
一个完整会话包含用户、坐席、可能的质检员三方，且坐席可能在 PC 后台、手机 App、企业微信多个终端同时在线。WebSocket 需支持“一对多”广播与“点对点”定向转发。
将 Markdown 文章转换为微信公众号兼容的纯 HTML 格式。当用户要求"转成微信格式"、"生成公众号文章 HTML"、"排版到微信草稿箱"、"微信粘贴格式"时触发。输出带内联样式的纯 HTML，微信编辑器可直接渲染，无需额外适配。支持标题、段落、列表、粗体、行内代码、表格、引用块、代码块、配图的完整转换。
立即学习“前端免费学习笔记（深入）”；
- 为每个会话生成唯一 sessionId（如 S20240520112233_abc789），用户首次发消息时由服务端生成并返回，后续所有消息必须携带该 ID；
- 坐席端连接时，除自身坐席 ID 外，还需订阅其已接管的 sessionId 列表（如从数据库查出当前分配给他的 3 个会话），服务端为每个 socket 维护 subscribedSessions = new Set(['S1', 'S2'])；
- 当用户发来消息：
{ "type": "msg", "sessionId": "S1", "content": "怎么退款？" }
服务端查出 S1 当前绑定坐席 A，且坐席 A 的多个终端 socket 都订阅了 S1 → 向这些 socket 全部推送该消息； - 坐席回复同理，但需附带 from: "agent" 字段，便于前端区分气泡方向与样式。
四、断线重连与会话恢复机制
网页端网络不稳定是常态。不能让用户断连后丢失排队位置或已输入内容。
- 前端监听 socket.onclose，触发自动重连（带指数退避），并在重连 URL 中带上上次的 sessionId（如有）和本地未确认消息队列；
- 服务端收到重连请求，先校验 sessionId 是否有效、是否仍处于可恢复状态（如未超时 5 分钟、未被人工转接），若有效则重建关联，补发离线期间的未读消息（从 Redis Stream 或消息队列中拉取）；
- 用户输入框内容建议本地 localStorage 缓存（key = `draft_${sessionId}`），连接恢复后自动填充，并提示“检测到您之前输入的内容，是否继续发送？”。
不复杂但容易忽略的是：分流策略必须可配置、可灰度、可回滚。把规则写死在代码里会导致每次调整都要发版。建议将常用策略（如“技能优先 > 负载均衡 > 随机”）抽象成 JSON 配置项，由运营后台动态下发，WebSocket 服务端监听配置变更事件实时加载。这样产品改个分流逻辑，运维点点鼠标就生效。
