WebSocket实现新闻流关键词热度云图，核心是数据实时进、词频动态算、云图秒级变：服务端轻量分词推送关键词，前端维护计数器并限频归一化，Canvas动态渲染可交互词云，支持断线重连与隐藏暂停，保障流畅稳定体验。
用 WebSocket 实现新闻流关键词热度云图，核心是“数据实时进、词频动态算、云图秒级变”。不依赖轮询，也不用刷新页面，服务器推一条新新闻，前端立刻提取关键词、更新统计、重绘词云。
一、服务端实时推送新闻流并附带关键词
WebSocket 服务端（如 Node.js + ws 库）需持续接入新闻源，并在推送前完成轻量 NLP 处理：
- 从 RSS、API 或消息队列（如 Kafka）拉取最新新闻标题/摘要
- 用简单规则或轻量模型（如 jieba 分词 + 停用词过滤）提取 3–5 个核心关键词，剔除“的”“了”“新华社”等无效词
- 推送格式为标准 JSON，含时间戳和关键词数组：
{"type":"news","id":"202604291822","keywords":["人工智能","监管","网信办","虚拟人"]} - 避免高频刷推——同一新闻源每 3 秒最多推 1 条，防止前端过载
二、前端用 WebSocket 接收并维护热词计数器
浏览器建立连接后，不再主动请求，只监听服务端下发的数据：
- 初始化 WebSocket：
const ws = new WebSocket("wss://your-api.com/news-ws"); - 收到消息后解析 keywords 字段，对每个词做累加：
wordCount[word] = (wordCount[word] || 0) + 1; - 限制内存占用：只保留出现频次 ≥3 的前 50 个词，其余自动淘汰（可用 Map + LRU 逻辑）
- 每 5 秒触发一次“归一化”：将所有词频映射到 12–48px 字体区间，避免某词暴涨导致其他词不可见
三、用 Canvas 动态渲染可交互词云图
不用 ECharts 等重型库，原生 Canvas 更轻、更可控，适合高频重绘：
立即学习“前端免费学习笔记（深入）”；
- 按词频降序排列热词，依次在画布上“随机散点+避让布局”绘制文字（可用简易碰撞检测避免重叠）
- 字体大小绑定频次，颜色可按领域区分：蓝色=科技类、红色=政策类、绿色=民生类（根据关键词字典预标）
- 支持鼠标悬停显示详情：
词名 + 当前频次 + 首次出现时间，提升信息密度 - 每轮重绘前清空画布，用
requestAnimationFrame平滑过渡，视觉不卡顿
四、保障稳定与体验的几个关键点
真实场景中网络波动、标签页切走、重复打开都常见，需针对性处理：
- 连接断开时自动尝试重连（指数退避：1s → 2s → 4s），重连成功后发
{"type":"sync"}请求最近 20 条新闻补全词频 - 页面隐藏（
visibilitychange）时暂停重绘，但继续接收并缓存数据，切回前台立即刷新 - 为防刷榜，服务端对同一 IP 每分钟最多接受 10 条新闻上报（适用于用户投稿型场景）
- 首次加载可预置微博热搜 Top10 作为兜底词云，避免白屏等待
