Smalldok's Tech Blog

穷则变、变则通、通则达


  • 首页

  • 分类

  • 关于

  • 标签

  • 归档

  • 公益 404

  • 搜索

1-心跳 HEARTBEAT

| 分类于 源码学习 , MPush , 源码分析 , Mpush Server , 接入服务 | 评论数: | 阅读次数:

接收消息,解码协议、解码body内容,站内搜索文章: 编码解码

客户端发送心跳:
场景一:

当与服务端建立连接时(ConnClientChannelHandler#channelActive),发送握手或者快速连接请求;
在接收到握手或者快速连接响应时(ConnClientChannelHandler#channelRead),发送心跳请求;

场景二:

当网络断开时不主动关闭连接,而是尝试发送一次心跳检测,如果能收到响应,说明网络短时间内又恢复了,否则就断开连接,等待网络恢复并重建连接。
见mpush-client-java工程 MPushClient#onNetStateChange()方法;

服务端接收处理心跳:

1
2
//ConnectionServer#init()
messageDispatcher.register(Command.HEARTBEAT, HeartBeatHandler::new);

1
2
3
4
5
6
7
public final class HeartBeatHandler implements MessageHandler {
@Override
public void handle(Packet packet, Connection connection) {
connection.send(packet);//ping -> pong
Logs.HB.info("ping -> pong, {}", connection);
}
}



接入服务文章目录:

  • 1-心跳 HEARTBEAT
  • 2-握手 HANDSHAKE
  • 3-用户绑定-解绑 BIND-UNBIND
  • 4-快速连接 FAST_CONNECT
  • 5-客户端推送 PUSH
  • 6-消息确认 ACK
  • 7-HTTP代理 HTTP_PROXY
1…737475…100
smalldok

smalldok

JAVA服务端架构,目前方向是微服务落地、基础设施、中间件、DevOps

100 日志
27 分类
17 标签
Links
  • sofa-bolt
  • sofa-rpc
  • dubbo
  • sofa-tracer
  • sofa-boot
  • Sentinel
  • COLA
  • nacos
  • xxl-job
  • apollo
  • sharding-sphere
  • fescar
  • ByteTCC
  • tcc-transaction
  • rocketmq
  • canal
  • arthas
  • jvm-sandbox
  • sofa-lookout
  • disruptor
  • mpush
© 2007 – 2019 smalldok
由 Hexo 强力驱动 v3.8.0
|
主题 – NexT.Mist v6.7.0