diff --git a/aio-pro/src/main/java/org/smartboot/socket/extension/plugins/HeartPlugin.java b/aio-pro/src/main/java/org/smartboot/socket/extension/plugins/HeartPlugin.java index 0925204ab5af6517f7be0c3e5d3160ed20d3986a..1d1c18aaf9d10b07350142ebef53e8f9d5416d85 100644 --- a/aio-pro/src/main/java/org/smartboot/socket/extension/plugins/HeartPlugin.java +++ b/aio-pro/src/main/java/org/smartboot/socket/extension/plugins/HeartPlugin.java @@ -92,11 +92,7 @@ public abstract class HeartPlugin extends AbstractPlugin { public final boolean preProcess(AioSession session, T t) { sessionMap.put(session, System.currentTimeMillis()); //是否心跳响应消息 - if (isHeartMessage(session, t)) { - //延长心跳监测时间 - return false; - } - return true; + return !isHeartMessage(session, t); } @Override @@ -136,10 +132,10 @@ public abstract class HeartPlugin extends AbstractPlugin { private void registerHeart(final AioSession session, final long heartRate) { if (heartRate <= 0) { - LOGGER.info("session:{} 因心跳超时时间为:{},终止启动心跳监测任务", session, heartRate); + LOGGER.info("session:{} 因心跳间隔为:{},终止启动心跳监测任务", session, heartRate); return; } - LOGGER.debug("session:{}注册心跳任务,超时时间:{}", session, heartRate); + LOGGER.debug("session:{}注册心跳任务,心跳间隔:{}", session, heartRate); QuickTimerTask.SCHEDULED_EXECUTOR_SERVICE.schedule(new TimerTask() { @Override public void run() {