WebSocket如何接收来自第三方的消息 Webhook转WebSocket教程【实战】-js教程-PHP中文网

webhook转websocket需中转服务：先接收webhook，再通过websocket广播；须注意并发安全、消息格式处理、签名验证及连接稳定性。

websocket如何接收来自第三方的消息 webhook转websocket教程【实战】

Webhook 转 WebSocket 不是“转换协议”，而是用 WebSocket 主动建立长连接替代被动接收 Webhook 的短轮询模式。直接改用 WebSocket 接收第三方消息，前提是对方**原生支持 WebSocket 推送**；若对方只提供 Webhook，你就得自己搭个中转服务——先收 Webhook，再推给前端 WebSocket 连接。

第三方只支持 Webhook，怎么让前端实时收到消息？

你没法让第三方“改成 WebSocket 发送”，只能在中间加一层代理服务：它对外暴露 Webhook 回调地址，对内维护一个 WebSocket 广播通道。所有业务逻辑集中在这一层，前端只管连 WebSocket。

必须用 http.HandleFunc 或 Express app.post() 显式监听 POST，别漏掉方法校验，否则收不到请求
Webhook 请求体要一次性读完（io.ReadAll(r.Body) 或 bodyParser.raw()），否则后续签名验证或 JSON 解析会失败
收到后立刻返回 200 OK 空响应，别写任何 body，否则第三方可能重试
把原始 payload 存入内存队列（如 Go 的 chan []byte 或 Node 的 EventEmitter），再由 WebSocket 广播协程异步分发
注意并发安全：多个 Webhook 并发到达时，广播逻辑不能阻塞接收协程

WebSocket 客户端如何正确识别和处理不同格式的消息？

第三方通过 WebSocket 发送的数据类型不固定，event.data 可能是 string、Blob 或 ArrayBuffer，直接 JSON.parse(event.data) 会报错。

WebSocket 8.18.2

WebSocket 8.18.2 是该协议规范的一个重要迭代版本，主要优化了连接稳定性与数据传输效率。它通过全双工通信机制，允许客户端与服务器在单一长连接上实时交换数据，大幅降低传统 HTTP 轮询的开销。该版本增强了心跳保活、自动重连及二进制帧传输能力，适用于即时通讯、在线游戏及金融行情推送等低延迟场景，为开发者提供更可靠的实时网络交互基础。

下载

先判断类型：typeof event.data === 'string' 才走 JSON 解析
如果是 Blob，需调用 event.data.text().then(...) 获取字符串后再解析
如果是 ArrayBuffer，用 new TextDecoder().decode(event.data) 转字符串
不要假设所有消息都带 type 字段，建议服务端统一加 {"type":"order_created","data":{...}} 结构，客户端按 msg.type 分发处理

为什么用 n8n + WebSocket 比纯 Webhook 更稳？

n8n 1.111.0+ 版本内置了 WebSocket 触发节点，可直连飞书、Discord 等平台的 WebSocket 网关，绕过 Webhook 的公网配置、SSL、签名、重试等环节。

Webhook 高峰期超时率可达 37%，而 WebSocket 中位延迟仅 28ms，因连接已预建好
n8n 的 WebSocket 节点自动处理心跳、断线重连、连接状态监控，不用自己写 setInterval 心跳逻辑
调试时可在 n8n UI 直接看到连接是否 active、最近收到哪条消息，比抓包查 Webhook 日志快得多
注意：KOOK 等平台明确禁止 Webhook 和 WebSocket 同时启用，切勿在后台同时开启两种模式

Go 实现 Webhook → WebSocket 中转时最易踩的坑

用 Go 写中转服务看似简单，但几个关键点一错就导致消息丢失或连接卡死。

http.HandleFunc 里千万别直接 json.Decode(r.Body) ——这会吞掉原始字节流，导致后续 HMAC 签名验证失败
广播给所有 WebSocket 连接时，必须对每个 *websocket.Conn 单独加锁或用 conn.SetWriteDeadline()，否则一个慢连接会拖垮整个广播循环
别把 time.Now().UnixMilli() 当唯一 ID：高并发下可能重复，建议用 atomic.AddInt64(&id, 1) 或 UUID
Webhook 请求头里的 X-Hub-Signature-256 必须在 io.ReadAll(r.Body) 后立即计算，且用 hmac.Equal 比对，不能用 ==
前端 WebSocket 连接数暴涨时，Go 的 net/http 默认 MaxHeaderBytes 可能不够，需显式设置 http.Server{ReadBufferSize: 4096}