CMPP协议需要客户端每隔一定的时间向服务器传送一条心跳信息，服务器端返回心跳信息的响应，如果客户端在规定的时间内没有收到响应，则认为与服务端的连接已经断开。假设客户端有一个Connection处理发送和接收消息
public class Connection {
public void sendMessage(...) throws ...;
...
}
消息的接收采用Observer模式，这时可以开启一个线程定时发送心跳信息，这个线程内可以嵌在Connection中
public class HeartBeatThread implements Runnable {
public void run() {
//设置一个timer，定时发送心跳信息
}
}
心跳响应的接收作为一个Observer监听所有的消息，同时开启一个Timer，如果再规定的时间内没有收到消息则进行相应的错误处理（断开连接、通知管理员等等）
public class HeartBeatListener implements PacketListener {
public HeartBeatListener(Connection conne
ction ) {
//这个类也可以nest在Connection中，这样构造函数不需要保留对Connection的引用
}
public void startListening() {
//开启timer
}
public void PacketReceived(Packet packet) {
//收到一条消息，这时reset Timer，并重新开启一个timer
}
public void timeOut() {
//在规定时间没有收到心跳信息，进行相应的处理（关闭Connection）
}
}