套接字發(fā)出超時確認

我的

AckWithTimeOut

帶有實現(xiàn)的自定義超時類

Ack

接口

public class AckWithTimeOut implements Ack {

private Timer timer;

private long timeOut = 0;

private boolean called = false;

public AckWithTimeOut() {

}

public AckWithTimeOut(long timeout_after) {

if (timeout_after <= 0)

return;

this.timeOut = timeout_after;

startTimer();

}

public void startTimer() {

timer = new Timer();

timer.schedule(new TimerTask() {

@Override

public void run() {

callback("No Ack");

}

}, timeOut);

}

public void resetTimer() {

if (timer != null) {

timer.cancel();

startTimer();

}

}

public void cancelTimer() {

if (timer != null)

timer.cancel();

}

void callback(Object... args) {

if (called) return;

called = true;

cancelTimer();

call(args);

}

@Override

public void call(Object... args) {

}

}

添加

確認超時

在套接字中發(fā)出偵聽器

mSocket.emit("socketChangeDeviceAck", obj, new AckWithTimeOut(5000) {

@Override

public void call(Object... args) {

if(args!=null){

if(args[0].toString().equalsIgnoreCase("No Ack")){

Log.d("ACK_SOCKET","AckWithTimeOut : "+ args[0].toString());

}else if(args[0].toString().equalsIgnoreCase("true")){

cancelTimer(); //cancel timer if emit ACK return true

Log.d("ACK_SOCKET","AckWithTimeOut : "+ args[0].toString());

}

}

}

});

總結(jié)

以上是生活随笔為你收集整理的android 方法超时,android socket.io中的发出或确认超时处理?的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。