perf: 调整registerHeartbeatTimer方法

heatbeat
huangfeng 3 months ago
parent 83d9e4e6c9
commit b82fe124d8

@ -50,6 +50,7 @@ import java.lang.reflect.Method;
import java.nio.channels.FileLock; import java.nio.channels.FileLock;
import java.text.SimpleDateFormat; import java.text.SimpleDateFormat;
import java.util.Arrays; import java.util.Arrays;
import java.util.Calendar;
import java.util.Date; import java.util.Date;
import java.util.List; import java.util.List;
import java.util.logging.Level; import java.util.logging.Level;
@ -764,67 +765,65 @@ public class MpMasterService extends Service {
} }
private void registerHeartbeatTimer() { private void registerHeartbeatTimer() {
long delaySec = 20; // 比i1延迟20秒
long timeout = mHeartbeatDuration; long interval = mHeartbeatDuration; // 距离下一次间隔默认10分钟
boolean keepAlive = false; boolean keepAlive = false;
long currentTimeMs = System.currentTimeMillis(); long currentSec = System.currentTimeMillis() / 1000;
if (mMntnMode) { if (mMntnMode) {
// 无延迟
delaySec = 0;
if (mQuickHbMode) { if (mQuickHbMode) {
timeout = mQuickHeartbeatDuration; interval = mQuickHeartbeatDuration;
} }
registerHeartbeatTimer(currentTimeMs + timeout * 1000, keepAlive); registerHeartbeatTimer((currentSec + interval + delaySec) * 1000, keepAlive);
} else { } else {
long closestTime = -1;
if (mUsingAbsHbTime) { if (mUsingAbsHbTime) {
Date dt = new Date(); long expandSec = 120; // 扩展2分钟之内的都触发
long ts = dt.getTime(); Calendar calendar = Calendar.getInstance();
ts -= ts % 1000; calendar.set(Calendar.HOUR_OF_DAY, 0);
calendar.set(Calendar.MINUTE, 0);
dt.setHours(0); calendar.set(Calendar.SECOND, 0);
dt.setMinutes(0); calendar.set(Calendar.MILLISECOND, 0);
dt.setSeconds(0); long todayZero = calendar.getTimeInMillis() / 1000;
long todaySec = currentSec - todayZero;
long zeroPoint = dt.getTime();
zeroPoint -= zeroPoint % 1000; long nextAbsSec = this.getNextAbsSec(todaySec);
long offsetTs = (ts - zeroPoint) / 1000; if (nextAbsSec - todaySec > interval + expandSec) {
keepAlive = true;
registerHeartbeatTimer((currentSec + interval + delaySec) * 1000, keepAlive);
} else {
registerHeartbeatTimer((todayZero + nextAbsSec) * 1000, keepAlive);
}
} else {
// mUsingAbsHbTime=false间隔10分钟 + 延迟
registerHeartbeatTimer((currentSec + interval + delaySec) * 1000, keepAlive);
}
}
}
private long getNextAbsSec(long todaySec) {
long nextAbsSec = -1;
if (mAbsHeartbeatTimes != null && mAbsHeartbeatTimes.length > 0) { if (mAbsHeartbeatTimes != null && mAbsHeartbeatTimes.length > 0) {
for (int i = 0; i < mAbsHeartbeatTimes.length; i++) { for (int i = 0; i < mAbsHeartbeatTimes.length; i++) {
if (mAbsHeartbeatTimes[i] > offsetTs) { if (mAbsHeartbeatTimes[i] > todaySec) {
closestTime = mAbsHeartbeatTimes[i]; nextAbsSec = mAbsHeartbeatTimes[i];
break; break;
} }
} }
if (closestTime == -1) { if (nextAbsSec == -1) {
// next day // next day
closestTime = mAbsHeartbeatTimes[0] + 86400; nextAbsSec = mAbsHeartbeatTimes[0] + 24 * 3600;
}
} else {
closestTime = 9 * 3600 + 13 * 60;
if (offsetTs > closestTime) {
closestTime += 86400;
}
}
if (zeroPoint + closestTime * 1000 > currentTimeMs + mMpHeartbeatDuration) {
keepAlive = true;
registerHeartbeatTimer(currentTimeMs + mMpHeartbeatDuration + 5000, keepAlive);
} else {
registerHeartbeatTimer(zeroPoint + closestTime * 1000, keepAlive);
} }
} else { } else {
// mUsingAbsHbTime: false nextAbsSec = 9 * 3600 + 13 * 60;
if ((mPreviousHeartbeatTime != 0) && (mPreviousHeartbeatTime - currentTimeMs < mHeartbeatDuration * 1000)) { if (todaySec > nextAbsSec) {
registerHeartbeatTimer(mPreviousHeartbeatTime + mHeartbeatDuration * 1000, keepAlive); nextAbsSec += 24 * 3600;
} else {
registerHeartbeatTimer(currentTimeMs + timeout * 1000, keepAlive);
}
} }
} }
return nextAbsSec;
} }
private void registerHeartbeatTimer(long triggerTime, boolean keepAlive) { private void registerHeartbeatTimer(long triggerTime, boolean keepAlive) {
AlarmManager alarmManager = (AlarmManager) getSystemService(ALARM_SERVICE); AlarmManager alarmManager = (AlarmManager) getSystemService(ALARM_SERVICE);

Loading…
Cancel
Save