Проблема с получением сообщения через веб-сокет (невозможно прослушивать) ⇐ Android
-
Гость
Проблема с получением сообщения через веб-сокет (невозможно прослушивать)
Я использую OkHttp для прослушивания сообщений сервера, но он не прослушивается, и после проверки я не уверен, в чем может быть проблема, проверьте ниже.
Вот моя функция веб-сокета
частное развлечение initWebSocket() { val URL = "wss://infomapapp.com/hmcpapi//wss?userId=4" вал запрос = Request.Builder() .url(URL) .строить() val wsListener = объект: WebSocketListener() { переопределить удовольствие onOpen(webSocket: WebSocket, ответ: Response) { // Соединение WebSocket открыто Log.d("WebSocket", "Соединение WebSocket открыто $response") } переопределить fun onMessage(webSocket: WebSocket, text: String) { Log.d("WebSocket", текст) newChatsItem = parseMessage(текст) Log.d("WebSocket", "Проанализированное сообщение: $newChatsItem") runOnUiThread { chatRecyclerView.scrollToPosition(chatList.size - 1) } } переопределить удовольствие onClosing(webSocket: WebSocket, код: Int, причина: String) { // WebSocket закрывается Log.d("WebSocket", "Закрытие WebSocket: $code/$reason") webSocket.close(NORMAL_CLOSURE_STATUS, ноль) } переопределить fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) { // WebSocket обнаружил ошибку Log.e("WebSocket", "Ошибка WebSocket: ${t.message}") } } webSocket = client.newWebSocket(запрос, wsListener) } вот как я это вызываю в onCreate.
initWebSocket().
Это объект Json, который я отправляю и оставлю ниже ожидаемого ответа сервера
частное развлечение sen() { newChatsItem = ChatsItem( имя_создателя_пользователя = имя_хранимого_пользователя!!, текст = messageEditText.text.toString().trim(), hcServiceId = ChatHcSerID!!, hC_WPLACE = чатHcWplace!!, hcId = hcIdChat!!, CreatorUserId = чатCreatorID!!, isSentByCitizen = правда, serviceId = serviceIDChat!!, clientSideMessageId = Date().getTime().toString(), Идентификатор Типа Сообщения = 1 ) webSocket?.send(Gson().toJson(newChatsItem).toString()) this.adapter.addMessage(newChatsItem).toString() Log.d("сообщение", "$newChatsItem") chatRecyclerView.scrollToPosition(chatList.size - 1) } {"serverMessage":true,"status":"received","error":"","info":"","clientSideMessageId":"1695284902791"} {"serverMessage":true,"status" :"saved","error":"","info":"","clientSideMessageId":"1695284902791"
Большое спасибо
Я использую OkHttp для прослушивания сообщений сервера, но он не прослушивается, и после проверки я не уверен, в чем может быть проблема, проверьте ниже.
Вот моя функция веб-сокета
частное развлечение initWebSocket() { val URL = "wss://infomapapp.com/hmcpapi//wss?userId=4" вал запрос = Request.Builder() .url(URL) .строить() val wsListener = объект: WebSocketListener() { переопределить удовольствие onOpen(webSocket: WebSocket, ответ: Response) { // Соединение WebSocket открыто Log.d("WebSocket", "Соединение WebSocket открыто $response") } переопределить fun onMessage(webSocket: WebSocket, text: String) { Log.d("WebSocket", текст) newChatsItem = parseMessage(текст) Log.d("WebSocket", "Проанализированное сообщение: $newChatsItem") runOnUiThread { chatRecyclerView.scrollToPosition(chatList.size - 1) } } переопределить удовольствие onClosing(webSocket: WebSocket, код: Int, причина: String) { // WebSocket закрывается Log.d("WebSocket", "Закрытие WebSocket: $code/$reason") webSocket.close(NORMAL_CLOSURE_STATUS, ноль) } переопределить fun onFailure(webSocket: WebSocket, t: Throwable, response: Response?) { // WebSocket обнаружил ошибку Log.e("WebSocket", "Ошибка WebSocket: ${t.message}") } } webSocket = client.newWebSocket(запрос, wsListener) } вот как я это вызываю в onCreate.
initWebSocket().
Это объект Json, который я отправляю и оставлю ниже ожидаемого ответа сервера
частное развлечение sen() { newChatsItem = ChatsItem( имя_создателя_пользователя = имя_хранимого_пользователя!!, текст = messageEditText.text.toString().trim(), hcServiceId = ChatHcSerID!!, hC_WPLACE = чатHcWplace!!, hcId = hcIdChat!!, CreatorUserId = чатCreatorID!!, isSentByCitizen = правда, serviceId = serviceIDChat!!, clientSideMessageId = Date().getTime().toString(), Идентификатор Типа Сообщения = 1 ) webSocket?.send(Gson().toJson(newChatsItem).toString()) this.adapter.addMessage(newChatsItem).toString() Log.d("сообщение", "$newChatsItem") chatRecyclerView.scrollToPosition(chatList.size - 1) } {"serverMessage":true,"status":"received","error":"","info":"","clientSideMessageId":"1695284902791"} {"serverMessage":true,"status" :"saved","error":"","info":"","clientSideMessageId":"1695284902791"
Большое спасибо
Мобильная версия