WebSocket 生产者发送台
支持单次发送和循环发送数据的 WebSocket 测试工具。
🚀 在线使用工具
工具介绍
WebSocket 生产者发送台 (ws_producer.html) 是一个专门用于向 WebSocket 服务器发送消息的测试工具。
核心功能
- 🚀 单次发送：手动编辑并发送单条消息
- 🔄 循环发送：按设定间隔自动循环发送消息
- 📝 数据模板：内置实时数据和告警数据模板，一键填充
- 🎲 数据随机化：循环发送时支持自动随机化数据（心率、呼吸、时间戳等）
- 📊 发送统计：实时统计发送消息数量、类型分布
- 📋 发送日志：记录所有发送操作和结果
适用场景
- WebSocket 服务的压力测试
- 模拟实时数据流
- 测试消息处理逻辑
- 验证数据格式
WebSocket 生产者概念
什么是生产者（Producer）？
生产者是消息队列和实时通信系统中的核心概念，指创建并发送消息的客户端或服务。
在 WebSocket 通信中：
- 生产者是连接到 WebSocket 服务器并发送消息的一方
- 生产者负责生成消息并推送给服务器
- 服务器可以将生产者发送的消息转发给其他消费者
生产者的特点
- 主动发送：生产者主动创建和发送消息
- 即时性：消息创建后立即发送，无需等待
- 独立性：生产者可以独立工作，不依赖消费者
- 可控性：生产者可以控制消息的内容、频率和时机
生产者的工作流程
生产者创建消息 → 发送到 WebSocket 服务器 → 服务器转发 → 消费者接收
业务场景
1. 智能硬件数据上报
场景描述：
- 物联网设备（传感器、监测仪等）作为生产者
- 定期采集数据并通过 WebSocket 上报到服务器
典型应用：
- 📱 体征监测仪：实时上报心率、呼吸、体温等健康数据
- 🌡️ 环境传感器：上报温度、湿度、PM2.5 等环境数据
- 🚗 车载设备：上报位置、速度、油耗等车辆数据
- 🏭 工业设备：上报运行状态、故障信息等设备数据
优势：
- 数据实时上报，延迟低
- 支持设备离线重连和数据补传
- 降低服务器负载（相比轮询）
2. 实时事件触发
场景描述：
- 系统检测到特定事件时，立即通过 WebSocket 发送消息
- 事件源作为生产者发送告警或通知
典型应用：
- 🚨 异常告警：设备故障、环境异常、行为异常等
- ⚠️ 安全事件：入侵检测、烟雾报警、紧急求助
- 🔔 业务事件：订单创建、支付成功、状态变更
- 📧 系统事件：日志记录、审计事件、操作记录
优势：
- 事件即时推送，响应速度快
- 支持事件优先级和分级处理
- 事件可追溯和审计
3. 用户行为上报
场景描述：
- 用户在客户端进行操作时，实时上报操作行为
- 客户端作为生产者发送用户行为数据
典型应用：
- 👆 用户交互：点击、滚动、停留时长等
- 🎮 游戏行为：角色移动、技能释放、物品获取
- 🛒 购物行为：浏览商品、加入购物车、下单
- 📱 APP 行为：页面访问、功能使用、错误上报
优势：
- 行为数据实时采集
- 支持大数据分析和用户画像
- 可用于实时推荐和个性化服务
4. 实时协作系统
场景描述：
- 用户在协作系统中进行操作时，实时同步给其他用户
- 每个用户既是生产者也是消费者
典型应用：
- ✏️ 协同编辑：多人同时编辑文档，操作实时同步
- 💬 在线聊天：发送消息给其他用户
- 🎨 协同设计：多人协作设计，操作实时同步
- 📊 数据协作：多人同时操作数据表格
优势：
- 实时同步，体验流畅
- 支持冲突检测和解决
- 提升协作效率
5. 数据采集与上报
场景描述：
- 各种数据源定时或按需采集数据
- 通过 WebSocket 批量或实时上报到数据处理中心
典型应用：
- 📊 业务数据上报：销售数据、用户数据、订单数据
- 📈 统计数据上报：访问量、转化率、活跃度
- 🔍 日志数据上报：应用日志、错误日志、性能日志
- 📡 监控数据上报：系统指标、性能指标、健康指标
优势：
- 数据上报高效，实时性强
- 支持批量上报，减少网络开销
- 数据集中处理，便于分析
使用场景示例
场景一：智能体征监测
体征监测仪（生产者）→ 采集心率、呼吸数据
↓
WebSocket 服务器
↓
消费者1：医生端监控
消费者2：护士端监控
消费者3：家属端查看
工作流程：
- 监测仪每 2 秒采集一次数据
- 数据封装成 JSON 格式
- 通过 WebSocket 发送到服务器
- 服务器广播给所有连接的消费者
场景二：告警系统
异常事件发生 → 生产者检测到异常
↓
生成告警消息
↓
WebSocket 发送告警
↓
服务器处理
↓
推送告警给相关人员
- 医护人员（消费者）
- 家属（消费者）
- 告警中心（消费者）
场景三：实时数据采集
多个数据源 → 生产者1：设备A数据
→ 生产者2：设备B数据
→ 生产者3：设备C数据
↓
WebSocket 服务器
↓
数据聚合处理
↓
推送给数据大屏（消费者）
技术优势
与 HTTP POST 对比
| 特性 | WebSocket 生产者 | HTTP POST |
|---|---|---|
| 连接开销 | ⭐⭐⭐⭐⭐ 一次连接，多次发送 | ⭐⭐ 每次请求新建连接 |
| 实时性 | ⭐⭐⭐⭐⭐ 毫秒级 | ⭐⭐⭐ 秒级 |
| 服务器压力 | ⭐⭐⭐⭐⭐ 低（长连接） | ⭐⭐ 高（短连接） |
| 双向通信 | ⭐⭐⭐⭐⭐ 支持 | ❌ 不支持 |
| 适用场景 | 高频、实时数据 | 低频、请求-响应 |
发送模式
1. 单次发送模式
- 适合：事件触发、告警推送、用户操作
- 特点：按需发送，消息独立
2. 循环发送模式
- 适合：定时上报、数据采集、状态监控
- 特点：周期性发送，数据连续
3. 批量发送模式
- 适合：日志上报、统计数据、批量同步
- 特点：一次发送多条，提高效率
最佳实践
1. 消息设计
- 消息格式：使用统一的 JSON 格式
- 消息大小：控制单条消息大小，避免过大
- 消息字段：包含必要的元数据（时间戳、来源、类型等）
2. 发送策略
- 发送频率：根据业务需求合理设置发送间隔
- 失败重试：实现发送失败的重试机制
- 消息缓冲：网络异常时缓冲消息，恢复后补发
3. 性能优化
- 批量发送：合并多条消息，减少网络请求
- 压缩传输：大数据量时使用压缩
- 连接复用：使用长连接，避免频繁建立连接
4. 错误处理
- 连接管理：处理连接断开和重连
- 消息验证：发送前验证消息格式
- 日志记录：记录发送成功和失败的情况
适用条件
适合使用 WebSocket 生产者的场景：
- ✅ 需要实时发送数据
- ✅ 发送频率较高（秒级或更频繁）
- ✅ 需要双向通信
- ✅ 需要推送通知或事件
- ✅ 多个消费者需要接收相同消息
不适合使用的场景：
- ❌ 发送频率极低（分钟级或更久）
- ❌ 只需要简单的请求-响应
- ❌ 服务器不支持 WebSocket
- ❌ 需要兼容不支持 WebSocket 的设备
提示：配合 ws_consumer.html（WebSocket 消费者监控台）一起使用，可以完整测试 WebSocket 服务的发送和接收功能。