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()) {