Kotlin中使用TCP Socket读取字符串的正确方式探讨

先贴出你使用的代码：

val readBuffer = BufferedReader(InputStreamReader(socket.inputStream))

private fun readLine(reader: BufferedReader): String? {
    val data = CharArray(4096)
    val count = reader.read(data)

    if(count < 0) {
        return null
    }

    return String(data, 0, count)
}

readLine(readBuffer)

1. 当前实现是否正确？ #

如果你的业务场景确实能保证每条消息的字符数不超过4096（注意是字符，不是字节——因为InputStreamReader涉及字符编码，比如UTF-8下单个字符可能占1-4字节），当前实现可以正常工作，但存在命名误区：你给方法起名readLine，但BufferedReader.read(char[])并不是按行读取，它只会尽可能填充你提供的CharArray，不会识别换行符。如果你的实际需求是按行读取，直接用BufferedReader.readLine()即可，无需自己实现。

2. 消息超过4096字节会发生什么？ #

BufferedReader.read(char[])的行为是读取最多等于CharArray长度的字符，如果输入流中的字符数超过缓冲区大小，它只会返回填满缓冲区的字符数（这里就是4096），剩余字符会留在输入流中，等待下一次read调用读取。

这意味着如果一条完整消息超过4096字符，你的readLine方法只会返回消息的前4096字符，剩下的内容会被遗留——而你的代码只调用了一次readLine(readBuffer)，最终导致消息被截断，丢失后续数据。

3. CharArray的初始化值选择 #

• 固定大小：你当前使用的4096是通用且合理的缓冲区大小，也可以选择8192、16384等数值，本质是权衡内存占用和读取效率——缓冲区越大，IO调用次数越少，但内存占用越高。
• 动态大小：如果需要动态分配缓冲区，不能依赖available()（原因见下一点），建议结合TCP通信的长度约定实现：比如先发送消息的总长度，再发送消息内容，读取时先获取长度，再创建对应大小的CharArray。

4. available()方法是否安全？ #

不安全。available()返回的是当前可无阻塞读取的字节数估计值，存在两个致命问题：

• 它只能反映输入流缓冲区中已有的数据，无法代表整条消息的总长度——如果消息还在网络传输中，available()返回的只是部分数据，用这个值创建缓冲区会直接截断消息。
• 不同输入流实现对available()的逻辑不同，某些场景下可能返回0，但后续仍有数据到达，此时创建的缓冲区长度为0，根本无法读取内容。

因此TCP Socket通信中，绝对不能依赖available()确定消息总长度。

内容的提问来源于stack exchange，提问作者Flock Dawson