org.voovan.network

Class HeartBeat

java.lang.Object

org.voovan.network.HeartBeat

public class HeartBeat
extends Object

心跳类

Method Summary

Modifier and Type	Method and Description
static HeartBeat	attachSession(IoSession session, int connectModel) 将心跳绑定到 Session 默认使用 PING, PONG 作为心跳消息
static HeartBeat	attachSession(IoSession session, String ping, String pong) 将心跳绑定到 Session
static boolean	beat(IoSession session) 一次心跳动作
int	getFailedCount() 获取连续失败次数 每次成功会被归零
byte[]	getPing() 获取 ping 报文
byte[]	getPong() 获取 pong 报文
static boolean	interceptHeartBeat(IoSession session) 截断心跳消息

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getPing

public byte[] getPing()

获取 ping 报文

Returns:

ping 报文

getPong

public byte[] getPong()

获取 pong 报文

Returns:

pong 报文

getFailedCount

public int getFailedCount()

获取连续失败次数 每次成功会被归零

Returns:

失败次数

interceptHeartBeat

public static boolean interceptHeartBeat(IoSession session)

截断心跳消息

Parameters:

session - 会话对象

Returns:

true: 成功, false: 失败

beat

public static boolean beat(IoSession session)

一次心跳动作

Parameters:

session - 会话对象

Returns:

true:心跳成功,false: 心跳失败

attachSession

public static HeartBeat attachSession(IoSession session,
                                      String ping,
                                      String pong)

将心跳绑定到 Session

Parameters:

session - 会话

ping - ping 消息

pong - pong 消息

Returns:

心跳消息对象

attachSession

public static HeartBeat attachSession(IoSession session,
                                      int connectModel)

将心跳绑定到 Session 默认使用 PING, PONG 作为心跳消息

Parameters:

session - Socket会话

connectModel - 模式,指定发送第一个 PING 的模式,服务端先发,或者客户端先发

Returns:

心跳消息对象