终端消息推送时断时续:WebSocket 心跳检测、断线重连与消息补发的落地记录

简介: 终端收不到推送要手动重启,WebSocket连接表面活着实际已断。记录30秒心跳ping/pong、missedPongs计数、指数退避重连、Nginx Upgrade头配置、lastMsgId消息补发的完整方案。

门店终端有时候收不到后台推送的价格变更通知,要手动重启终端才能恢复。查日志发现 WebSocket 连接表面上还在,但实际已经断了——中间经过了一层 Nginx 反向代理,空闲连接 60 秒就被断开,但终端不知道,还以为连接正常。

前后花了两天把心跳和重连机制加上,记录下来。

一、问题:TCP 断开了但应用层不知道

WebSocket 是长连接,但中间经过负载均衡或 Nginx,空闲连接超时会被断开。如果没有心跳机制,客户端不会知道连接已断,继续往"死连接"上发消息,消息全部丢失。

判断连接是否存活,不能只看 WebSocket.readyState === OPEN,要靠应用层心跳。

二、心跳:客户端定时发 ping,服务端回 pong

客户端每 30 秒发一个心跳消息,服务端收到后回 pong。如果连续 3 次没收到 pong,判定连接已断,主动重连:

// 客户端伪代码
let ws, heartbeatTimer, missedPongs = 0;

function connect() {
   
    ws = new WebSocket('wss://你的站/ws');
    ws.onopen = () => {
   
        missedPongs = 0;
        heartbeatTimer = setInterval(sendPing, 30000);
    };
    ws.onmessage = (event) => {
   
        if (event.data === 'pong') {
   
            missedPongs = 0;  // 收到pong重置计数
        } else {
   
            handleBusinessMessage(event.data);
        }
    };
    ws.onclose = () => {
   
        clearInterval(heartbeatTimer);
        setTimeout(connect, 3000);  // 3秒后重连
    };
}

function sendPing() {
   
    missedPongs++;
    if (missedPongs >= 3) {
   
        ws.close();  // 连续3次没pong,主动断开触发重连
        return;
    }
    ws.send('ping');
}

关键参数:心跳间隔 30 秒,Nginx 空闲超时一般是 60 秒,30 秒一次心跳能保持连接不被断开。missedPongs 连续 3 次(90 秒)没收到 pong 才判定断开,避免网络抖动误判。

三、Nginx WebSocket 代理配置

Nginx 代理 WebSocket 要加 Upgrade 头,否则握手会失败:

location /ws {
    proxy_pass http://backend;
    proxy_http_version 1.1;
    proxy_set_header Upgrade $http_upgrade;
    proxy_set_header Connection "upgrade";
    proxy_read_timeout 3600s;   # 心跳保持连接,超时放宽到1小时
    proxy_send_timeout 3600s;
}

proxy_read_timeout 默认 60 秒,我们的心跳间隔 30 秒,理论上不会超时。但 Nginx 版本不同默认值可能不一样,显式设到 3600 秒最保险。

四、消息补发:断线期间的消息不能丢

客户端重连后,要告诉服务端"我最后收到的消息 ID 是多少",服务端把断线期间错过的消息补发过来:

// 重连时带上最后收到的消息ID
ws.onopen = () => {
   
    ws.send(JSON.stringify({
   
        type: 'resume',
        lastMsgId: localStorage.getItem('lastMsgId') || 0
    }));
};

// 收到消息后记录ID
ws.onmessage = (event) => {
   
    const msg = JSON.parse(event.data);
    localStorage.setItem('lastMsgId', msg.id);
    handleBusinessMessage(msg);
};

服务端收到 resume 请求后,从 lastMsgId 之后开始推送历史消息。这样断线期间错过的消息不会丢。

五、踩坑清单(5 条实际踩过的)

  1. WebSocket.readyState === OPEN 不代表连接真的活着,必须用心跳确认。
  2. 心跳间隔要小于 Nginx/负载均衡的空闲超时,否则连接中间就被断了。
  3. 重连要加指数退避,别每秒疯狂重连,服务器恢复时会被冲垮。
  4. 消息 ID 要持久化到 localStorage,终端重启后重连也能补发历史消息。
  5. Nginx 代理 WebSocket 必须加 Upgrade 和 Connection 头,否则握手 400。
方案 断线检测 消息不丢 复杂度
无心跳 慢(数分钟) 否 低
心跳+重连 快(90秒) 否 中
心跳+重连+补发 快 是 中高

这次终端消息推送的稳定性改造是在唯顿收银系统的终端推送模块上做的,我主要负责加 WebSocket 心跳检测、写断线重连逻辑和消息补发那几段,改完后消息丢失率从每天十几条降到 0。

复盘

  • WebSocket 长连接必须有心跳,readyState 不可信。
  • 心跳间隔小于中间代理的空闲超时,重连加指数退避。
  • 消息补发靠客户端带 lastMsgId,服务端补发断线期间的历史消息。

