前一篇聊了三马代驾系统的整体架构和三级派单，这次往细里抠一层：司机端和乘客端挂在 Netty 长连接上，手机进电梯、切后台、弱网闪断都是家常便饭，

连接断了之后怎么发现、怎么重连、断线期间的消息怎么不丢

——这套机制才是派单链路真正能跑起来的地基。

下面的代码全部取自三马代驾系统的生产实现。

一、协议设计：两个枚举定生死

长连接第一件事不是写代码，是定协议。我们把"客户端要干什么"和"服务端回了什么"拆成两个枚举。

客户端操作类型（NettyHandleEnums）：

服务端返回码（NettyCodeEnums）截取几个关键的：

KEEPALIVE(1,"心跳正常"),
KEEPALIVE_ERROR(-1,"心跳异常"),
CONNECT(2,"第一次连接正常"),
CONNECT_ERROR(-2,"第一次连接异常"),
DRIVER_UNFINISHED_ORDER(29,"司机有未完成订单"),
DRIVER_STATUS_RESET(30,"刷新司机状态"),
ORDER_MOVE(100,"订单行驶中"),
SOCKET_TIME_OUT(101,"读写超时"),
LOGIN_ERROR(997,"账号登录失效")

 这两个码，它们存在的唯一意义就是

二、服务端 pipeline：10 秒空闲就踢

ChannelPipeline pipeline = socketChannel.pipeline();
pipeline.addLast(new HttpServerCodec());
pipeline.addLast(new ChunkedWriteHandler());
pipeline.addLast(new HttpObjectAggregator(1024*64));

//===========================增加心跳支持==============================
/**
 * 针对客户端，如果在1分钟时间内没有向服务端发送读写心跳（ALL），则主动断开连接
 */
pipeline.addLast(new IdleStateHandler(0, 0, 10, TimeUnit.SECONDS));
pipeline.addLast(dataAcceptHandler);
pipeline.addLast(new WebSocketServerProtocolHandler("/ws"));

 的含义是：读空闲不查、写空闲不查，但

读加写一共 10 秒没有任何动静就触发 ALL_IDLE 事件

。客户端心跳间隔必须小于这个值，我们 App 端实际是几秒一次。

public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
    if (evt instanceof IdleStateEvent) {
        IdleStateEvent event = (IdleStateEvent) evt;
        if (event.state() == IdleState.ALL_IDLE) {
            log.info("===客户端===(ALL_IDLE 总超时 重新连接)");
        }
    }
    ctx.channel().writeAndFlush(new MsgVo(NettyCodeEnums.SOCKET_TIME_OUT).toJsonStringbuf());
    channelInactive(ctx);//清除netty通道
}

，万一它还活着，能知道自己被踢了、立刻重连，然后再进 

三、CONNECT：重连不只是重连，是状态恢复

连接管理用的是个单机 HashMap，key 带角色前缀：

public class UserChanelRel {
    private static HashMap<String, Channel> manage = new HashMap<>();
    // key 前缀区分角色：driver:{id} / user:{id}
    public static void put(String senderId, Channel channel){
        manage.put(senderId, channel);
    }
}

case CONNECT:
    //客户端连接--第一次或者重连处理
    if (chanelContext.equals("CONNECT")) {
        //每次连接或者重连时，把连接存入连接池中
        UserChanelRel.put(didStr, ctx.channel());
        channel.writeAndFlush(new MsgVo(NettyCodeEnums.CONNECT).toJsonStringbuf());
        if (cal.isEquals(channelIdentity, StaticUtils.STATUS_YES)){
            //校验司机是否处于服务状态
            OrderMain orderMain = orderMainService.selectOrderByDriver(did);
            if (orderMain != null) {
                //反馈司机有未完成订单
                MsgVo msgVo = new MsgVo(NettyCodeEnums.DRIVER_UNFINISHED_ORDER);
                msgVo.setOrderCode(orderMain.getOrderCode());
                channel.writeAndFlush(msgVo.toJsonStringbuf());
            }
        }

。司机端重连后，服务端要查他名下有没有未完成订单，有就推 

，App 收到后把订单界面恢复出来。用户端更细——如果重连时带着 orderCode，且订单正在行驶中，服务端会把里程、等待时长、费用等完整状态通过 

 推回去，用户端直接接着断线前的界面渲染。

这是踩过坑才想明白的：只恢复连接不恢复状态，用户看到的就是一个"回到首页"的 App，订单凭空消失，投诉就是这么来的。

四、KEEPALIVE：心跳顺手干三件正事

心跳包不只是保活，我们的心跳分支顺手做了三件事：

case KEEPALIVE:
    //1. 心跳包超过350字节判定为非法，直接断开
    if (length > 350) {
        ctx.channel().writeAndFlush(new MsgVo(NettyCodeEnums.SOCKET_ERROR).toJsonStringbuf());
        channelInactive(ctx);
        UserChanelRel.delChannel(didStr);
    }
    //2. 没走过CONNECT的心跳请求，移除
    Channel channel1 = UserChanelRel.get(didStr);
    if (channel1 == null){
        ctx.writeAndFlush(new MsgVo(NettyCodeEnums.SOCKET_ERROR).toJsonStringbuf());
        channelInactive(ctx);
    }

先做两道安全校验：包太大（超过 350 字节）的是恶意流量，踢；没经过 CONNECT 注册就发心跳的，也是非法连接，踢。

，所以心跳等于位置上报，一举两得：

if (cal.isEquals(channelIdentity, StaticUtils.STATUS_YES)) {
    //更新司机位置
    DDriver driver = dDriverService.getById(did);
    driver.setLonVal(requestVo.getLongitude());
    driver.setLatVal(requestVo.getLatitude());
    driver.setAddress(requestVo.getAddress());
    //异常状态的司机，名下没单则恢复为可接单
    Integer state = driver.getState();
    if (cal.isEquals(state,StaticUtils.STATUS_SUCCESS)||cal.isEquals(state,StaticUtils.STATUS_FAIL)){
        OrderMain orderMain = orderMainService.selectOrderByDriver(did);
        if (orderMain==null){
            driver.setState(StaticUtils.STATUS_YES);
        }
    }
    dDriverService.updateById(driver);
    //回推最新司机状态，让App刷新接单开关
    MsgVo msgVo = new MsgVo(NettyCodeEnums.DRIVER_STATUS_RESET);
    msgVo.setDriverStatus(driver.getState());
    ctx.channel().writeAndFlush(msgVo.toJsonStringbuf());
}

——断线期间推不出去的消息暂存在 Redis，心跳一上来就补发：

}else {
    String key = redisUtilsService.getKey(didStr);
    if (StringUtils.isNotEmpty(key)){
        MsgVo msgVo = JSONObject.parseObject(key, MsgVo.class);
        ctx.channel().writeAndFlush(msgVo.toJsonStringbuf());
        redisUtilsService.delete(didStr);
    }
}

