java心跳是怎么回事儿?

Python014

java心跳是怎么回事儿?,第1张

1.什么是心跳包?

心跳包就是在客户端服务器间定时通知对方自己状态的一个自己定义的命令字,按照一定的时间间隔发送,类似于心跳,所以叫做心跳包。

用来判断对方(设备,进程或其它网元)是否正常运行,采用定时发送简单的通讯包,如果在指定时间段内未收到对方响应,则判断对方已经离线。用于检测TCP的异常断开。基本原因是服务器端不能有效的判断客户端是否在线,也就是说,服务器无法区分客户端是长时间在空闲,还是已经掉线的情况。所谓的心跳包就是客户端定时发送简单的信息给服务器端告诉它我还在而已。代码就是每隔几分钟发送一个固定信息给服务端,服务端收到后回复一个固定信息如果服务端几分钟内没有收到客户端信息则视客户端断开。

比如有些通信软件长时间不使用,要想知道它的状态是在线还是离线就需要心跳包,定时发包收包。发包方:可以是客户也可以是服务端,看哪边实现方便合理,一般是客户端。服务器也可以定时发心跳下去。一般来说,出于效率的考虑,是由客户端主动向服务器端发包,而不是服务器向客户端发。客户端每隔一段时间发一个包,使用TCP的,用send发,使用UDP的,用sendto发,服务器收到后,就知道当前客户端还处于“活着”的状态,否则,如果隔一定时间未收到这样的包,则服务器认为客户端已经断开,进行相应的客户端断开逻辑处理。

socket.setKeepAlive()应该写在客户端,server.accept()是服务器端的。

心跳的也有现成的,不过依赖别的类。大概贴一下,就是这么个意思。

public class HBHBThread extends Thread {

private CommandDeal command

 

/**

 * @return the command

 */

public CommandDeal getCommand() {

return command

}

/**

 * @param command

 *            the command to set

 */

public void setCommand(CommandDeal command) {

this.command = command

}

public void run() {

long maxWait = SendConfig.hbhb_wait

if (maxWait < 1000) {

maxWait = 1000

}

Date lastTime

long timeDiv=0

while (1 == 1) {

 lastTime=SocketQueueObject.getLastContactTime()

 if(lastTime!=null){

 timeDiv=(new Date()).getTime() - SocketQueueObject.getLastContactTime().getTime()

 System.out.println("TimeDiv:"+timeDiv)

 }

// 上次联系的时间超过最大等待,或者还没联系过

if (lastTime == null|| timeDiv >=maxWait) {

System.out.println("HBHB") 

command.sendHbhbCommand()

}else if(maxWait>timeDiv){

maxWait=maxWait-timeDiv

}

try{

this.sleep(maxWait)

}catch(Exception e){

e.printStackTrace()

}

}

} public class HBHBCommandDeal extends CommandDealInterface {

private static Logger msg_logger = Logger.getLogger("socketMsg")

@SuppressWarnings("unchecked")

public List doCommand(SocketQueueObject socketQueueObject, Map command) throws Exception {

List<String> commandList = (List) command.get(Constants.SMSCOMMAND)

byte[] hbhbMsg = TL1Tool.createCommand(commandList.get(0))

msg_logger.info(" send message to sms packed:" + new String(hbhbMsg, "ISO-8859-1"))

TL1RetrunMessage retMsg = socketQueueObject.commNGNServer(hbhbMsg)

retMsg.resolve()

msg_logger.info(" recevice message from sms:"+ retMsg.getMessage()) 

List returnList = new ArrayList()

returnList.add(retMsg)

return returnList

}

}

你可以自己找找看啊。