| | |
|---|
| | | 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); |
|---|
