如何解决我在okHttp3 webscocket android的错误？

Question

我收到这样的错误在我的websocket。

Error: [okio.RealBufferedSource.require(RealBufferedSource.kt:201), okio.RealBufferedSource.readByte(RealBufferedSource.kt:210), okhttp3.internal.ws.WebSocketReader.readHeader(WebSocketReader.kt:119), okhttp3.internal.ws.WebSocketReader.processNextFrame(WebSocketReader.kt:102), okhttp3.internal.ws.RealWebSocket.loopReader(RealWebSocket.kt:293), okhttp3.internal.ws.RealWebSocket$connect$1.onResponse(RealWebSocket.kt:195), okhttp3.internal.connection.RealCall$AsyncCall.run(RealCall.kt:504), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1162), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:636), java.lang.Thread.run(Thread.java:764)]

当我尝试发送分块的字符串文件到服务器时，就会发生这样的错误。例如，当我发送14B大小的字符串文件时，一切都很顺利，但当我发送10kB大小的文件时，我收到这样的错误。当我尝试发送120kB的分块文件时，我收到这样的错误。

Error:  [okio.RealBufferedSource.require(RealBufferedSource.kt:201), okio.RealBufferedSource.readByte(RealBufferedSource.kt:210), okhttp3.internal.ws.WebSocketReader.readHeader(WebSocketReader.kt:119), okhttp3.internal.ws.WebSocketReader.processNextFrame(WebSocketReader.kt:102), okhttp3.internal.ws.RealWebSocket.loopReader(RealWebSocket.kt:293), okhttp3.internal.ws.RealWebSocket$connect$1.onResponse(RealWebSocket.kt:195), okhttp3.internal.connection.RealCall$AsyncCall.run(RealCall.kt:504), java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1162), java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:636), java.lang.Thread.run(Thread.java:764)]

我发送文件的地方。

override fun onActivityResult(requestCode: Int, resultCode: Int, data: Intent?) {
        super.onActivityResult(requestCode, resultCode, data)

        when {
            requestCode == 1 && resultCode == Activity.RESULT_OK -> {
                if (data != null) {
                    val fileUri = data.data!!
                    val partSize = 10000
                    val fileString = readTextFile(fileUri)
                    var name = ""
                    var size: Long? = null

                    fileUri.let { returnUri ->
                        contentResolver.query(returnUri, null, null, null, null)
                    }?.use { cursor ->
                        val nameIndex = cursor.getColumnIndex(OpenableColumns.DISPLAY_NAME)
                        val sizeIndex = cursor.getColumnIndex(OpenableColumns.SIZE)
                        cursor.moveToFirst()
                        name = cursor.getString(nameIndex)
                        size = cursor.getLong(sizeIndex)
                    }



                    if (size!! <= partSize) {
                        ws.send(ChatRequestMessages.sendFile(fileString!!,
                                name,
                                selectedContactId.toString(),
                                size!!,
                                0))
                    } else {
                        val partsCount = if (size!!.rem(partSize).toInt() == 0) {
                            size!!.div(partSize)
                        } else {
                            size!!.div(partSize)
                        }


                        for (currentPart in 0..size!!.div(partSize)) {
                            val slicedString = if ((currentPart + 1) * partSize <= size!!.toInt()) {
                                fileString!!.substring(currentPart.toInt() * partSize..(currentPart + 1).toInt() * partSize)
                            } else {
                                fileString!!.substring(currentPart.toInt() * partSize until fileString.length)
                            }

                            Timber.i("${fileString.length.toLong()}  ${currentPart * partSize} ${slicedString.length} $slicedString $name")


                            ws.send(ChatRequestMessages.sendFile(slicedString,
                                    name,
                                    selectedContactId.toString(),
                                    fileString.length.toLong(),
                                    (currentPart * partSize).toInt()))
                        }
                    }


                }
            }
}

我不明白为什么小文件不会发生这种情况，如何解决这些错误 :(

Answer 1

它看起来像一个空的响应。脚本中的javadoc RealBufferedSource.require 说 当缓冲区中至少有 byteCount 字节。如果在读取所需字节之前，源已耗尽，则抛出一个[java.io.EOFException]。.okhttp.internal.ws.WebSocketReader 试图从响应中读取第一个字节，但没有得到。