|
@@ -47,6 +47,9 @@ public class TcpClientHandler extends SimpleChannelInboundHandler<String> {
|
|
connected = true;
|
|
connected = true;
|
|
connecteds = true;
|
|
connecteds = true;
|
|
retryTimes = 0;
|
|
retryTimes = 0;
|
|
|
|
+// TcpModel tcpModel = DeviceUtil.deviceConnect(Constants.Companion.getImei());
|
|
|
|
+// TcpClient.getInstance().sendMsg(tcpModel.toJson());
|
|
|
|
+
|
|
TcpModel tcpModel = DeviceUtil.deviceConnect(Constants.Companion.getImei());
|
|
TcpModel tcpModel = DeviceUtil.deviceConnect(Constants.Companion.getImei());
|
|
TcpClient.getInstance().sendMsg(tcpModel.toJson());
|
|
TcpClient.getInstance().sendMsg(tcpModel.toJson());
|
|
// EventBus.getDefault().register(this);
|
|
// EventBus.getDefault().register(this);
|
|
@@ -92,8 +95,7 @@ public class TcpClientHandler extends SimpleChannelInboundHandler<String> {
|
|
//读心跳包超时执行
|
|
//读心跳包超时执行
|
|
}else if (event.state() == IdleState.READER_IDLE){
|
|
}else if (event.state() == IdleState.READER_IDLE){
|
|
Log.i(TAG,"TcpClientHandler ===> pong from server failed");
|
|
Log.i(TAG,"TcpClientHandler ===> pong from server failed");
|
|
- ctx.writeAndFlush("0");
|
|
|
|
-// ctx.close();
|
|
|
|
|
|
+ ctx.close();
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|
|
}
|