心跳消息服务器,smart

消息服务器,smart"/>

心跳消息服务器,smart

一、背景

在通信中设计的心跳消息，通常是为了检查网络链路是否正常。虽然TCP协议提供keep-alive机制，但需要在链路空闲2小时后才触发检测，这显然对业务非常不友好。当存在大量连接异常，而服务端却需要等2个小时后才感知到的时候，有限的系统资源会被逐渐耗尽，最终无法为新连接请求继续提供服务。

二、原理

要解决此类问题，业界的普遍做法是在应用层加入心跳机制。心跳消息可以是单向心跳也可以是双向心跳，所谓单向心跳表示由服务端或者客户端的其中一方主动发送心跳请求消息，而另一方返回响应消息(如下图)。双向心跳表示服务端与客户端相互发送心跳请求和响应。因为无论何种类型，实现方案都是一样的，本文以单向心跳为例给大家做讲解。

三、方案

心跳消息通常是周期性的发送，或者是在链路空闲一定时长后触发。如果经历几个周期后都未收到响应，则可以视为链路异常。此时可以继续尝试发送心跳，也可以执行告警并断开连接。

在 smart-socket 中我们提供了现成的心跳插件 HeartPlugin，可以很方便的实现心跳。本文是假定读者朋友对 smart-socket 已有了初步的了解，所以不会涉及 smart-socket 的基础使用，重点描述如何在服务中集成心跳插件。

3.1 HeartPlugin插件概述

3.1.1 心跳策略

在HeartPlugin中有三种心跳策略可供选择，通过选择不同的构造方案确定。

HeartPlugin(int heartRate, TimeUnit timeUnit)

heartRate 表示心跳消息的发送频率；timeUnit 表示 heartRate 的数值单位。例如：heartRate=3,timeUnit=TimeUnit.SECONDS，表示每 3秒钟发送一次心跳。heartRate=2000,timeUnit=TimeUnit.MILLISECONDS，表示每 2秒钟发送一次心跳。该策略为周期性发送心跳消息，无论对方是否返回响应。

HeartPlugin(int heartRate, int timeout, TimeUnit unit)

该构造方法相较前一个多出一个参数：timeout(过期时间)，必须大于heartRate。如果在timeout时长内发送的心跳消息都没有收到响应消息，则视为链路异常并且该链路会被关闭，释放资源。

HeartPlugin(int heartRate, int timeout, TimeUnit timeUnit, TimeoutCallback timeoutCallback)