这套东西能跑，但放在更大规模下有几个明确的坑：

长连接这块的完整代码（NettyServer、DataAcceptInitializer、DataAcceptHandler、UserChanelRel、协议枚举）都在三马代驾系统里，配上上一篇的派单和计价，主链路就闭环了。协议怎么定、心跳参数怎么配、重连之后恢复什么，这三件事想清楚了，长连接才算真的能用。

上面每一段都是三马代驾在真机上跑出来的结果，欢迎在评论区聊聊你们是怎么处理弱网重连的。

前一篇聊了三马代驾系统的整体架构和三级派单，这次往细里抠一层：司机端和乘客端挂在 Netty 长连接上，手机进电梯、切后台、弱网闪断都是家常便饭，连接断了之后怎么发现、怎么重连、断线期间的消息怎么不丢——这套机制才是派单链路真正能跑起来的地基。

三马代驾实战（二）：长连接心跳、断线重连与消息补偿

三马代驾司机端与乘客端挂在 Netty 长连接上，本文讲透心跳保活、断线重连后的状态恢复，以及断线期间消息不丢的补偿机制，全部代码来自三马代驾生产实现。

后端

网络与通信

架构设计

本文深入剖析三马代驾系统基于Netty的长连接可靠性机制，重点讲解连接断开后的心跳检测、断线重连及消息补偿方案。通过IdleStateHandler实现10秒空闲踢出，CONNECT重连时恢复司机订单状态，KEEPALIVE心跳同时完成位置上报与消息补发。文章还坦承了单机连接池、心跳超时等生产环境不足，为高并发IM系统设计提供实战参考。

文章

问答

视频

教程

学习中心

腾讯云实验室

直播

竞赛

腾讯云代码分析专区

腾讯iOA零信任安全管理系统专区

腾讯云架构师技术同盟交流圈

腾讯云数据库专区

腾讯云智能顾问专区

腾讯云原生专区

腾讯混元专区

腾讯云TCE专区

腾讯云Lighthouse专区

腾讯云HAI专区

腾讯云Edgeone专区

腾讯云存储专区

腾讯云智能专区

腾讯轻联专区 

腾讯云开发专区

TAPD专区

腾讯轻量云游戏服专区

EdgeOne AI 安全实战专区

腾讯云最具价值专家

腾讯云架构师技术同盟

腾讯云创作之星

腾讯云开发者先锋

腾讯云代码助手

云原生构建

TAPD 敏捷项目管理

Cloud Studio

SDK中心

API中心

命令行工具

涵盖代码开发、场景应用、自动测试全流程，助你从零构建专属AI助手

一站式MCP教程库，解锁AI应用新玩法

聚焦“写作效率、视觉美观与运行性能”三方面进行全面升级，为您提供更高效、稳定的创作环境

社区富文本&Markdown编辑器全新改版上线，欢迎大家体验!

诚挚邀请您参与本次调研，分享您的真实使用感受与建议。您的反馈至关重要，感谢您的支持与参与！

社区新版编辑器体验调研

本文深入剖析三马代驾系统基于Netty的长连接可靠性机制，重点讲解连接断开后的心跳检测、断线重连及消息补偿方案。通过IdleStateHandler实现10秒空闲踢出，CONNECT重连时恢复司机订单状态，KEEPALIVE心跳同时完成位置上报与消息补发。文章还坦承了单机连接池、心跳超时等生产环境不足，为高并发IM系统...

三马代驾实战（二）：长连接心跳、断线重连与消息补偿

三马代驾实战（二）：长连接心跳、断线重连与消息补偿

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