| | |
| | | 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; |
| | | } |
| | |
| | | */ |
| | | private IConnectionManager sendBytes(byte[] bytes) { |
| | | if (ioManager == null || connectionStatus.get() != SocketStatus.SOCKET_CONNECTED) { |
| | | LogUtil.w("sendBytes错误-----ioManager为null或者connectionStatus状态不为已连接"); |
| | | return this; |
| | | } |
| | | ioManager.sendBytes(bytes); |
| | | return this; |
| | | } |
| | | |
| | | /** |
| | | * 消息回调主要处理超时消息 |
| | | * @param callBack |
| | | */ |
| | | @Override |
| | | public void onCallBack(SuperCallBack callBack) { |
| | | callbackResponseDispatcher.addSocketCallback(callBack); |