以上是个人实践记录,各平台具体功能以官方实时信息为准。

你们做 WebSocket 推送时,心跳间隔一般设多少?

相关文章
|
2天前
|
云安全 人工智能 运维
当攻击全面Agent化,你的安全防御能否跟上AI Speed?
多起客户侧AK泄露事件应急的真实观察
1199 1
|
25天前
|
人工智能 JSON API
全网刷屏的 Jev 模型正式开放!一手实战测评 + 保姆级教程
全网爆火的 Jev 模型是什么?有什么用?怎么使用?怎么接入 AI 编程工具?效果真的好么?傻子可懂的 Jev 保姆级实战教程 + 项目实战测评来啦
9587 32
|
11天前
|
存储 人工智能 并行计算
大模型本地部署终端选型方法论:以 Qwen3.8-27B 为例的四档分层完整流程
本文提出一套大模型本地部署终端选型方法论:定约束、定档位、定框架、定参数四步决策法,配合入门、主力、质量、无损四档分层模型。以 Qwen3.8-27B 实测数据为例,逐环节解读显存、带宽、存储、散热、系统、预算等要素,给出面向不同预算的优选方案、决策自查清单与市场观察框架。文末前瞻 AI 笔记本的 CPU+GPU 与统一内存两条路线,论证四步决策法在新品类上的延续性。
|
10天前
|
人工智能 JSON 自然语言处理
2026 年 Jev 决策模型深度拆解:原理解读、实战测评与保姆级落地教程
有一款特殊AI模型在开发者圈子刷屏,它摒弃传统大模型擅长的对话聊天能力,专注做高速结构化决策,它就是TypeSafe AI推出的Jev模型。该模型由ChatGPT共同发明人Diogo Almeida主导研发,定位为**System One Model(系统一模型)**,对标人类大脑快速直觉判断的思维模式,在响应延迟、调用成本、结构化输出稳定性上相比传统生成式大模型有着巨大差异。本文会完整拆解Jev底层原理、三大核心原语能力、适用业务场景,同时提供可直接运行的curl、Python代码示例,并且结合多组实测数据,客观分析模型优势与能力边界,帮助普通开发者和AI应用从业者快速上手落地。
787 1
|
6天前
|
人工智能 JSON 自然语言处理
2026 年 Jev 决策模型全解析:核心原理拆解,性能实战测评与落地部署教程
有一款特殊AI模型在开发者圈子刷屏,它摒弃传统大模型擅长的对话聊天能力,专注做高速结构化决策,它就是TypeSafe AI推出的Jev模型。该模型由ChatGPT共同发明人Diogo Almeida主导研发,定位为System One Model(系统一模型),对标人类大脑快速直觉判断的思维模式,在响应延迟、调用成本、结构化输出稳定性上相比传统生成式大模型有着巨大差异。本文会完整拆解Jev底层原理、三大核心原语能力、适用业务场景,同时提供可直接运行的curl、Python代码示例,并且结合多组实测数据,客观分析模型优势与能力边界,帮助普通开发者和AI应用从业者快速上手落地。
522 0
|
23天前
|
人工智能 测试技术 API
最近全网爆火的 Jev 到底是什么?适合干什么、怎么用,一篇讲透!
Jev是TypeSafe AI推出的“系统一模型”,不生成文本,专做毫秒级结构化决策:Choice(多选)、Score(打分)、Noul(是非概率)。响应快193倍、成本低444倍,适合工单路由、内容审核、测试定级等高频判断场景。
2605 4
最近全网爆火的 Jev 到底是什么?适合干什么、怎么用,一篇讲透!
|
7天前
|
存储 人工智能 自然语言处理
千问办公官网入口链接在哪?2026年最新QwenWork测评、千问办公怎么样?一文看懂
千问办公(QwenWork)是阿里云推出的AI智能办公平台,提供网页端和阿里云官网双入口。支持PPT/Word/Excel生成、多模态处理、网页全栈搭建、钉钉深度集成等6大核心能力。个人版免费可用,高级版198元/月;企业版198元/人/月。新用户注册即赠2000积分。阿里千问办公QwenWork官网:https://t.aliyun.com/U/0VCTGt 阿里AI工作平台,一句话完成数据分析、PPT 生成、视频剪辑、网页搭建等复杂任务
1013 0
|
17天前
|
Windows
【保姆级】.NET Framework 3.5离线安装教程(2026最新实测)
.NET Framework 3.5是微软经典运行库,专为兼容老软件、老游戏设计。Win7自带,Win10/11需手动启用(在线或离线安装)。它与4.x系列并存不冲突,缺它会导致“找不到组件”报错。本文详解两种安装方式及常见问题解决,小白也能轻松上手。(239字)
2205 0

热门文章

最新文章