Kotlin中while循环复用循环条件内函数返回值的问题

问题分析 #

你当前的循环无法终止，核心原因是Socket的readLine()只有在流被关闭时才会返回null。如果服务器发送完第一条消息后没有关闭输出流，readLine()会一直阻塞等待下一行数据，不会触发循环终止，自然无法进入第二条消息的读取流程。

Android Studio自动转换的写法本身语法没问题，但在Socket多消息场景下不适用——它依赖null终止循环，而实际业务中我们不会频繁关闭Socket流来区分消息。

解决方案 #

1. 兼容Java逻辑的Kotlin循环写法 #

如果一定要复刻Java的赋值+判断逻辑，可这样写（无需提前声明变量）：

var line: String?
while (reader.readLine().also { line = it } != null) {
    line?.let {
        Log.d("Line", it)
        lines.add(it)
    }
}

但注意：这个写法仅在Socket流关闭时会终止循环，不适合多消息连续传输的场景。

2. 约定消息结束标记（推荐方案） #

在Socket通信中，通常约定一个结束行标记（比如"MESSAGE_END"），当读到这个标记时，就认为当前消息读取完成，终止循环并清空lines等待下一条消息：

// 处理第一条消息
while (true) {
    val line = reader.readLine() ?: break // 流意外关闭时退出
    if (line == "MESSAGE_END") {
        break // 第一条消息读取完成
    }
    Log.d("Line", line)
    lines.add(line)
}

// 清空列表，准备读取第二条消息
lines.clear()

// 处理第二条消息
while (true) {
    val line = reader.readLine() ?: break
    if (line == "MESSAGE_END") {
        break
    }
    Log.d("Line", line)
    lines.add(line)
}

服务器发送每条消息时，最后一行发送约定的结束标记，客户端就能准确区分不同消息，无需关闭Socket流。

3. 更简洁的Kotlin风格写法 #

用generateSequence生成行序列，遍历处理直到遇到结束标记：

// 读取第一条消息
generateSequence { reader.readLine() }
    .takeWhile { it != "MESSAGE_END" && it != null }
    .forEach { line ->
        Log.d("Line", line)
        lines.add(line)
    }

lines.clear()

// 读取第二条消息
generateSequence { reader.readLine() }
    .takeWhile { it != "MESSAGE_END" && it != null }
    .forEach { line ->
        Log.d("Line", line)
        lines.add(line)
    }

注意事项 #

• 确保服务器端和客户端约定的结束标记完全一致（包括大小写、空格等）
• 处理readLine()返回null的情况，避免空指针异常
• Socket读取操作要放在子线程中执行，避免阻塞主线程

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