publicclass UDPHandler extends IoHandlerAdapter {

private final Logger logger =Logger.getLogger(this.getClass());

?

@Override

public void messageSent(IoSessionsession, Object message) throws Exception {

}

?

@Override

public void exceptionCaught(IoSessionsession, Throwable cause)

? ? throws Exception {

? ? logger.error(cause);

? ? session.close(true);

}

?

@Override

? ? public void messageReceived(IoSessionsession, Object message) throws Exception {

? ? ? ? logger.info("messageReceived");

? if (message instanceof IoBuffer) {

? ? ? ? IoBuffer buffer = (IoBuffer) message;

? ? ? ? UDPRequestServer controller = UDPRequestServer.getInstance();

? ? ? ? ? ? ? IoBuffer buffer1 =controller.dealRequest(buffer);

? ? ? ? ? ? ? session.write(buffer1);

? }

? ?

? ? }

}

注意点：

>心跳机制：

(1)客户端会定时发送心跳请求（注意定时时间必须小于，服务器端的IDLE监控时间）,同时需要监听心跳反馈，以此来判断是否与服务器丢失连接。对于服务器的心跳请求不给与反馈。

(2)心跳情况在60秒之内

(3)客户端和服务端同时都需要设置心跳请求