From 035efb80adf83aa352a7a8633cc79602896091e6 Mon Sep 17 00:00:00 2001 From: chenfufeng Date: Tue, 21 Feb 2023 11:06:08 +0800 Subject: [PATCH] =?UTF-8?q?[Fix]=E8=A7=A3=E5=86=B3=E5=8F=B8=E6=9C=BA?= =?UTF-8?q?=E5=B1=8Fip=E5=8F=98=E5=8C=96=E5=90=8E=E9=87=8D=E8=BF=9E?= =?UTF-8?q?=E5=A4=B1=E8=B4=A5=E7=9A=84=E9=97=AE=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../main/java/com/mogo/telematic/NSDNettyManager.java | 10 +++------- 1 file changed, 3 insertions(+), 7 deletions(-) diff --git a/libraries/mogo-telematic/src/main/java/com/mogo/telematic/NSDNettyManager.java b/libraries/mogo-telematic/src/main/java/com/mogo/telematic/NSDNettyManager.java index a726e61..56c0ba0 100644 --- a/libraries/mogo-telematic/src/main/java/com/mogo/telematic/NSDNettyManager.java +++ b/libraries/mogo-telematic/src/main/java/com/mogo/telematic/NSDNettyManager.java @@ -30,8 +30,8 @@ public class NSDNettyManager { private static final String TAG = "NSDNettyManager"; - private static final long COUNTDOWN_TIME = 70 * 1000; - private static final long INTERVAL_TIME = 30 * 1000; + private static final long COUNTDOWN_TIME = 30 * 1000; + private static final long INTERVAL_TIME = 10 * 1000; private volatile static NSDNettyManager sInstance; // client端用来过滤的 @@ -331,7 +331,6 @@ public class NSDNettyManager { .setHeartBeatData(new MogoProtocolMsg(MogoProtocolMsg.HEART_DATA, 2, new byte[]{0x00, 0x00})) //设置心跳数据，可以是String类型，也可以是byte[]，以后设置的为准 .setSign(sign) //设置客户端标识.(因为可能存在多个tcp连接) .build(); - // TODO:("断开连接时关闭原有EventGroup并重新扫描ip") mNettyTcpClient.setListener(new NettyClientListener() { @Override public void onMessageResponseClient(Object msg, String sign, Channel channel) { @@ -346,14 +345,11 @@ public class NSDNettyManager { mClientListener.onClientStatusConnectChanged(statusCode, content, channel); } if (statusCode == STATUS_CONNECT_CLOSED) { - // 开启重连倒计时(70s) + // 开启重连倒计时 new CustomTimer(COUNTDOWN_TIME, INTERVAL_TIME).start(); } } }); - if (mClientListener != null) { - mNettyTcpClient.setListener(mClientListener); //设置TCP监听 - } } if (!mNettyTcpClient.getConnectStatus()) {