org.voovan.network

类 HeartBeat

java.lang.Object

org.voovan.network.HeartBeat

public class HeartBeat
extends Object

类文字命名

方法概要

限定符和类型	方法和说明
static HeartBeat	attachSession(IoSession session, ConnectModel connectModel) 将心跳绑定到 Session 默认使用 PING, PONG 作为心跳消息
static HeartBeat	attachSession(IoSession session, ConnectModel connectModel, String ping, String pong) 将心跳绑定到 Session
static boolean	beat(IoSession session) 一次心跳动作
int	getFailedCount() 获取连续失败次数 每次成功会被归零
byte[]	getPing() 获取 ping 报文
byte[]	getPong() 获取 pong 报文
static void	interceptHeartBeat(IoSession session, ByteBufferChannel byteBufferChannel) 截断心跳消息
static void	main(String[] args)

从类继承的方法 java.lang.Object

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

方法详细资料

getPing

public byte[] getPing()

获取 ping 报文

返回:

ping 报文

getPong

public byte[] getPong()

获取 pong 报文

返回:

pong 报文

getFailedCount

public int getFailedCount()

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

返回:

失败次数

interceptHeartBeat

public static void interceptHeartBeat(IoSession session,
                                      ByteBufferChannel byteBufferChannel)

截断心跳消息

参数:

session - 会话对象

byteBufferChannel - 保存消息 ByteBufferChannel 对象

beat

public static boolean beat(IoSession session)

一次心跳动作

参数:

session - 会话对象

返回:

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

attachSession

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

将心跳绑定到 Session

参数:

session - 会话

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

ping - ping 消息

pong - pong 消息

返回:

心跳消息对象

attachSession

public static HeartBeat attachSession(IoSession session,
                                      ConnectModel connectModel)

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

参数:

session - Socket会话

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

返回:

心跳消息对象

main

public static void main(String[] args)
                 throws IOException

抛出:

IOException