|
@@ -30,7 +30,7 @@ public class TcpClient {
|
|
//数据处理
|
|
//数据处理
|
|
TcpClientHandler tcpClientHandler = new TcpClientHandler();
|
|
TcpClientHandler tcpClientHandler = new TcpClientHandler();
|
|
//重试间隔
|
|
//重试间隔
|
|
- private Integer retrySeconds = 5;
|
|
|
|
|
|
+ private Integer retrySeconds = 3;
|
|
//重试计数
|
|
//重试计数
|
|
public Integer retryTimes = 1;
|
|
public Integer retryTimes = 1;
|
|
|
|
|
|
@@ -46,10 +46,10 @@ public class TcpClient {
|
|
|
|
|
|
//初始化Netty Tcp Client 并连接
|
|
//初始化Netty Tcp Client 并连接
|
|
public synchronized void init(String serverIP, Integer serverPort, Integer heartBeatSeconds, ITcpCallBack iTcpCallBack) {
|
|
public synchronized void init(String serverIP, Integer serverPort, Integer heartBeatSeconds, ITcpCallBack iTcpCallBack) {
|
|
-// if (bootstrap!=null){
|
|
|
|
-// doConnect(iTcpCallBack);
|
|
|
|
-// return;
|
|
|
|
-// }
|
|
|
|
|
|
+ if (bootstrap!=null){
|
|
|
|
+ doConnect(iTcpCallBack);
|
|
|
|
+ return;
|
|
|
|
+ }
|
|
|
|
|
|
final Integer hbSeconds = heartBeatSeconds;
|
|
final Integer hbSeconds = heartBeatSeconds;
|
|
bootstrap = new Bootstrap();
|
|
bootstrap = new Bootstrap();
|