From ed69bdc11b999aa73315916e9d0e9da8476507d6 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=9C=B0=E5=B9=B3=E7=BA=BF?= <22250530@qq.com>
Date: Mon, 21 Sep 2015 10:26:34 +0800
Subject: [PATCH]

---
 src/com/wentch/redkale/net/http/WebSocketEngine.java | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/src/com/wentch/redkale/net/http/WebSocketEngine.java b/src/com/wentch/redkale/net/http/WebSocketEngine.java
index d7c4a6e7b..9af713c86 100644
--- a/src/com/wentch/redkale/net/http/WebSocketEngine.java
+++ b/src/com/wentch/redkale/net/http/WebSocketEngine.java
@@ -44,11 +44,9 @@ public final class WebSocketEngine {
             t.setDaemon(true);
             return t;
         });
-        long now = System.currentTimeMillis() / 1000;
-        long delay = liveinterval - now / liveinterval;
         scheduler.scheduleWithFixedDelay(() -> {
-            getWebSocketGroups().stream().forEach(x -> x.getWebSockets().forEach(y -> y.send(DEFAULT_PING_PACKET)));
-        }, delay, liveinterval, TimeUnit.SECONDS);
+            getWebSocketGroups().stream().forEach(x -> x.sendEach(DEFAULT_PING_PACKET));
+        }, (liveinterval - System.currentTimeMillis() / 1000 % liveinterval), liveinterval, TimeUnit.SECONDS);
         if (finest) logger.finest(this.getClass().getSimpleName() + "(" + engineid + ")" + " start keeplive(interval:" + liveinterval + "s) scheduler executor");
     }