1

Имеется задача - написать чат на android. Так же присутствует чат-сервер. Насколько я понял все нужно будет делать на сокетах. Но я не могу понять с чего начать :( Во-первых сложно найти адекватно работающую библиотеку или способ который даст ожидаемый результат. Надеялся что получится сделать все через scarlet от Tinder но что-то пошло не так, и зависимости не подключились адекватно. Появилось много проблем после установки требуемой версии java в build.gradle. Есть много библиотек и еще больше кустарных способов, но большинство из них отпадает из-за того что в адресах сервера используется протокол http/https а у меня используется wss. На текущий момент моя последняя попытка взята отсюда и тоже запрос не шлется:

val wsFactory = WebSocketFactory()
                .createSocket("wss://server/")
                .addHeader("token", context!!.getSharedPreferences("app_data", 0).getString("access_token", "")!!)

Либо я что-то не могу понять в принципах создания чата. До этого я работал с retrofit и возможно я жду обычного запрос-ответ поведения. Но судя по тому что я читаю, то здесь тоже приблизительно так все реализовано. Была так же такая попытка:

private fun instantiateWebSocket() {
        val client = OkHttpClient()
        val request: Request = Request.Builder()
                .url("wss://server/")
                .addHeader("token", context!!.getSharedPreferences("app_data", 0).getString("access_token", "")!!)
                .build()


        Timber.i(request.toString())

        val socketListener = SocketListener(context!!)
        webSocket = client.newWebSocket(request, socketListener)
        webSocket!!.send("0909")

    }

    class SocketListener(cont: Context) : WebSocketListener() {
        var context: Context = cont
        override fun onOpen(webSocket: WebSocket, response: Response) {
            Timber.i(response.toString())
            Runnable { Toast.makeText(context, "Connection Established!", Toast.LENGTH_LONG).show() }
        }

        override fun onMessage(webSocket: WebSocket, text: String) {
            val jsonObject = JSONObject()
            try {
                jsonObject.put("message", text)
                jsonObject.put("byServer", true)
            } catch (e: JSONException) {
                e.printStackTrace()
            }

        }

        init {
            this.context = cont
        }
    }

и тут запрос тоже не шлется. Что я не так делаю? Может у кого-то был опыт создания чата и есть рабочий способ?

2 ответа 2

2

Данный ответ пишу для таких же как и я - тех кто ничего не знает про сокеты и как писать чат. Я потратил немного времени на исследование и в итоге у меня получилось реализовать то что нужно. Для создания чата я использовал OkHttp. Для начала создадим клиент:

 val client = OkHttpClient.Builder()
                .addInterceptor(loggingInterceptor)
                .build()

дальше формируем запрос:

val request = Request.Builder()
                .url(Constants.TEST_CHAT_URL)
                .build()

и наконец создаем сокет:

webSocket = client.newWebSocket(request, object : WebSocketListener() {
            override fun onClosed(webSocket: WebSocket, code: Int, reason: String) {
                super.onClosed(webSocket, code, reason)
                Timber.i("closing data: $code -> $reason")
            }

            override fun onClosing(webSocket: WebSocket, code: Int, reason: String) {
                super.onClosing(webSocket, code, reason)
                webSocket.close(1000, null)
                Timber.i("Closing : $code / $reason")
            }

            override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
                super.onFailure(webSocket, t, response)
                Timber.i("Error: %s", t.localizedMessage)
            }

            override fun onMessage(webSocket: WebSocket, text: String) {
                super.onMessage(webSocket, text)
                Timber.i("Receiving : $text")

            }

            override fun onMessage(webSocket: WebSocket, bytes: ByteString) {
                super.onMessage(webSocket, bytes)
                Timber.i("Receiving bytes : %s", bytes.hex())
            }

            override fun onOpen(webSocket: WebSocket, response: Response) {
                super.onOpen(webSocket, response)
                Timber.i("on open")
            }
        })

После того как пообщались с человеком, нужно закрыть соединение:

webSocket.close(1000, null)

Для отправки сообщения нужно использовать функцию send:

webSocket.send("some_string")

Вот и все :) Оказалось не так сложно как казалось вначале. Возможно у кого-то будут замечания/предложения - выслушаю с удовольствием.

1

Вот отличная статья по этой теме

Так же клиент:

private val client: OkHttpClient = OkHttpClient.Builder().writeTimeout(5, TimeUnit.SECONDS)
    .readTimeout(5, TimeUnit.SECONDS)
    .connectTimeout(5, TimeUnit.SECONDS)
    .build()

Запрос:

val request = Request.Builder().url(url).build()

И создаем сокет:

webSocket = client.newWebSocket(request, object : WebSocketListener() {

        override fun onOpen(webSocket: WebSocket, response: Response) {
            super.onOpen(webSocket, response)
        }

        override fun onMessage(webSocket: WebSocket, text: String) {
            super.onMessage(webSocket, text)
        }

        override fun onMessage(webSocket: WebSocket, bytes: ByteString) {
            super.onMessage(webSocket, bytes)
        }

        override fun onClosing(webSocket: WebSocket, code: Int, reason: String) {
            super.onClosing(webSocket, code, reason)
        }

        override fun onClosed(webSocket: WebSocket, code: Int, reason: String) {
            super.onClosed(webSocket, code, reason)
        }

        override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
            super.onFailure(webSocket, t, response)
        }
    })
}

Ну и отправка сообщений + возможность закрытие сокет соединения

private fun sendMessage(message: String) {
    webSocket?.send(message)
}

private fun close(code: Int, reason: String) {
    webSocket?.close(code, reason)
}

Итогом послужит вот такой класс который можно разбросать в зависимости от вашей архитектуры

class WebSocketManager private constructor() {

    private val client: OkHttpClient = OkHttpClient.Builder().writeTimeout(5, TimeUnit.SECONDS)
        .readTimeout(5, TimeUnit.SECONDS)
        .connectTimeout(5, TimeUnit.SECONDS)
        .build()

    private var webSocket: WebSocket? = null

    companion object {
        val instance: WebSocketManager by lazy(mode = LazyThreadSafetyMode.SYNCHRONIZED) { WebSocketManager() }
    }

    fun connect(url: String) {
        webSocket?.cancel()
        val request = Request.Builder().url(url).build()
        webSocket = client.newWebSocket(request, object : WebSocketListener() {

            override fun onOpen(webSocket: WebSocket, response: Response) {
                super.onOpen(webSocket, response)
            }

            override fun onMessage(webSocket: WebSocket, text: String) {
                super.onMessage(webSocket, text)
            }

            override fun onMessage(webSocket: WebSocket, bytes: ByteString) {
                super.onMessage(webSocket, bytes)
            }

            override fun onClosing(webSocket: WebSocket, code: Int, reason: String) {
                super.onClosing(webSocket, code, reason)
            }

            override fun onClosed(webSocket: WebSocket, code: Int, reason: String) {
                super.onClosed(webSocket, code, reason)
            }

            override fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) {
                super.onFailure(webSocket, t, response)
            }
        })
    }

    private fun sendMessage(message: String) {
        webSocket?.send(message)
    }

    private fun close(code: Int, reason: String) {
        webSocket?.close(code, reason)
    }
}

Еще советую почитать доку по кодам закрытия соединения onClosing, если кратко то обычно хватает 1000 если сделали все что хотели или 1001 если просто ушли в другое место в приложении

Так же можно ознакомиться с MQTT, как говорит сам автор статьи:

WebSocket проще и гибче, тогда как MQTT относительно сложен, но мощен, и вы можете выбирать в соответствии со своими сценариями использования.

Когда нибудь на хабр её перенесу с переводом

1

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.