|  |  |  | 
|---|
|  |  |  | public synchronized void connect() { | 
|---|
|  |  |  |  | 
|---|
|  |  |  | if (connectionStatus.get() == SocketStatus.SOCKET_DISCONNECTING) { | 
|---|
|  |  |  | new Handler().postDelayed(new Runnable() { | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void run() { | 
|---|
|  |  |  | LogUtil.d("---> socket>>connect>>正在断开连接,延时一秒執行重连"); | 
|---|
|  |  |  | connect(); | 
|---|
|  |  |  | } | 
|---|
|  |  |  | new Handler().postDelayed(() -> { | 
|---|
|  |  |  | LogUtil.d("---> socket>>connect>>正在断开连接,延时一秒執行重连"); | 
|---|
|  |  |  | connect(); | 
|---|
|  |  |  | }, 1000); // 延时1秒 | 
|---|
|  |  |  | return; | 
|---|
|  |  |  | } | 
|---|
|  |  |  | 
|---|
|  |  |  | return this; | 
|---|
|  |  |  | } | 
|---|
|  |  |  |  | 
|---|
|  |  |  | /** | 
|---|
|  |  |  | * 消息回调主要处理超时消息 | 
|---|
|  |  |  | * @param callBack | 
|---|
|  |  |  | */ | 
|---|
|  |  |  | @Override | 
|---|
|  |  |  | public void onCallBack(SuperCallBack callBack) { | 
|---|
|  |  |  | callbackResponseDispatcher.addSocketCallback(callBack); | 
|---|