OkSocket

allprojects {
    repositories {
        maven {
            url 'https://s01.oss.sonatype.org/content/repositories/releases/'
        }
    }
}

dependencies {
       implementation('com.gitee.chinasoft_ohos:socket-client:1.0.0')

       implementation('com.gitee.chinasoft_ohos:socket-common-interface:1.0.0')

       implementation('com.gitee.chinasoft_ohos:socket-server:1.0.0')

       implementation('com.gitee.chinasoft_ohos:socket-core:1.0.0')
    ......
 }

SocketActionAdapter adapter = new SocketActionAdapter() {
        @Override
        public void onSocketConnectionSuccess(ConnectionInfo info, String action) {
           // Соединение успешно установлено
        }
};
``````markdown
        @Override
        public void onSocketDisconnection(ConnectionInfo info, String action, Exception e) {
           // Соединение было прервано
        }

        @Override
        public void onSocketConnectionFailed(ConnectionInfo info, String action, Exception e) {
           // Соединение не установлено
        }

        @Override
        public void onSocketReadResponse(ConnectionInfo info, String action, OriginalData data) {
          // Ответ на запрос данных от сервера
        }

        @Override
        public void onSocketWriteResponse(ConnectionInfo info, String action, ISendable data) {
           // Ответ на запись данных на сервер
        }
``````markdown
        @Override
        public void onPulseSend(ConnectionInfo info, IPulseSendable data) {
          // Callback после отправки пульса
        }
    };
    ConnectionInfo mInfo = new ConnectionInfo(ip, port);
    OkSocketOptions mOkOptions = new OkSocketOptions.Builder()
            .setReconnectionManager(new NoneReconnect())
            .setConnectTimeoutSeconds(10)
            .setCallbackThreadModeToken(new OkSocketOptions.ThreadModeToken() {
                @Override
                public void handleCallbackEvent(ActionDispatcher.ActionRunnable runnable) {
                    mHandler.post(runnable);
                }
            })
            .build();
    IConnectionManager mManager = OkSocket.open(mInfo).option(mOkOptions);
    mManager.registerReceiver(adapter);

Copyright [2018] [Сю Хао]
```Разрешено с использованием лицензии Apache, версия 2.0 ("Лицензия"); вы можете использовать этот файл только в соответствии с Лицензией. Вы можете получить копию Лицензии по адресу:

http://www.apache.org/licenses/LICENSE-2.0

Если это требует применимого закона или письменного соглашения, программное обеспечение, распространяемое по Лицензии, распространяется на условиях "КАК ЕСТЬ". БЕЗ КАКИХ-ЛИБО ГАРАНТИЙ ИЛИ УСЛОВИЙ В КАЧЕСТВЕ, ЯВНО ИМПЛЮЧЕННЫХ ИЛИ НЕЯВНО.

Смотрите Лицензию для конкретного языка, регулирующего права использования и ограничения, предусмотренные Лицензией.